summaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorTimothy Pearson <kb9vqf@pearsoncomputing.net>2012-07-03 15:26:53 -0500
committerTimothy Pearson <kb9vqf@pearsoncomputing.net>2012-07-03 15:26:53 -0500
commit9b06e81c075fc6cdbcea135c3c39a7da14d10386 (patch)
tree9f6739d38da6cf2a4b55458c36a7125a8b799cc2 /lib
parent623cde93fda148d0c36ba13701a7006bd6bea294 (diff)
downloadulab-9b06e81c075fc6cdbcea135c3c39a7da14d10386.tar.gz
ulab-9b06e81c075fc6cdbcea135c3c39a7da14d10386.zip
Add preliminary basic remotefpga protocol support
Diffstat (limited to 'lib')
-rw-r--r--lib/libtdekrb/src/tdekrbclientsocket.cpp4
-rw-r--r--lib/libtdekrb/src/tdekrbclientsocket.h3
-rw-r--r--lib/libtdekrb/src/tdekrbserversocket.cpp4
-rw-r--r--lib/libtdekrb/src/tdekrbserversocket.h3
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;