- // FIXME - debería tirar una excepción?
- if (!socket->is_open()) {
- cerr << "No se pudo conectar a " << socket->peerhost() <<
- ":" << socket->peerport() << "." << endl;
- } else {
- cerr << "Conectado a " << socket->peerhost() <<
- ":" << socket->peerport() << "." << endl;
+ char buf[BUFSIZ];
+ bool in_frame = false;
+ stringstream ss;
+ while (!stop && socket.getline(buf, BUFSIZ)) {
+ string sbuf = buf;
+ if (in_frame) {
+ string::size_type pos = sbuf.find(FRAME_END);
+ if (pos == string::npos) { // No encuentra el fin
+ ss << sbuf << endl;
+ } else { // Encuentra el fin.
+ // Agrego al mensaje actual hasta el final </plantstatus>.
+ ss << sbuf.substr(0, pos + FRAME_END.length());
+ frame_received(ss.str());
+ ss.str("");
+ in_frame = false;
+ }
+ } else { // No esta en un frame.
+ string::size_type pos = sbuf.find(FRAME_BEGIN);
+ if (pos != string::npos) { // Encuentra el inicio
+ ss << sbuf.substr(pos) << endl;
+ in_frame = true;
+ }
+ }