nml_srv.hh

Source code for an Numeric Cmputer

/********************************************************************
* Description: nml_srv.hh
*
*   Derived from a work by Fred Proctor & Will Shackleford
*
* Author:
* License: LGPL Version 2
* System: Linux
*    
* Copyright (c) 2004 All rights reserved.
*
* Last change: 
* $Revision: 1.5 $
* $Author: paul_c $
* $Date: 2005/05/23 16:34:15 $
********************************************************************/

#ifndef NML_SERVER_HH
#define NML_SERVER_HH

#ifdef __cplusplus
extern "C" {
#endif

#include <sys/types.h>
#include <unistd.h>		/* pid_t */

#ifdef __cplusplus
}
#endif
#include "cms_srv.hh"		/* class CMS_SERVER */
#include "nml.hh"		/* class NML */
#include "rem_msg.hh"		/* struct REMOTE_READ_REQUEST, */
class NML_SERVER_LOCAL_PORT:public CMS_SERVER_LOCAL_PORT {
  protected:
    NML * nml;
    REMOTE_READ_REPLY *reader(REMOTE_READ_REQUEST * _req);
    REMOTE_READ_REPLY *blocking_read(REMOTE_READ_REQUEST * _req);
    REMOTE_WRITE_REPLY *writer(REMOTE_WRITE_REQUEST * _req);
    REMOTE_SET_DIAG_INFO_REPLY *set_diag_info(REMOTE_SET_DIAG_INFO_REQUEST *
	buf);
    REMOTE_GET_DIAG_INFO_REPLY *get_diag_info(REMOTE_GET_DIAG_INFO_REQUEST *
	buf);
    REMOTE_GET_MSG_COUNT_REPLY *get_msg_count(REMOTE_GET_DIAG_INFO_REQUEST *
	buf);
    void reset_diag_info();

    friend class NML_SUPER_SERVER;
    friend class NML_SERVER;
    int batch_list_id;

  public:
      NML_SERVER_LOCAL_PORT(NML * _nml);
      virtual ~ NML_SERVER_LOCAL_PORT();
};

class NML_SERVER:public CMS_SERVER {
  protected:
    int super_server_list_id;
    int being_deleted;

  public:
      NML_SERVER(NML * _nml, int set_to_master = 0);
      virtual ~ NML_SERVER();
    void delete_from_list();
    void add_to_nml_server_list();
    friend class NML_SUPER_SERVER;
};

class NML_SUPER_SERVER {
  public:
    LinkedList * servers;
    NML_SUPER_SERVER();
    ~NML_SUPER_SERVER();
    void add_to_list(NML *);
    void add_to_list(NML_SERVER *);
    void spawn_all_servers();
    void kill_all_servers();
    void delete_all_servers();
    int unspawned_servers;
};

extern NML_SUPER_SERVER *NML_Default_Super_Server;
extern void run_nml_servers();
extern void spawn_nml_servers();
extern void kill_nml_servers();
extern "C" {
    extern void nml_server_cleanup();
}
#endif				/* !NML_SERVER_HH */