From 9b06e81c075fc6cdbcea135c3c39a7da14d10386 Mon Sep 17 00:00:00 2001 From: Timothy Pearson Date: Tue, 3 Jul 2012 15:26:53 -0500 Subject: Add preliminary basic remotefpga protocol support --- lib/libtdekrb/src/tdekrbclientsocket.cpp | 4 ++++ lib/libtdekrb/src/tdekrbclientsocket.h | 3 +++ lib/libtdekrb/src/tdekrbserversocket.cpp | 4 ++++ lib/libtdekrb/src/tdekrbserversocket.h | 3 +++ 4 files changed, 14 insertions(+) (limited to 'lib') 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; -- cgit v1.2.1