diff options
Diffstat (limited to 'protocols/ace/HTBP/HTBP_Notifier.cpp')
-rw-r--r-- | protocols/ace/HTBP/HTBP_Notifier.cpp | 86 |
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 |