X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/6f70c17ffefd6150b68ac0f64a8116e730437408..1219cbffa9b305ac8ed53e2bb333443ea3bb1a75:/Server/src/controlserver.cpp?ds=sidebyside diff --git a/Server/src/controlserver.cpp b/Server/src/controlserver.cpp index 2fd7652..966e362 100644 --- a/Server/src/controlserver.cpp +++ b/Server/src/controlserver.cpp @@ -29,8 +29,6 @@ #include "plaqui/server/command.h" #include "plaqui/server/httperror.h" #include "plaqui/server/httpresponse.h" -//#include -//#include #ifdef DEBUG # include "plaqui/server/string.h" # include @@ -62,23 +60,17 @@ void ControlServer::real_run(void) throw() { cerr << __FILE__ << "(" << __LINE__ << ")" << ": real_run()" << endl; #endif // DEBUG - //char buf[BUFSIZ]; while (!stop()) { Command command; try { - //Glib::Mutex::Lock lock(socket_mutex); socket >> command; } catch (const ios::failure& e) { // TODO poner buenos codigos de error. - signal_error().emit(1000000, "Se desconectó."); + signal_error().emit(200000, "Se desconectó."); return; } catch (const sockerr& e) { signal_error().emit(e.serrno(), e.errstr()); return; - // Si se cerró el socket. - //} catch (const ios::failure& e) { - // stop = true; - // continue; // Si hay un error al parsear el comando, se envia una respuesta con el // error. } catch (const HTTPError& e) { @@ -88,48 +80,9 @@ void ControlServer::real_run(void) throw() { << e.code << " | reason = " << HTTPMessage::reason(e.code) << " | desc = " << e.what() << endl; #endif // DEBUG - //Glib::Mutex::Lock lock(socket_mutex); socket << HTTPResponse(e) << flush; continue; } - // TODO agregar las verificaciones de abajo a HTTPRequest y padres. - // Actualizacion: Estoy usando trim() en casi todos lados, no debería - // ser necesario. -/* - // Primera línea no vacía (que debe ser el request). - bool is_first = true; - while (!stop && socket.getline(buf, BUFSIZ)) { -#ifdef DEBUG - cerr << __FILE__ << "(" << __LINE__ << ")" - << " Recibiendo inea: " << buf << endl; -#endif // DEBUG - int len = strlen(buf); - // Si tiene un retorno de carro, lo elimina. - if (len && (buf[len-1] == '\r')) { - buf[--len] = '\0'; - } - // Si tiene contenido, lo agrego a la información del request. - if (len) { - // Si es la primera línea, es el request. - if (is_first) { - request.set_request(buf, socket->peerhost(), - socket->peerport()); - is_first = false; - } else { - // TODO request.parse_header(buf); - } - // Si viene la línea vacía - } else { - // Si no es la primera, terminan las cabeceras HTTP. - if (!is_first) { - // Podría ir un break. - stop = true; - continue; - } - // Si es la primera, no pasa nada, sigue esperando un request. - } - } -*/ #ifdef DEBUG cerr << __FILE__ << "(" << __LINE__ << ")" << " : real_run() Despachando comando: target = " @@ -142,8 +95,7 @@ void ControlServer::real_run(void) throw() { } } -void ControlServer::send(const HTTPResponse& response) { - //Glib::Mutex::Lock lock(socket_mutex); +void ControlServer::send(const Response& response) { socket << response << flush; #ifdef DEBUG cerr << __FILE__ << "(" << __LINE__ << ")"