diff options
Diffstat (limited to 'nxcomp/src')
| -rw-r--r-- | nxcomp/src/Loop.cpp | 1620 |
1 files changed, 810 insertions, 810 deletions
diff --git a/nxcomp/src/Loop.cpp b/nxcomp/src/Loop.cpp index 78b0b55d9..e6c6805b2 100644 --- a/nxcomp/src/Loop.cpp +++ b/nxcomp/src/Loop.cpp @@ -1148,7 +1148,7 @@ int NXTransProxy(int fd, int mode, const char* options) if (setjmp(context) == 1) { nxinfo << "NXTransProxy: Out of the long jump with pid '" - << lastProxy << "'.\n" << std::flush; + << lastProxy << "'.\n" << std::flush; return -1; } @@ -1168,7 +1168,7 @@ int NXTransProxy(int fd, int mode, const char* options) lastProxy = getpid(); nxinfo << "NXTransProxy: Main process started with pid '" - << lastProxy << "'.\n" << std::flush; + << lastProxy << "'.\n" << std::flush; SetMode(mode); @@ -1178,10 +1178,10 @@ int NXTransProxy(int fd, int mode, const char* options) { nxinfo << "NXTransProxy: Agent descriptor for X client connections is FD#" - << fd << ".\n" << std::flush; + << fd << ".\n" << std::flush; nxinfo << "NXTransProxy: Disabling listening on further X client connections.\n" - << std::flush; + << std::flush; useTcpSocket = 0; @@ -1196,7 +1196,7 @@ int NXTransProxy(int fd, int mode, const char* options) if (fd != NX_FD_ANY) { nxinfo << "NXTransProxy: PANIC! Agent descriptor for X server connections " - << "not supported yet.\n" << std::flush; + << "not supported yet.\n" << std::flush; cerr << "Error" << ": Agent descriptor for X server connections " << "not supported yet.\n"; @@ -1227,7 +1227,7 @@ int NXTransProxy(int fd, int mode, const char* options) SetLogs(); nxinfo << "NXTransProxy: Going to run the NX transport loop.\n" - << std::flush; + << std::flush; WaitCleanup(); @@ -1250,15 +1250,15 @@ void NXTransExit(int code) if (++recurse > 1) { nxinfo << "NXTransExit: Aborting process with pid '" - << getpid() << "' due to recursion through " - << "exit.\n" << std::flush; + << getpid() << "' due to recursion through " + << "exit.\n" << std::flush; abort(); } nxinfo << "NXTransExit: Process with pid '" - << getpid() << "' called exit with code '" - << code << "'.\n" << std::flush; + << getpid() << "' called exit with code '" + << code << "'.\n" << std::flush; if (control != NULL) { @@ -1353,7 +1353,7 @@ int NXTransCreate(int fd, int mode, const char* options) lastProxy = getpid(); nxinfo << "NXTransCreate: Caller process running with pid '" - << lastProxy << "'.\n" << std::flush; + << lastProxy << "'.\n" << std::flush; // // Set the local proxy mode an parse the @@ -1390,10 +1390,10 @@ int NXTransCreate(int fd, int mode, const char* options) proxyFD = fd; nxinfo << "NXTransCreate: Called with NX proxy descriptor '" - << proxyFD << "'.\n" << std::flush; + << proxyFD << "'.\n" << std::flush; nxinfo << "NXTransCreate: Creation of the NX transport completed.\n" - << std::flush; + << std::flush; return 1; } @@ -1448,11 +1448,11 @@ int NXTransAgent(int fd[2]) nxinfo << "NXTransAgent: Internal descriptors for agent are FD#" - << agentFD[0] << " and FD#" << agentFD[1] << ".\n" - << std::flush; + << agentFD[0] << " and FD#" << agentFD[1] << ".\n" + << std::flush; nxinfo << "NXTransAgent: Disabling listening for further X client " - << "connections.\n" << std::flush; + << "connections.\n" << std::flush; agent = new Agent(agentFD); @@ -1468,7 +1468,7 @@ int NXTransAgent(int fd[2]) } nxinfo << "NXTransAgent: Enabling memory-to-memory transport.\n" - << std::flush; + << std::flush; return 1; } @@ -1493,7 +1493,7 @@ int NXTransClose(int fd) if (proxy != NULL) { nxinfo << "NXTransClose: Closing down all the X connections.\n" - << std::flush; + << std::flush; CleanupConnections(); } @@ -1501,7 +1501,7 @@ int NXTransClose(int fd) else { nxinfo << "NXTransClose: The NX transport is not running.\n" - << std::flush; + << std::flush; } return 1; @@ -1531,13 +1531,13 @@ int NXTransDestroy(int fd) if (proxy != NULL) { nxinfo << "NXTransDestroy: Closing down all the X connections.\n" - << std::flush; + << std::flush; CleanupConnections(); } nxinfo << "NXTransDestroy: Waiting for the NX transport to terminate.\n" - << std::flush; + << std::flush; lastDestroy = 1; @@ -1546,7 +1546,7 @@ int NXTransDestroy(int fd) else { nxinfo << "NXTransDestroy: The NX transport is not running.\n" - << std::flush; + << std::flush; } return 1; @@ -1630,7 +1630,7 @@ int NXTransSignal(int signal, int action) if (action == NX_SIGNAL_RAISE) { nxinfo << "NXTransSignal: Raising signal '" << DumpSignal(signal) - << "' in the proxy handler.\n" << std::flush; + << "' in the proxy handler.\n" << std::flush; HandleSignal(signal); @@ -1639,7 +1639,7 @@ int NXTransSignal(int signal, int action) else if (signal == NX_SIGNAL_ANY) { nxinfo << "NXTransSignal: Setting action of all signals to '" - << action << "'.\n" << std::flush; + << action << "'.\n" << std::flush; for (int i = 0; i < 32; i++) { @@ -1654,8 +1654,8 @@ int NXTransSignal(int signal, int action) else if (CheckSignal(signal) == 1) { nxinfo << "NXTransSignal: Setting action of signal '" - << DumpSignal(signal) << "' to '" << action - << "'.\n" << std::flush; + << DumpSignal(signal) << "' to '" << action + << "'.\n" << std::flush; if (action == NX_SIGNAL_ENABLE || action == NX_SIGNAL_FORWARD) @@ -1673,8 +1673,8 @@ int NXTransSignal(int signal, int action) } nxwarn << "NXTransSignal: WARNING! Unable to perform action '" - << action << "' on signal '" << DumpSignal(signal) - << "'.\n" << std::flush; + << action << "' on signal '" << DumpSignal(signal) + << "'.\n" << std::flush; cerr << "Warning" << ": Unable to perform action '" << action << "' on signal '" << DumpSignal(signal) @@ -1690,7 +1690,7 @@ int NXTransCongestion(int fd) int congestion = proxy -> getCongestion(proxyFD); nxdbg << "NXTransCongestion: Returning " << congestion - << " as current congestion level.\n" << std::flush; + << " as current congestion level.\n" << std::flush; return congestion; @@ -1732,18 +1732,18 @@ int NXTransHandler(int fd, int type, void (*handler)(void *parameter, default: { nxinfo << "NXTransHandler: WARNING! Failed to set " - << "the NX callback for event '" << type << "' to '" - << (void *) handler << "' and parameter '" - << parameter << "'.\n" << std::flush; + << "the NX callback for event '" << type << "' to '" + << (void *) handler << "' and parameter '" + << parameter << "'.\n" << std::flush; return 0; } } nxinfo << "NXTransHandler: Set the NX " - << "callback for event '" << type << "' to '" - << (void *) handler << "' and parameter '" - << parameter << "'.\n" << std::flush; + << "callback for event '" << type << "' to '" + << (void *) handler << "' and parameter '" + << parameter << "'.\n" << std::flush; return 1; } @@ -1759,7 +1759,7 @@ int NXTransRead(int fd, char *data, int size) fd == agentFD[0]) { nxdbg << "NXTransRead: Dequeuing " << size << " bytes " - << "from FD#" << agentFD[0] << ".\n" << std::flush; + << "from FD#" << agentFD[0] << ".\n" << std::flush; int result = agent -> dequeueData(data, size); @@ -1767,12 +1767,12 @@ int NXTransRead(int fd, char *data, int size) if (result < 0 && EGET() == EAGAIN) { nxdbg << "NXTransRead: WARNING! Dequeuing from FD#" - << agentFD[0] << " would block.\n" << std::flush; + << agentFD[0] << " would block.\n" << std::flush; } else { nxdbg << "NXTransRead: Dequeued " << result << " bytes " - << "to FD#" << agentFD[0] << ".\n" << std::flush; + << "to FD#" << agentFD[0] << ".\n" << std::flush; } @@ -1781,7 +1781,7 @@ int NXTransRead(int fd, char *data, int size) else { nxdbg << "NXTransRead: Reading " << size << " bytes " - << "from FD#" << fd << ".\n" << std::flush; + << "from FD#" << fd << ".\n" << std::flush; return read(fd, data, size); } @@ -1802,7 +1802,7 @@ int NXTransReadVector(int fd, struct iovec *iovdata, int iovsize) agent -> localReadable() > 0) { nxdbg << "NXTransReadVector: WARNING! Agent has data readable.\n" - << std::flush; + << std::flush; } @@ -1827,8 +1827,8 @@ int NXTransReadVector(int fd, struct iovec *iovdata, int iovsize) while (length > 0) { nxdbg << "NXTransReadVector: Dequeuing " << length - << " bytes " << "from FD#" << agentFD[0] << ".\n" - << std::flush; + << " bytes " << "from FD#" << agentFD[0] << ".\n" + << std::flush; result = agent -> dequeueData(base, length); @@ -1836,13 +1836,13 @@ int NXTransReadVector(int fd, struct iovec *iovdata, int iovsize) if (result < 0 && EGET() == EAGAIN) { nxdbg << "NXTransReadVector: WARNING! Dequeuing from FD#" - << agentFD[0] << " would block.\n" << std::flush; + << agentFD[0] << " would block.\n" << std::flush; } else { nxdbg << "NXTransReadVector: Dequeued " << result - << " bytes " << "from FD#" << agentFD[0] << ".\n" - << std::flush; + << " bytes " << "from FD#" << agentFD[0] << ".\n" + << std::flush; } @@ -1868,8 +1868,8 @@ int NXTransReadVector(int fd, struct iovec *iovdata, int iovsize) else { nxdbg << "NXTransReadVector: Reading vector with " - << iovsize << " elements from FD#" << fd << ".\n" - << std::flush; + << iovsize << " elements from FD#" << fd << ".\n" + << std::flush; return readv(fd, iovdata, iovsize); } @@ -1890,13 +1890,13 @@ int NXTransReadable(int fd, int *readable) if (result == -1) { nxdbg << "NXTransReadable: Error detected on FD#" - << fd << ".\n" << std::flush; + << fd << ".\n" << std::flush; } else { nxdbg << "NXTransReadable: Returning " << *readable - << " bytes as readable from FD#" << fd - << ".\n" << std::flush; + << " bytes as readable from FD#" << fd + << ".\n" << std::flush; } return result; @@ -1920,8 +1920,8 @@ int NXTransReadable(int fd, int *readable) if (proxy != NULL && proxy -> canRead() == 1) { nxinfo << "NXTransReadable: WARNING! Trying to " - << "read to generate new agent data.\n" - << std::flush; + << "read to generate new agent data.\n" + << std::flush; // // Set the context as the function @@ -1936,8 +1936,8 @@ int NXTransReadable(int fd, int *readable) if (proxy -> handleRead() < 0) { nxinfo << "NXTransReadable: Failure reading " - << "messages from proxy FD#" << proxyFD - << ".\n" << std::flush; + << "messages from proxy FD#" << proxyFD + << ".\n" << std::flush; HandleShutdown(); } @@ -1952,8 +1952,8 @@ int NXTransReadable(int fd, int *readable) } nxdbg << "NXTransReadable: Returning " << 0 - << " bytes as readable from FD#" << fd - << " with result 0.\n" << std::flush; + << " bytes as readable from FD#" << fd + << " with result 0.\n" << std::flush; *readable = 0; @@ -1962,8 +1962,8 @@ int NXTransReadable(int fd, int *readable) case -1: { nxdbg << "NXTransReadable: Returning " << 0 - << " bytes as readable from FD#" << fd - << " with result -1.\n" << std::flush; + << " bytes as readable from FD#" << fd + << " with result -1.\n" << std::flush; *readable = 0; @@ -1972,8 +1972,8 @@ int NXTransReadable(int fd, int *readable) default: { nxdbg << "NXTransReadable: Returning " << result - << " bytes as readable from FD#" << fd - << " with result 0.\n" << std::flush; + << " bytes as readable from FD#" << fd + << " with result 0.\n" << std::flush; *readable = result; @@ -2003,8 +2003,8 @@ int NXTransWrite(int fd, char *data, int size) if (proxy -> canRead(agentFD[1]) == 0) { nxdbg << "NXTransWrite: WARNING! Delayed enqueuing to FD#" - << agentFD[0] << " with proxy unable to read.\n" - << std::flush; + << agentFD[0] << " with proxy unable to read.\n" + << std::flush; ESET(EAGAIN); @@ -2027,8 +2027,8 @@ int NXTransWrite(int fd, char *data, int size) // nxdbg << "NXTransWrite: Letting the channel borrow " - << size << " bytes from FD#" << agentFD[0] - << ".\n" << std::flush; + << size << " bytes from FD#" << agentFD[0] + << ".\n" << std::flush; result = proxy -> handleRead(agentFD[1], data, size); @@ -2058,7 +2058,7 @@ int NXTransWrite(int fd, char *data, int size) // nxdbg << "NXTransWrite: Enqueuing " << size << " bytes " - << "to FD#" << agentFD[0] << ".\n" << std::flush; + << "to FD#" << agentFD[0] << ".\n" << std::flush; result = agent -> enqueueData(data, size); } @@ -2069,19 +2069,19 @@ int NXTransWrite(int fd, char *data, int size) if (EGET() == EAGAIN) { nxdbg << "NXTransWrite: WARNING! Enqueuing to FD#" - << agentFD[0] << " would block.\n" - << std::flush; + << agentFD[0] << " would block.\n" + << std::flush; } else { nxdbg << "NXTransWrite: WARNING! Error enqueuing to FD#" - << agentFD[0] << ".\n" << std::flush; + << agentFD[0] << ".\n" << std::flush; } } else { nxdbg << "NXTransWrite: Enqueued " << result << " bytes " - << "to FD#" << agentFD[0] << ".\n" << std::flush; + << "to FD#" << agentFD[0] << ".\n" << std::flush; } @@ -2090,7 +2090,7 @@ int NXTransWrite(int fd, char *data, int size) else { nxdbg << "NXTransWrite: Writing " << size << " bytes " - << "to FD#" << fd << ".\n" << std::flush; + << "to FD#" << fd << ".\n" << std::flush; return write(fd, data, size); } @@ -2123,8 +2123,8 @@ int NXTransWriteVector(int fd, struct iovec *iovdata, int iovsize) if (proxy -> canRead(agentFD[1]) == 0) { nxdbg << "NXTransWriteVector: WARNING! Delayed enqueuing to FD#" - << agentFD[0] << " with proxy unable to read.\n" - << std::flush; + << agentFD[0] << " with proxy unable to read.\n" + << std::flush; ESET(EAGAIN); @@ -2169,8 +2169,8 @@ int NXTransWriteVector(int fd, struct iovec *iovdata, int iovsize) // nxdbg << "NXTransWriteVector: Letting the channel borrow " - << length << " bytes from FD#" << agentFD[0] - << ".\n" << std::flush; + << length << " bytes from FD#" << agentFD[0] + << ".\n" << std::flush; result = proxy -> handleRead(agentFD[1], base, length); @@ -2200,8 +2200,8 @@ int NXTransWriteVector(int fd, struct iovec *iovdata, int iovsize) // nxdbg << "NXTransWriteVector: Enqueuing " << length - << " bytes " << "to FD#" << agentFD[0] << ".\n" - << std::flush; + << " bytes " << "to FD#" << agentFD[0] << ".\n" + << std::flush; result = agent -> enqueueData(base, length); } @@ -2212,20 +2212,20 @@ int NXTransWriteVector(int fd, struct iovec *iovdata, int iovsize) if (EGET() == EAGAIN) { nxdbg << "NXTransWriteVector: WARNING! Enqueuing to FD#" - << agentFD[0] << " would block.\n" - << std::flush; + << agentFD[0] << " would block.\n" + << std::flush; } else { nxdbg << "NXTransWriteVector: WARNING! Error enqueuing to FD#" - << agentFD[0] << ".\n" << std::flush; + << agentFD[0] << ".\n" << std::flush; } } else { nxdbg << "NXTransWriteVector: Enqueued " << result - << " bytes " << "to FD#" << agentFD[0] << ".\n" - << std::flush; + << " bytes " << "to FD#" << agentFD[0] << ".\n" + << std::flush; } @@ -2251,8 +2251,8 @@ int NXTransWriteVector(int fd, struct iovec *iovdata, int iovsize) else { nxdbg << "NXTransWriteVector: Writing vector with " - << iovsize << " elements to FD#" << fd << ".\n" - << std::flush; + << iovsize << " elements to FD#" << fd << ".\n" + << std::flush; return writev(fd, iovdata, iovsize); } @@ -2265,10 +2265,10 @@ int NXTransPolicy(int fd, int type) if (usePolicy == -1) { nxinfo << "NXTransPolicy: Setting flush policy on " - << "proxy FD#" << proxyFD << " to '" - << DumpPolicy(type == NX_POLICY_DEFERRED ? - policy_deferred : policy_immediate) - << "'.\n" << std::flush; + << "proxy FD#" << proxyFD << " to '" + << DumpPolicy(type == NX_POLICY_DEFERRED ? + policy_deferred : policy_immediate) + << "'.\n" << std::flush; control -> FlushPolicy = (type == NX_POLICY_DEFERRED ? policy_deferred : policy_immediate); @@ -2283,9 +2283,9 @@ int NXTransPolicy(int fd, int type) else { nxinfo << "NXTransPolicy: Ignoring the agent " - << "setting with user policy set to '" - << DumpPolicy(control -> FlushPolicy) - << "'.\n" << std::flush; + << "setting with user policy set to '" + << DumpPolicy(control -> FlushPolicy) + << "'.\n" << std::flush; return 0; } @@ -2300,17 +2300,17 @@ int NXTransFlushable(int fd) fd != agentFD[0]) { nxdbg << "NXTransFlushable: Returning 0 bytes as " - << "flushable for unrecognized FD#" << fd - << ".\n" << std::flush; + << "flushable for unrecognized FD#" << fd + << ".\n" << std::flush; return 0; } else { nxdbg << "NXTransFlushable: Returning " << proxy -> - getFlushable(proxyFD) << " as bytes flushable on " - << "proxy FD#" << proxyFD << ".\n" - << std::flush; + getFlushable(proxyFD) << " as bytes flushable on " + << "proxy FD#" << proxyFD << ".\n" + << std::flush; return proxy -> getFlushable(proxyFD); } @@ -2321,8 +2321,8 @@ int NXTransFlush(int fd) if (proxy != NULL) { nxinfo << "NXTransFlush: Requesting an immediate flush of " - << "proxy FD#" << proxyFD << ".\n" - << std::flush; + << "proxy FD#" << proxyFD << ".\n" + << std::flush; return proxy -> handleFlush(); } @@ -2345,8 +2345,8 @@ int NXTransChannel(int fd, int channelFd, int type) } nxinfo << "NXTransChannel: Going to create a new channel " - << "with type '" << type << "' on FD#" << channelFd - << ".\n" << std::flush; + << "with type '" << type << "' on FD#" << channelFd + << ".\n" << std::flush; int result = -1; @@ -2419,7 +2419,7 @@ int NXTransChannel(int fd, int channelFd, int type) default: { nxwarn << "NXTransChannel: WARNING! Unrecognized channel " - << "type '" << type << "'.\n" << std::flush; + << "type '" << type << "'.\n" << std::flush; break; } @@ -2429,8 +2429,8 @@ int NXTransChannel(int fd, int channelFd, int type) if (result != 1) { nxwarn << "NXTransChannel: WARNING! Could not create the " - << "new channel with type '" << type << "' on FD#" - << channelFd << ".\n" << std::flush; + << "new channel with type '" << type << "' on FD#" + << channelFd << ".\n" << std::flush; } @@ -2498,8 +2498,8 @@ int NXTransAlert(int code, int local) if (proxy != NULL) { nxdbg << "NXTransAlert: Requesting a NX dialog with code " - << code << " and local " << local << ".\n" - << std::flush; + << code << " and local " << local << ".\n" + << std::flush; if (local == 0) { @@ -2534,7 +2534,7 @@ int NXTransAlert(int code, int local) } nxdbg << "NXTransAlert: Can't request an alert without " - << "a valid NX transport.\n" << std::flush; + << "a valid NX transport.\n" << std::flush; } return 0; @@ -2566,7 +2566,7 @@ int NXTransPrepare(int *setFDs, fd_set *readSet, } nxinfo << "NXTransPrepare: Going to prepare the NX transport.\n" - << std::flush; + << std::flush; if (control -> ProxyStage < stage_operational) { @@ -2578,16 +2578,16 @@ int NXTransPrepare(int *setFDs, fd_set *readSet, if (isTimestamp(*selectTs) == 0) { nxinfo << "Loop: WARNING! Preparing the select with requested " - << "timeout of " << selectTs -> tv_sec << " S and " - << (double) selectTs -> tv_usec / 1000 << " Ms.\n" - << std::flush; + << "timeout of " << selectTs -> tv_sec << " S and " + << (double) selectTs -> tv_usec / 1000 << " Ms.\n" + << std::flush; } else { nxinfo << "Loop: Preparing the select with requested " - << "timeout of " << selectTs -> tv_sec << " S and " - << (double) selectTs -> tv_usec / 1000 << " Ms.\n" - << std::flush; + << "timeout of " << selectTs -> tv_sec << " S and " + << (double) selectTs -> tv_usec / 1000 << " Ms.\n" + << std::flush; } @@ -2632,8 +2632,8 @@ int NXTransPrepare(int *setFDs, fd_set *readSet, int diffTs = diffTimestamp(startTs, nowTs); nxinfo << "Loop: Mark - 0 - at " << strMsTimestamp() - << " with " << diffTs << " Ms elapsed.\n" - << std::flush; + << " with " << diffTs << " Ms elapsed.\n" + << std::flush; // // TODO: Should add the read time in two @@ -2650,7 +2650,7 @@ int NXTransPrepare(int *setFDs, fd_set *readSet, startTs = nowTs; nxdbg << "Loop: New timestamp is " << strMsTimestamp(startTs) - << ".\n" << std::flush; + << ".\n" << std::flush; return 1; } @@ -2692,7 +2692,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, } nxinfo << "NXTransSelect: Going to select the NX descriptors.\n" - << std::flush; + << std::flush; handleCheckSelectInLoop(*setFDs, *readSet, *writeSet, *selectTs); @@ -2702,8 +2702,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, if (diffTs > 20) { nxdbg << "Loop: TIME! Spent " << diffTs - << " Ms handling messages for proxy FD#" - << proxyFD << ".\n" << std::flush; + << " Ms handling messages for proxy FD#" + << proxyFD << ".\n" << std::flush; } lastTs = getNewTimestamp(); @@ -2712,18 +2712,18 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, if (isTimestamp(*selectTs) == 0) { nxinfo << "Loop: WARNING! Executing the select with requested " - << "timeout of " << selectTs -> tv_sec << " S and " - << (double) selectTs -> tv_usec / 1000 << " Ms.\n" - << std::flush; + << "timeout of " << selectTs -> tv_sec << " S and " + << (double) selectTs -> tv_usec / 1000 << " Ms.\n" + << std::flush; } else if (proxy != NULL && proxy -> getFlushable(proxyFD) > 0) { nxinfo << "Loop: WARNING! Proxy FD#" << proxyFD - << " has " << proxy -> getFlushable(proxyFD) - << " bytes to write but timeout is " - << selectTs -> tv_sec << " S and " - << selectTs -> tv_usec / 1000 << " Ms.\n" - << std::flush; + << " has " << proxy -> getFlushable(proxyFD) + << " bytes to write but timeout is " + << selectTs -> tv_sec << " S and " + << selectTs -> tv_usec / 1000 << " Ms.\n" + << std::flush; } @@ -2743,8 +2743,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, if (diffTs > 100) { nxdbg << "Loop: TIME! Spent " << diffTs - << " Ms waiting for new data for proxy FD#" - << proxyFD << ".\n" << std::flush; + << " Ms waiting for new data for proxy FD#" + << proxyFD << ".\n" << std::flush; } lastTs = getNewTimestamp(); @@ -2769,13 +2769,13 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, diffTs = diffTimestamp(startTs, nowTs); nxinfo << "Loop: Out of select after " << diffTs << " Ms " - << "at " << strMsTimestamp(nowTs) << " with result " - << *resultFDs << ".\n" << std::flush; + << "at " << strMsTimestamp(nowTs) << " with result " + << *resultFDs << ".\n" << std::flush; startTs = nowTs; nxdbg << "Loop: New timestamp is " << strMsTimestamp(startTs) - << ".\n" << std::flush; + << ".\n" << std::flush; if (control -> ProxyStage >= stage_operational) { @@ -2807,13 +2807,13 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, if (*errorFDs == EINTR) { nxinfo << "Loop: Select failed due to EINTR error.\n" - << std::flush; + << std::flush; } else { nxinfo << "Loop: WARNING! Call to select failed. Error is " - << EGET() << " '" << ESTR() << "'.\n" - << std::flush; + << EGET() << " '" << ESTR() << "'.\n" + << std::flush; } } @@ -2859,7 +2859,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, } nxinfo << "NXTransExecute: Going to execute I/O on the NX descriptors.\n" - << std::flush; + << std::flush; if (control -> ProxyStage >= stage_operational) { @@ -2874,8 +2874,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, } nxinfo << "Loop: Mark - 1 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; // // Rotate the channel that will be handled @@ -2891,8 +2891,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, handleWritableInLoop(*resultFDs, *writeSet); nxinfo << "Loop: Mark - 2 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; // // Check if any socket has become readable. @@ -2901,8 +2901,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, handleReadableInLoop(*resultFDs, *readSet); nxinfo << "Loop: Mark - 3 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; // // Handle the scheduled events on channels. @@ -2923,8 +2923,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, handleEventsInLoop(); nxinfo << "Loop: Mark - 4 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; // // Check if user sent a signal to produce @@ -2946,8 +2946,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, } nxinfo << "Loop: Mark - 5 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; // // Check if there is any data to flush. @@ -2958,8 +2958,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, handleFlushInLoop(); nxinfo << "Loop: Mark - 6 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; } // @@ -2991,8 +2991,8 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet, handleCheckStateInLoop(*setFDs); nxinfo << "Loop: Mark - 7 - at " << strMsTimestamp() - << " with " << diffTimestamp(startTs, getTimestamp()) - << " Ms elapsed.\n" << std::flush; + << " with " << diffTimestamp(startTs, getTimestamp()) + << " Ms elapsed.\n" << std::flush; } // @@ -3034,8 +3034,8 @@ int InitBeforeNegotiation() initTs = nowTs; nxinfo << "Loop: INIT! Taking mark for initialization at " - << strMsTimestamp(initTs) << ".\n" - << std::flush; + << strMsTimestamp(initTs) << ".\n" + << std::flush; // // If not explicitly specified, determine if local @@ -3059,8 +3059,8 @@ int InitBeforeNegotiation() if (control -> ProxyMode == proxy_client) { nxinfo << "Loop: Starting watchdog process with timeout of " - << control -> InitTimeout / 1000 << " seconds.\n" - << std::flush; + << control -> InitTimeout / 1000 << " seconds.\n" + << std::flush; lastWatchdog = NXTransWatchdog(control -> InitTimeout); @@ -3074,7 +3074,7 @@ int InitBeforeNegotiation() else { nxinfo << "Loop: Watchdog started with pid '" - << lastWatchdog << "'.\n" << std::flush; + << lastWatchdog << "'.\n" << std::flush; } } @@ -3107,8 +3107,8 @@ int InitBeforeNegotiation() setHostBigEndian(*((unsigned char *) (&test)) == 0); nxinfo << "Loop: Local host is " - << (hostBigEndian() ? "big endian" : "little endian") - << ".\n" << std::flush; + << (hostBigEndian() ? "big endian" : "little endian") + << ".\n" << std::flush; if (control -> ProxyMode == proxy_client) { @@ -3196,13 +3196,13 @@ int SetupProxyConnection() if (connectSocket.getSpec(&socketUri)) { nxinfo << "Loop: Going to connect to '" << socketUri - << "'.\n" << std::flush; + << "'.\n" << std::flush; free(socketUri); proxyFD = ConnectToRemote(connectSocket); nxinfo << "Loop: Connected to remote proxy on FD#" - << proxyFD << ".\n" << std::flush; + << proxyFD << ".\n" << std::flush; cerr << "Info" << ": Connected to remote proxy on FD#" << proxyFD << ".\n"; @@ -3219,7 +3219,7 @@ int SetupProxyConnection() if (listenSocket.getSpec(&socketUri)) { nxinfo << "Loop: Going to wait for connection at '" - << socketUri << "'.\n" << std::flush; + << socketUri << "'.\n" << std::flush; free(socketUri); proxyFD = WaitForRemote(listenSocket); @@ -3227,12 +3227,12 @@ int SetupProxyConnection() if (WE_LISTEN_FORWARDER) { nxinfo << "Loop: Connected to remote forwarder on FD#" - << proxyFD << ".\n" << std::flush; + << proxyFD << ".\n" << std::flush; } else { nxinfo << "Loop: Connected to remote proxy on FD#" - << proxyFD << ".\n" << std::flush; + << proxyFD << ".\n" << std::flush; } } @@ -3241,7 +3241,7 @@ int SetupProxyConnection() else { nxinfo << "Loop: Using the inherited connection on FD#" - << proxyFD << ".\n" << std::flush; + << proxyFD << ".\n" << std::flush; } // @@ -3273,7 +3273,7 @@ int SetupProxyConnection() int InitAfterNegotiation() { nxinfo << "Loop: Connection with remote proxy completed.\n" - << std::flush; + << std::flush; cerr << "Info" << ": Connection with remote proxy completed.\n" << logofs_flush; @@ -3360,9 +3360,9 @@ int InitAfterNegotiation() // nxinfo << "Loop: INIT! Completed initialization at " - << strMsTimestamp(nowTs) << " with " - << diffTimestamp(initTs, nowTs) << " Ms " - << "since the init mark.\n" << std::flush; + << strMsTimestamp(nowTs) << " with " + << diffTimestamp(initTs, nowTs) << " Ms " + << "since the init mark.\n" << std::flush; initTs = getNewTimestamp(); @@ -3391,16 +3391,16 @@ int SetMode(int mode) if (mode == NX_MODE_CLIENT) { nxinfo << "Loop: INIT! Initializing with mode " - << "NX_MODE_CLIENT at " << strMsTimestamp() - << ".\n" << std::flush; + << "NX_MODE_CLIENT at " << strMsTimestamp() + << ".\n" << std::flush; control -> ProxyMode = proxy_client; } else if (mode == NX_MODE_SERVER) { nxinfo << "Loop: INIT! Initializing with mode " - << "NX_MODE_SERVER at " << strMsTimestamp() - << ".\n" << std::flush; + << "NX_MODE_SERVER at " << strMsTimestamp() + << ".\n" << std::flush; control -> ProxyMode = proxy_server; } @@ -3550,8 +3550,8 @@ int SetupProxyInstance() if (proxy -> getFlushable(proxyFD) > 0) { nxinfo << "Loop: WARNING! Proxy FD#" << proxyFD << " has data " - << "to flush after setup of the NX transport.\n" - << std::flush; + << "to flush after setup of the NX transport.\n" + << std::flush; } @@ -3604,7 +3604,7 @@ int SetupAuthInstance() *(launchdAddrUnix.sun_path + launchdAddrNameLength - 1) = '\0'; nxinfo << "Loop: Connecting to launchd service " - << "on Unix port '" << displayHost << "'.\n" << std::flush; + << "on Unix port '" << displayHost << "'.\n" << std::flush; int launchdFd = socket(launchdAddrFamily, SOCK_STREAM, PF_UNSPEC); @@ -3617,9 +3617,9 @@ int SetupAuthInstance() else if ((success = connect(launchdFd, (sockaddr *) &launchdAddrUnix, launchdAddrLength)) < 0) { nxwarn << "Loop: WARNING! Connection to launchd service " - << "on Unix port '" << displayHost << "' failed " - << "with error " << EGET() << ", '" << ESTR() << "'.\n" - << std::flush; + << "on Unix port '" << displayHost << "' failed " + << "with error " << EGET() << ", '" << ESTR() << "'.\n" + << std::flush; } if (launchdFd >= 0) @@ -3669,8 +3669,8 @@ int SetupAuthInstance() else if (auth -> isFake() == 1) { nxwarn << "Loop: WARNING! Could not retrieve the X server " - << "authentication cookie.\n" - << std::flush; + << "authentication cookie.\n" + << std::flush; cerr << "Warning" << ": Failed to read data from the X " << "auth command.\n"; @@ -3682,13 +3682,13 @@ int SetupAuthInstance() else { nxinfo << "Loop: No proxy cookie was provided for " - << "authentication.\n" << std::flush; + << "authentication.\n" << std::flush; cerr << "Info" << ": No proxy cookie was provided for " << "authentication.\n"; nxinfo << "Loop: Forwarding the real X authorization " - << "cookie.\n" << std::flush; + << "cookie.\n" << std::flush; cerr << "Info" << ": Forwarding the real X authorization " << "cookie.\n"; @@ -3868,7 +3868,7 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, if ((strncasecmp(display, "/tmp/launch", 11) == 0) || (strncasecmp(display, "/private/tmp/com.apple.launchd", 30) == 0)) { nxinfo << "Loop: Using launchd service on socket '" - << display << "'.\n" << std::flush; + << display << "'.\n" << std::flush; useLaunchdSocket = 1; } @@ -3892,8 +3892,8 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, xPort = atoi(separator + 1); nxinfo << "Loop: Using local X display '" << displayHost - << "' with host '" << display << "' and port '" - << xPort << "'.\n" << std::flush; + << "' with host '" << display << "' and port '" + << xPort << "'.\n" << std::flush; #ifdef __APPLE__ @@ -3911,7 +3911,7 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, // nxinfo << "Loop: Using real X server on UNIX domain socket.\n" - << std::flush; + << std::flush; sockaddr_un *xServerAddrUNIX = new sockaddr_un; @@ -3991,7 +3991,7 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, *(unixSocketDir + DEFAULT_STRING_LENGTH - 1) = '\0'; nxinfo << "Loop: Assuming X socket in directory '" - << unixSocketDir << "'.\n" << std::flush; + << unixSocketDir << "'.\n" << std::flush; if (stat(unixSocketDir, &statInfo) < 0) { @@ -4023,7 +4023,7 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, #endif nxinfo << "Loop: Assuming X socket name '" << unixSocketName - << "'.\n" << std::flush; + << "'.\n" << std::flush; strcpy(xServerAddrUNIX -> sun_path, unixSocketName); @@ -4042,7 +4042,7 @@ int SetupDisplaySocket(int &addr_family, sockaddr *&addr, // nxinfo << "Loop: Using real X server on TCP port.\n" - << std::flush; + << std::flush; addr_family = AF_INET; @@ -4312,14 +4312,14 @@ static int AcceptConnection(int fd, int domain, const char *label) if (domain == AF_UNIX) { nxinfo << "Loop: Going to accept new Unix " << label - << " connection on FD#" << fd << ".\n" - << std::flush; + << " connection on FD#" << fd << ".\n" + << std::flush; } else { nxinfo << "Loop: Going to accept new TCP " << label - << " connection on FD#" << fd << ".\n" - << std::flush; + << " connection on FD#" << fd << ".\n" + << std::flush; } @@ -4363,8 +4363,8 @@ void HandleShutdown() cerr << "Error" << ": Connection with remote peer broken.\n"; nxinfo << "Loop: Bytes received so far are " - << (unsigned long long) statistics -> getBytesIn() - << ".\n" << std::flush; + << (unsigned long long) statistics -> getBytesIn() + << ".\n" << std::flush; cerr << "Error" << ": Please check the state of your " << "network and retry.\n"; @@ -4374,7 +4374,7 @@ void HandleShutdown() if (control -> ProxyMode == proxy_server) { nxinfo << "Loop: Showing the proxy abort dialog.\n" - << std::flush; + << std::flush; HandleAlert(ABORT_PROXY_CONNECTION_ALERT, 1); @@ -4384,7 +4384,7 @@ void HandleShutdown() else { nxinfo << "Loop: Finalized the remote proxy shutdown.\n" - << std::flush; + << std::flush; } HandleCleanup(); @@ -4408,9 +4408,9 @@ int KillProcess(int pid, const char *label, int signal, int wait) if (pid > 0) { nxinfo << "Loop: Killing the " << label << " process '" - << pid << "' from process with pid '" << getpid() - << "' with signal '" << DumpSignal(signal) - << "'.\n" << std::flush; + << pid << "' from process with pid '" << getpid() + << "' with signal '" << DumpSignal(signal) + << "'.\n" << std::flush; signal = (signal == 0 ? SIGTERM : signal); @@ -4434,8 +4434,8 @@ int KillProcess(int pid, const char *label, int signal, int wait) else { nxinfo << "Loop: No " << label << " process " - << "to kill with pid '" << pid - << "'.\n" << std::flush; + << "to kill with pid '" << pid + << "'.\n" << std::flush; return 0; } @@ -4444,14 +4444,14 @@ int KillProcess(int pid, const char *label, int signal, int wait) int CheckProcess(int pid, const char *label) { nxinfo << "Loop: Checking the " << label << " process '" - << pid << "' from process with pid '" << getpid() - << "'.\n" << std::flush; + << pid << "' from process with pid '" << getpid() + << "'.\n" << std::flush; if (kill(pid, SIGCONT) < 0 && EGET() == ESRCH) { nxwarn << "Loop: WARNING! The " << label << " process " - << "with pid '" << pid << "' has exited.\n" - << std::flush; + << "with pid '" << pid << "' has exited.\n" + << std::flush; cerr << "Warning" << ": The " << label << " process " << "with pid '" << pid << "' has exited.\n"; @@ -4493,8 +4493,8 @@ int StartKeeper() if (control -> LocalTotalStorageSize > 0) { nxinfo << "Loop: Starting the house-keeping process with " - << "storage size " << control -> PersistentCacheDiskLimit - << ".\n" << std::flush; + << "storage size " << control -> PersistentCacheDiskLimit + << ".\n" << std::flush; lastKeeper = NXTransKeeper(control -> PersistentCacheDiskLimit, 0, control -> RootPath); @@ -4502,7 +4502,7 @@ int StartKeeper() if (IsFailed(lastKeeper)) { nxwarn << "Loop: WARNING! Failed to start the NX keeper process.\n" - << std::flush; + << std::flush; cerr << "Warning" << ": Failed to start the NX keeper process.\n"; @@ -4511,14 +4511,14 @@ int StartKeeper() else { nxinfo << "Loop: Keeper started with pid '" - << lastKeeper << "'.\n" << std::flush; + << lastKeeper << "'.\n" << std::flush; } } else { nxinfo << "Loop: Nothing to do for the keeper process " - << "with persistent cache not enabled.\n" - << std::flush; + << "with persistent cache not enabled.\n" + << std::flush; } return 1; @@ -4527,8 +4527,8 @@ int StartKeeper() void HandleCleanupForReconnect() { nxinfo << "Loop: Going to clean up system resources for Reconnect " - << "in process '" << getpid() << "'.\n" - << std::flush; + << "in process '" << getpid() << "'.\n" + << std::flush; handleTerminatedInLoop(); DisableSignals(); if (control) @@ -4547,8 +4547,8 @@ void HandleCleanupForReconnect() void HandleCleanup(int code) { nxinfo << "Loop: Going to clean up system resources " - << "in process '" << getpid() << "'.\n" - << std::flush; + << "in process '" << getpid() << "'.\n" + << std::flush; handleTerminatedInLoop(); @@ -4604,14 +4604,14 @@ void HandleCleanup(int code) if (getpid() == lastProxy) { nxinfo << "Loop: Reverting to loop context in process with " - << "pid '" << getpid() << "' at " << strMsTimestamp() - << ".\n" << std::flush; + << "pid '" << getpid() << "' at " << strMsTimestamp() + << ".\n" << std::flush; } else { nxinfo << "Loop: Exiting from child process with pid '" - << getpid() << "' at " << strMsTimestamp() - << ".\n" << std::flush; + << getpid() << "' at " << strMsTimestamp() + << ".\n" << std::flush; } @@ -4647,8 +4647,8 @@ void CleanupKeeper() if (keeper != NULL) { nxinfo << "Loop: Freeing up keeper in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete keeper; @@ -4668,8 +4668,8 @@ void CleanupStreams() #ifndef __CYGWIN32__ nxinfo << "Loop: Freeing up streams in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; if (logofs != NULL && logofs != &cerr && *errorsFileName != '\0') @@ -4766,9 +4766,9 @@ void CleanupChildren() if (IsRunning(lastDialog)) { nxinfo << "Loop: WARNING! Leaving the dialog process '" - << lastDialog << "' running in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << lastDialog << "' running in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; SetNotRunning(lastDialog); } @@ -4780,8 +4780,8 @@ void CleanupChildren() if (control -> EnableRestartOnShutdown == 1) { nxwarn << "Loop: WARNING! Respawning the NX client " - << "on display '" << displayHost << "'.\n" - << std::flush; + << "on display '" << displayHost << "'.\n" + << std::flush; NXTransClient(displayHost); } @@ -4789,8 +4789,8 @@ void CleanupChildren() for (int i = 0; i < control -> KillDaemonOnShutdownNumber; i++) { nxwarn << "Loop: WARNING! Killing the NX daemon with " - << "pid '" << control -> KillDaemonOnShutdown[i] - << "'.\n" << std::flush; + << "pid '" << control -> KillDaemonOnShutdown[i] + << "'.\n" << std::flush; KillProcess(control -> KillDaemonOnShutdown[i], "daemon", SIGTERM, 0); } @@ -4801,8 +4801,8 @@ void CleanupGlobal() if (proxy != NULL) { nxinfo << "Loop: Freeing up proxy in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete proxy; @@ -4812,8 +4812,8 @@ void CleanupGlobal() if (agent != NULL) { nxinfo << "Loop: Freeing up agent in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete agent; @@ -4823,8 +4823,8 @@ void CleanupGlobal() if (auth != NULL) { nxinfo << "Loop: Freeing up auth data in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete auth; @@ -4834,8 +4834,8 @@ void CleanupGlobal() if (statistics != NULL) { nxinfo << "Loop: Freeing up statistics in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete statistics; @@ -4845,8 +4845,8 @@ void CleanupGlobal() if (control != NULL) { nxinfo << "Loop: Freeing up control in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; delete control; @@ -4859,12 +4859,12 @@ void CleanupConnections() if (proxy -> getChannels(channel_x11) != 0) { nxinfo << "Loop: Closing any remaining X connections.\n" - << std::flush; + << std::flush; proxy -> handleCloseAllXConnections(); nxinfo << "Loop: Closing any remaining listener.\n" - << std::flush; + << std::flush; proxy -> handleCloseAllListeners(); } @@ -4879,8 +4879,8 @@ void CleanupListeners() if (tcpFD != -1) { nxinfo << "Loop: Closing TCP listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(tcpFD); @@ -4895,8 +4895,8 @@ void CleanupListeners() if (unixFD != -1) { nxinfo << "Loop: Closing UNIX listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(unixFD); @@ -4906,8 +4906,8 @@ void CleanupListeners() if (*unixSocketName != '\0') { nxinfo << "Loop: Going to remove the Unix domain socket '" - << unixSocketName << "' in process " << "with pid '" - << getpid() << "'.\n" << std::flush; + << unixSocketName << "' in process " << "with pid '" + << getpid() << "'.\n" << std::flush; unlink(unixSocketName); } @@ -4930,8 +4930,8 @@ void CleanupListeners() if (cupsFD != -1) { nxinfo << "Loop: Closing CUPS listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(cupsFD); @@ -4946,8 +4946,8 @@ void CleanupListeners() if (auxFD != -1) { nxinfo << "Loop: Closing auxiliary X11 listener " - << "in process " << "with pid '" << getpid() - << "'.\n" << std::flush; + << "in process " << "with pid '" << getpid() + << "'.\n" << std::flush; close(auxFD); @@ -4962,8 +4962,8 @@ void CleanupListeners() if (smbFD != -1) { nxinfo << "Loop: Closing SMB listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(smbFD); @@ -4978,8 +4978,8 @@ void CleanupListeners() if (mediaFD != -1) { nxinfo << "Loop: Closing multimedia listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(mediaFD); @@ -4994,8 +4994,8 @@ void CleanupListeners() if (httpFD != -1) { nxinfo << "Loop: Closing http listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(httpFD); @@ -5010,8 +5010,8 @@ void CleanupListeners() if (fontFD != -1) { nxinfo << "Loop: Closing font server listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(fontFD); @@ -5026,8 +5026,8 @@ void CleanupListeners() if (slaveFD != -1) { nxinfo << "Loop: Closing slave listener in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(slaveFD); @@ -5043,8 +5043,8 @@ void CleanupSockets() if (proxyFD != -1) { nxinfo << "Loop: Closing proxy FD in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(proxyFD); @@ -5054,8 +5054,8 @@ void CleanupSockets() if (agentFD[1] != -1) { nxinfo << "Loop: Closing agent FD in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; close(agentFD[1]); @@ -5198,8 +5198,8 @@ int CheckAbort() if (lastSignal != 0) { nxinfo << "Loop: Aborting the procedure due to signal '" - << lastSignal << "', '" << DumpSignal(lastSignal) - << "'.\n" << std::flush; + << lastSignal << "', '" << DumpSignal(lastSignal) + << "'.\n" << std::flush; cerr << "Info" << ": Aborting the procedure due to signal '" << lastSignal << "'.\n"; @@ -5256,7 +5256,7 @@ void HandleAbort() } nxinfo << "Loop: Showing the proxy abort dialog.\n" - << std::flush; + << std::flush; if (control -> ProxyMode == proxy_server) { @@ -5289,8 +5289,8 @@ void HandleAlert(int code, int local) if (lastAlert.code == 0) { nxinfo << "Loop: Requesting an alert dialog with code " - << code << " and local " << local << ".\n" - << std::flush; + << code << " and local " << local << ".\n" + << std::flush; lastAlert.code = code; lastAlert.local = local; @@ -5298,8 +5298,8 @@ void HandleAlert(int code, int local) else { nxinfo << "Loop: WARNING! Alert dialog already requested " - << "with code " << lastAlert.code << ".\n" - << std::flush; + << "with code " << lastAlert.code << ".\n" + << std::flush; } return; @@ -5310,16 +5310,16 @@ void FlushCallback(int length) if (flushCallback != NULL) { nxinfo << "Loop: Reporting a flush request at " - << strMsTimestamp() << " with " << length - << " bytes written.\n" << std::flush; + << strMsTimestamp() << " with " << length + << " bytes written.\n" << std::flush; (*flushCallback)(flushParameter, length); } else if (control -> ProxyMode == proxy_client) { nxinfo << "Loop: WARNING! Can't find a flush " - << "callback in process with pid '" << getpid() - << "'.\n" << std::flush; + << "callback in process with pid '" << getpid() + << "'.\n" << std::flush; } } @@ -5336,8 +5336,8 @@ void KeeperCallback() control -> ImageCacheEnableSave == 1) { nxinfo << "Loop: Starting the house-keeping process with " - << "image storage size " << control -> ImageCacheDiskLimit - << ".\n" << std::flush; + << "image storage size " << control -> ImageCacheDiskLimit + << ".\n" << std::flush; lastKeeper = NXTransKeeper(0, control -> ImageCacheDiskLimit, control -> RootPath); @@ -5345,34 +5345,34 @@ void KeeperCallback() if (IsFailed(lastKeeper)) { nxwarn << "Loop: WARNING! Can't start the NX keeper process.\n" - << std::flush; + << std::flush; SetNotRunning(lastKeeper); } else { nxinfo << "Loop: Keeper started with pid '" - << lastKeeper << "'.\n" << std::flush; + << lastKeeper << "'.\n" << std::flush; } } else { nxinfo << "Loop: Nothing to do for the keeper process " - << "with image cache not enabled.\n" - << std::flush; + << "with image cache not enabled.\n" + << std::flush; } } else { nxinfo << "Loop: Nothing to do with the keeper process " - << "already running.\n" << std::flush; + << "already running.\n" << std::flush; } } void InstallSignals() { nxinfo << "Loop: Installing signals in process with pid '" - << getpid() << "'.\n" << std::flush; + << getpid() << "'.\n" << std::flush; for (int i = 0; i < 32; i++) { @@ -5389,7 +5389,7 @@ void InstallSignals() void RestoreSignals() { nxinfo << "Loop: Restoring signals in process with pid '" - << getpid() << "'.\n" << std::flush; + << getpid() << "'.\n" << std::flush; if (lastMasks.installed == 1) { @@ -5433,8 +5433,8 @@ void DisableSignals() if (CheckSignal(i) > 0) { nxdbg << "Loop: Disabling signal " << i << " '" - << DumpSignal(i) << "' in process with pid '" - << getpid() << "'.\n" << std::flush; + << DumpSignal(i) << "' in process with pid '" + << getpid() << "'.\n" << std::flush; sigaddset(&newMask, i); } @@ -5447,8 +5447,8 @@ void DisableSignals() else { nxinfo << "Loop: WARNING! Signals were already blocked in " - << "process with pid '" << getpid() << "'.\n" - << std::flush; + << "process with pid '" << getpid() << "'.\n" + << std::flush; } } @@ -5457,7 +5457,7 @@ void EnableSignals() if (lastMasks.blocked == 1) { nxinfo << "Loop: Enabling signals in process with pid '" - << getpid() << "'.\n" << std::flush; + << getpid() << "'.\n" << std::flush; sigprocmask(SIG_SETMASK, &lastMasks.saved, NULL); @@ -5466,8 +5466,8 @@ void EnableSignals() else { nxwarn << "Loop: WARNING! Signals were not blocked in " - << "process with pid '" << getpid() << "'.\n" - << std::flush; + << "process with pid '" << getpid() << "'.\n" + << std::flush; cerr << "Warning" << ": Signals were not blocked in " << "process with pid '" << getpid() << "'.\n"; @@ -5481,9 +5481,9 @@ void InstallSignal(int signal, int action) if (action == NX_SIGNAL_FORWARD) { nxinfo << "Loop: Forwarding handler for signal " << signal - << " '" << DumpSignal(signal) << "' in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << " '" << DumpSignal(signal) << "' in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; lastMasks.forward[signal] = 1; @@ -5492,17 +5492,17 @@ void InstallSignal(int signal, int action) else { nxinfo << "Loop: Reinstalling handler for signal " << signal - << " '" << DumpSignal(signal) << "' in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << " '" << DumpSignal(signal) << "' in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; } } else { nxinfo << "Loop: Installing handler for signal " << signal - << " '" << DumpSignal(signal) << "' in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << " '" << DumpSignal(signal) << "' in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; } if (signal == SIGALRM && isTimestamp(lastTimer.start)) @@ -5542,8 +5542,8 @@ void RestoreSignal(int signal) if (lastMasks.enabled[signal] == 0) { nxwarn << "Loop: WARNING! Signal '" << DumpSignal(signal) - << " not installed in process with pid '" - << getpid() << "'.\n" << std::flush; + << " not installed in process with pid '" + << getpid() << "'.\n" << std::flush; cerr << "Warning" << ": Signal '" << DumpSignal(signal) << " not installed in process with pid '" @@ -5553,9 +5553,9 @@ void RestoreSignal(int signal) } nxinfo << "Loop: Restoring handler for signal " << signal - << " '" << DumpSignal(signal) << "' in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << " '" << DumpSignal(signal) << "' in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; if (signal == SIGALRM && isTimestamp(lastTimer.start)) { @@ -5579,21 +5579,21 @@ void HandleSignal(int signal) if (lastSignal != 0) { nxinfo << "Loop: WARNING! Last signal is '" << lastSignal - << "', '" << DumpSignal(signal) << "' and not zero " - << "in process with pid '" << getpid() << "'.\n" - << std::flush; + << "', '" << DumpSignal(signal) << "' and not zero " + << "in process with pid '" << getpid() << "'.\n" + << std::flush; } nxinfo << "Loop: Signal '" << signal << "', '" - << DumpSignal(signal) << "' received in process " - << "with pid '" << getpid() << "'.\n" << std::flush; + << DumpSignal(signal) << "' received in process " + << "with pid '" << getpid() << "'.\n" << std::flush; if (getpid() != lastProxy && signalHandler != NULL) { nxinfo << "Loop: Calling slave handler in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; if ((*signalHandler)(signal) == 0) { @@ -5679,12 +5679,12 @@ void HandleSignal(int signal) // nxinfo << "Loop: WARNING! Received signal '12' in " - << "process with pid '" << getpid() << "'.\n" - << std::flush; + << "process with pid '" << getpid() << "'.\n" + << std::flush; nxinfo << "Loop: WARNING! Please check that the " - << "cygserver daemon is running.\n" - << std::flush; + << "cygserver daemon is running.\n" + << std::flush; break; } @@ -5702,9 +5702,9 @@ void HandleSignal(int signal) if (getpid() == lastProxy) { nxinfo << "Loop: Registering end of session request " - << "due to signal '" << signal << "', '" - << DumpSignal(signal) << "'.\n" - << std::flush; + << "due to signal '" << signal << "', '" + << DumpSignal(signal) << "'.\n" + << std::flush; lastSignal = signal; } @@ -5725,16 +5725,16 @@ void HandleSignal(int signal) lastMasks.action[signal].sa_handler != HandleSignal) { nxinfo << "Loop: Forwarding signal '" << signal << "', '" - << DumpSignal(signal) << "' to previous handler.\n" - << std::flush; + << DumpSignal(signal) << "' to previous handler.\n" + << std::flush; lastMasks.action[signal].sa_handler(signal); } else if (lastMasks.action[signal].sa_handler == NULL) { nxwarn << "Loop: WARNING! Parent requested to forward " - << "signal '" << signal << "', '" << DumpSignal(signal) - << "' but didn't set a handler.\n" << std::flush; + << "signal '" << signal << "', '" << DumpSignal(signal) + << "' but didn't set a handler.\n" << std::flush; } } } @@ -5750,7 +5750,7 @@ int HandleChildren() if (IsRunning(lastDialog) && HandleChild(lastDialog) == 1) { nxinfo << "Loop: Resetting pid of last dialog process " - << "in handler.\n" << std::flush; + << "in handler.\n" << std::flush; SetNotRunning(lastDialog); @@ -5765,12 +5765,12 @@ int HandleChildren() if (IsRunning(lastWatchdog) && HandleChild(lastWatchdog) == 1) { nxinfo << "Loop: Watchdog is gone. Setting the last " - << "signal to SIGHUP.\n" << std::flush; + << "signal to SIGHUP.\n" << std::flush; lastSignal = SIGHUP; nxinfo << "Loop: Resetting pid of last watchdog process " - << "in handler.\n" << std::flush; + << "in handler.\n" << std::flush; SetNotRunning(lastWatchdog); @@ -5788,7 +5788,7 @@ int HandleChildren() if (IsRunning(lastKeeper) && HandleChild(lastKeeper) == 1) { nxinfo << "Loop: Resetting pid of last house-keeping " - << "process in handler.\n" << std::flush; + << "process in handler.\n" << std::flush; SetNotRunning(lastKeeper); @@ -5803,7 +5803,7 @@ int HandleChildren() if (IsRunning(lastChild)) { nxinfo << "Loop: Resetting pid of last child process " - << "in handler.\n" << std::flush; + << "in handler.\n" << std::flush; SetNotRunning(lastChild); @@ -5820,7 +5820,7 @@ int HandleChildren() // nxinfo << "Loop: Ignoring signal received for the " - << "unregistered child.\n" << std::flush; + << "unregistered child.\n" << std::flush; return 0; } @@ -5848,8 +5848,8 @@ int WaitChild(int child, const char* label, int force) for (;;) { nxinfo << "Loop: Waiting for the " << label - << " process '" << child << "' to die.\n" - << std::flush; + << " process '" << child << "' to die.\n" + << std::flush; pid = waitpid(child, &status, options); @@ -5861,9 +5861,9 @@ int WaitChild(int child, const char* label, int force) } nxwarn << "Loop: WARNING! Ignoring signal while " - << "waiting for the " << label << " process '" - << child << "' to die.\n" - << std::flush; + << "waiting for the " << label << " process '" + << child << "' to die.\n" + << std::flush; continue; } @@ -5883,8 +5883,8 @@ int CheckChild(int pid, int status) if (WIFSTOPPED(status)) { nxinfo << "Loop: Child process '" << pid << "' was stopped " - << "with signal " << (WSTOPSIG(status)) << ".\n" - << std::flush; + << "with signal " << (WSTOPSIG(status)) << ".\n" + << std::flush; return 0; } @@ -5893,8 +5893,8 @@ int CheckChild(int pid, int status) if (WIFEXITED(status)) { nxinfo << "Loop: Child process '" << pid << "' exited " - << "with status '" << (WEXITSTATUS(status)) - << "'.\n" << std::flush; + << "with status '" << (WEXITSTATUS(status)) + << "'.\n" << std::flush; lastStatus = WEXITSTATUS(status); } @@ -5903,9 +5903,9 @@ int CheckChild(int pid, int status) if (CheckSignal(WTERMSIG(status)) != 1) { nxwarn << "Loop: WARNING! Child process '" << pid - << "' died because of signal " << (WTERMSIG(status)) - << ", '" << DumpSignal(WTERMSIG(status)) << "'.\n" - << std::flush; + << "' died because of signal " << (WTERMSIG(status)) + << ", '" << DumpSignal(WTERMSIG(status)) << "'.\n" + << std::flush; cerr << "Warning" << ": Child process '" << pid << "' died because of signal " << (WTERMSIG(status)) @@ -5914,9 +5914,9 @@ int CheckChild(int pid, int status) else { nxinfo << "Loop: Child process '" << pid - << "' died because of signal " << (WTERMSIG(status)) - << ", '" << DumpSignal(WTERMSIG(status)) << "'.\n" - << std::flush; + << "' died because of signal " << (WTERMSIG(status)) + << ", '" << DumpSignal(WTERMSIG(status)) << "'.\n" + << std::flush; } lastStatus = 1; @@ -5947,7 +5947,7 @@ int CheckChild(int pid, int status) // nxinfo << "Loop: No more children processes running.\n" - << std::flush; + << std::flush; return 1; } @@ -5961,15 +5961,15 @@ void RegisterChild(int child) if (IsNotRunning(lastChild)) { nxinfo << "Loop: Registering child process '" << child - << "' in process with pid '" << getpid() - << "'.\n" << std::flush; + << "' in process with pid '" << getpid() + << "'.\n" << std::flush; } else { nxinfo << "Loop: WARNING! Overriding registered child '" - << lastChild << "' with new child '" << child - << "' in process with pid '" << getpid() - << "'.\n" << std::flush; + << lastChild << "' with new child '" << child + << "' in process with pid '" << getpid() + << "'.\n" << std::flush; } @@ -5981,8 +5981,8 @@ int CheckParent(const char *name, const char *type, int parent) if (parent != getppid() || parent == 1) { nxwarn << name << ": WARNING! Parent process appears " - << "to be dead. Exiting " << type << ".\n" - << std::flush; + << "to be dead. Exiting " << type << ".\n" + << std::flush; cerr << "Warning" << ": Parent process appears " << "to be dead. Exiting " << type << ".\n"; @@ -6000,8 +6000,8 @@ void HandleTimer(int signal) if (isTimestamp(lastTimer.start)) { nxinfo << "Loop: Timer expired at " << strMsTimestamp() - << " in process with pid '" << getpid() << "'.\n" - << std::flush; + << " in process with pid '" << getpid() << "'.\n" + << std::flush; if (proxy != NULL) { @@ -6045,8 +6045,8 @@ void SetTimer(int value) if (diffTs > lastTimer.next.tv_usec / 1000 * 2) { nxwarn << "Loop: WARNING! Timer missed to expire at " - << strMsTimestamp() << " in process with pid '" - << getpid() << "'.\n" << std::flush; + << strMsTimestamp() << " in process with pid '" + << getpid() << "'.\n" << std::flush; cerr << "Warning" << ": Timer missed to expire at " << strMsTimestamp() << " in process with pid '" @@ -6057,8 +6057,8 @@ void SetTimer(int value) else { nxinfo << "Loop: Timer already running at " - << strMsTimestamp() << " in process with pid '" - << getpid() << "'.\n" << std::flush; + << strMsTimestamp() << " in process with pid '" + << getpid() << "'.\n" << std::flush; return; } @@ -6092,10 +6092,10 @@ void SetTimer(int value) timer.it_value = lastTimer.next; nxinfo << "Loop: Timer set to " << lastTimer.next.tv_sec - << " S and " << lastTimer.next.tv_usec / 1000 - << " Ms at " << strMsTimestamp() << " in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << " S and " << lastTimer.next.tv_usec / 1000 + << " Ms at " << strMsTimestamp() << " in process " + << "with pid '" << getpid() << "'.\n" + << std::flush; if (setitimer(ITIMER_REAL, &timer, &lastTimer.value) < 0) { @@ -6120,15 +6120,15 @@ void ResetTimer() if (isTimestamp(lastTimer.start) == 0) { nxinfo << "Loop: Timer not running in process " - << "with pid '" << getpid() << "'.\n" - << std::flush; + << "with pid '" << getpid() << "'.\n" + << std::flush; return; } nxinfo << "Loop: Timer reset at " << strMsTimestamp() - << " in process with pid '" << getpid() - << "'.\n" << std::flush; + << " in process with pid '" << getpid() + << "'.\n" << std::flush; // // Restore the old signal mask and timer. @@ -6227,8 +6227,8 @@ int WaitForRemote(ChannelEndPoint &socketAddress) socketAddress.getSpec(&socketUri); nxinfo << "Loop: Waiting for connection from " - << hostLabel << " on socket '" << socketUri - << "'.\n" << std::flush; + << hostLabel << " on socket '" << socketUri + << "'.\n" << std::flush; cerr << "Info" << ": Waiting for connection from " << hostLabel << " on socket '" << socketUri << "'.\n"; @@ -6316,8 +6316,8 @@ int WaitForRemote(ChannelEndPoint &socketAddress) char * unixPath = NULL; socketAddress.getUnixPath(&unixPath); nxinfo << "Loop: Accepted connection from this host on Unix file socket '" - << unixPath << "'.\n" - << std::flush; + << unixPath << "'.\n" + << std::flush; cerr << "Info" << ": Accepted connection from this host on Unix file socket '" << unixPath << "'.\n"; @@ -6336,8 +6336,8 @@ int WaitForRemote(ChannelEndPoint &socketAddress) unsigned int connectedPort = ntohs(newAddrINET.sin_port); nxinfo << "Loop: Accepted connection from '" << connectedHost - << "' with port '" << connectedPort << "'.\n" - << std::flush; + << "' with port '" << connectedPort << "'.\n" + << std::flush; cerr << "Info" << ": Accepted connection from '" << connectedHost << "'.\n"; @@ -6450,9 +6450,9 @@ int PrepareProxyConnectionTCP(char** hostName, long int* portNum, int* timeout, HandleCleanup(); } - nxinfo << "Loop: Connecting to remote host '" - << *hostName << ":" << *portNum << "'.\n" - << std::flush; + nxinfo << "Loop: Connecting to remote host '" + << *hostName << ":" << *portNum << "'.\n" + << std::flush; cerr << "Info" << ": Connecting to remote host '" << *hostName << ":" << *portNum << "'.\n" @@ -6615,9 +6615,9 @@ int ConnectToRemote(ChannelEndPoint &socketAddress) { nxdbg << "Loop: Timer set to " << connectTimeout / 1000 - << " S " << "with retry set to " << retryConnect - << " in process with pid '" << getpid() - << "'.\n" << std::flush; + << " S " << "with retry set to " << retryConnect + << " in process with pid '" << getpid() + << "'.\n" << std::flush; if (socketAddress.getUnixPath(&unixPath)) result = PrepareProxyConnectionUnix(&unixPath, &connectTimeout, &pFD, &reason); @@ -6664,8 +6664,8 @@ int ConnectToRemote(ChannelEndPoint &socketAddress) else { nxinfo << "Loop: Sleeping " << retryTimeout - << " ms before retrying.\n" - << std::flush; + << " ms before retrying.\n" + << std::flush; usleep(retryTimeout * 1000); @@ -6723,8 +6723,8 @@ int ConnectToRemote(ChannelEndPoint &socketAddress) } { nxinfo << "Loop: Not showing the dialog with " - << (diffTimestamp(lastRetry, getTimestamp()) / 1000) - << " seconds elapsed.\n" << std::flush; + << (diffTimestamp(lastRetry, getTimestamp()) / 1000) + << " seconds elapsed.\n" << std::flush; } ESET(reason); @@ -6732,16 +6732,16 @@ int ConnectToRemote(ChannelEndPoint &socketAddress) if (unixPath && unixPath[0] != '\0' ) { nxinfo << "Loop: Connection to Unix socket file '" - << unixPath << "' failed with error '" - << ESTR() << "'. Retrying.\n" - << std::flush; + << unixPath << "' failed with error '" + << ESTR() << "'. Retrying.\n" + << std::flush; } else { nxinfo << "Loop: Connection to '" << hostName - << ":" << portNum << "' failed with error '" - << ESTR() << "'. Retrying.\n" - << std::flush; + << ":" << portNum << "' failed with error '" + << ESTR() << "'. Retrying.\n" + << std::flush; } } else @@ -6923,7 +6923,7 @@ int SendProxyOptions(int fd) } nxinfo << "Loop: Sending remote options '" - << options << "'.\n" << std::flush; + << options << "'.\n" << std::flush; return WriteLocalData(fd, options, strlen(options)); } @@ -6931,7 +6931,7 @@ int SendProxyOptions(int fd) int ReadProxyVersion(int fd) { nxinfo << "Loop: Going to read the remote proxy version " - << "from FD#" << fd << ".\n" << std::flush; + << "from FD#" << fd << ".\n" << std::flush; // // Read until the first space in string. @@ -6958,8 +6958,8 @@ int ReadProxyVersion(int fd) } nxinfo << "Loop: Received remote version string '" - << options << "' from FD#" << fd << ".\n" - << std::flush; + << options << "' from FD#" << fd << ".\n" + << std::flush; if (strncmp(options, "NXPROXY-", strlen("NXPROXY-")) != 0) { @@ -6992,8 +6992,8 @@ int ReadProxyVersion(int fd) major != -1 && minor != -1 && patch != -1) { nxinfo << "Loop: Read trailing remote version '" << major - << "." << minor << "." << patch << "'.\n" - << std::flush; + << "." << minor << "." << patch << "'.\n" + << std::flush; control -> CompatVersionMajor = major; control -> CompatVersionMinor = minor; @@ -7047,7 +7047,7 @@ int ReadProxyVersion(int fd) int ReadProxyOptions(int fd) { nxinfo << "Loop: Going to read the remote proxy options " - << "from FD#" << fd << ".\n" << std::flush; + << "from FD#" << fd << ".\n" << std::flush; char options[DEFAULT_REMOTE_OPTIONS_LENGTH]; @@ -7059,8 +7059,8 @@ int ReadProxyOptions(int fd) } nxinfo << "Loop: Received remote options string '" - << options << "' from FD#" << fd << ".\n" - << std::flush; + << options << "' from FD#" << fd << ".\n" + << std::flush; // // Get the remote options, delimited by a space character. @@ -7086,7 +7086,7 @@ int ReadProxyOptions(int fd) int SendProxyCaches(int fd) { nxinfo << "Loop: Synchronizing local and remote caches.\n" - << std::flush; + << std::flush; if (control -> ProxyMode == proxy_client) { @@ -7096,7 +7096,7 @@ int SendProxyCaches(int fd) // nxinfo << "Loop: Going to send the list of local caches.\n" - << std::flush; + << std::flush; SetCaches(); @@ -7108,7 +7108,7 @@ int SendProxyCaches(int fd) control -> PersistentCacheEnableLoad == 0) { nxinfo << "Loop: Writing an empty list to FD#" << fd - << ".\n" << std::flush; + << ".\n" << std::flush; return WriteLocalData(fd, "cachelist=none ", strlen("cachelist=none ")); } @@ -7116,7 +7116,7 @@ int SendProxyCaches(int fd) int count = 0; nxinfo << "Loop: Looking for cache files in directory '" - << control -> PersistentCachePath << "'.\n" << std::flush; + << control -> PersistentCachePath << "'.\n" << std::flush; DIR *cacheDir = opendir(control -> PersistentCachePath); @@ -7143,8 +7143,8 @@ int SendProxyCaches(int fd) } nxinfo << "Loop: Writing entry '" << control -> PersistentCachePath - << "/" << dirEntry -> d_name << "' to FD#" << fd - << ".\n" << std::flush; + << "/" << dirEntry -> d_name << "' to FD#" << fd + << ".\n" << std::flush; // // Write cache file name to the socket, @@ -7163,7 +7163,7 @@ int SendProxyCaches(int fd) if (count == 0) { nxinfo << "Loop: Writing an empty list to FD#" << fd - << ".\n" << std::flush; + << ".\n" << std::flush; return WriteLocalData(fd, "cachelist=none ", strlen("cachelist=none ")); } @@ -7179,15 +7179,15 @@ int SendProxyCaches(int fd) // nxinfo << "Loop: Going to send the selected cache.\n" - << std::flush; + << std::flush; char buffer[DEFAULT_STRING_LENGTH]; if (control -> PersistentCacheName != NULL) { nxinfo << "Loop: Name of selected cache file is '" - << control -> PersistentCacheName << "'.\n" - << std::flush; + << control -> PersistentCacheName << "'.\n" + << std::flush; sprintf(buffer, "cachefile=%s%s ", *(control -> PersistentCacheName) == 'C' ? "S-" : "C-", @@ -7196,14 +7196,14 @@ int SendProxyCaches(int fd) else { nxinfo << "Loop: No valid cache file was selected.\n" - << std::flush; + << std::flush; sprintf(buffer, "cachefile=none "); } nxinfo << "Loop: Sending string '" << buffer - << "' as selected cache file.\n" - << std::flush; + << "' as selected cache file.\n" + << std::flush; return WriteLocalData(fd, buffer, strlen(buffer)); } @@ -7214,7 +7214,7 @@ int ReadProxyCaches(int fd) if (control -> ProxyMode == proxy_client) { nxinfo << "Loop: Going to receive the selected proxy cache.\n" - << std::flush; + << std::flush; // // We will read the name of cache plus the stop character. @@ -7259,7 +7259,7 @@ int ReadProxyCaches(int fd) if (strncasecmp(cacheName, "none", strlen("none")) == 0) { nxinfo << "Loop: No cache file selected by remote proxy.\n" - << std::flush; + << std::flush; } else if (strlen(cacheName) != MD5_LENGTH * 2 + 3 || *(cacheName + MD5_LENGTH * 2 + 2) != ' ') @@ -7286,13 +7286,13 @@ int ReadProxyCaches(int fd) strcpy(control -> PersistentCacheName, cacheName); nxinfo << "Loop: Cache file '" << control -> PersistentCacheName - << "' selected by remote proxy.\n" << std::flush; + << "' selected by remote proxy.\n" << std::flush; } } else { nxinfo << "Loop: Going to receive the list of remote caches.\n" - << std::flush; + << std::flush; SetCaches(); @@ -7311,7 +7311,7 @@ int ReadProxyCaches(int fd) } nxinfo << "Loop: Read list of caches from remote side as '" - << buffer << "'.\n" << std::flush; + << buffer << "'.\n" << std::flush; // // Prepare the buffer. What we want is a list @@ -7348,7 +7348,7 @@ int ReadProxyCaches(int fd) int ReadForwarderVersion(int fd) { nxinfo << "Loop: Going to negotiate the forwarder version.\n" - << std::flush; + << std::flush; // // Check if we actually expect the session cookie. @@ -7357,7 +7357,7 @@ int ReadForwarderVersion(int fd) if (*authCookie == '\0') { nxinfo << "Loop: No authentication cookie required " - << "from FD#" << fd << ".\n" << std::flush; + << "from FD#" << fd << ".\n" << std::flush; return 1; } @@ -7372,7 +7372,7 @@ int ReadForwarderVersion(int fd) } nxinfo << "Loop: Received forwarder version string '" << options - << "' from FD#" << fd << ".\n" << std::flush; + << "' from FD#" << fd << ".\n" << std::flush; if (strncmp(options, "NXSSH-", strlen("NXSSH-")) != 0) { @@ -7393,8 +7393,8 @@ int ReadForwarderVersion(int fd) &(control -> RemoteVersionMinor), &(control -> RemoteVersionPatch)); nxinfo << "Loop: Read forwarder version '" << control -> RemoteVersionMajor - << "." << control -> RemoteVersionMinor << "." << control -> RemoteVersionPatch - << "'.\n" << std::flush; + << "." << control -> RemoteVersionMinor << "." << control -> RemoteVersionPatch + << "'.\n" << std::flush; return 1; } @@ -7408,7 +7408,7 @@ int ReadForwarderOptions(int fd) if (*authCookie == '\0') { nxinfo << "Loop: No authentication cookie required " - << "from FD#" << fd << ".\n" << std::flush; + << "from FD#" << fd << ".\n" << std::flush; return 1; } @@ -7423,8 +7423,8 @@ int ReadForwarderOptions(int fd) } nxinfo << "Loop: Received forwarder options string '" - << options << "' from FD#" << fd << ".\n" - << std::flush; + << options << "' from FD#" << fd << ".\n" + << std::flush; if (ParseForwarderOptions(options) < 0) { @@ -7444,7 +7444,7 @@ int ReadForwarderOptions(int fd) int ReadRemoteData(int fd, char *buffer, int size, char stop) { nxinfo << "Loop: Going to read remote data from FD#" - << fd << ".\n" << std::flush; + << fd << ".\n" << std::flush; if (size >= MAXIMUM_REMOTE_OPTIONS_LENGTH) { @@ -7470,7 +7470,7 @@ int ReadRemoteData(int fd, char *buffer, int size, char stop) if (EGET() == EAGAIN) { nxinfo << "Loop: Reading data from FD#" << fd - << " would block.\n" << std::flush; + << " would block.\n" << std::flush; return 0; } @@ -7496,7 +7496,7 @@ int ReadRemoteData(int fd, char *buffer, int size, char stop) else if (*(remoteData + remotePosition) == stop) { nxinfo << "Loop: Read stop character from FD#" - << fd << ".\n" << std::flush; + << fd << ".\n" << std::flush; remotePosition++; @@ -7510,8 +7510,8 @@ int ReadRemoteData(int fd, char *buffer, int size, char stop) memcpy(buffer, remoteData, remotePosition + 1); nxinfo << "Loop: Remote string '" << remoteData - << "' read from FD#" << fd << ".\n" - << std::flush; + << "' read from FD#" << fd << ".\n" + << std::flush; int t = remotePosition; @@ -7529,9 +7529,9 @@ int ReadRemoteData(int fd, char *buffer, int size, char stop) if (isgraph(*(remoteData + remotePosition)) == 0) { nxwarn << "Loop: WARNING! Non printable character decimal '" - << (unsigned int) *(remoteData + remotePosition) - << "' received in remote data from FD#" - << fd << ".\n" << std::flush; + << (unsigned int) *(remoteData + remotePosition) + << "' received in remote data from FD#" + << fd << ".\n" << std::flush; cerr << "Warning" << ": Non printable character decimal '" << (unsigned int) *(remoteData + remotePosition) @@ -7542,8 +7542,8 @@ int ReadRemoteData(int fd, char *buffer, int size, char stop) } nxdbg << "Loop: Read a further character " - << "from FD#" << fd << ".\n" - << std::flush; + << "from FD#" << fd << ".\n" + << std::flush; remotePosition++; } @@ -7620,7 +7620,7 @@ int WriteLocalData(int fd, const char *buffer, int size) ret = select(fd+1, NULL, &writeSet, NULL, &selectTs); nxdbg << "Loop: WriteLocalData: select() returned with a code of " << ret << " and remaining timeout of " - << selectTs.tv_sec << " sec, " << selectTs.tv_usec << "usec\n" << std::flush; + << selectTs.tv_sec << " sec, " << selectTs.tv_usec << "usec\n" << std::flush; if ( ret < 0 ) { @@ -7649,7 +7649,7 @@ int WriteLocalData(int fd, const char *buffer, int size) } nxinfo << "Loop: Error writing data to FD#" - << fd << ".\n" << std::flush; + << fd << ".\n" << std::flush; return -1; } @@ -7693,8 +7693,8 @@ int ParseEnvironmentOptions(const char *env, int force) if (setjmp(context) == 1) { nxinfo << "Loop: Out of the long jump while parsing " - << "the environment options.\n" - << std::flush; + << "the environment options.\n" + << std::flush; return -1; } @@ -7702,8 +7702,8 @@ int ParseEnvironmentOptions(const char *env, int force) if (force == 0 && parsedOptions == 1) { nxinfo << "Loop: Skipping a further parse of environment " - << "options string '" << (env != NULL ? env : "") - << "'.\n" << std::flush; + << "options string '" << (env != NULL ? env : "") + << "'.\n" << std::flush; return 1; } @@ -7711,15 +7711,15 @@ int ParseEnvironmentOptions(const char *env, int force) if (env == NULL || *env == '\0') { nxinfo << "Loop: Nothing to do with empty environment " - << "options string '" << (env != NULL ? env : "") - << "'.\n" << std::flush; + << "options string '" << (env != NULL ? env : "") + << "'.\n" << std::flush; return 0; } nxinfo << "Loop: Going to parse the environment options " - << "string '" << env << "'.\n" - << std::flush; + << "string '" << env << "'.\n" + << std::flush; parsedOptions = 1; @@ -7785,7 +7785,7 @@ int ParseEnvironmentOptions(const char *env, int force) else if (force == 0) { nxinfo << "Loop: Ignoring host X server display string '" - << opts << "'.\n" << std::flush; + << opts << "'.\n" << std::flush; return 0; } @@ -7849,7 +7849,7 @@ int ParseEnvironmentOptions(const char *env, int force) } nxinfo << "Loop: Parsing options string '" - << nextOpts << "'.\n" << std::flush; + << nextOpts << "'.\n" << std::flush; // // Now all the other optional parameters. @@ -8256,7 +8256,7 @@ int ParseEnvironmentOptions(const char *env, int force) else if (strcasecmp(name, "sync") == 0) { nxwarn << "Loop: WARNING! No 'sync' channel in current version. " - << "Assuming 'cups' channel.\n" << std::flush; + << "Assuming 'cups' channel.\n" << std::flush; cerr << "Warning" << ": No 'sync' channel in current version. " << "Assuming 'cups' channel.\n"; @@ -8300,7 +8300,7 @@ int ParseEnvironmentOptions(const char *env, int force) if (timeout == 0) { nxinfo << "Loop: Disabling timeout on broken " - << "proxy connection.\n" << std::flush; + << "proxy connection.\n" << std::flush; control -> ProxyTimeout = 0; } @@ -8316,7 +8316,7 @@ int ParseEnvironmentOptions(const char *env, int force) if (cleanup == 0) { nxinfo << "Loop: Disabling grace timeout on " - << "proxy shutdown.\n" << std::flush; + << "proxy shutdown.\n" << std::flush; control -> CleanupTimeout = 0; } @@ -8352,9 +8352,9 @@ int ParseEnvironmentOptions(const char *env, int force) control -> KillDaemonOnShutdownLimit) { nxinfo << "Loop: WARNING! Adding process with pid '" - << ValidateArg("local", name, value) << " to the " - << "daemons to kill at shutdown.\n" - << std::flush; + << ValidateArg("local", name, value) << " to the " + << "daemons to kill at shutdown.\n" + << std::flush; control -> KillDaemonOnShutdown[control -> KillDaemonOnShutdownNumber] = @@ -8365,7 +8365,7 @@ int ParseEnvironmentOptions(const char *env, int force) else { nxwarn << "Loop: WARNING! Number of daemons to kill " - << "at shutdown exceeded.\n" << std::flush; + << "at shutdown exceeded.\n" << std::flush; cerr << "Warning" << ": Number of daemons to kill " << "at shutdown exceeded.\n"; @@ -8402,8 +8402,8 @@ int ParseEnvironmentOptions(const char *env, int force) strcasecmp(name, "tolerancechecks") == 0) { nxdbg << "Loop: Ignoring agent option '" << name - << "' with value '" << value << "'.\n" - << std::flush; + << "' with value '" << value << "'.\n" + << std::flush; } else if (strcasecmp(name, "composite") == 0 || strcasecmp(name, "shmem") == 0 || @@ -8417,8 +8417,8 @@ int ParseEnvironmentOptions(const char *env, int force) strcasecmp(name, "xinerama") == 0) { nxdbg << "Loop: Ignoring agent option '" << name - << "' with value '" << value << "'.\n" - << std::flush; + << "' with value '" << value << "'.\n" + << std::flush; } else if (strcasecmp(name, "defer") == 0 || strcasecmp(name, "tile") == 0 || @@ -8426,14 +8426,14 @@ int ParseEnvironmentOptions(const char *env, int force) strcasecmp(name, "state") == 0 ) { nxdbg << "Loop: Ignoring agent option '" << name - << "' with value '" << value << "'.\n" - << std::flush; + << "' with value '" << value << "'.\n" + << std::flush; } else { nxwarn << "Loop: WARNING! Ignoring unknown option '" - << name << "' with value '" << value << "'.\n" - << std::flush; + << name << "' with value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Ignoring unknown option '" << name << "' with value '" << value << "'.\n"; @@ -8455,14 +8455,14 @@ int ParseEnvironmentOptions(const char *env, int force) } nxinfo << "Loop: Completed parsing of string '" - << env << "'.\n" << std::flush; + << env << "'.\n" << std::flush; if ((*fileOptions != '\0') && (strncmp(fileOptions, "/dev/", 5) != 0) && (strncmp(fileOptions, "/proc/", 6) != 0) && (strncmp(fileOptions, "/sys/", 5) != 0)) { if (strcmp(fileOptions, optionsFileName) != 0) { nxinfo << "Loop: Reading options from '" << fileOptions - << "'.\n" << std::flush; + << "'.\n" << std::flush; if (ParseFileOptions(fileOptions) < 0) { @@ -8472,8 +8472,8 @@ int ParseEnvironmentOptions(const char *env, int force) else { nxwarn << "Loop: WARNING! Name of the options file " - << "specified multiple times. Not parsing " - << "again.\n" << std::flush; + << "specified multiple times. Not parsing " + << "again.\n" << std::flush; } if (*optionsFileName == '\0') @@ -8481,8 +8481,8 @@ int ParseEnvironmentOptions(const char *env, int force) strncpy(optionsFileName, value, DEFAULT_STRING_LENGTH - 1); nxinfo << "Loop: Assuming name of options file '" - << optionsFileName << "'.\n" - << std::flush; + << optionsFileName << "'.\n" + << std::flush; } } @@ -8523,8 +8523,8 @@ int ParseCommandLineOptions(int argc, const char **argv) if (setjmp(context) == 1) { nxinfo << "Loop: Out of the long jump while parsing " - << "the command line options.\n" - << std::flush; + << "the command line options.\n" + << std::flush; return -1; } @@ -8541,13 +8541,13 @@ int ParseCommandLineOptions(int argc, const char **argv) if (parsedCommand == 1) { nxinfo << "Loop: Skipping a further parse of command line options.\n" - << std::flush; + << std::flush; return 1; } nxinfo << "Loop: Going to parse the command line options.\n" - << std::flush; + << std::flush; parsedCommand = 1; @@ -8592,7 +8592,7 @@ int ParseCommandLineOptions(int argc, const char **argv) if (WE_SET_PROXY_MODE == 0) { nxinfo << "Loop: Setting local proxy mode to proxy_client.\n" - << std::flush; + << std::flush; control -> ProxyMode = proxy_client; } @@ -8618,7 +8618,7 @@ int ParseCommandLineOptions(int argc, const char **argv) if (WE_SET_PROXY_MODE == 0) { nxinfo << "Loop: Setting local proxy mode to proxy_server.\n" - << std::flush; + << std::flush; control -> ProxyMode = proxy_server; } @@ -8850,7 +8850,7 @@ int ParseFileOptions(const char *file) } nxinfo << "Loop: Going to read options from file '" - << fileName << "'.\n" << std::flush; + << fileName << "'.\n" << std::flush; FILE *filePtr = fopen(fileName, "r"); @@ -8912,7 +8912,7 @@ int ParseFileOptions(const char *file) } nxinfo << "Loop: Read options '" << options << "' from file '" - << fileName << "'.\n" << std::flush; + << fileName << "'.\n" << std::flush; if (ParseEnvironmentOptions(options, 1) < 0) { @@ -8934,8 +8934,8 @@ int ParseFileOptions(const char *file) int ParseRemoteOptions(char *opts) { nxinfo << "Loop: Going to parse the remote options " - << "string '" << opts << "'.\n" - << std::flush; + << "string '" << opts << "'.\n" + << std::flush; char *name; char *value; @@ -8981,8 +8981,8 @@ int ParseRemoteOptions(char *opts) if (WE_PROVIDE_CREDENTIALS) { nxwarn << "Loop: WARNING! Ignoring remote option 'cookie' " - << "with value '" << value << "' when initiating " - << "connection.\n" << std::flush; + << "with value '" << value << "' when initiating " + << "connection.\n" << std::flush; cerr << "Warning" << ": Ignoring remote option 'cookie' " << "with value '" << value << "' when initiating " @@ -9013,8 +9013,8 @@ int ParseRemoteOptions(char *opts) if (*linkSpeedName != '\0' && strcasecmp(linkSpeedName, value) != 0) { nxwarn << "Loop: WARNING! Overriding option 'link' " - << "with new value '" << value << "'.\n" - << std::flush; + << "with new value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Overriding option 'link' " << "with new value '" << value << "'.\n"; @@ -9046,8 +9046,8 @@ int ParseRemoteOptions(char *opts) if (*packMethodName != '\0' && strcasecmp(packMethodName, value) != 0) { nxwarn << "Loop: WARNING! Overriding option 'pack' " - << "with remote value '" << value << "'.\n" - << std::flush; + << "with remote value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Overriding option 'pack' " << "with remote value '" << value << "'.\n"; @@ -9139,8 +9139,8 @@ int ParseRemoteOptions(char *opts) strcasecmp(bitrateLimitName, value) != 0) { nxwarn << "Loop: WARNING! Overriding option 'limit' " - << "with new value '" << value << "'.\n" - << std::flush; + << "with new value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Overriding option 'limit' " << "with new value '" << value << "'.\n"; @@ -9226,7 +9226,7 @@ int ParseRemoteOptions(char *opts) { nxfatal << "Loop: PANIC! Can't identify size of shared memory " << "segment in string '" << value << "'.\n" - << std::flush; + << std::flush; cerr << "Error" << ": Can't identify size of shared memory " << "segment in string '" << value << "'.\n"; @@ -9357,14 +9357,14 @@ int ParseRemoteOptions(char *opts) // nxdbg << "Loop: Ignoring obsolete remote option '" - << name << "' with value '" << value - << "'.\n" << std::flush; + << name << "' with value '" << value + << "'.\n" << std::flush; } else { nxwarn << "Loop: WARNING! Ignoring unknown remote option '" - << name << "' with value '" << value << "'.\n" - << std::flush; + << name << "' with value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Ignoring unknown remote option '" << name << "' with value '" << value << "'.\n"; @@ -9473,8 +9473,8 @@ int ParseRemoteOptions(char *opts) int ParseForwarderOptions(char *opts) { nxinfo << "Loop: Going to parse the forwarder options " - << "string '" << opts << "'.\n" - << std::flush; + << "string '" << opts << "'.\n" + << std::flush; char *name; char *value; @@ -9520,8 +9520,8 @@ int ParseForwarderOptions(char *opts) else { nxwarn << "Loop: WARNING! Ignoring unknown forwarder option '" - << name << "' with value '" << value << "'.\n" - << std::flush; + << name << "' with value '" << value << "'.\n" + << std::flush; cerr << "Warning" << ": Ignoring unknown forwarder option '" << name << "' with value '" << value << "'.\n"; @@ -9554,7 +9554,7 @@ int SetCore() if (getrlimit(RLIMIT_CORE, &rlim)) { nxinfo << "Cannot read RLIMIT_CORE. Error is '" - << ESTR() << "'.\n" << std::flush; + << ESTR() << "'.\n" << std::flush; return -1; } @@ -9566,14 +9566,14 @@ int SetCore() if (setrlimit(RLIMIT_CORE, &rlim)) { nxinfo << "Loop: Cannot read RLIMIT_CORE. Error is '" - << ESTR() << "'.\n" << std::flush; + << ESTR() << "'.\n" << std::flush; return -2; } } nxinfo << "Loop: Set RLIMIT_CORE to "<< rlim.rlim_max - << ".\n" << std::flush; + << ".\n" << std::flush; #endif // #ifdef COREDUMPS @@ -9586,8 +9586,8 @@ char *GetLastCache(char *listBuffer, const char *searchPath) strncmp(listBuffer, "cachelist=", strlen("cachelist=")) != 0) { nxinfo << "Loop: Invalid parameters '" << listBuffer << "' and '" - << (searchPath != NULL ? searchPath : "") - << "'. Can't select any cache.\n" << std::flush; + << (searchPath != NULL ? searchPath : "") + << "'. Can't select any cache.\n" << std::flush; return NULL; } @@ -9635,7 +9635,7 @@ char *GetLastCache(char *listBuffer, const char *searchPath) if (strncmp(fileName, "none", strlen("none")) == 0) { nxinfo << "Loop: No cache files seem to be available.\n" - << std::flush; + << std::flush; delete [] selectedName; @@ -9645,7 +9645,7 @@ char *GetLastCache(char *listBuffer, const char *searchPath) strncmp(fileName, remotePrefix, 2) != 0) { nxfatal << "Loop: PANIC! Bad cache file name '" - << fileName << "'.\n" << std::flush; + << fileName << "'.\n" << std::flush; cerr << "Error" << ": Bad cache file name '" << fileName << "'.\n"; @@ -9656,7 +9656,7 @@ char *GetLastCache(char *listBuffer, const char *searchPath) } nxinfo << "Loop: Parsing remote cache name '" - << fileName << "'.\n" << std::flush; + << fileName << "'.\n" << std::flush; // // Prefix, received as "S-", becomes @@ -9672,7 +9672,7 @@ char *GetLastCache(char *listBuffer, const char *searchPath) if (stat(fullPath, &fileStat) == 0) { nxinfo << "Loop: Found a matching cache '" - << std::string(fullPath) << "'.\n" << std::flush; + << std::string(fullPath) << "'.\n" << std::flush; if (fileStat.st_mtime >= selectedTime) { @@ -9684,7 +9684,7 @@ char *GetLastCache(char *listBuffer, const char *searchPath) else { nxinfo << "Loop: Can't get stats of file '" - << std::string(fullPath) << "'.\n" << std::flush; + << std::string(fullPath) << "'.\n" << std::flush; } fileName = strtok(NULL, ","); @@ -9716,14 +9716,14 @@ char *GetTempPath() if (tempEnv == NULL || *tempEnv == '\0') { nxinfo << "Loop: WARNING! No environment for NX_TEMP.\n" - << std::flush; + << std::flush; tempEnv = getenv("TEMP"); if (tempEnv == NULL || *tempEnv == '\0') { nxinfo << "Loop: WARNING! No environment for TEMP.\n" - << std::flush; + << std::flush; tempEnv = "/tmp"; } @@ -9745,7 +9745,7 @@ char *GetTempPath() strcpy(tempDir, tempEnv); nxinfo << "Loop: Assuming temporary NX directory '" - << tempDir << "'.\n" << std::flush; + << tempDir << "'.\n" << std::flush; } char *tempPath = new char[strlen(tempDir) + 1]; @@ -9779,7 +9779,7 @@ char *GetClientPath() if (clientEnv == NULL || *clientEnv == '\0') { nxinfo << "Loop: WARNING! No environment for NX_CLIENT.\n" - << std::flush; + << std::flush; // // Try to guess the location of the client. @@ -9816,7 +9816,7 @@ char *GetClientPath() strcpy(clientDir, clientEnv); nxinfo << "Loop: Assuming NX client location '" - << clientDir << "'.\n" << std::flush; + << clientDir << "'.\n" << std::flush; } char *clientPath = new char[strlen(clientDir) + 1]; @@ -9850,7 +9850,7 @@ char *GetSystemPath() if (systemEnv == NULL || *systemEnv == '\0') { nxinfo << "Loop: WARNING! No environment for NX_SYSTEM.\n" - << std::flush; + << std::flush; systemEnv = "/usr/NX"; } @@ -9871,7 +9871,7 @@ char *GetSystemPath() strcpy(systemDir, systemEnv); nxinfo << "Loop: Assuming system NX directory '" - << systemDir << "'.\n" << std::flush; + << systemDir << "'.\n" << std::flush; } char *systemPath = new char[strlen(systemDir) + 1]; @@ -9905,7 +9905,7 @@ char *GetHomePath() if (homeEnv == NULL || *homeEnv == '\0') { nxinfo << "Loop: WARNING! No environment for NX_HOME.\n" - << std::flush; + << std::flush; homeEnv = getenv("HOME"); @@ -9936,7 +9936,7 @@ char *GetHomePath() strcpy(homeDir, homeEnv); nxinfo << "Loop: Assuming NX user's home directory '" - << homeDir << "'.\n" << std::flush; + << homeDir << "'.\n" << std::flush; } char *homePath = new char[strlen(homeDir) + 1]; @@ -9970,7 +9970,7 @@ char *GetRootPath() if (rootEnv == NULL || *rootEnv == '\0') { nxinfo << "Loop: WARNING! No environment for NX_ROOT.\n" - << std::flush; + << std::flush; // // We will determine the root NX directory @@ -9995,7 +9995,7 @@ char *GetRootPath() } nxinfo << "Loop: Assuming NX root directory in " - << "the user's home '" << homeEnv + << "the user's home '" << homeEnv << "'.\n" << std::flush; strcpy(rootDir, homeEnv); @@ -10044,7 +10044,7 @@ char *GetRootPath() } nxinfo << "Loop: Assuming NX root directory '" - << rootDir << "'.\n" << std::flush; + << rootDir << "'.\n" << std::flush; } char *rootPath = new char[strlen(rootDir) + 1]; @@ -10250,7 +10250,7 @@ char *GetSessionPath() } nxinfo << "Loop: Root of NX session is '" << sessionDir - << "'.\n" << std::flush; + << "'.\n" << std::flush; delete [] rootPath; } @@ -10321,11 +10321,11 @@ int ParseLinkOption(const char *opt) int ParsePackOption(const char *opt) { nxdbg << "Loop: Pack method is " << packMethod - << " quality is " << packQuality << ".\n" - << std::flush; + << " quality is " << packQuality << ".\n" + << std::flush; nxdbg << "Loop: Parsing pack method '" << opt - << "'.\n" << std::flush; + << "'.\n" << std::flush; if (strcasecmp(opt, "0") == 0 || strcasecmp(opt, "none") == 0 || @@ -10514,7 +10514,7 @@ int ParsePackOption(const char *opt) packQuality = atoi(dash + 1); nxdbg << "Loop: Using pack quality '" - << packQuality << "'.\n" << std::flush; + << packQuality << "'.\n" << std::flush; } } else @@ -10818,12 +10818,12 @@ int SetLogs() strcpy(statsFileName, "stats"); nxinfo << "Loop: Assuming default statistics file '" - << statsFileName << "'.\n" << std::flush; + << statsFileName << "'.\n" << std::flush; } else { nxinfo << "Loop: Name selected for statistics is '" - << statsFileName << "'.\n" << std::flush; + << statsFileName << "'.\n" << std::flush; } if (OpenLogFile(statsFileName, statofs) < 0) @@ -10838,12 +10838,12 @@ int SetLogs() strcpy(errorsFileName, "errors"); nxinfo << "Loop: Assuming default log file name '" - << errorsFileName << "'.\n" << std::flush; + << errorsFileName << "'.\n" << std::flush; } else { nxinfo << "Loop: Name selected for log file is '" - << errorsFileName << "'.\n" << std::flush; + << errorsFileName << "'.\n" << std::flush; } // @@ -10883,12 +10883,12 @@ int SetLogs() if (*sessionFileName != '\0') { nxinfo << "Loop: Name selected for session file is '" - << sessionFileName << "'.\n" << std::flush; + << sessionFileName << "'.\n" << std::flush; if (errofs != NULL) { nxwarn << "Loop: WARNING! Unexpected value for stream errofs.\n" - << std::flush; + << std::flush; cerr << "Warning" << ": Unexpected value for stream errofs.\n"; } @@ -10896,7 +10896,7 @@ int SetLogs() if (errsbuf != NULL) { nxwarn << "Loop: WARNING! Unexpected value for buffer errsbuf.\n" - << std::flush; + << std::flush; cerr << "Warning" << ": Unexpected value for buffer errsbuf.\n"; } @@ -10958,7 +10958,7 @@ int SetPorts() nxinfo << "Loop: cups port: " << cupsPort << "\n" - << std::flush; + << std::flush; if (control -> ProxyMode == proxy_client) { auxPort.setDefaultTCPPort(DEFAULT_NX_AUX_PORT_OFFSET + proxyPort); @@ -10968,8 +10968,8 @@ int SetPorts() if ( auxPort.getTCPPort() != 1 ) { nxwarn << "Loop: WARNING! Overriding auxiliary X11 " - << "port with new value '" << 1 << "'.\n" - << std::flush; + << "port with new value '" << 1 << "'.\n" + << std::flush; cerr << "Warning" << ": Overriding auxiliary X11 " << "port with new value '" << 1 << "'.\n"; @@ -10979,7 +10979,7 @@ int SetPorts() } nxinfo << "Loop: aux port: " << auxPort << "\n" - << std::flush; + << std::flush; if (control -> ProxyMode == proxy_client) { smbPort.setDefaultTCPPort(DEFAULT_NX_SMB_PORT_OFFSET + proxyPort); @@ -10990,7 +10990,7 @@ int SetPorts() nxinfo << "Loop: smb port: " << smbPort << "\n" - << std::flush; + << std::flush; if ( mediaPort.configured() ) { if (control -> ProxyMode == proxy_client) { @@ -11010,7 +11010,7 @@ int SetPorts() } nxinfo << "Loop: Using multimedia port '" << mediaPort - << "'.\n" << std::flush; + << "'.\n" << std::flush; if (control -> ProxyMode == proxy_client) { httpPort.setDefaultTCPPort(DEFAULT_NX_HTTP_PORT_OFFSET + proxyPort); @@ -11020,12 +11020,12 @@ int SetPorts() } nxinfo << "Loop: Using HTTP port '" << httpPort - << "'.\n" << std::flush; + << "'.\n" << std::flush; if (ParseFontPath(fontPort) <= 0) { nxinfo << "Loop: Disabling font server connections.\n" - << std::flush; + << std::flush; *fontPort = '\0'; @@ -11050,7 +11050,7 @@ int SetPorts() } nxinfo << "Loop: Using font server port '" << fontPort - << "'.\n" << std::flush; + << "'.\n" << std::flush; } if (control -> ProxyMode == proxy_client) { @@ -11061,7 +11061,7 @@ int SetPorts() } nxinfo << "Loop: Using slave port '" << slavePort - << "'.\n" << std::flush; + << "'.\n" << std::flush; return 1; } @@ -11149,7 +11149,7 @@ int SetCaches() } nxinfo << "Loop: Path of cache files is '" << control -> PersistentCachePath - << "'.\n" << std::flush; + << "'.\n" << std::flush; return 1; } @@ -11273,8 +11273,8 @@ int SetSession() if (*sessionType != '\0') { nxwarn << "Loop: WARNING! Unrecognized session type '" - << sessionType << "'. Assuming agent session.\n" - << std::flush; + << sessionType << "'. Assuming agent session.\n" + << std::flush; cerr << "Warning" << ": Unrecognized session type '" << sessionType << "'. Assuming agent session.\n"; @@ -11284,9 +11284,9 @@ int SetSession() } nxinfo << "Loop: Assuming session type '" - << DumpSession(control -> SessionMode) << "' with " - << "string '" << sessionType << "'.\n" - << std::flush; + << DumpSession(control -> SessionMode) << "' with " + << "string '" << sessionType << "'.\n" + << std::flush; // // By default the policy is immediate. Agents @@ -11307,16 +11307,16 @@ int SetSession() } nxinfo << "Loop: WARNING! Forcing flush policy to '" - << DumpPolicy(control -> FlushPolicy) - << ".\n" << std::flush; + << DumpPolicy(control -> FlushPolicy) + << ".\n" << std::flush; } else { control -> FlushPolicy = policy_immediate; nxinfo << "Loop: Setting initial flush policy to '" - << DumpPolicy(control -> FlushPolicy) - << "'.\n" << std::flush; + << DumpPolicy(control -> FlushPolicy) + << "'.\n" << std::flush; } // @@ -11340,14 +11340,14 @@ int SetSession() if (control -> LinkEncrypted == 1) { nxinfo << "Loop: Proxy running as part of an " - << "encrypting client.\n" - << std::flush; + << "encrypting client.\n" + << std::flush; } else { nxinfo << "Loop: Assuming proxy running as a " - << "standalone program.\n" - << std::flush; + << "standalone program.\n" + << std::flush; } // @@ -11370,7 +11370,7 @@ int SetSession() if (stat(fileName, &fileStat) == 0) { nxinfo << "Loop: Enabling respawn of client at session shutdown.\n" - << std::flush; + << std::flush; control -> EnableRestartOnShutdown = 1; } @@ -11425,17 +11425,17 @@ int SetStorage() } nxdbg << "Loop: Storage size limit is " - << control -> ClientTotalStorageSize - << " at client and " - << control -> ServerTotalStorageSize - << " at server.\n" - << std::flush; + << control -> ClientTotalStorageSize + << " at client and " + << control -> ServerTotalStorageSize + << " at server.\n" + << std::flush; nxdbg << "Loop: Storage local limit set to " - << control -> LocalTotalStorageSize - << " remote limit set to " - << control -> RemoteTotalStorageSize - << ".\n" << std::flush; + << control -> LocalTotalStorageSize + << " remote limit set to " + << control -> RemoteTotalStorageSize + << ".\n" << std::flush; // // Never reserve for split store more than @@ -11446,8 +11446,8 @@ int SetStorage() SplitTotalStorageSize > size / 2) { nxinfo << "Loop: Reducing size of split store to " - << size / 2 << " bytes.\n" - << std::flush; + << size / 2 << " bytes.\n" + << std::flush; control -> SplitTotalStorageSize = size / 2; } @@ -11461,8 +11461,8 @@ int SetStorage() if (control -> HideRender == 1) { nxinfo << "Loop: Not loading render extension " - << "from persistent cache.\n" - << std::flush; + << "from persistent cache.\n" + << std::flush; control -> PersistentCacheLoadRender = 0; } @@ -11532,13 +11532,13 @@ int SetShmem() control -> ShmemServer = 1; nxinfo << "Loop: Set initial shared memory size " - << "to " << control -> ShmemServerSize - << " bytes.\n" << std::flush; + << "to " << control -> ShmemServerSize + << " bytes.\n" << std::flush; } else { nxinfo << "Loop: Disabled use of the shared memory " - << "extension.\n" << std::flush; + << "extension.\n" << std::flush; control -> ShmemServer = 0; } @@ -11558,8 +11558,8 @@ int SetShmem() int SetPack() { nxinfo << "Loop: Setting pack with initial method " - << packMethod << " and quality " << packQuality - << ".\n" << std::flush; + << packMethod << " and quality " << packQuality + << ".\n" << std::flush; // // Check if this is a proxy session and, in @@ -11571,7 +11571,7 @@ int SetPack() if (control -> SessionMode == session_proxy) { nxinfo << "Loop: WARNING! Disabling pack with proxy session.\n" - << std::flush; + << std::flush; packMethod = PACK_NONE; } @@ -11593,8 +11593,8 @@ int SetPack() control -> PersistentCacheLoadPacked = 0; nxinfo << "Loop: Not loading packed images " - << "from persistent cache.\n" - << std::flush; + << "from persistent cache.\n" + << std::flush; } return 1; @@ -11615,8 +11615,8 @@ int SetImages() if (control -> SessionMode == session_proxy) { nxinfo << "Loop: Disabling image cache with " - << "session '" << DumpSession(control -> - SessionMode) << "'.\n" << std::flush; + << "session '" << DumpSession(control -> + SessionMode) << "'.\n" << std::flush; sprintf(imagesSizeName, "0"); @@ -11655,13 +11655,13 @@ int SetImages() } nxinfo << "Loop: Path of image cache files is '" << control -> ImageCachePath - << "'.\n" << std::flush; + << "'.\n" << std::flush; } } else { nxinfo << "Loop: Disabling the persistent image cache.\n" - << std::flush; + << std::flush; control -> ImageCacheEnableLoad = 0; control -> ImageCacheEnableSave = 0; @@ -11702,8 +11702,8 @@ int SetVersion() patch = control -> CompatVersionPatch; nxinfo << "Loop: Using compatibility version '" - << major << "." << minor << "." << patch - << "'.\n" << std::flush; + << major << "." << minor << "." << patch + << "'.\n" << std::flush; } else if (control -> LocalVersionMajor > control -> RemoteVersionMajor) @@ -11719,8 +11719,8 @@ int SetVersion() patch = control -> RemoteVersionPatch; nxinfo << "Loop: Using remote version '" - << major << "." << minor << "." << patch - << "'.\n" << std::flush; + << major << "." << minor << "." << patch + << "'.\n" << std::flush; } else { @@ -11739,8 +11739,8 @@ int SetVersion() patch = control -> RemoteVersionPatch; nxinfo << "Loop: Using remote version '" - << major << "." << minor << "." << patch - << "'.\n" << std::flush; + << major << "." << minor << "." << patch + << "'.\n" << std::flush; } else { @@ -11749,8 +11749,8 @@ int SetVersion() patch = control -> LocalVersionPatch; nxinfo << "Loop: Using local version '" - << major << "." << minor << "." << patch - << "'.\n" << std::flush; + << major << "." << minor << "." << patch + << "'.\n" << std::flush; } } @@ -11776,8 +11776,8 @@ int SetVersion() if (step == 0) { nxfatal << "Loop: PANIC! Unable to set the protocol step value from " - << "the negotiated protocol version " << major << "." << minor - << "." << patch << ".\n" << std::flush; + << "the negotiated protocol version " << major << "." << minor + << "." << patch << ".\n" << std::flush; cerr << "Error" << ": Unable to set the protocol step value from " << "the negotiated protocol version " << major << "." << minor @@ -11799,7 +11799,7 @@ int SetVersion() } nxinfo << "Loop: Using NX protocol step " - << step << ".\n" << std::flush; + << step << ".\n" << std::flush; control -> setProtoStep(step); @@ -11816,10 +11816,10 @@ int SetVersion() if (local != remote) { nxwarn << "Loop: WARNING! Connected to remote version " - << control -> RemoteVersionMajor << "." << control -> RemoteVersionMinor - << "." << control -> RemoteVersionPatch << " with local version " - << control -> LocalVersionMajor << "." << control -> LocalVersionMinor - << "." << control -> LocalVersionPatch << ".\n" << std::flush; + << control -> RemoteVersionMajor << "." << control -> RemoteVersionMinor + << "." << control -> RemoteVersionPatch << " with local version " + << control -> LocalVersionMajor << "." << control -> LocalVersionMinor + << "." << control -> LocalVersionPatch << ".\n" << std::flush; cerr << "Warning" << ": Connected to remote version " << control -> RemoteVersionMajor << "." << control -> RemoteVersionMinor @@ -11850,10 +11850,10 @@ int SetVersion() // nxinfo << __FILE__ << " : " << __LINE__ << " - " - << "step = " << control -> getProtoStep() - << " packMethod = " << packMethod - << " packQuality = " << packQuality - << ".\n" << std::flush; + << "step = " << control -> getProtoStep() + << " packMethod = " << packMethod + << " packQuality = " << packQuality + << ".\n" << std::flush; // // Update the pack method name. @@ -11881,8 +11881,8 @@ int SetVersion() // Since ProtoStep8 (#issue 108) nxinfo << "Loop: Disabling image cache with protocol " - << "step '" << control -> getProtoStep() - << "'.\n" << std::flush; + << "step '" << control -> getProtoStep() + << "'.\n" << std::flush; sprintf(imagesSizeName, "0"); @@ -11901,7 +11901,7 @@ int SetVersion() int SetLink() { nxinfo << "Loop: Setting link with initial value " - << linkSpeedName << ".\n" << std::flush; + << linkSpeedName << ".\n" << std::flush; if (*linkSpeedName == '\0') { @@ -11909,7 +11909,7 @@ int SetLink() } nxinfo << "Loop: Link speed is " << linkSpeedName - << ".\n" << std::flush; + << ".\n" << std::flush; if (strcasecmp(linkSpeedName, "modem") == 0) { @@ -11989,8 +11989,8 @@ int SetLink() else { nxwarn << "Loop: WARNING! Forcing taint of replies " - << "with a proxy session.\n" - << std::flush; + << "with a proxy session.\n" + << std::flush; control -> TaintReplies = 1; } @@ -12015,8 +12015,8 @@ int SetLink() if (control -> SessionMode == session_proxy) { nxwarn << "Loop: WARNING! Forcing flush on priority " - << "with a proxy session.\n" - << std::flush; + << "with a proxy session.\n" + << std::flush; control -> FlushPriority = 1; } @@ -12031,7 +12031,7 @@ int SetLink() int SetLinkModem() { nxinfo << "Loop: Setting parameters for MODEM.\n" - << std::flush; + << std::flush; control -> LinkMode = LINK_TYPE_MODEM; @@ -12059,7 +12059,7 @@ int SetLinkModem() int SetLinkIsdn() { nxinfo << "Loop: Setting parameters for ISDN.\n" - << std::flush; + << std::flush; control -> LinkMode = LINK_TYPE_ISDN; @@ -12087,7 +12087,7 @@ int SetLinkIsdn() int SetLinkAdsl() { nxinfo << "Loop: Setting parameters for ADSL.\n" - << std::flush; + << std::flush; control -> LinkMode = LINK_TYPE_ADSL; @@ -12115,7 +12115,7 @@ int SetLinkAdsl() int SetLinkWan() { nxinfo << "Loop: Setting parameters for WAN.\n" - << std::flush; + << std::flush; control -> LinkMode = LINK_TYPE_WAN; @@ -12143,7 +12143,7 @@ int SetLinkWan() int SetLinkLan() { nxinfo << "Loop: Setting parameters for LAN.\n" - << std::flush; + << std::flush; control -> LinkMode = LINK_TYPE_LAN; @@ -12401,9 +12401,9 @@ int SetLimits() if (useStrict == 1) { nxinfo << "Loop: LIMIT! Decreasing the token limit " - << "to " << control -> TokenLimit / 2 - << " with option 'strict'.\n" - << std::flush; + << "to " << control -> TokenLimit / 2 + << " with option 'strict'.\n" + << std::flush; control -> TokenLimit /= 2; } @@ -12413,9 +12413,9 @@ int SetLimits() control -> TokenLimit = 1; nxinfo << "Loop: WARNING! LIMIT! Setting the token limit " - << "to " << control -> TokenLimit - << " to simulate the proxy congestion.\n" - << std::flush; + << "to " << control -> TokenLimit + << " to simulate the proxy congestion.\n" + << std::flush; #endif @@ -12448,11 +12448,11 @@ int SetLimits() } nxinfo << "Loop: LIMIT! Setting client bitrate limit " - << "to " << control -> ClientBitrateLimit - << " server bitrate limit to " << control -> - ServerBitrateLimit << " with local limit " - << control -> LocalBitrateLimit << ".\n" - << std::flush; + << "to " << control -> ClientBitrateLimit + << " server bitrate limit to " << control -> + ServerBitrateLimit << " with local limit " + << control -> LocalBitrateLimit << ".\n" + << std::flush; return 1; } @@ -12480,7 +12480,7 @@ int ParseCacheOption(const char *opt) } nxinfo << "Loop: Setting size of cache to " - << size << " bytes.\n" << std::flush; + << size << " bytes.\n" << std::flush; control -> ClientTotalStorageSize = size; control -> ServerTotalStorageSize = size; @@ -12490,12 +12490,12 @@ int ParseCacheOption(const char *opt) if (size == 0) { nxwarn << "Loop: WARNING! Disabling NX delta compression.\n" - << std::flush; + << std::flush; control -> LocalDeltaCompression = 0; nxwarn << "Loop: WARNING! Disabling use of NX persistent cache.\n" - << std::flush; + << std::flush; control -> PersistentCacheEnableLoad = 0; control -> PersistentCacheEnableSave = 0; @@ -12521,7 +12521,7 @@ int ParseImagesOption(const char *opt) } nxinfo << "Loop: Setting size of images cache to " - << size << " bytes.\n" << std::flush; + << size << " bytes.\n" << std::flush; control -> ImageCacheDiskLimit = size; @@ -12550,8 +12550,8 @@ int ParseShmemOption(const char *opt) control -> ShmemServerSize = size; nxinfo << "Loop: Set shared memory size to " - << control -> ShmemServerSize << " bytes.\n" - << std::flush; + << control -> ShmemServerSize << " bytes.\n" + << std::flush; strcpy(shsegSizeName, opt); @@ -12579,14 +12579,14 @@ int ParseBitrateOption(const char *opt) if (bitrate == 0) { nxinfo << "Loop: Disabling bitrate limit on proxy link.\n" - << std::flush; + << std::flush; control -> LocalBitrateLimit = 0; } else { nxinfo << "Loop: Setting bitrate to " << bitrate - << " bits per second.\n" << std::flush; + << " bits per second.\n" << std::flush; // // Internal representation is in bytes @@ -12602,7 +12602,7 @@ int ParseBitrateOption(const char *opt) int ParseHostOption(const char *opt, char *host, long &port) { nxinfo << "Loop: Trying to parse options string '" << opt - << "' as a remote NX host.\n" << std::flush; + << "' as a remote NX host.\n" << std::flush; if (opt == NULL || *opt == '\0') { @@ -12644,7 +12644,7 @@ int ParseHostOption(const char *opt, char *host, long &port) if (newPort < 0 || *check != '\0') { nxinfo << "Loop: Can't identify remote NX port in string '" - << separator << "'.\n" << std::flush; + << separator << "'.\n" << std::flush; return 0; } @@ -12657,7 +12657,7 @@ int ParseHostOption(const char *opt, char *host, long &port) // nxinfo << "Loop: Can't identify remote NX port in string '" - << opt << "'.\n" << std::flush; + << opt << "'.\n" << std::flush; return 0; } @@ -12683,7 +12683,7 @@ int ParseHostOption(const char *opt, char *host, long &port) if (*check != '\0') { nxinfo << "Loop: Can't identify remote NX host in string '" - << newHost << "'.\n" << std::flush; + << newHost << "'.\n" << std::flush; return 0; } @@ -12707,8 +12707,8 @@ int ParseHostOption(const char *opt, char *host, long &port) if (*host != '\0' && strcmp(host, newHost) != 0) { nxwarn << "Loop: WARNING! Overriding remote NX host '" - << host << "' with new value '" << newHost - << "'.\n" << std::flush; + << host << "' with new value '" << newHost + << "'.\n" << std::flush; } strcpy(host, newHost); @@ -12716,13 +12716,13 @@ int ParseHostOption(const char *opt, char *host, long &port) if (port != -1 && port != newPort) { nxwarn << "Loop: WARNING! Overriding remote NX port '" - << port << "' with new value '" << newPort - << "'.\n" << std::flush; + << port << "' with new value '" << newPort + << "'.\n" << std::flush; } nxinfo << "Loop: Parsed options string '" << opt - << "' with host '" << newHost << "' and port '" - << newPort << "'.\n" << std::flush; + << "' with host '" << newHost << "' and port '" + << newPort << "'.\n" << std::flush; port = newPort; @@ -12741,7 +12741,7 @@ int ParseFontPath(char *path) } nxinfo << "Loop: Parsing font server option '" << path - << "'.\n" << std::flush; + << "'.\n" << std::flush; // // Convert the value to our default port. @@ -12772,7 +12772,7 @@ int ParseFontPath(char *path) if (atoi(path) > 0) { nxinfo << "Loop: Assuming numeric TCP port '" << atoi(path) - << "' for font server.\n" << std::flush; + << "' for font server.\n" << std::flush; return 1; } @@ -12791,7 +12791,7 @@ int ParseFontPath(char *path) *(path + DEFAULT_STRING_LENGTH - 1) = '\0'; nxinfo << "Loop: Assuming Unix socket '" << path - << "' for font server.\n" << std::flush; + << "' for font server.\n" << std::flush; } else if (strncmp("tcp/:", path, 5) == 0) { @@ -12805,7 +12805,7 @@ int ParseFontPath(char *path) } nxinfo << "Loop: Assuming TCP port '" << atoi(path) - << "' for font server.\n" << std::flush; + << "' for font server.\n" << std::flush; } else { @@ -12820,7 +12820,7 @@ int ParseFontPath(char *path) } nxinfo << "Loop: Assuming Unix socket '" << path - << "' for font server.\n" << std::flush; + << "' for font server.\n" << std::flush; } return 1; @@ -12828,8 +12828,8 @@ int ParseFontPath(char *path) ParseFontPathError: nxinfo << "Loop: Unable to determine the font server " - << "port in string '" << path << "'.\n" - << std::flush; + << "port in string '" << path << "'.\n" + << std::flush; return -1; } @@ -12839,7 +12839,7 @@ int OpenLogFile(char *name, ostream *&stream) if (name == NULL || *name == '\0') { nxinfo << "Loop: WARNING! No name provided for output. Using standard error.\n" - << std::flush; + << std::flush; if (stream == NULL) { @@ -12939,8 +12939,8 @@ int ReopenLogFile(char *name, ostream *&stream, int limit) if (stat(name, &fileStat) != 0) { nxwarn << "Loop: WARNING! Can't get stats of file '" - << name << "'. Error is " << EGET() - << " '" << ESTR() << "'.\n" << std::flush; + << name << "'. Error is " << EGET() + << " '" << ESTR() << "'.\n" << std::flush; return 0; } @@ -12951,8 +12951,8 @@ int ReopenLogFile(char *name, ostream *&stream, int limit) } nxinfo << "Loop: Deleting file '" << name - << "' with size " << fileStat.st_size - << ".\n" << std::flush; + << "' with size " << fileStat.st_size + << ".\n" << std::flush; // // Create a new stream over the previous @@ -12979,7 +12979,7 @@ int ReopenLogFile(char *name, ostream *&stream, int limit) umask(fileMode); nxinfo << "Loop: Reopened file '" << name - << "'.\n" << std::flush; + << "'.\n" << std::flush; } return 1; @@ -13284,9 +13284,9 @@ void PrintOptionIgnored(const char *type, const char *name, const char *value) if (control -> ProxyMode == proxy_server) { nxwarn << "Loop: WARNING! Ignoring " << type - << " option '" << name << "' with value '" - << value << "' at " << "NX client side.\n" - << std::flush; + << " option '" << name << "' with value '" + << value << "' at " << "NX client side.\n" + << std::flush; cerr << "Warning" << ": Ignoring " << type << " option '" << name << "' with value '" @@ -13295,9 +13295,9 @@ void PrintOptionIgnored(const char *type, const char *name, const char *value) else { nxwarn << "Loop: WARNING! Ignoring " << type - << " option '" << name << "' with value '" - << value << "' at " << "NX server side.\n" - << std::flush; + << " option '" << name << "' with value '" + << value << "' at " << "NX server side.\n" + << std::flush; cerr << "Warning" << ": Ignoring " << type << " option '" << name << "' with value '" @@ -13314,8 +13314,8 @@ const char *GetOptions(const char *options) strncasecmp(options, "nx:", 3) != 0) { nxinfo << "Loop: PANIC! Display options string '" << options - << "' must start with 'nx' or 'nx/nx' prefix.\n" - << std::flush; + << "' must start with 'nx' or 'nx/nx' prefix.\n" + << std::flush; cerr << "Error" << ": Display options string '" << options << "' must start with 'nx' or 'nx/nx' prefix.\n"; @@ -13361,8 +13361,8 @@ const char *GetArg(int &argi, int argc, const char **argv) int CheckArg(const char *type, const char *name, const char *value) { nxinfo << "Loop: Parsing " << type << " option '" << name - << "' with value '" << (value ? value : "(null)") - << "'.\n" << std::flush; + << "' with value '" << (value ? value : "(null)") + << "'.\n" << std::flush; if (value == NULL || strstr(value, "=") != NULL) { @@ -13474,7 +13474,7 @@ int ParseArg(const char *type, const char *name, const char *value) delete [] string; nxinfo << "Loop: Integer option parsed to '" - << (int) result << "'.\n" << std::flush; + << (int) result << "'.\n" << std::flush; return (int) result; } @@ -13610,15 +13610,15 @@ static void handleCheckSessionInLoop() if (proxy -> getShutdown() > 0) { nxinfo << "Loop: End of NX transport requested " - << "by remote.\n" << std::flush; + << "by remote.\n" << std::flush; handleTerminatingInLoop(); if (control -> ProxyMode == proxy_server) { nxinfo << "Loop: Bytes received so far are " - << (unsigned long long) statistics -> getBytesIn() - << ".\n" << std::flush; + << (unsigned long long) statistics -> getBytesIn() + << ".\n" << std::flush; if (statistics -> getBytesIn() < 1024) { @@ -13632,15 +13632,15 @@ static void handleCheckSessionInLoop() } nxinfo << "Loop: Shutting down the NX transport.\n" - << std::flush; + << std::flush; HandleCleanup(); } else if (proxy -> handlePing() < 0) { nxinfo << "Loop: Failure handling the ping for " - << "proxy FD#" << proxyFD << ".\n" - << std::flush; + << "proxy FD#" << proxyFD << ".\n" + << std::flush; HandleShutdown(); } @@ -13654,13 +13654,13 @@ static void handleCheckSessionInLoop() if (IsRunning(lastWatchdog) && CheckProcess(lastWatchdog, "watchdog") == 0) { nxwarn << "Loop: WARNING! Watchdog is gone unnoticed. " - << "Setting the last signal to SIGTERM.\n" - << std::flush; + << "Setting the last signal to SIGTERM.\n" + << std::flush; lastSignal = SIGTERM; nxwarn << "Loop: WARNING! Resetting pid of last " - << "watchdog process.\n" << std::flush; + << "watchdog process.\n" << std::flush; SetNotRunning(lastWatchdog); } @@ -13679,11 +13679,11 @@ static void handleCheckSessionInLoop() channel_none && lastKill == 0 && lastDestroy == 1) { nxinfo << "Loop: End of NX transport requested " - << "by agent.\n" << std::flush; + << "by agent.\n" << std::flush; nxinfo << "Loop: Bytes sent so far are " - << (unsigned long long) statistics -> getBytesOut() - << ".\n" << std::flush; + << (unsigned long long) statistics -> getBytesOut() + << ".\n" << std::flush; if (statistics -> getBytesOut() < 1024) { @@ -13749,8 +13749,8 @@ static void handleCheckSessionInLoop() if (signal != 0) { nxinfo << "Loop: End of NX transport requested by signal '" - << signal << "' '" << DumpSignal(signal) - << "'.\n" << std::flush; + << signal << "' '" << DumpSignal(signal) + << "'.\n" << std::flush; handleTerminatingInLoop(); } @@ -13780,7 +13780,7 @@ static void handleCheckSessionInLoop() else if (lastKill == 2) { nxinfo << "Loop: Shutting down the NX transport.\n" - << std::flush; + << std::flush; proxy -> handleShutdown(); @@ -13814,13 +13814,13 @@ static void handleCheckSessionInLoop() } nxinfo << "Loop: Starting watchdog process with timeout " - << "of " << timeout << " Ms.\n" - << std::flush; + << "of " << timeout << " Ms.\n" + << std::flush; } else { nxinfo << "Loop: Starting watchdog process without " - << "a timeout.\n" << std::flush; + << "a timeout.\n" << std::flush; } lastWatchdog = NXTransWatchdog(timeout); @@ -13838,7 +13838,7 @@ static void handleCheckSessionInLoop() else { nxinfo << "Loop: Watchdog started with pid '" - << lastWatchdog << "'.\n" << std::flush; + << lastWatchdog << "'.\n" << std::flush; } } else @@ -13857,7 +13857,7 @@ static void handleCheckSessionInLoop() if (control -> CleanupTimeout > 0) { nxinfo << "Loop: Waiting the cleanup timeout to complete.\n" - << std::flush; + << std::flush; cerr << "Info" << ": Waiting the cleanup timeout to complete.\n"; } @@ -13873,7 +13873,7 @@ static void handleCheckSessionInLoop() << "'.\n"; nxinfo << "Loop: Waiting the watchdog process to complete.\n" - << std::flush; + << std::flush; cerr << "Info" << ": Waiting the watchdog process to complete.\n"; } @@ -13887,10 +13887,10 @@ static void handleCheckBitrateInLoop() static long int slept = 0; nxinfo << "Loop: Bitrate is " << statistics -> getBitrateInShortFrame() - << " B/s and " << statistics -> getBitrateInLongFrame() - << " B/s in " << control -> ShortBitrateTimeFrame / 1000 - << "/" << control -> LongBitrateTimeFrame / 1000 - << " seconds timeframes.\n" << std::flush; + << " B/s and " << statistics -> getBitrateInLongFrame() + << " B/s in " << control -> ShortBitrateTimeFrame / 1000 + << "/" << control -> LongBitrateTimeFrame / 1000 + << " seconds timeframes.\n" << std::flush; // // This can be improved. We may not jump out @@ -13901,8 +13901,8 @@ static void handleCheckBitrateInLoop() if (control -> LocalBitrateLimit > 0) { nxinfo << "Loop: Calculating bandwidth usage with limit " - << control -> LocalBitrateLimit << ".\n" - << std::flush; + << control -> LocalBitrateLimit << ".\n" + << std::flush; int reference = (statistics -> getBitrateInLongFrame() + statistics -> getBitrateInShortFrame()) / 2; @@ -13922,8 +13922,8 @@ static void handleCheckBitrateInLoop() if (slept > 2000) { nxwarn << "Loop: WARNING! Sleeping due to " - << "reference bitrate of " << reference - << " B/s.\n" << std::flush; + << "reference bitrate of " << reference + << " B/s.\n" << std::flush; cerr << "Warning" << ": Sleeping due to " << "reference bitrate of " << reference @@ -13971,8 +13971,8 @@ static void handleCheckStateInLoop(int &setFDs) if (fdLength > 0) { nxinfo << "Loop: WARNING! Buffer for descriptor FD#" - << j << " has " << fdLength << " bytes to write.\n" - << std::flush; + << j << " has " << fdLength << " bytes to write.\n" + << std::flush; } } } @@ -14005,8 +14005,8 @@ static void handleCheckStateInLoop(int &setFDs) else { nxinfo << "Loop: WARNING! Buffer for proxy descriptor FD#" - << proxyFD << " has " << fdLength << " bytes " - << "to write.\n" << std::flush; + << proxyFD << " has " << fdLength << " bytes " + << "to write.\n" << std::flush; } } @@ -14015,8 +14015,8 @@ static void handleCheckStateInLoop(int &setFDs) if (fdSplits > 0) { nxwarn << "Loop: WARNING! Proxy descriptor FD#" << proxyFD - << " has " << fdSplits << " splits to send.\n" - << std::flush; + << " has " << fdSplits << " splits to send.\n" + << std::flush; } } @@ -14024,8 +14024,8 @@ static void handleCheckSelectInLoop(int &setFDs, fd_set &readSet, fd_set &writeSet, T_timestamp selectTs) { nxinfo << "Loop: Maximum descriptors is [" - << setFDs << "] at " << strMsTimestamp() - << ".\n" << std::flush; + << setFDs << "] at " << strMsTimestamp() + << ".\n" << std::flush; int i; @@ -14079,9 +14079,9 @@ static void handleCheckSelectInLoop(int &setFDs, fd_set &readSet, } nxinfo << "Loop: Select timeout is " - << selectTs.tv_sec << " S and " - << (double) selectTs.tv_usec / 1000 - << " Ms.\n" << std::flush; + << selectTs.tv_sec << " S and " + << (double) selectTs.tv_usec / 1000 + << " Ms.\n" << std::flush; } static void handleCheckResultInLoop(int &resultFDs, int &errorFDs, int &setFDs, fd_set &readSet, @@ -14095,16 +14095,16 @@ static void handleCheckResultInLoop(int &resultFDs, int &errorFDs, int &setFDs, (control -> LatencyTimeout * 4))) { nxinfo << "Loop: Select result is [" << resultFDs - << "] at " << strMsTimestamp() << " with no " - << "communication within " << diffTs - << " Ms.\n" << std::flush; + << "] at " << strMsTimestamp() << " with no " + << "communication within " << diffTs + << " Ms.\n" << std::flush; } else { nxinfo << "Loop: Select result is [" << resultFDs - << "] error is [" << errorFDs << "] at " - << strMsTimestamp() << " after " << diffTs - << " Ms.\n" << std::flush; + << "] error is [" << errorFDs << "] at " + << strMsTimestamp() << " after " << diffTs + << " Ms.\n" << std::flush; } @@ -14164,7 +14164,7 @@ static void handleCheckResultInLoop(int &resultFDs, int &errorFDs, int &setFDs, static void handleCheckSessionInConnect() { nxinfo << "Loop: Going to check session in connect.\n" - << std::flush; + << std::flush; if (control -> ProxyMode == proxy_client) { @@ -14209,8 +14209,8 @@ static void handleStatisticsInLoop() if (mode == TOTAL_STATS || mode == PARTIAL_STATS) { nxinfo << "Loop: Going to request proxy statistics " - << "with signal '" << DumpSignal(lastSignal) - << "'.\n" << std::flush; + << "with signal '" << DumpSignal(lastSignal) + << "'.\n" << std::flush; if (proxy != NULL) { @@ -14233,17 +14233,17 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, while (yield == 0) { nxinfo << "Loop: Going to run a new negotiation loop " - << "with stage " << control -> ProxyStage - << " at " << strMsTimestamp() << ".\n" - << std::flush; + << "with stage " << control -> ProxyStage + << " at " << strMsTimestamp() << ".\n" + << std::flush; switch (control -> ProxyStage) { case stage_undefined: { nxinfo << "Loop: Handling negotiation with '" - << "stage_undefined" << "'.\n" - << std::flush; + << "stage_undefined" << "'.\n" + << std::flush; control -> ProxyStage = stage_initializing; @@ -14252,8 +14252,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_initializing: { nxinfo << "Loop: Handling negotiation with '" - << "stage_initializing" << "'.\n" - << std::flush; + << "stage_initializing" << "'.\n" + << std::flush; InitBeforeNegotiation(); @@ -14264,8 +14264,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_connecting: { nxinfo << "Loop: Handling negotiation with '" - << "stage_connecting" << "'.\n" - << std::flush; + << "stage_connecting" << "'.\n" + << std::flush; SetupProxyConnection(); @@ -14276,8 +14276,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_connected: { nxinfo << "Loop: Handling negotiation with '" - << "stage_connected" << "'.\n" - << std::flush; + << "stage_connected" << "'.\n" + << std::flush; // // Server side proxy must always be the one that @@ -14319,8 +14319,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_sending_proxy_options: { nxinfo << "Loop: Handling negotiation with '" - << "stage_sending_proxy_options" << "'.\n" - << std::flush; + << "stage_sending_proxy_options" << "'.\n" + << std::flush; if (SendProxyOptions(proxyFD) < 0) { @@ -14341,8 +14341,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_waiting_forwarder_version: { nxinfo << "Loop: Handling negotiation with '" - << "stage_waiting_forwarder_version" << "'.\n" - << std::flush; + << "stage_waiting_forwarder_version" << "'.\n" + << std::flush; int result = ReadForwarderVersion(proxyFD); @@ -14364,8 +14364,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_waiting_forwarder_options: { nxinfo << "Loop: Handling negotiation with '" - << "stage_waiting_forwarder_options" << "'.\n" - << std::flush; + << "stage_waiting_forwarder_options" << "'.\n" + << std::flush; int result = ReadForwarderOptions(proxyFD); @@ -14387,8 +14387,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_waiting_proxy_version: { nxinfo << "Loop: Handling negotiation with '" - << "stage_waiting_proxy_version" << "'.\n" - << std::flush; + << "stage_waiting_proxy_version" << "'.\n" + << std::flush; int result = ReadProxyVersion(proxyFD); @@ -14410,8 +14410,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_waiting_proxy_options: { nxinfo << "Loop: Handling negotiation with '" - << "stage_waiting_proxy_options" << "'.\n" - << std::flush; + << "stage_waiting_proxy_options" << "'.\n" + << std::flush; int result = ReadProxyOptions(proxyFD); @@ -14440,8 +14440,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_sending_proxy_caches: { nxinfo << "Loop: Handling negotiation with '" - << "stage_sending_proxy_caches" << "'.\n" - << std::flush; + << "stage_sending_proxy_caches" << "'.\n" + << std::flush; if (SendProxyCaches(proxyFD) < 0) { @@ -14462,8 +14462,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_waiting_proxy_caches: { nxinfo << "Loop: Handling negotiation with '" - << "stage_waiting_proxy_caches" << "'.\n" - << std::flush; + << "stage_waiting_proxy_caches" << "'.\n" + << std::flush; int result = ReadProxyCaches(proxyFD); @@ -14492,8 +14492,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, case stage_operational: { nxinfo << "Loop: Handling negotiation with '" - << "stage_operational" << "'.\n" - << std::flush; + << "stage_operational" << "'.\n" + << std::flush; InitAfterNegotiation(); @@ -14539,8 +14539,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet, setMinTimestamp(selectTs, control -> PingTimeout); nxinfo << "Loop: Selected proxy FD#" << proxyFD << " in negotiation " - << "phase with timeout of " << selectTs.tv_sec << " S and " - << selectTs.tv_usec << " Ms.\n" << std::flush; + << "phase with timeout of " << selectTs.tv_sec << " S and " + << selectTs.tv_usec << " Ms.\n" << std::flush; return; @@ -14621,7 +14621,7 @@ static void handleAlertInLoop() if (proxy != NULL) { nxinfo << "Loop: Requesting a remote alert with code '" - << lastAlert.code << "'.\n" << std::flush; + << lastAlert.code << "'.\n" << std::flush; if (proxy -> handleAlert(lastAlert.code) < 0) { @@ -14632,7 +14632,7 @@ static void handleAlertInLoop() else { nxinfo << "Loop: Handling a local alert with code '" - << lastAlert.code << "'.\n" << std::flush; + << lastAlert.code << "'.\n" << std::flush; if (control -> ProxyMode == proxy_client) { @@ -14867,8 +14867,8 @@ static void handleAlertInLoop() if (lastAlert.code > LAST_PROTO_STEP_7_ALERT) { nxwarn << "Loop: WARNING! An unrecognized alert type '" - << lastAlert.code << "' was requested.\n" - << std::flush; + << lastAlert.code << "' was requested.\n" + << std::flush; cerr << "Warning" << ": An unrecognized alert type '" << lastAlert.code << "' was requested.\n"; @@ -14876,7 +14876,7 @@ static void handleAlertInLoop() else { nxwarn << "Loop: WARNING! Ignoring obsolete alert type '" - << lastAlert.code << "'.\n" << std::flush; + << lastAlert.code << "'.\n" << std::flush; } message = NULL; @@ -14891,7 +14891,7 @@ static void handleAlertInLoop() if (replace == 1 && IsRunning(lastDialog)) { nxinfo << "Loop: Killing the previous dialog with pid '" - << lastDialog << "'.\n" << std::flush; + << lastDialog << "'.\n" << std::flush; // // The client ignores the TERM signal @@ -14930,13 +14930,13 @@ static void handleAlertInLoop() else { nxinfo << "Loop: Dialog started with pid '" - << lastDialog << "'.\n" << std::flush; + << lastDialog << "'.\n" << std::flush; } } else { nxinfo << "Loop: No new dialog required for code '" - << lastAlert.code << "'.\n" << std::flush; + << lastAlert.code << "'.\n" << std::flush; } } } @@ -14953,7 +14953,7 @@ static inline void handleSetAgentInLoop(int &setFDs, fd_set &readSet, fd_set &writeSet, struct timeval &selectTs) { nxinfo << "Loop: Preparing the masks for the agent descriptors.\n" - << std::flush; + << std::flush; agent -> saveChannelState(); @@ -14968,7 +14968,7 @@ static inline void handleSetAgentInLoop(int &setFDs, fd_set &readSet, agent -> proxyCanRead()) { nxinfo << "Loop: Setting a null timeout with agent descriptors ready.\n" - << std::flush; + << std::flush; // // Force a null timeout so we'll bail out @@ -14982,7 +14982,7 @@ static inline void handleSetAgentInLoop(int &setFDs, fd_set &readSet, } nxinfo << "Loop: Clearing the read and write agent descriptors.\n" - << std::flush; + << std::flush; agent -> clearReadMask(&readSet); agent -> clearWriteMask(&writeSet); @@ -14992,7 +14992,7 @@ static inline void handleAgentInLoop(int &resultFDs, int &errorFDs, int &setFDs, fd_set &writeSet, struct timeval &selectTs) { nxinfo << "Loop: Setting proxy and local agent descriptors.\n" - << std::flush; + << std::flush; // // Check if I/O is possible on the local @@ -15009,14 +15009,14 @@ static inline void handleAgentInLoop(int &resultFDs, int &errorFDs, int &setFDs, agent -> saveChannelState(); nxinfo << "Loop: Values were resultFDs " << resultFDs - << " errorFDs " << errorFDs << " setFDs " - << setFDs << ".\n" << std::flush; + << " errorFDs " << errorFDs << " setFDs " + << setFDs << ".\n" << std::flush; if (agent -> localCanRead() == 1) { nxinfo << "Loop: Setting agent descriptor FD#" << agent -> - getLocalFd() << " as ready to read.\n" - << std::flush; + getLocalFd() << " as ready to read.\n" + << std::flush; agent -> setLocalRead(&readSet, &resultFDs); } @@ -15026,21 +15026,21 @@ static inline void handleAgentInLoop(int &resultFDs, int &errorFDs, int &setFDs, agent -> proxyCanRead() == 1) { nxinfo << "Loop: WARNING! Can read from proxy FD#" - << proxyFD << " but the descriptor " - << "is not selected.\n" << std::flush; + << proxyFD << " but the descriptor " + << "is not selected.\n" << std::flush; } if (agent -> proxyCanRead(&readSet) == 1) { nxinfo << "Loop: Setting proxy descriptor FD#" << agent -> - getProxyFd() << " as ready to read.\n" - << std::flush; + getProxyFd() << " as ready to read.\n" + << std::flush; } nxinfo << "Loop: Values are now resultFDs " << resultFDs - << " errorFDs " << errorFDs << " setFDs " - << setFDs << ".\n" << std::flush; + << " errorFDs " << errorFDs << " setFDs " + << setFDs << ".\n" << std::flush; } } @@ -15048,7 +15048,7 @@ static inline void handleAgentLateInLoop(int &resultFDs, int &errorFDs, int &set fd_set &writeSet, struct timeval &selectTs) { nxinfo << "Loop: Setting remote agent descriptors.\n" - << std::flush; + << std::flush; // // We reset the masks before calling our select. @@ -15070,15 +15070,15 @@ static inline void handleAgentLateInLoop(int &resultFDs, int &errorFDs, int &set agent -> saveChannelState(); nxinfo << "Loop: Values were resultFDs " << resultFDs - << " errorFDs " << errorFDs << " setFDs " - << setFDs << ".\n" << std::flush; + << " errorFDs " << errorFDs << " setFDs " + << setFDs << ".\n" << std::flush; if (agent -> remoteCanRead(agent -> getSavedReadMask()) == 1) { nxinfo << "Loop: Setting agent descriptor FD#" << agent -> - getRemoteFd() << " as ready to read.\n" - << std::flush; + getRemoteFd() << " as ready to read.\n" + << std::flush; agent -> setRemoteRead(&readSet, &resultFDs); } @@ -15087,15 +15087,15 @@ static inline void handleAgentLateInLoop(int &resultFDs, int &errorFDs, int &set getSavedWriteMask()) == 1) { nxinfo << "Loop: Setting agent descriptor FD#" << agent -> - getRemoteFd() << " as ready to write.\n" - << std::flush; + getRemoteFd() << " as ready to write.\n" + << std::flush; agent -> setRemoteWrite(&writeSet, &resultFDs); } nxinfo << "Loop: Values are now resultFDs " << resultFDs - << " errorFDs " << errorFDs << " setFDs " - << setFDs << ".\n" << std::flush; + << " errorFDs " << errorFDs << " setFDs " + << setFDs << ".\n" << std::flush; } } @@ -15237,8 +15237,8 @@ static inline void handleReadableInLoop(int &resultFDs, fd_set &readSet) // nxinfo << "Loop: Trying to read immediately " - << "from descriptor FD#" << newFD - << ".\n" << std::flush; + << "from descriptor FD#" << newFD + << ".\n" << std::flush; FD_SET(newFD, &readSet); @@ -15247,21 +15247,21 @@ static inline void handleReadableInLoop(int &resultFDs, fd_set &readSet) else { nxinfo << "Loop: Nothing to read immediately " - << "from descriptor FD#" << newFD - << ".\n" << std::flush; + << "from descriptor FD#" << newFD + << ".\n" << std::flush; } } } } nxdbg << "Loop: Going to check the readable descriptors.\n" - << std::flush; + << std::flush; if (proxy -> handleRead(resultFDs, readSet) < 0) { nxinfo << "Loop: Failure reading from descriptors " - << "for proxy FD#" << proxyFD << ".\n" - << std::flush; + << "for proxy FD#" << proxyFD << ".\n" + << std::flush; HandleShutdown(); } @@ -15270,13 +15270,13 @@ static inline void handleReadableInLoop(int &resultFDs, fd_set &readSet) static inline void handleWritableInLoop(int &resultFDs, fd_set &writeSet) { nxdbg << "Loop: Going to check the writable descriptors.\n" - << std::flush; + << std::flush; if (resultFDs > 0 && proxy -> handleFlush(resultFDs, writeSet) < 0) { nxinfo << "Loop: Failure writing to descriptors " - << "for proxy FD#" << proxyFD << ".\n" - << std::flush; + << "for proxy FD#" << proxyFD << ".\n" + << std::flush; HandleShutdown(); } @@ -15285,7 +15285,7 @@ static inline void handleWritableInLoop(int &resultFDs, fd_set &writeSet) static inline void handleFlushInLoop() { nxdbg << "Loop: Going to flush any data to the proxy.\n" - << std::flush; + << std::flush; if (agent == NULL || control -> FlushPolicy == policy_immediate) @@ -15295,14 +15295,14 @@ static inline void handleFlushInLoop() ProxyMode == proxy_client) { nxinfo << "Loop: WARNING! Flushing the proxy link " - << "on behalf of the agent.\n" << std::flush; + << "on behalf of the agent.\n" << std::flush; } if (proxy -> handleFlush() < 0) { nxinfo << "Loop: Failure flushing the proxy FD#" - << proxyFD << ".\n" << std::flush; + << proxyFD << ".\n" << std::flush; HandleShutdown(); } @@ -15312,8 +15312,8 @@ static inline void handleFlushInLoop() static inline void handleRotateInLoop() { nxdbg << "Loop: Going to rotate channels " - << "for proxy FD#" << proxyFD << ".\n" - << std::flush; + << "for proxy FD#" << proxyFD << ".\n" + << std::flush; proxy -> handleRotate(); } @@ -15321,14 +15321,14 @@ static inline void handleRotateInLoop() static inline void handleEventsInLoop() { nxdbg << "Loop: Going to check channel events " - << "for proxy FD#" << proxyFD << ".\n" - << std::flush; + << "for proxy FD#" << proxyFD << ".\n" + << std::flush; if (proxy -> handleEvents() < 0) { nxinfo << "Loop: Failure handling channel events " - << "for proxy FD#" << proxyFD << ".\n" - << std::flush; + << "for proxy FD#" << proxyFD << ".\n" + << std::flush; HandleShutdown(); } @@ -15349,7 +15349,7 @@ static void handleLogReopenInLoop(T_timestamp &lTs, T_timestamp &nTs) #endif { nxdbg << "Loop: Checking size of log file '" - << errorsFileName << "'.\n" << std::flush; + << errorsFileName << "'.\n" << std::flush; #ifndef MIXED @@ -15396,8 +15396,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener tcpFD " << tcpFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useUnixSocket == 1) @@ -15410,8 +15410,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener unixFD " << unixFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useCupsSocket == 1) @@ -15424,8 +15424,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener cupsFD " << cupsFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useAuxSocket == 1) @@ -15438,8 +15438,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener auxFD " << auxFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useSmbSocket == 1) @@ -15452,8 +15452,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener smbFD " << smbFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useMediaSocket == 1) @@ -15466,8 +15466,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener mediaFD " << mediaFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } if (useHttpSocket == 1) @@ -15480,8 +15480,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener httpFD " << httpFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } } else @@ -15496,8 +15496,8 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener fontFD " << fontFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } } @@ -15511,7 +15511,7 @@ static void handleSetListenersInLoop(fd_set &readSet, int &setFDs) } nxdbg << "Loop: Selected listener slaveFD " << slaveFD - << " with setFDs " << setFDs << ".\n" - << std::flush; + << " with setFDs " << setFDs << ".\n" + << std::flush; } } |