diff options
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; |