// $Id$
//
-#include "plaqui/server/httpresponse.h"
+#include "plaqui/server/response.h"
#include "plaqui/server/controlclient.h"
#ifdef DEBUG
# include <iostream>
ControlClient::ControlClient(const string& _host,
const Connection::Port& _port) throw(sockerr):
Connection(sockbuf::sock_stream, _host, _port) {
-#ifdef DEBUG
- cerr << __FILE__ << "(" << __LINE__ << ")"
- << ": host = " << host
- << " | port = " << port << endl;
-#endif // DEBUG
socket->connect(host.c_str(), port);
host = socket->localhost();
port = socket->localport();
#ifdef DEBUG
cerr << __FILE__ << "(" << __LINE__ << ")"
- << ": REAL | host = " << host
+ << ": host = " << host
<< " | port = " << port << endl;
#endif // DEBUG
receiver = new Receiver(7528, host);
cerr << ": REAL | host = " << host
<< " | port = " << port << endl;
#endif // DEBUG
- try {
- } catch (const sockerr& e) {
- // TODO Poner una señal de error específica?
- signal_error().emit(e.serrno(), e.errstr());
- return;
- }
- // TODO sacar signal_connected?
- connected();
// TODO Temporal: el receiver empieza a escuchar.
receiver->run();
while (!stop()) {
- HTTPResponse response;
+ Response response;
try {
//Glib::Mutex::Lock lock(socket_mutex);
socket >> response;
error_received(e);
continue;
}
- switch (response.status_code) {
- case HTTPMessage::OK:
- ok_received(response.get_body());
+ switch (response.xml_code) {
+ case Response::OK:
+ ok_received(response.xml_body);
break;
default:
- error_received(response.status_code);
+ error_received(response.xml_code);
break;
}
}
#endif // DEBUG
}
-ControlClient::SignalConnected& ControlClient::signal_connected(void) {
- return connected;
-}
-
ControlClient::SignalOKReceived& ControlClient::signal_ok_received(void) {
return ok_received;
}