---

tcp_srv.hh

Go to the documentation of this file.

#ifndef TCP_SRV_HH
#define TCP_SRV_HH

#include "cms_srv.hh"           /* class CMS_SERVER_REMOTE_PORT */
#include "linklist.hh"          /* class RCS_LINKED_LIST */
#include "rcs_defs.hh"          /* EXTERN_C_STD_HEADERS */
#include "sokintrf.h"           // fd_set, sockaddr_in, timeval
#include "rem_msg.hh"

#ifdef EXTERN_C_STD_HEADERS
extern "C"
{
#endif

#include <string.h>             /* memset(), strerror() */

#ifndef UNDER_CE
#include <errno.h>              /* errno */
#include <signal.h>             // SIGPIPE, signal()
#endif

#ifdef EXTERN_C_STD_HEADERS
}
#endif

#ifndef NO_THREADS
#ifdef sunos5
#include <thread.h>
#endif

#ifdef linux
#define NO_THREADS
#endif

#ifdef POSIX_THREADS
#include <pthread.h>
#endif

#endif

#include "dbg_mem.h"            /* DEBUG_FREE,DEBUG_MALLOC,DEBUG_CALLOC */

#define MAX_TCP_BUFFER_SIZE 16
class CLIENT_TCP_PORT;

class CMS_SERVER_REMOTE_TCP_PORT:public CMS_SERVER_REMOTE_PORT
{
public:
  CMS_SERVER_REMOTE_TCP_PORT (CMS_SERVER * _cms_server);
  virtual ~ CMS_SERVER_REMOTE_TCP_PORT ();
  int accept_local_port_cms (CMS *);
  void run ();
  void register_port ();
  void unregister_port ();
  double dtimeout;
protected:
    fd_set read_fd_set, write_fd_set;
  void handle_request (CLIENT_TCP_PORT *);
  int maxfdpl;
  RCS_LINKED_LIST *client_ports;
  RCS_LINKED_LIST *subscription_buffers;
  int connection_socket;
  long connection_port;
  struct sockaddr_in server_socket_address;
  REMOTE_CMS_REQUEST *request;
  char temp_buffer[0x2000];
  int current_poll_interval_millis;
  int polling_enabled;
  struct timeval select_timeout;
  void update_subscriptions ();
  void add_subscription_client (int buffer_number, int subscription_type,
                                int poll_interval_millis,
                                CLIENT_TCP_PORT * clnt);
  void remove_subscription_client (CLIENT_TCP_PORT * clnt, int buffer_number);
  void recalculate_polling_interval ();
  void CMS_SERVER_REMOTE_TCP_PORT::switch_function (CLIENT_TCP_PORT *
                                                    _client_tcp_port,
                                                    CMS_SERVER * server,
                                                    long request_type,
                                                    long buffer_number,
                                                    long
                                                    received_serial_number);
};

class TCP_BUFFER_SUBSCRIPTION_INFO
{
public:
  TCP_BUFFER_SUBSCRIPTION_INFO ();
  ~TCP_BUFFER_SUBSCRIPTION_INFO ();
  int buffer_number;
  int min_last_id;
  int list_id;
  RCS_LINKED_LIST *sub_clnt_info;
};

class TCP_CLIENT_SUBSCRIPTION_INFO
{
public:
  TCP_CLIENT_SUBSCRIPTION_INFO ();
  ~TCP_CLIENT_SUBSCRIPTION_INFO ();
  int subscription_type;
  int poll_interval_millis;
  double last_sub_sent_time;
  int subscription_list_id;
  int buffer_number;
  int subscription_paused;
  int last_id_read;
  TCP_BUFFER_SUBSCRIPTION_INFO *sub_buf_info;
  CLIENT_TCP_PORT *clnt_port;
};

class TCPSVR_BLOCKING_READ_REQUEST;

class CLIENT_TCP_PORT
{
public:
  CLIENT_TCP_PORT ();
  ~CLIENT_TCP_PORT ();
  long serial_number;
  int errors, max_errors;
  struct sockaddr_in address;
  int socket_fd;
  RCS_LINKED_LIST *subscriptions;
#if defined(WIN32) && !defined(gnuwin32)
  DWORD tid;
  DWORD pid;
#else
#ifdef VXWORKS
  int tid;
  int pid;
#else
  pid_t tid;
  pid_t pid;
#endif
#endif
  int blocking;
#if defined(sunos5) && !defined(NO_THREADS)
  thread_t threadId;
#else
#ifdef POSIX_THREADS
  pthread_t threadId;
#else
  int threadId;
#endif
#endif
  TCPSVR_BLOCKING_READ_REQUEST *blocking_read_req;
  REMOTE_SET_DIAG_INFO_REQUEST *diag_info;

};

class TCPSVR_BLOCKING_READ_REQUEST:public REMOTE_BLOCKING_READ_REQUEST
{
public:
  TCPSVR_BLOCKING_READ_REQUEST ();
  ~TCPSVR_BLOCKING_READ_REQUEST ();
  CLIENT_TCP_PORT *_client_tcp_port;
  CMS_SERVER_REMOTE_TCP_PORT *remport;
  CMS_SERVER *server;
  REMOTE_BLOCKING_READ_REPLY *read_reply;
};




#endif /* TCP_SRV_HH */

---