summaryrefslogtreecommitdiff
path: root/ace/RMCast/RMCast_Receiver_Module.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ace/RMCast/RMCast_Receiver_Module.cpp')
-rw-r--r--ace/RMCast/RMCast_Receiver_Module.cpp157
1 files changed, 0 insertions, 157 deletions
diff --git a/ace/RMCast/RMCast_Receiver_Module.cpp b/ace/RMCast/RMCast_Receiver_Module.cpp
deleted file mode 100644
index 05e6ceb8c7f..00000000000
--- a/ace/RMCast/RMCast_Receiver_Module.cpp
+++ /dev/null
@@ -1,157 +0,0 @@
-//
-// $Id$
-//
-
-#include "RMCast_Receiver_Module.h"
-#include "RMCast_Proxy.h"
-#include "ace/Log_Msg.h"
-
-#if !defined (__ACE_INLINE__)
-# include "RMCast_Receiver_Module.i"
-#endif /* ! __ACE_INLINE__ */
-
-ACE_RCSID(RMCast, RMCast_Receiver_Module, "$Id$")
-
-ACE_RMCast_Receiver_Module::~ACE_RMCast_Receiver_Module (void)
-{
-}
-
-int
-ACE_RMCast_Receiver_Module::data (ACE_RMCast::Data &data)
-{
- switch (this->state_)
- {
- case RS_NON_EXISTENT:
- case RS_JOINING:
- if (data.source != 0)
- {
- //ACE_DEBUG ((LM_DEBUG,
- // "Receiver_Module::data - joining\n"));
-
- this->state_ = RS_JOINING;
- ACE_RMCast::Join join;
- if (data.source->reply_join (join) != 0)
- this->leaving (data.source);
- }
- break;
-
- case RS_JOINED:
- // ACE_DEBUG ((LM_DEBUG,
- // "Receiver_Module::data - joined\n"));
- if (this->ACE_RMCast_Module::data (data) != 0)
- this->leaving (data.source);
- break;
-
- default:
- case RS_LEAVING:
- this->leaving (data.source);
- break;
- }
- return 0;
-}
-
-int
-ACE_RMCast_Receiver_Module::poll (ACE_RMCast::Poll &poll)
-{
- switch (this->state_)
- {
- case RS_NON_EXISTENT:
- case RS_JOINING:
- if (poll.source != 0)
- {
- this->state_ = RS_JOINING;
- ACE_RMCast::Join join;
- if (poll.source->reply_join (join) != 0)
- this->leaving (poll.source);
- }
- break;
-
- case RS_JOINED:
- if (this->ACE_RMCast_Module::poll (poll) != 0)
- this->leaving (poll.source);
-
- default:
- case RS_LEAVING:
- this->leaving (poll.source);
- break;
- }
- return 0;
-}
-
-int
-ACE_RMCast_Receiver_Module::ack_join (ACE_RMCast::Ack_Join &ack_join)
-{
- switch (this->state_)
- {
- case RS_NON_EXISTENT:
- if (ack_join.source != 0)
- {
- //ACE_DEBUG ((LM_DEBUG,
- // "Receiver_Module::ack_join - joining\n"));
-
- this->state_ = RS_JOINING;
- ACE_RMCast::Join join;
- if (ack_join.source->reply_join (join) != 0)
- this->leaving (ack_join.source);
- }
- break;
-
- case RS_JOINING:
- case RS_JOINED:
- //ACE_DEBUG ((LM_DEBUG,
- // "Receiver_Module::ack_join - joined\n"));
-
- this->state_ = RS_JOINED;
- if (this->ACE_RMCast_Module::ack_join (ack_join) != 0)
- this->leaving (ack_join.source);
- break;
-
- default:
- case RS_LEAVING:
- this->leaving (ack_join.source);
- break;
- }
- return 0;
-}
-
-int
-ACE_RMCast_Receiver_Module::ack_leave (ACE_RMCast::Ack_Leave &ack_leave)
-{
- //ACE_DEBUG ((LM_DEBUG,
- // "Receiver_Module::ack_leave\n"));
-
- (void) this->ACE_RMCast_Module::ack_leave (ack_leave);
-
- // Returning -1 should remove the Proxy from the local set
- return -1;
-}
-
-int
-ACE_RMCast_Receiver_Module::ack (ACE_RMCast::Ack &)
-{
- return -1;
-}
-
-int
-ACE_RMCast_Receiver_Module::join (ACE_RMCast::Join &)
-{
- return -1;
-}
-
-int
-ACE_RMCast_Receiver_Module::leave (ACE_RMCast::Leave &)
-{
- return -1;
-}
-
-void
-ACE_RMCast_Receiver_Module::leaving (ACE_RMCast_Proxy *proxy)
-{
- this->state_ = RS_LEAVING;
- if (proxy != 0)
- {
- ACE_RMCast::Leave leave;
- (void) proxy->reply_leave (leave);
- }
- (void) this->close ();
-}