---

oi_msg.cc

Go to the documentation of this file.

extern "C"
{
#include <string.h>             /* memcpy() */
#include <stdlib.h>             /* malloc() */
}

#include "oi_msg.hh"


RCS_OI_REQUEST_MSG::RCS_OI_REQUEST_MSG (NMLTYPE t, size_t sz):NMLmsg (t, sz)
{
// just avoi_requestding an inline function.
}

int
RCS_OI_REQUEST_format (NMLTYPE t, void *buf, CMS * cms)
{
  switch (t)
    {
    case RCS_GENERIC_OI_REQUEST_TYPE:
      ((RCS_GENERIC_OI_REQUEST *) buf)->update (cms);
      return (1);

    default:
      return (0);
    }
  return (0);
}

RCS_GENERIC_OI_REQUEST::RCS_GENERIC_OI_REQUEST ():
RCS_OI_REQUEST_MSG (RCS_GENERIC_OI_REQUEST_TYPE,
                    sizeof (RCS_GENERIC_OI_REQUEST))
{
// Just avoiding an inline function.
}

void
RCS_GENERIC_OI_REQUEST::update (CMS * cms)
{
// Just avoiding an inline function.
}


#ifdef __BORLANDC__
RCS_OI_REQUEST_CHANNEL::RCS_OI_REQUEST_CHANNEL (NML_FORMAT_PTR f_ptr,
                                                char *name, char *process,
                                                char *file, int set_to_server)
#else
RCS_OI_REQUEST_CHANNEL::RCS_OI_REQUEST_CHANNEL (NML_FORMAT_PTR f_ptr,
                                                char *name, char *process,
                                                char *file,
                                                int set_to_server = 0)
#endif
  :
NML (name, process, file, set_to_server)
{
  format_chain = new RCS_LINKED_LIST;
  prefix_format_chain (f_ptr);
  prefix_format_chain (RCS_OI_REQUEST_format);
  register_with_server ();
}


RCS_OI_REPLY_MSG::RCS_OI_REPLY_MSG (NMLTYPE t, size_t sz):NMLmsg (t, sz)
{
// just avoi_replyding an inline function.
}

int
RCS_OI_REPLY_format (NMLTYPE t, void *buf, CMS * cms)
{
  switch (t)
    {
    case RCS_GENERIC_OI_REPLY_TYPE:
      ((RCS_GENERIC_OI_REPLY *) buf)->update (cms);
      return (1);

    default:
      return (0);
    }
  return (0);
}

RCS_GENERIC_OI_REPLY::RCS_GENERIC_OI_REPLY ():
RCS_OI_REPLY_MSG (RCS_GENERIC_OI_REPLY_TYPE, sizeof (RCS_GENERIC_OI_REPLY))
{
// Just avoiding an inline function.
}

void
RCS_GENERIC_OI_REPLY::update (CMS * cms)
{
// Just avoiding an inline function.
}

#ifdef __BORLANDC__
RCS_OI_REPLY_CHANNEL::RCS_OI_REPLY_CHANNEL (NML_FORMAT_PTR f_ptr, char *name,
                                            char *process, char *file,
                                            int set_to_server)
#else
RCS_OI_REPLY_CHANNEL::RCS_OI_REPLY_CHANNEL (NML_FORMAT_PTR f_ptr, char *name,
                                            char *process, char *file,
                                            int set_to_server = 0)
#endif
  :
NML (name, process, file, set_to_server)
{
  format_chain = new RCS_LINKED_LIST;
  prefix_format_chain (f_ptr);
  prefix_format_chain (RCS_OI_REPLY_format);
  register_with_server ();
}


OI_REPLY_QUEUE_NODE::OI_REPLY_QUEUE_NODE (RCS_OI_REPLY_MSG * _msg)
{
  next = NULL;
  if (NULL != _msg)
    {
      msg = (RCS_OI_REPLY_MSG *) malloc (_msg->size);
      memcpy (msg, _msg, _msg->size);
    }
  else
    {
      msg = NULL;
    }
}

OI_REPLY_QUEUE_NODE::~OI_REPLY_QUEUE_NODE ()
{
  /* Do NOT delete msg. */
}

OI_REPLY_QUEUE::OI_REPLY_QUEUE ()
{
  head = NULL;
  tail = NULL;
}

OI_REPLY_QUEUE::~OI_REPLY_QUEUE ()
{
  flush ();
}


void
OI_REPLY_QUEUE::add_message (RCS_OI_REPLY_MSG * _msg)
{
  OI_REPLY_QUEUE_NODE *new_reply_node;

  new_reply_node = new OI_REPLY_QUEUE_NODE (_msg);

  if (NULL == head)
    {
      head = new_reply_node;
    }
  if (NULL != tail)
    {
      tail->next = new_reply_node;
      tail = new_reply_node;
    }
  else
    {
      tail = new_reply_node;
    }
}



RCS_OI_REPLY_MSG *
OI_REPLY_QUEUE::get_message ()
{
  RCS_OI_REPLY_MSG *return_msg;
  OI_REPLY_QUEUE_NODE *first_reply_node;

  if (NULL != head)
    {
      return_msg = head->msg;
      first_reply_node = head;
      head = head->next;
      delete first_reply_node;
      return return_msg;
    }
  return NULL;
}


void
OI_REPLY_QUEUE::flush ()
{
  OI_REPLY_QUEUE_NODE *temp;
  while (NULL != head)
    {
      delete head->msg;
      head->msg = NULL;
      temp = head;
      head = head->next;
      delete temp;
    }
  tail = NULL;
}

---