- } else if ( get_direction() == in ) {
- if ( io->read( buf, &length ) ) {
- parse_message();
+ } else if ( get_direction() == SG_IO_IN ) {
+ if ( (length = io->readline( buf, FG_MAX_MSG_SIZE )) > 0 ) {
+ FG_LOG( FG_IO, FG_ALERT, "Success reading data." );
+ if ( parse_message() ) {
+ FG_LOG( FG_IO, FG_ALERT, "Success parsing data." );
+ } else {
+ FG_LOG( FG_IO, FG_ALERT, "Error parsing data." );
+ }