11 #include "udp_server_socket.hh" 23 udp_server_socket t_server( 23530 );
25 LINFO(
plog,
"Server is listening" );
27 const size_t t_buff_size = 1024;
28 char* t_data =
new char[ t_buff_size ];
30 ssize_t t_size_received = 0;
31 while( t_size_received >= 0 )
33 LINFO(
plog,
"Waiting for a message" );
34 t_size_received = t_server.recv( t_data, t_buff_size, 0 );
35 if( t_size_received > 0 )
37 LINFO(
plog,
"Message received: " << t_data );
41 LDEBUG(
plog,
"No message received & no error present" );
46 catch( std::exception& e )
48 LERROR(
plog,
"Exception caught: " << e.what() );
static scarab::logger plog("batch_executor")
LOGGER(plog, "egg_writer")