X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/e4f66a8221e3f2156d89a7a358073863503b2564..31a4d1fea320e59487fa28bbb406ee50d4e7ec76:/Server/src/controlserver.cpp?ds=inline

diff --git a/Server/src/controlserver.cpp b/Server/src/controlserver.cpp
index 23f89c4..1c253c5 100644
--- a/Server/src/controlserver.cpp
+++ b/Server/src/controlserver.cpp
@@ -44,36 +44,47 @@ namespace Server {
 
 ControlServer::~ControlServer(void) {
 #ifdef DEBUG
-	cerr << __FILE__ << ": destructor." << endl;
+	cerr << __FILE__ << "(" << __LINE__ << ")"
+		<< ": destructor." << endl;
 #endif // DEBUG
 }
 
 ControlServer::ControlServer(const sockbuf::sockdesc& sd):
 		Connection(sd) {
 #ifdef DEBUG
-	cerr << __FILE__ << ": sd = " << sd.sock << endl;
+	cerr << __FILE__ << "(" << __LINE__ << ")"
+		<< ": sd = " << sd.sock << endl;
 #endif // DEBUG
 }
 
-void ControlServer::real_run(void) {
+void ControlServer::real_run(void) throw() {
 #ifdef DEBUG
-	cerr << __FILE__ << ": real_run()" << endl;
+	cerr << __FILE__ << "(" << __LINE__ << ")"
+		<< ": real_run()" << endl;
 #endif // DEBUG
 	//char buf[BUFSIZ];
-	while (!stop) {
+	while (!stop()) {
 		Command command;
 		try {
 			//Glib::Mutex::Lock lock(socket_mutex);
 			socket >> command;
-		// Si se cerró el socket.
 		} catch (const ios::failure& e) {
-			stop = true;
-			continue;
+			// TODO poner buenos codigos de error.
+			signal_error().emit(1000000, "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) {
 #ifdef DEBUG
-			cerr << __FILE__ << " : real_run() ERROR: status_code = "
+			cerr << __FILE__ << "(" << __LINE__ << ")"
+				<< " : real_run() ERROR: status_code = "
 				<< e.code << " | reason = " << HTTPMessage::reason(e.code)
 				<< " | desc = " << e.what() << endl;
 #endif // DEBUG
@@ -89,7 +100,8 @@ void ControlServer::real_run(void) {
 		bool is_first = true;
 		while (!stop && socket.getline(buf, BUFSIZ)) {
 #ifdef DEBUG
-			cerr << __FILE__ << "  Recibiendo inea: " << buf << endl;
+			cerr << __FILE__ << "(" << __LINE__ << ")"
+			<< "  Recibiendo inea: " << buf << endl;
 #endif // DEBUG
 			int len = strlen(buf);
 			// Si tiene un retorno de carro, lo elimina.
@@ -119,7 +131,8 @@ void ControlServer::real_run(void) {
 		}
 */
 #ifdef DEBUG
-		cerr << __FILE__ << " : real_run() Despachando comando: target = "
+		cerr << __FILE__ << "(" << __LINE__ << ")"
+			<< " : real_run() Despachando comando: target = "
 			<< command.get_target() << " | command = " << command.get_command()
 			<< " | args = [" << String::join(command.get_args(), ", ") << "]"
 			<< endl;
@@ -129,11 +142,12 @@ void ControlServer::real_run(void) {
 	}
 }
 
-void ControlServer::send(const HTTPResponse& response) {
+void ControlServer::send(const Response& response) {
 	//Glib::Mutex::Lock lock(socket_mutex);
 	socket << response << flush;
 #ifdef DEBUG
-	cerr << __FILE__ << ": send() Enviado!" << endl;
+	cerr << __FILE__ << "(" << __LINE__ << ")"
+		<< ": send() Enviado!" << endl;
 #endif // DEBUG
 }