4 files changed, 10 insertions, 6 deletions
diff --git a/lib/libtdekrb/src/tdekrbclientsocket.cpp b/lib/libtdekrb/src/tdekrbclientsocket.cpp
index 4bf840b..ce5842e 100644
--- a/lib/libtdekrb/src/tdekrbclientsocket.cpp
+++ b/lib/libtdekrb/src/tdekrbclientsocket.cpp
@@ -763,8 +763,10 @@ int TDEKerberosClientSocket::writeEndOfFrame() {
 	return ret;
 }
 
-bool TDEKerberosClientSocket::canReadFrame() {
-	processPendingData();
+bool TDEKerberosClientSocket::canReadFrame(bool callProcessPendingData) {
+	if (callProcessPendingData) {
+		processPendingData();
+	}
 	if (m_readBufferLength > 0) {
 		if (m_readBuffer->buffer().find(255, m_readBufferReadPointer) >= 0) {
 			return true;
diff --git a/lib/libtdekrb/src/tdekrbclientsocket.h b/lib/libtdekrb/src/tdekrbclientsocket.h
index b941eb0..2bdbad1 100644
--- a/lib/libtdekrb/src/tdekrbclientsocket.h
+++ b/lib/libtdekrb/src/tdekrbclientsocket.h
@@ -75,7 +75,7 @@ class TDEKerberosClientSocket : public TQSocket
 		void clearIncomingData();
 
 		int writeEndOfFrame();
-		bool canReadFrame();
+		bool canReadFrame(bool processPendingData=true);
 		void clearFrameTail();
 		void writeBufferedData();
 
diff --git a/lib/libtdekrb/src/tdekrbserversocket.cpp b/lib/libtdekrb/src/tdekrbserversocket.cpp
index 2c21517..7371f09 100644
--- a/lib/libtdekrb/src/tdekrbserversocket.cpp
+++ b/lib/libtdekrb/src/tdekrbserversocket.cpp
@@ -760,8 +760,10 @@ int TDEKerberosServerSocket::writeEndOfFrame() {
 	return ret;
 }
 
-bool TDEKerberosServerSocket::canReadFrame() {
-	processPendingData();
+bool TDEKerberosServerSocket::canReadFrame(bool callProcessPendingData) {
+	if (callProcessPendingData) {
+		processPendingData();
+	}
 	if (m_readBufferLength > 0) {
 		if (m_readBuffer->buffer().find(255, m_readBufferReadPointer) >= 0) {
 			return true;
diff --git a/lib/libtdekrb/src/tdekrbserversocket.h b/lib/libtdekrb/src/tdekrbserversocket.h
index 654e4e0..745a70b 100644
--- a/lib/libtdekrb/src/tdekrbserversocket.h
+++ b/lib/libtdekrb/src/tdekrbserversocket.h
@@ -74,7 +74,7 @@ class TDEKerberosServerSocket : public TQSocket
 		void clearIncomingData();
 
 		int writeEndOfFrame();
-		bool canReadFrame();
+		bool canReadFrame(bool processPendingData=true);
 		void clearFrameTail();
 		void writeBufferedData();