diff options
Diffstat (limited to 'knode/knprotocolclient.cpp')
| -rw-r--r-- | knode/knprotocolclient.cpp | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/knode/knprotocolclient.cpp b/knode/knprotocolclient.cpp index dc1a299f2..8289d02ee 100644 --- a/knode/knprotocolclient.cpp +++ b/knode/knprotocolclient.cpp @@ -57,9 +57,9 @@ KNProtocolClient::~KNProtocolClient() void KNProtocolClient::run() { if (0!=pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,NULL)) - qWarning("pthread_setcancelstate failed!"); + tqWarning("pthread_setcancelstate failed!"); if (0!= pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS,NULL)) - qWarning("pthread_setcanceltype failed!"); + tqWarning("pthread_setcanceltype failed!"); signal(SIGPIPE,SIG_IGN); // ignore sigpipe waitForWork(); @@ -112,13 +112,13 @@ void KNProtocolClient::waitForWork() // if select() returns early because of a signal if (selectRet == 0) { #ifndef NDEBUG - qDebug("knode: KNProtocolClient::waitForWork(): hold time elapsed, closing connection."); + tqDebug("knode: KNProtocolClient::waitForWork(): hold time elapsed, closing connection."); #endif closeConnection(); // nothing happend... } else { if (((selectRet > 0)&&(!FD_ISSET(fdPipeIn,&fdsR)))||(selectRet == -1)) { #ifndef NDEBUG - qDebug("knode: KNProtocolClient::waitForWork(): connection broken, closing it"); + tqDebug("knode: KNProtocolClient::waitForWork(): connection broken, closing it"); #endif closeSocket(); } @@ -139,7 +139,7 @@ void KNProtocolClient::waitForWork() sendSignal(TSjobStarted); if (job) { - // qDebug("knode: KNProtocolClient::waitForWork(): got job"); + // tqDebug("knode: KNProtocolClient::waitForWork(): got job"); if (job->net()&&!(account == *job->account())) { // server changed account = *job->account(); @@ -185,7 +185,7 @@ bool KNProtocolClient::openConnection() sendSignal(TSconnect); #ifndef NDEBUG - qDebug("knode: KNProtocolClient::openConnection(): opening connection"); + tqDebug("knode: KNProtocolClient::openConnection(): opening connection"); #endif if (account.server().isEmpty()) { @@ -225,7 +225,7 @@ void KNProtocolClient::closeConnection() timeval tv; #ifndef NDEBUG - qDebug("knode: KNProtocolClient::closeConnection(): closing connection"); + tqDebug("knode: KNProtocolClient::closeConnection(): closing connection"); #endif FD_ZERO(&fdsW); @@ -335,7 +335,7 @@ bool KNProtocolClient::getNextLine() thisLine = input; inputEnd = input+div-1; #ifndef NDEBUG - qDebug("knode: KNProtocolClient::getNextLine(): input buffer enlarged"); + tqDebug("knode: KNProtocolClient::getNextLine(): input buffer enlarged"); #endif } if (!waitForRead()) @@ -443,7 +443,7 @@ void KNProtocolClient::handleErrors() void KNProtocolClient::sendSignal(threadSignal s) { int signal=(int)s; - // qDebug("knode: KNProtcolClient::sendSignal() : sending signal to main thread"); + // tqDebug("knode: KNProtcolClient::sendSignal() : sending signal to main thread"); write(fdPipeOut, &signal, sizeof(int)); } @@ -485,7 +485,7 @@ bool KNProtocolClient::waitForRead() if (ret > 0) { if (FD_ISSET(fdPipeIn,&fdsR)) { // stop signal #ifndef NDEBUG - qDebug("knode: KNProtocolClient::waitForRead(): got stop signal"); + tqDebug("knode: KNProtocolClient::waitForRead(): got stop signal"); #endif closeConnection(); return false; @@ -547,7 +547,7 @@ bool KNProtocolClient::waitForWrite() if (ret > 0) { if (FD_ISSET(fdPipeIn,&fdsR)) { // stop signal #ifndef NDEBUG - qDebug("knode: KNProtocolClient::waitForWrite(): got stop signal"); + tqDebug("knode: KNProtocolClient::waitForWrite(): got stop signal"); #endif closeConnection(); return false; |