blob: 36507c31cb2728ac17b789d349dac6d5b9c6bf22 (
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
|
#include "Coordinator.h"
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 ()
{
delete[] this->peers_;
}
int
Coordinator::has_all_peers () 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)
{
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_);
}
}
void
Coordinator::shutdown_all_peers ()
{
for (Test::Peer_var *i = this->peers_;
i != this->peers_ + this->peer_count_;
++i)
{
try
{
(*i)->shutdown ();
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Coordinator::shutdown, ignored");
}
}
}
void
Coordinator::add_peer (Test::Peer_ptr peer)
{
if (this->peer_count_ >= this->peer_max_)
return;
this->peers_[this->peer_count_++] =
Test::Peer::_duplicate (peer);
}
|