Home
last modified time | relevance | path

Searched refs:fds (Results 1 – 3 of 3) sorted by relevance

/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTSocket.cpp216 struct THRIFT_POLLFD fds[2]; in peek() local
217 std::memset(fds, 0, sizeof(fds)); in peek()
218 fds[0].fd = socket_; in peek()
219 fds[0].events = THRIFT_POLLIN; in peek()
220 fds[1].fd = *(interruptListener_.get()); in peek()
221 fds[1].events = THRIFT_POLLIN; in peek()
222 int ret = THRIFT_POLL(fds, 2, (recvTimeout_ == 0) ? -1 : recvTimeout_); in peek()
233 if (fds[1].revents & THRIFT_POLLIN) { in peek()
365 struct THRIFT_POLLFD fds[1]; in openConnection() local
366 std::memset(fds, 0, sizeof(fds)); in openConnection()
[all …]
DTServerSocket.cpp600 struct THRIFT_POLLFD fds[2]; in isOpen() local
606 std::memset(fds, 0, sizeof(fds)); in isOpen()
607 fds[0].fd = serverSocket_; in isOpen()
608 fds[0].events = THRIFT_POLLIN; in isOpen()
610 fds[1].fd = interruptSockReader_; in isOpen()
611 fds[1].events = THRIFT_POLLIN; in isOpen()
617 int ret = THRIFT_POLL(fds, 2, accTimeout_); in isOpen()
631 if (interruptSockReader_ != THRIFT_INVALID_SOCKET && (fds[1].revents & THRIFT_POLLIN)) { in isOpen()
641 if (fds[0].revents & THRIFT_POLLIN) { in isOpen()
DTSSLSocket.cpp832 struct THRIFT_POLLFD fds[2]; in waitForEvent() local
833 memset(fds, 0, sizeof(fds)); in waitForEvent()
834 fds[0].fd = fdSocket; in waitForEvent()
837 fds[0].events = wantRead ? THRIFT_POLLIN : THRIFT_POLLIN | THRIFT_POLLOUT; in waitForEvent()
840 fds[1].fd = *(interruptListener_.get()); in waitForEvent()
841 fds[1].events = THRIFT_POLLIN; in waitForEvent()
852 int ret = THRIFT_POLL(fds, interruptListener_ ? 2 : 1, timeout); in waitForEvent()
863 if (fds[1].revents & THRIFT_POLLIN) { in waitForEvent()