---

udpmem.hh

Go to the documentation of this file.

#ifndef UDPMEM_HH
#define UDPMEM_HH

#include "cms.hh"               /* class CMS */
#include "sokintrf.h"           // struct sockaddr_in, msghdr, iovec


class UDPMEM:public CMS
{
public:
  UDPMEM (char *bufline, char *procline);
    virtual ~ UDPMEM ();

  /* Overloaded CMS functions. */
  CMS_STATUS clear ();
  int check_if_read ();
  CMS_STATUS read ();
  CMS_STATUS blocking_read (double);
  CMS_STATUS peek ();
  CMS_STATUS write (void *data);
  CMS_STATUS write_if_read (void *data);

protected:
  int call_on_server ();
  int verify_bufname ();
  int setup_subscription ();
  int cancel_subscription ();
  int init_variables ();
  int polling;
  int get_reply;
  int last_reply_timed_out;
  long reply_size;
  long request_size;
  double retry_timeout;
  unsigned long serial_number;
  unsigned long returned_serial_number;
#ifndef VXWORKS
  struct hostent *server_host_entry;
  struct hostent *broadcast_server_host_entry;
#endif
  struct sockaddr_in server_socket_address;
  struct sockaddr_in broadcast_server_socket_address;
  int socket_fd;
  char request_buffer[32];
  char reply_buffer[32];
  struct msghdr request_message_header;
  struct msghdr reply_message_header;
  int send_broadcast;
  long send_broadcast_addr;
  int recieve_broadcast;
  long recieve_broadcast_port;
  int subscription_type;
  int poll_interval_millis;
  int subscription_id;
  int send_request;
  struct sockaddr_in cli_addr;
  struct iovec request_iov2[2];
  struct iovec reply_iov2[2];
  int broadcast_subscriptions;
  int broadcast_clnt_port;

};




#endif

---