summaryrefslogtreecommitdiff
path: root/protocols/ace/HTBP/HTBP_Notifier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'protocols/ace/HTBP/HTBP_Notifier.cpp')
-rw-r--r--protocols/ace/HTBP/HTBP_Notifier.cpp86
1 files changed, 0 insertions, 86 deletions
diff --git a/protocols/ace/HTBP/HTBP_Notifier.cpp b/protocols/ace/HTBP/HTBP_Notifier.cpp
deleted file mode 100644
index 70a6df54023..00000000000
--- a/protocols/ace/HTBP/HTBP_Notifier.cpp
+++ /dev/null
@@ -1,86 +0,0 @@
-/* -*- C++ -*- */
-
-//=============================================================================
-/**
- * @file HTBP_Notifier.cpp
- *
- * $Id$
- *
- * @author Phil Mesnier, Priyanka Gontla
- */
-//=============================================================================
-#include "HTBP_Notifier.h"
-#include "HTBP_Channel.h"
-#include "HTBP_Session.h"
-#include "ace/Reactor.h"
-
-ACE_BEGIN_VERSIONED_NAMESPACE_DECL
-
-ACE::HTBP::Notifier::Notifier (ACE::HTBP::Channel *s)
- : channel_(s)
-{
-}
-
-int
-ACE::HTBP::Notifier::handle_input(ACE_HANDLE )
-{
- switch (this->channel_->state())
- {
- case ACE::HTBP::Channel::Detached:
- this->channel_->pre_recv();
- break;
- case ACE::HTBP::Channel::Wait_For_Ack:
- this->channel_->recv_ack();
- break;
- default:
- this->channel_->load_buffer();
- }
-
- if (this->channel_->state() == ACE::HTBP::Channel::Closed)
- {
- this->unregister();
- return 0;
- }
-
- if (this->channel_->session_)
- {
- if (this->channel_ == this->channel_->session_->inbound())
- {
- ACE_Event_Handler *h = this->channel_->session_->handler();
- if (h && this->reactor())
- this->reactor()->notify(h,
- ACE_Event_Handler::READ_MASK);
- else
- ACE_DEBUG ((LM_DEBUG,"Notifier cannot notify, session has no handler (%x), or reactor (%x)\n",h,this->reactor()));
- }
- else
- this->channel_->flush_buffer();
- }
- else
- ACE_DEBUG ((LM_DEBUG,"Notifier has no session to notify!\n"));
- return 0;
-}
-
-int
-ACE::HTBP::Notifier::handle_output (ACE_HANDLE )
-{
- return -1;
-
-}
-
-void
-ACE::HTBP::Notifier::unregister (void)
-{
- if (this->reactor())
- this->reactor()->remove_handler(this,
- ACE_Event_Handler::READ_MASK |
- ACE_Event_Handler::DONT_CALL);
-}
-
-ACE_HANDLE
-ACE::HTBP::Notifier::get_handle(void) const
-{
- return this->channel_->ace_stream().get_handle();
-}
-
-ACE_END_VERSIONED_NAMESPACE_DECL