| 294 | } |
| 295 | |
| 296 | bool IsReadTimeoutTException(const TTransportException& e) { |
| 297 | // String taken from TSocket::read() Thrift's TSocket.cpp and TSSLSocket.cpp. |
| 298 | // Specifically, "THRIFT_EAGAIN (timed out)" from TSocket.cpp, |
| 299 | // and "THRIFT_POLL (timed out)" from TSSLSocket.cpp. |
| 300 | return (e.getType() == TTransportException::TIMED_OUT |
| 301 | && strstr(e.what(), "(timed out)") != nullptr); |
| 302 | } |
| 303 | |
| 304 | bool IsPeekTimeoutTException(const TTransportException& e) { |
| 305 | // String taken from TSocket::peek() Thrift's TSocket.cpp and TSSLSocket.cpp. |
no test coverage detected