blob: 57d3ca6ec8afd92dd0d671c32b785b40cdd5a539 (
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
|
#include "Notify_Structured_Push_Consumer.h"
#include "Notify_Test_Client.h"
#include "ace/OS_NS_unistd.h"
Notify_Structured_Push_Consumer::Notify_Structured_Push_Consumer (
const char* name,
unsigned int expected,
Notify_Test_Client& client)
: name_ (name),
expected_ (expected),
count_ (0),
delay_count_ (0),
delay_period_ (5),
client_ (client)
{
this->client_.consumer_start (this);
}
void
Notify_Structured_Push_Consumer::set_delay_parameters (unsigned int delay_count, unsigned long delay_period)
{
this->delay_count_ = delay_count;
this->delay_period_ = delay_period;
}
void
Notify_Structured_Push_Consumer::push_structured_event (
const CosNotification::StructuredEvent& /*event*/)
{
ACE_DEBUG((LM_DEBUG, "-"));
++count_;
if (this->delay_count_ != 0 && this->count_ % this->delay_count_ == 0)
{
ACE_OS::sleep (this->delay_period_);
}
if (this->count_ > this->expected_)
{
ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: too many events received.\n")));
}
if (this->count_ >= this->expected_)
{
this->client_.consumer_done (this);
}
}
|
