blob: 9a2432155c9b62c56bf16a93def55f23aec933ac (
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/tests
//
// = FILENAME
// server.h
//
// = AUTHOR
// Andy Gokhale, Sumedh Mungee,Sergio Flores-Gaitan and Nagarajan
// Surendran.
//
// ============================================================================
#ifndef SERVER_H
#define SERVER_H
// ACE includes.
#if defined (TAO_PLATFORM_SVC_CONF_FILE_NOTSUP)
#define TAO_DEFAULT_SERVER_STRATEGY_FACTORY_ARGS \
{ "-ORBconcurrency", "thread-per-connection", \
"-ORBdemuxstrategy", "dynamic", \
"-ORBtablesize", "128" }
#endif /* TAO_PLATFORM_SVC_CONF_FILE_NOTSUP */
#include "ace/OS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Get_Opt.h"
#include "ace/Log_Msg.h"
#include "ace/ARGV.h"
#include "ace/Sched_Params.h"
// TAO includes.
#include "tao/corba.h"
#include "tao/TAO.h"
// MT Cubit application includes.
#include "cubit_i.h"
#include "Task_Client.h"
#include "Util_Thread.h"
#include "Globals.h"
#include "Cubit_Task.h"
#if defined (VME_DRIVER)
#include <hostLib.h>
extern "C" STATUS vmeDrv (void);
extern "C" STATUS vmeDevCreate (char *);
#endif /* VME_DRIVER */
class Server
{
// = TITLE
// A multithreaded cubit server class.
//
// = DESCRIPTION
// This class encapsulates the functionality of a multi-threaded
// cubit server. To use this, call initialize and then
// start_servants method.
public:
Server (void);
// Default constructor.
int init (int argc, char **argv);
// Initialize the server state.
int run (void);
// Run method.
private:
int start_servants (void);
// Start the high and low priority servants.
void prelim_args_process (void);
// Preliminary argument processing code.
void init_low_priority (void);
// sets the priority to be used for the low priority servants.
int write_iors (void);
// Writes the iors of the servants to a file
int activate_high_servant (void);
// Activates the high priority servant.
int activate_low_servants (void);
// Activates the low priority servants.
int argc_;
// Number of arguments for the servant.
char **argv_;
// Arguments for the ORB.
CORBA::String *cubits_;
// Array to hold pointers to the Cubit objects.
Cubit_Task *high_priority_task_;
// Pointer to the high priority task
Cubit_Task **low_priority_tasks_;
// Array to hold pointers to the low priority tasks.
ACE_Sched_Priority high_priority_;
// Priority used for the high priority servant.
ACE_Sched_Priority low_priority_;
// Priority used by the low priority servants.
u_int num_low_priority_;
// Number of low priority servants
u_int num_priorities_;
// Number of priorities used.
u_int grain_;
// Granularity of the assignment of the priorities. Some OSs have
// fewer levels of priorities than we have threads in our test, so
// with this mechanism we assign priorities to groups of threads
// when there are more threads than priorities.
u_int counter_;
// count of the number of priorities used within a grain.
ACE_ARGV *high_argv_;
// argv passed to the high priority servant.
ACE_ARGV *low_argv_;
// argv passed to the low priority servants.
MT_Priority priority_;
// Priority helper object.
ACE_Thread_Manager servant_manager_;
// Thread manager for the servant threads.
};
#endif /* SERVER_H */
|
