---

udp_srv.hh

Go to the documentation of this file.

#ifndef UDP_SRV_HH
#define UDP_SRV_HH

#include "rcs_defs.hh"          /* WIN32 */
#include "cms_srv.hh"           /* class CMS_SERVER_REMOTE_PORT */
#include "linklist.hh"          /* class RCS_LINKED_LIST */
#include "msghdr.h"             /* struct msghdr */
#include "sokintrf.h"           // fd_set, sockaddr_in,

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

#ifdef linux
#define NO_THREADS
#endif

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


#define MAX_UDP_BUFFER_SIZE 16

class UDP_BROADCAST_DATA;

class CLIENT_UDP_PORT
{
public:
  CLIENT_UDP_PORT ();
  int subscription_id;
  int last_read_id;
  unsigned long serial_number;
  int errors, max_errors;
  struct sockaddr_in address;
  int socket_fd;
  RCS_LINKED_LIST *subscriptions;
  struct msghdr reply_message_header;
  struct sockaddr_in client_socket_address;
  struct iovec reply_iov2[2];
  int client_list_id;

#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;
#ifdef sunos5
  thread_t threadId;
#else
#ifdef POSIX_THREADS
  pthread_t threadId;
#else
  int threadId;
#endif
#endif
};


class CMS_SERVER_REMOTE_UDP_PORT:public CMS_SERVER_REMOTE_PORT
{
public:
  CMS_SERVER_REMOTE_UDP_PORT (CMS_SERVER * _cms_server);
  virtual ~ CMS_SERVER_REMOTE_UDP_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 ();
  int maxfdpl;
  int request_length;
  RCS_LINKED_LIST *client_ports;
  int connection_socket;
  long connection_port;
  struct sockaddr_in server_socket_address;
  REMOTE_CMS_REQUEST *request;
  char temp_buffer[32];
  CMS_SERVER *server;
  struct sockaddr_in client_address;
  struct msghdr message_header;
  int client_addresslen;
  double polling_period;
  struct iovec iov2[2];
  RCS_LINKED_LIST *subscription_buffers;
  int current_poll_interval_millis;
  int polling_enabled;
  struct timeval select_timeout;
  void update_subscriptions ();
  void add_subscription_client (int buffer_number, int subdiv,
                                int subscription_type,
                                int poll_interval_millis,
                                CLIENT_UDP_PORT * clnt);
  void remove_subscription (int subscription_id, int buffer_number,
                            int subdiv);
  void remove_subscription_client (CLIENT_UDP_PORT * clnt, int buffer_number,
                                   int subdiv);
  CLIENT_UDP_PORT *get_client_port (sockaddr_in * client_address);
  void recalculate_polling_interval ();
  int last_subscription_id;
  RCS_LINKED_LIST *broadcast_ports;
  int request_header_size;
  int reply_header_size;
  struct sockaddr_in broadcast_address;
  int broadcast_address_set;
  void set_broadcast_address (CMS *);
#ifndef VXWORKS
  struct hostent *broadcast_server_host_entry;
#endif
  int broadcast_subscriptions;
};

class UDP_BROADCAST_DATA
{
public:
  int buffer_number;
  struct sockaddr_in broadcast_address;
  int broadcast_clnt_port;
};


class UDP_BUFFER_SUBSCRIPTION_INFO
{
public:
  UDP_BUFFER_SUBSCRIPTION_INFO ();
  ~UDP_BUFFER_SUBSCRIPTION_INFO ();
  int buffer_number;
  int subdiv;
  int min_last_id;
  unsigned long max_serial_number;
  int list_id;
  double last_update_time;
  double min_update_interval;
  UDP_BROADCAST_DATA *broadcast_data;
  RCS_LINKED_LIST *sub_clnt_info;
};

class UDP_CLIENT_SUBSCRIPTION_INFO
{
public:
  UDP_CLIENT_SUBSCRIPTION_INFO ();
  ~UDP_CLIENT_SUBSCRIPTION_INFO ();
  int subscription_type;
  int poll_interval_millis;
  double last_sub_sent_time;
  int subscription_list_id;
  int buffer_number;
  int subdiv;
  int subscription_paused;
  int last_id_read;
  int subscription_id;
  CLIENT_UDP_PORT *clnt_port;
  UDP_BUFFER_SUBSCRIPTION_INFO *sub_buf_info;
};


#endif /* UDP_SRV_HH */

---