| 742 | } |
| 743 | |
| 744 | void TServerSocket::notify(THRIFT_SOCKET notifySocket) { |
| 745 | if (notifySocket != THRIFT_INVALID_SOCKET) { |
| 746 | int8_t byte = 0; |
| 747 | if (-1 == send(notifySocket, cast_sockopt(&byte), sizeof(int8_t), 0)) { |
| 748 | TOutput::instance().perror("TServerSocket::notify() send() ", THRIFT_GET_SOCKET_ERROR); |
| 749 | } |
| 750 | } |
| 751 | } |
| 752 | |
| 753 | void TServerSocket::interrupt() { |
| 754 | concurrency::Guard g(rwMutex_); |
no test coverage detected