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
|
//
// $Id$
//
#include "Coordinator.h"
ACE_RCSID(Big_Oneways, Coordinator, "$Id$")
Coordinator::Coordinator (CORBA::ULong peer_count)
: peers_ (0)
, peer_count_ (0)
, peer_max_ (peer_count)
{
ACE_NEW (this->peers_, Test::Peer_var[this->peer_max_]);
}
Coordinator::~Coordinator (void)
{
delete[] this->peers_;
}
int
Coordinator::has_all_peers (void) const
{
return this->peer_count_ == this->peer_max_;
}
void
Coordinator::create_session_list (Test::Session_Control_ptr session_control,
CORBA::ULong payload_size,
CORBA::ULong thread_count,
CORBA::ULong message_count,
Test::Session_List &session_list,
CORBA::Environment &ACE_TRY_ENV)
{
session_list.length (this->peer_count_);
CORBA::ULong count = 0;
for (Test::Peer_var *i = this->peers_;
i != this->peers_ + this->peer_count_;
++i)
{
session_list[count++] =
(*i)->create_session (session_control,
payload_size,
thread_count,
message_count,
this->peer_count_,
ACE_TRY_ENV);
ACE_CHECK;
}
}
void
Coordinator::shutdown_all_peers (CORBA::Environment &ACE_TRY_ENV)
{
for (Test::Peer_var *i = this->peers_;
i != this->peers_ + this->peer_count_;
++i)
{
ACE_TRY
{
(*i)->shutdown (ACE_TRY_ENV);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Coordinator::shutdown, ignored");
}
ACE_ENDTRY;
}
}
void
Coordinator::add_peer (Test::Peer_ptr peer,
CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException))
{
if (this->peer_count_ >= this->peer_max_)
return;
this->peers_[this->peer_count_++] =
Test::Peer::_duplicate (peer);
}
|
