public:
TestServer (bool digest)
: Server (TEST_SERVER_PORT, 30)
- , _buffer (new uint8_t[TEST_SERVER_BUFFER_LENGTH])
+ , _buffer (TEST_SERVER_BUFFER_LENGTH)
, _size (0)
, _result (false)
, _digest (digest)
try {
_thread.join ();
} catch (...) {}
- delete[] _buffer;
}
void expect (int size)
}
uint8_t const * buffer() const {
- return _buffer;
+ return _buffer.data();
}
void await ()
}
private:
- void handle (std::shared_ptr<Socket> socket)
+ void handle (std::shared_ptr<Socket> socket) override
{
boost::mutex::scoped_lock lm (_mutex);
BOOST_REQUIRE (_size);
if (_digest) {
Socket::ReadDigestScope ds (socket);
- socket->read (_buffer, _size);
+ socket->read (_buffer.data(), _size);
_size = 0;
_condition.notify_one ();
_result = ds.check();
} else {
- socket->read (_buffer, _size);
+ socket->read (_buffer.data(), _size);
_size = 0;
_condition.notify_one ();
}
boost::thread _thread;
boost::mutex _mutex;
boost::condition _condition;
- uint8_t* _buffer;
+ std::vector<uint8_t> _buffer;
int _size;
bool _result;
bool _digest;