| 105 | } |
| 106 | |
| 107 | void readerWorkerMustThrow(shared_ptr<TTransport> tt) { |
| 108 | try { |
| 109 | uint8_t buf[400]; |
| 110 | tt->read(buf, 1); |
| 111 | tt->read(buf, 400); |
| 112 | BOOST_ERROR("should not have gotten here"); |
| 113 | } catch (const TTransportException& tx) { |
| 114 | BOOST_CHECK_EQUAL(TTransportException::INTERRUPTED, tx.getType()); |
| 115 | } |
| 116 | } |
| 117 | |
| 118 | shared_ptr<TSSLSocketFactory> createServerSocketFactory() { |
| 119 | shared_ptr<TSSLSocketFactory> pServerSocketFactory; |