| 223 | } |
| 224 | |
| 225 | void peekerWorkerInterrupt(shared_ptr<TTransport> tt) { |
| 226 | uint8_t buf[400]; |
| 227 | try { |
| 228 | tt->read(buf, 1); |
| 229 | tt->peek(); |
| 230 | } catch (const TTransportException& tx) { |
| 231 | BOOST_CHECK_EQUAL(TTransportException::INTERRUPTED, tx.getType()); |
| 232 | } |
| 233 | } |
| 234 | |
| 235 | BOOST_AUTO_TEST_CASE(test_ssl_interruptable_child_peek) { |
| 236 | shared_ptr<TSSLSocketFactory> pServerSocketFactory = createServerSocketFactory(); |