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
|
// $Id$
#include "RMCast_UDP_Reliable_Sender.h"
#include "RMCast_UDP_Event_Handler.h"
#include "RMCast_Resend_Handler.h"
#include "ace/Reactor.h"
#if !defined (__ACE_INLINE__)
# include "RMCast_UDP_Reliable_Sender.i"
#endif /* ! __ACE_INLINE__ */
ACE_RCSID(RMCast, RMCast_UDP_Reliable_Sender, "$Id$")
ACE_RMCast_UDP_Reliable_Sender::ACE_RMCast_UDP_Reliable_Sender (ACE_RMCast_Module *user_control)
: user_control_ (user_control)
// We use a singleton factory, all proxys send their messages to the
// retransmission module. There should be only control messages
// coming back, so this is OK.
, factory_ (&membership_)
, io_udp_ (&factory_)
{
// Control messages are received by the membership module and passed
// up to the both the retransmission and user modules, we use a fork
// module to do that
this->membership_.next (&this->fork_);
this->fork_.next (&this->retransmission_);
this->fork_.secondary (user_control);
// Messages are passed down to the sequencer module
this->next (&this->sequencer_);
// then to the retransmission module
this->sequencer_.next (&this->retransmission_);
// Then fork the messages, at this point control messages are sent
// back to the user, other messages continue down to the
// fragmentation layer.
this->retransmission_.next (&this->fragment_);
// The fragmentation layer delegates all messages to the UDP I/O
// module, that sends every message back to the application.
this->fragment_.next (&this->io_udp_);
}
ACE_RMCast_UDP_Reliable_Sender::~ACE_RMCast_UDP_Reliable_Sender (void)
{
}
void
ACE_RMCast_UDP_Reliable_Sender::reactive_incoming_messages (ACE_Reactor *reactor)
{
ACE_RMCast_UDP_Event_Handler *eh;
ACE_NEW (eh, ACE_RMCast_UDP_Event_Handler (&this->io_udp_));
/// @@ TODO Make sure it is removed from the Reactor at some point
(void) reactor->register_handler (eh, ACE_Event_Handler::READ_MASK);
}
void
ACE_RMCast_UDP_Reliable_Sender::reactive_resends (ACE_Reactor *reactor,
const ACE_Time_Value &period)
{
ACE_RMCast_Resend_Handler *eh;
ACE_NEW (eh, ACE_RMCast_Resend_Handler (&this->retransmission_));
/// @@ TODO make sure it is removed from the Reactor at some point
(void) reactor->schedule_timer (eh, 0, period, period);
}
|
