diff options
| author | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2012-07-03 15:26:53 -0500 |
|---|---|---|
| committer | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2012-07-03 15:26:53 -0500 |
| commit | 9b06e81c075fc6cdbcea135c3c39a7da14d10386 (patch) | |
| tree | 9f6739d38da6cf2a4b55458c36a7125a8b799cc2 /lib/libtdekrb | |
| parent | 623cde93fda148d0c36ba13701a7006bd6bea294 (diff) | |
| download | ulab-9b06e81c075fc6cdbcea135c3c39a7da14d10386.tar.gz ulab-9b06e81c075fc6cdbcea135c3c39a7da14d10386.zip | |
Add preliminary basic remotefpga protocol support
Diffstat (limited to 'lib/libtdekrb')
| -rw-r--r-- | lib/libtdekrb/src/tdekrbclientsocket.cpp | 4 | ||||
| -rw-r--r-- | lib/libtdekrb/src/tdekrbclientsocket.h | 3 | ||||
| -rw-r--r-- | lib/libtdekrb/src/tdekrbserversocket.cpp | 4 | ||||
| -rw-r--r-- | lib/libtdekrb/src/tdekrbserversocket.h | 3 |
4 files changed, 14 insertions, 0 deletions
diff --git a/lib/libtdekrb/src/tdekrbclientsocket.cpp b/lib/libtdekrb/src/tdekrbclientsocket.cpp index 952f28d..bf4c410 100644 --- a/lib/libtdekrb/src/tdekrbclientsocket.cpp +++ b/lib/libtdekrb/src/tdekrbclientsocket.cpp @@ -238,6 +238,7 @@ int TDEKerberosClientSocket::processPendingData() { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -298,6 +299,7 @@ TQ_LONG TDEKerberosClientSocket::readBlock(char *data, TQ_ULONG maxlen) { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -361,6 +363,7 @@ TQ_LONG TDEKerberosClientSocket::readLine(char *data, TQ_ULONG maxlen) { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -415,6 +418,7 @@ TQString TDEKerberosClientSocket::readLine() { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); diff --git a/lib/libtdekrb/src/tdekrbclientsocket.h b/lib/libtdekrb/src/tdekrbclientsocket.h index fc7da95..303da6b 100644 --- a/lib/libtdekrb/src/tdekrbclientsocket.h +++ b/lib/libtdekrb/src/tdekrbclientsocket.h @@ -67,6 +67,8 @@ class TDEKerberosClientSocket : public TQSocket KerberosStatus kerberosStatus() const; bool canReadData(); + + public slots: int processPendingData(); private: @@ -83,6 +85,7 @@ class TDEKerberosClientSocket : public TQSocket signals: void statusMessageUpdated(const TQString&); + void newDataReceived(); private: bool m_kerberosRequested; diff --git a/lib/libtdekrb/src/tdekrbserversocket.cpp b/lib/libtdekrb/src/tdekrbserversocket.cpp index d395936..954ddf0 100644 --- a/lib/libtdekrb/src/tdekrbserversocket.cpp +++ b/lib/libtdekrb/src/tdekrbserversocket.cpp @@ -238,6 +238,7 @@ int TDEKerberosServerSocket::processPendingData() { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -298,6 +299,7 @@ TQ_LONG TDEKerberosServerSocket::readBlock(char *data, TQ_ULONG maxlen) { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -361,6 +363,7 @@ TQ_LONG TDEKerberosServerSocket::readLine(char *data, TQ_ULONG maxlen) { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); @@ -415,6 +418,7 @@ TQString TDEKerberosServerSocket::readLine() { wrlen = m_buffer->writeBlock(buf, reclen); if (wrlen > 0) { m_bufferLength = m_bufferLength + wrlen; + emit(newDataReceived()); } } free(buf); diff --git a/lib/libtdekrb/src/tdekrbserversocket.h b/lib/libtdekrb/src/tdekrbserversocket.h index 42f3a2d..73bb6fa 100644 --- a/lib/libtdekrb/src/tdekrbserversocket.h +++ b/lib/libtdekrb/src/tdekrbserversocket.h @@ -67,6 +67,8 @@ class TDEKerberosServerSocket : public TQSocket KerberosStatus kerberosStatus() const; bool canReadData(); + + public slots: int processPendingData(); private: @@ -83,6 +85,7 @@ class TDEKerberosServerSocket : public TQSocket signals: void statusMessageUpdated(const TQString&); + void newDataReceived(); protected: TQString m_authenticatedUserName; |