OpenSRF/src/utils/socket_test.c

   1 #include "socket_bundle.h"
   2
   3 int count = 0;
   4 void printme(void* blob, socket_manager* mgr,
   5                 int sock_fd, char* data, int parent_id) {
   6
   7         fprintf(stderr, "Got data from socket %d with parent %d => %s",
   8                         sock_fd, parent_id, data );
   9
  10         socket_send(sock_fd, data);
  11
  12         if(count++ > 2) {
  13 //              socket_disconnect(mgr, sock_fd);
  14                 _socket_print_list(mgr);
  15                 socket_manager_free(mgr);
  16                 exit(0);
  17         }
  18 }
  19
  20 int main(int argc, char* argv[]) {
  21         socket_manager* manager = safe_malloc(sizeof(socket_manager));
  22         int port = 11000;
  23         if(argv[1])
  24                 port = atoi(argv[1]);
  25
  26         manager->data_received = &printme;
  27         socket_open_tcp_server(manager, port);
  28
  29         while(1)
  30                 socket_wait_all(manager, -1);
  31
  32         return 0;
  33 }