blob: ddadfbd7d4933881af6d1e831176708f2b8aef20 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
/********************************************************************
* 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:
********************************************************************/
#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 */
|
