std::condition_variable condvar;
io_service_->post(std::bind(&HATest::signalServiceRunning, this, std::ref(running),
- std::ref(mutex), std::ref(condvar)));
+ std::ref(mutex), std::ref(condvar)));
boost::shared_ptr<std::thread>
th(new std::thread(std::bind(&IOService::run, io_service_.get())));
// pointer to our completion handler method, receiveCompletionHandler.
RawBufferPtr buffer(new uint8_t[RECV_BUF_MAX]);
UDPEndpointPtr data_source(new asiolink::UDPEndpoint());
- recv_callback_.reset(new
- UDPCallback(buffer, RECV_BUF_MAX, data_source,
- std::bind(&NameChangeUDPListener::
- receiveCompletionHandler, this, ph::_1, ph::_2)));
+ recv_callback_.reset(new UDPCallback(buffer, RECV_BUF_MAX, data_source,
+ std::bind(&NameChangeUDPListener::receiveCompletionHandler,
+ this, ph::_1, ph::_2)));
}
NameChangeUDPListener::~NameChangeUDPListener() {
RawBufferPtr buffer(new uint8_t[SEND_BUF_MAX]);
UDPEndpointPtr data_source(new asiolink::UDPEndpoint());
send_callback_.reset(new UDPCallback(buffer, SEND_BUF_MAX, data_source,
- std::bind(&NameChangeUDPSender::
- sendCompletionHandler, this,
- ph::_1, ph::_2)));
+ std::bind(&NameChangeUDPSender::sendCompletionHandler,
+ this, ph::_1, ph::_2)));
}
NameChangeUDPSender::~NameChangeUDPSender() {
/// @brief Returns D2ClientErroHandler bound to this::error_handler_.
D2ClientErrorHandler getErrorHandler() {
- return (std::bind(&D2ClientMgrTest::error_handler, this, ph::_1, ph::_2));
+ return (std::bind(&D2ClientMgrTest::error_handler, this, ph::_1, ph::_2));
}
/// @brief Constructs a NameChangeRequest message from a fixed JSON string.