#endif // DEBUG
}
-ControlClient::ControlClient(string host, int port):
- Connection(sockbuf::sock_stream), host(host), port(port) {
+ControlClient::ControlClient(const string& host, const Connection::Port& port):
+ Connection(sockbuf::sock_stream, host, port) {
#ifdef DEBUG
cerr << __FILE__ << ": host = " << host
<< " | port = " << port << endl;
#ifdef DEBUG
cerr << __FILE__ << ": real_run." << endl;
#endif // DEBUG
- socket->connect(host.c_str(), port);
- // TODO - mejorar manejo de errores de conexion.
- // volver a poner signal_disconnected()? reciclar signal_error_received()
- // y/o llamarla signal_error()?
- if (false) {
+ try {
+ socket->connect(host.c_str(), port);
+ } catch (const sockerr& e) {
+ // Poner una señal de error específica?
+ error_received(1);
finish();
- } else {
- connected();
+ return;
}
+ host = socket->localhost();
+ port = socket->localport();
+ // TODO sacar a la mierda?
+ connected();
while (!stop) {
HTTPResponse response;
try {
}
switch (response.status_code) {
case HTTPMessage::OK:
- ok_received();
+ ok_received(response.get_body());
break;
default:
error_received(response.status_code);