Searched refs:recvTimeout_ (Results 1 – 10 of 10) sorted by relevance
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TSocket.cpp | 95 recvTimeout_(0), in TSocket()
111 recvTimeout_(0), in TSocket()
127 recvTimeout_(0), in TSocket()
143 recvTimeout_(0), in TSocket()
167 recvTimeout_(0), in TSocket()
222 int ret = THRIFT_POLL(fds, 2, (recvTimeout_ == 0) ? -1 : recvTimeout_); in peek()
289 if (recvTimeout_ > 0) { in openConnection()
290 setRecvTimeout(recvTimeout_); in openConnection()
529 if (recvTimeout_) { in read()
533 eagainThresholdMicros = (recvTimeout_ * 1000) / ((maxRecvRetries_ > 0) ? maxRecvRetries_ : 2); in read()
[all …]
|
| D | TNonblockingServerSocket.cpp | 94 recvTimeout_(0), in TNonblockingServerSocket()
109 recvTimeout_(recvTimeout), in TNonblockingServerSocket()
125 recvTimeout_(0), in TNonblockingServerSocket()
141 recvTimeout_(0), in TNonblockingServerSocket()
188 recvTimeout_ = recvTimeout; in isOpen()
592 if (recvTimeout_ > 0) { in isOpen()
593 client->setRecvTimeout(recvTimeout_); in isOpen()
|
| D | TServerSocket.cpp | 110 recvTimeout_(0), in TServerSocket()
129 recvTimeout_(recvTimeout), in TServerSocket()
149 recvTimeout_(0), in TServerSocket()
169 recvTimeout_(0), in TServerSocket()
220 recvTimeout_ = recvTimeout; in isOpen()
688 if (recvTimeout_ > 0) { in isOpen()
689 client->setRecvTimeout(recvTimeout_); in isOpen()
|
| D | TNonblockingServerSocket.h | 131 int recvTimeout_; variable
|
| D | TServerSocket.h | 159 int recvTimeout_; variable
|
| D | TSocket.h | 343 int recvTimeout_; variable
|
| D | TSSLSocket.cpp | 845 if (wantRead && recvTimeout_) { in waitForEvent()
846 timeout = recvTimeout_; in waitForEvent()
|
| /thrift-3.4.0/lib/d/src/thrift/transport/ |
| D | socket.d | 143 return recvTimeout_; in recvTimeout()
148 recvTimeout_ = value; in recvTimeout()
193 Duration recvTimeout_; variable
428 setTimeout(SocketOption.RCVTIMEO, recvTimeout_); in setSocketOpts()
|
| /thrift-3.4.0/lib/d/src/thrift/server/transport/ |
| D | socket.d | 57 recvTimeout_ = recvTimeout;
76 recvTimeout_ = recvTimeout; in recvTimeout()
179 client.recvTimeout = recvTimeout_;
198 Duration recvTimeout_; variable
|
| /thrift-3.4.0/lib/d/src/thrift/async/ |
| D | socket.d | 308 timeout = recvTimeout_; in yieldOnBlock()
|
