| 95 | #endif |
| 96 | |
| 97 | void readerWorker(shared_ptr<TTransport> tt, uint32_t expectedResult) { |
| 98 | uint8_t buf[4]; |
| 99 | try { |
| 100 | tt->read(buf, 1); |
| 101 | BOOST_CHECK_EQUAL(expectedResult, tt->read(buf, 4)); |
| 102 | } catch (const TTransportException& tx) { |
| 103 | BOOST_CHECK_EQUAL(TTransportException::TIMED_OUT, tx.getType()); |
| 104 | } |
| 105 | } |
| 106 | |
| 107 | void readerWorkerMustThrow(shared_ptr<TTransport> tt) { |
| 108 | try { |