OpenSRF/src/libtransport/transport_socket.h

   1 #include <stdio.h>
   2 #include <stdlib.h>
   3 #include <sys/types.h>
   4 #include <errno.h>
   5
   6 #include "utils.h"
   7 #include "logging.h"
   8 //---------------------------------------------------------------
   9 // WIN32
  10 //---------------------------------------------------------------
  11 #ifdef WIN32
  12 #include <Windows.h>
  13 #include <Winsock.h>
  14 #else
  15
  16 //---------------------------------------------------------------
  17 // Unix headers
  18 //---------------------------------------------------------------
  19 #include <unistd.h>
  20 #include <sys/time.h>
  21 #include <sys/stat.h>
  22 #include <fcntl.h>
  23 #include <sys/socket.h>
  24 #include <arpa/inet.h>
  25 #include <netdb.h>
  26 #include <netinet/in.h>
  27 #endif
  28
  29 #ifndef TRANSPORT_SOCKET_H
  30 #define TRANSPORT_SOCKET_H
  31
  32 /* how many characters we read from the socket at a time */
  33 #ifdef _ROUTER
  34 #define BUFSIZE 412
  35 #else
  36 #define BUFSIZE 4096
  37 #endif
  38
  39 /* we maintain the socket information */
  40 struct transport_socket_struct {
  41         /* for a client, sock_fd is THE socket connection.  For a server,
  42                 it's the socket we listen on */
  43         int     sock_fd;
  44         int     connected;
  45         char* server; /* remote server name or ip */
  46         int     port;
  47         void* user_data;
  48
  49         /* user_data may be anything.  it's whatever you wish
  50                 to see showing up in the callback in addition to
  51                 the acutal character data*/
  52         void (*data_received_callback) (void * user_data, char*);
  53 };
  54 typedef struct transport_socket_struct transport_socket;
  55
  56 /* connects.  If is_server is true, we call tcp_server_connect */
  57 int tcp_connect( transport_socket* obj );
  58
  59 int tcp_send( transport_socket* obj, const char* data );
  60
  61 int tcp_disconnect( transport_socket* obj );
  62
  63 /* does both client and server waiting.
  64         returns the socket_fd on success, 0 on error */
  65 int tcp_wait( transport_socket* obj, int timeout );
  66
  67 int tcp_connected(transport_socket* obj);
  68
  69
  70
  71 #endif