Home
last modified time | relevance | path

Searched refs:GlobalOutput (Results 1 – 24 of 24) sorted by relevance

/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTServerSocket.cpp207 GlobalOutput.perror(vError.c_str(), THRIFT_GET_SOCKET_ERROR); in isOpen()
270 GlobalOutput.perror("TServerSocket::listen() setsockopt() THRIFT_NO_SOCKET_CACHING ", in isOpen()
287 GlobalOutput.perror("TServerSocket::listen() setsockopt() SO_SNDBUF ", errno_copy); in isOpen()
302 GlobalOutput.perror("TServerSocket::listen() setsockopt() SO_RCVBUF ", errno_copy); in isOpen()
314 GlobalOutput.perror("TServerSocket::listen() setsockopt() SO_LINGER ", errno_copy); in isOpen()
322 GlobalOutput.perror("TServerSocket::listen() setsockopt() SO_NOSIGPIPE", errno_copy); in isOpen()
334 GlobalOutput.perror("TServerSocket::listen() THRIFT_FCNTL() THRIFT_F_GETFL ", errno_copy); in isOpen()
342 GlobalOutput.perror("TServerSocket::listen() THRIFT_FCNTL() THRIFT_O_NONBLOCK ", errno_copy); in isOpen()
361 GlobalOutput.perror("TServerSocket::listen() setsockopt() TCP_DEFER_ACCEPT ", errno_copy); in isOpen()
373 GlobalOutput.perror("TServerSocket::listen() setsockopt() TCP_NODELAY ", errno_copy); in isOpen()
[all …]
DTNonblockingServerSocket.cpp175 GlobalOutput.perror(vError.c_str(), THRIFT_GET_SOCKET_ERROR); in isOpen()
227 … GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() THRIFT_NO_SOCKET_CACHING ", in isOpen()
244 GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() SO_SNDBUF ", errno_copy); in isOpen()
259 GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() SO_RCVBUF ", errno_copy); in isOpen()
271 GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() SO_LINGER ", errno_copy); in isOpen()
279 … GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() SO_KEEPALIVE ", errno_copy); in isOpen()
289 GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() SO_NOSIGPIPE", errno_copy); in isOpen()
301 …GlobalOutput.perror("TNonblockingServerSocket::listen() THRIFT_FCNTL() THRIFT_F_GETFL ", errno_cop… in isOpen()
310 …GlobalOutput.perror("TNonblockingServerSocket::listen() THRIFT_FCNTL() THRIFT_O_NONBLOCK ", errno_… in isOpen()
331 GlobalOutput.perror("TNonblockingServerSocket::listen() setsockopt() TCP_NODELAY ", errno_copy); in isOpen()
[all …]
DTPipeServer.cpp64 GlobalOutput.perror("TPipeServer Create(Anon)Pipe failed, GLE=", GetLastError()); in TAnonPipeServer()
234 GlobalOutput.perror("TPipeServer unable to initiate pipe comms, GLE=", GetLastError()); in acceptImpl()
246 GlobalOutput.perror("TPipeServer CreateNamedPipe failed, GLE=", GetLastError()); in initiateNamedConnect()
260 GlobalOutput.printf("Client connected."); in initiateNamedConnect()
270 GlobalOutput.printf("Client connected."); in initiateNamedConnect()
278 GlobalOutput.perror("TPipeServer ConnectNamedPipe failed, GLE=", dwErr); in initiateNamedConnect()
323 GlobalOutput.perror("Client connection failed. TTransportExceptionType=", ttx.getType()); in acceptImpl()
328 GlobalOutput.printf("Client connected."); in acceptImpl()
335 GlobalOutput.perror("TPipeServer ConnectNamedPipe GLE=", gle); in acceptImpl()
360 GlobalOutput.perror("TPipeServer::ConvertStringSecurityDescriptorToSecurityDescriptorA() GLE=", in createNamedPipe()
[all …]
DTSocket.cpp200 …GlobalOutput.perror("TSocket::hasPendingDataToRead() THRIFT_IOCTL_SOCKET() " + getSocketInfo(), er… in hasPendingDataToRead()
229 GlobalOutput.perror("TSocket::peek() THRIFT_POLL() ", errno_copy); in peek()
259 GlobalOutput.perror("TSocket::peek() recv() " + getSocketInfo(), errno_copy); in peek()
279 GlobalOutput.perror("TSocket::open() socket() " + getSocketInfo(), errno_copy); in openConnection()
323 GlobalOutput.perror("TSocket::open() THRIFT_FCNTL() " + getSocketInfo(), errno_copy); in openConnection()
329 GlobalOutput.perror("TSocket::open() THRIFT_FCNTL " + getSocketInfo(), errno_copy); in openConnection()
345 …GlobalOutput.perror("TSocket::open() Unix Domain socket path not supported on this version of Wind… in openConnection()
361 GlobalOutput.perror("TSocket::open() connect() " + getSocketInfo(), errno_copy); in openConnection()
379 GlobalOutput.perror("TSocket::open() getsockopt() " + getSocketInfo(), errno_copy); in openConnection()
386 GlobalOutput.perror("TSocket::open() error on socket (after THRIFT_POLL) " + getSocketInfo(), in openConnection()
[all …]
DSocketCommon.cpp40 …GlobalOutput.perror("TSocket::open() Abstract Namespace Domain sockets only supported on linux: ",… in fillUnixSocketAddr()
54 GlobalOutput.perror("TSocket::open() Unix Domain socket path too long", errno_copy); in fillUnixSocketAddr()
DTFileTransport.cpp106 GlobalOutput.printf("error, current file (%s) not closed", filename_.c_str()); in resetOutputFile()
109 GlobalOutput.perror("TFileTransport: resetOutputFile() ::close() ", errno_copy); in resetOutputFile()
164 GlobalOutput.perror("TFileTransport: ~TFileTransport() ::close() ", THRIFT_ERRNO); in ~TFileTransport()
311 GlobalOutput.perror("TFileTransport: writerThread() openLogFile() ", errno_copy); in writerThread()
327 GlobalOutput.perror("TFileTransport: writerThread() truncate ", errno_copy); in writerThread()
332 GlobalOutput.perror("TFileTransport: writerThread() initialization ", errno_copy); in writerThread()
353 GlobalOutput.perror("TFileTransport: writerThread() ::close() ", errno_copy); in writerThread()
431 GlobalOutput.perror("TFileTransport: writerThread() error while padding zeros ", in writerThread()
445 GlobalOutput.perror("TFileTransport: error while writing event ", errno_copy); in writerThread()
625 GlobalOutput("TFileTransport: error while reading from file"); in readEvent()
[all …]
DTPipe.cpp147 GlobalOutput.perror("TPipe ::ReadFile errored GLE=", readOverlap_.last_error); in beginAsyncRead()
189 GlobalOutput.perror("TPipe ::WriteFile errored GLE=", ::GetLastError()); in pseudo_sync_write()
196 GlobalOutput.perror("TPipe ::GetOverlappedResult errored GLE=", ::GetLastError()); in pseudo_sync_write()
211 GlobalOutput.perror("TPipe ::ReadFile errored GLE=", ::GetLastError()); in pseudo_sync_read()
218 GlobalOutput.perror("TPipe ::GetOverlappedResult errored GLE=", ::GetLastError()); in pseudo_sync_read()
289 GlobalOutput.perror("TPipe::open ::CreateFile errored GLE=", ::GetLastError()); in open()
295 GlobalOutput.perror("TPipe::open ::CreateFile errored GLE=", ::GetLastError()); in open()
DTSocketPool.cpp82 GlobalOutput("TSocketPool::TSocketPool: hosts.size != ports.size"); in TSocketPool()
232 GlobalOutput(errStr.c_str()); in open()
254 GlobalOutput("TSocketPool::open: all connections failed"); in open()
DTFDTransport.h53 GlobalOutput.printf("~TFDTransport TTransportException: '%s'", ex.what()); in ~TFDTransport()
DTSSLSocket.cpp384 GlobalOutput(("SSL_shutdown: " + errors).c_str()); in close()
391 GlobalOutput.printf("SSL_shutdown: %s", te.what()); in close()
604 GlobalOutput.perror("thriftServerEventHandler: set THRIFT_O_NONBLOCK (THRIFT_FCNTL) ", in initializeHandshakeParams()
860 GlobalOutput.perror("TSSLSocket::read THRIFT_POLL() ", errno_copy); in waitForEvent()
DTZlibTransport.cpp86 GlobalOutput(output.c_str()); in checkZlibRvNothrow()
DTFileTransport.h221 GlobalOutput("Cannot change the buffer size after writer thread started"); in setEventBufferSize()
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp342 GlobalOutput.printf("TNonblockingServer: client died: %s", ttx.what()); in run()
344 GlobalOutput("TNonblockingServer: caught bad_alloc exception."); in run()
347 GlobalOutput.printf("TNonblockingServer: process() exception: %s: %s", in run()
351 GlobalOutput.printf("TNonblockingServer: unknown exception while processing."); in run()
356 GlobalOutput.printf("TNonblockingServer: failed to notifyIOThread, closing."); in run()
450 GlobalOutput.printf("TConnection::workSocket(): %s", te.what()); in workSocket()
467 GlobalOutput.printf( in workSocket()
497 GlobalOutput.printf("TNonblockingServer: frame size too short"); in workSocket()
510 GlobalOutput.printf("TConnection::workSocket(): %s", te.what()); in workSocket()
546 GlobalOutput("WARNING: Send state with no data to send"); in workSocket()
[all …]
DTConnectedClient.cpp78 GlobalOutput(errStr.c_str()); in run()
85 GlobalOutput(errStr.c_str()); in run()
103 GlobalOutput(errStr.c_str()); in cleanup()
110 GlobalOutput(errStr.c_str()); in cleanup()
117 GlobalOutput(errStr.c_str()); in cleanup()
DTServerFramework.cpp104 GlobalOutput(errStr.c_str()); in releaseOneDescriptor()
182 GlobalOutput(errStr.c_str()); in serve()
/thrift-3.4.0/lib/cpp/src/thrift/
DTDispatchProcessor.h64 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
79 GlobalOutput.printf("received invalid message type %d from client", mtype); in processFast()
117 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
DTOutput.h56 THRIFT_EXPORT extern TOutput GlobalOutput;
DTOutput.cpp34 THRIFT_EXPORT TOutput GlobalOutput; variable
/thrift-3.4.0/lib/cpp/src/thrift/async/
DTAsyncDispatchProcessor.h65 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
82 GlobalOutput.printf("received invalid message type %d from client", mtype); in processFast()
126 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
/thrift-3.4.0/lib/cpp/src/thrift/windows/
DSync.h79 GlobalOutput.perror("TAutoResetEvent unable to create event, GLE=", GetLastError()); in TAutoResetEvent()
92 GlobalOutput.perror("TManualResetEvent unable to create event, GLE=", GetLastError()); in TManualResetEvent()
DOverlappedSubmissionThread.cpp55 GlobalOutput.perror("TPipe ::GetOverlappedResult errored GLE=", ::GetLastError()); in overlappedResults()
116 GlobalOutput.perror("TOverlappedSubmissionThread unable to create thread, errno=", errno); in TOverlappedSubmissionThread()
/thrift-3.4.0/contrib/transport-sample/
DThriftCommon.cpp28 GlobalOutput.perror("TPipeServer CreateProcess failed, GLE=", GetLastError()); in LaunchAnonPipeChild()
/thrift-3.4.0/lib/cpp/test/processor/
DServerThread.h94 GlobalOutput.printf("error shutting down server"); in ~ServerThread()
/thrift-3.4.0/lib/cpp/src/thrift/concurrency/
DThreadManager.cpp312 GlobalOutput.printf("[ERROR] task->run() raised an exception: %s", e.what()); in run()
314 GlobalOutput.printf("[ERROR] task->run() raised an unknown exception"); in run()