blob: 8a3f6dd3c3fb85c9799fa5014269bd513230b6bf (
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
|
// $Id$
#ifndef FOOSERVANTLIST_H
#define FOOSERVANTLIST_H
#include "tao/PortableServer/PortableServer.h"
#include "tao/PortableServer/Servant_Base.h"
#include "ace/SString.h"
class ClientTask;
class Foo_i;
class FooServantList
{
public:
FooServantList(const char* prefix,
unsigned num_servants,
unsigned num_clients,
int collocated_test,
int servant_to_deactivate,
CORBA::ORB_ptr orb);
~FooServantList();
void create_and_activate(CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa);
void client_done(void);
ClientTask* collocated_client () const;
void deactivate_servant (void);
private:
typedef ACE_SYNCH_MUTEX LockType;
typedef ACE_Guard<LockType> GuardType;
Foo_i** servants_;
PortableServer::ServantBase_var* safe_servants_;
ACE_CString prefix_;
unsigned num_servants_;
LockType num_clients_lock_;
unsigned num_clients_;
unsigned init_num_clients_;
int collocated_test_;
// The servant_to_be_deactivate_ should be an integer greater than -2.
// -1 => defatult value, DONT deactivate servant.
// 0 => deactivate all servants.
// > 0 => the index of the servant to be deactivated.
int servant_to_deactivate_;
ClientTask* collocated_client_;
/// The poa to activate and deactivate servant.
PortableServer::POA_var poa_;
CORBA::ORB_var orb_;
};
#endif
|
