Revision 90fc8d36 deps/liboi/test/ping_pong.c

View differences:

deps/liboi/test/ping_pong.c
30 30 
on_client_close(oi_socket *socket)
31 31 
{
32 32 
  //printf("client connection closed\n");
33 
  ev_unloop(socket->loop, EVUNLOOP_ALL);
33 
  ev_unloop(EV_DEFAULT_ EVUNLOOP_ALL);
34 34 
}
35 35 

  		




  36
  36
  
    
static oi_socket* 


  		




  ......




  87
  87
  
    
main(int argc, const char *argv[])


  		




  88
  88
  
    
{


  		




  89
  89
  
    
  int r;


  		




  90
  
  
    
  struct ev_loop *loop = ev_default_loop(0);


  		




  91
  90
  
    
  oi_server server;


  		




  92
  91
  
    
  oi_socket client;


  		




  93
  92
  
    

  		




  ......




  133
  132
  
    
#endif


  		




  134
  133
  
    
  r = oi_server_listen(&server, servinfo);


  		




  135
  134
  
    
  assert(r == 0);


  		




  136
  
  
    
  oi_server_attach(&server, loop);


  		




  
  135
  
    
  oi_server_attach(EV_DEFAULT_ &server);


  		




  137
  136
  
    

  		




  138
  137
  
    
  oi_socket_init(&client, 5.0);


  		




  139
  138
  
    
  client.on_read    = on_client_read;


  		




  ......




  150
  149
  
    

  		




  151
  150
  
    
  r = oi_socket_connect(&client, servinfo);


  		




  152
  151
  
    
  assert(r == 0 && "problem connecting");


  		




  153
  
  
    
  oi_socket_attach(&client, loop);


  		




  
  152
  
    
  oi_socket_attach(EV_DEFAULT_ &client);


  		




  154
  153
  
    

  		




  155
  
  
    
  ev_loop(loop, 0);


  		




  
  154
  
    
  ev_loop(EV_DEFAULT_ 0);


  		




  156
  155
  
    

  		




  157
  156
  
    
  assert(successful_ping_count == EXCHANGES + 1);


  		




  158
  157
  
    
  assert(nconnections == 1);


  		












Also available in:  Unified diff