summaryrefslogtreecommitdiff
path: root/ace/RMCast/RMCast_UDP_Reliable_Sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ace/RMCast/RMCast_UDP_Reliable_Sender.cpp')
-rw-r--r--ace/RMCast/RMCast_UDP_Reliable_Sender.cpp70
1 files changed, 0 insertions, 70 deletions
diff --git a/ace/RMCast/RMCast_UDP_Reliable_Sender.cpp b/ace/RMCast/RMCast_UDP_Reliable_Sender.cpp
deleted file mode 100644
index 641fb3403ac..00000000000
--- a/ace/RMCast/RMCast_UDP_Reliable_Sender.cpp
+++ /dev/null
@@ -1,70 +0,0 @@
-// $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);
-}