client.reset(new UnixControlClient());
ASSERT_TRUE(client);
- // Connect and then call server's receivePacket() so it can
- // detect the control socket connect and call the accept handler
+ // Connect.
ASSERT_TRUE(client->connectToServer(socket_path_));
- ASSERT_NO_THROW(server_->receivePacket(0));
- ASSERT_NO_THROW(getIOService()->run_one());
+ ASSERT_NO_THROW(getIOService()->poll());
- // Send the command and then call server's receivePacket() so it can
- // detect the inbound data and call the read handler
+ // Send the command.
ASSERT_TRUE(client->sendCommand(command));
- ASSERT_NO_THROW(server_->receivePacket(0));
- ASSERT_NO_THROW(getIOService()->run_one());
+ ASSERT_NO_THROW(getIOService()->poll());
// Read the response generated by the server. Note that getResponse
// only fails if there an IO error or no response data was present.
// Now disconnect and process the close event
client->disconnectFromServer();
- ASSERT_NO_THROW(server_->receivePacket(0));
-// ASSERT_NO_THROW(getIOService()->run_one());
ASSERT_NO_THROW(getIOService()->poll());
}
client.reset(new UnixControlClient());
ASSERT_TRUE(client);
- // Connect and then call server's receivePacket() so it can
- // detect the control socket connect and call the accept handler
+ // Connect.
ASSERT_TRUE(client->connectToServer(socket_path_));
- ASSERT_NO_THROW(server_->receivePacket(0));
- ASSERT_NO_THROW(getIOService()->run_one());
+ ASSERT_NO_THROW(getIOService()->poll());
- // Send the command and then call server's receivePacket() so it can
- // detect the inbound data and call the read handler
+ // Send the command.
ASSERT_TRUE(client->sendCommand(command));
- ASSERT_NO_THROW(server_->receivePacket(0));
- ASSERT_NO_THROW(getIOService()->run_one());
+ ASSERT_NO_THROW(getIOService()->poll());
// Read the response generated by the server. Note that getResponse
// only fails if there an IO error or no response data was present.
// Now disconnect and process the close event
client->disconnectFromServer();
- ASSERT_NO_THROW(server_->receivePacket(0));
ASSERT_NO_THROW(getIOService()->poll());
}