TAO_DII_Deferred_Reply_Dispatcher Class Reference

Reply dispatcher for DII deferred requests. More...

#include <DII_Reply_Dispatcher.h>

Inheritance diagram for TAO_DII_Deferred_Reply_Dispatcher:

[legend]Collaboration diagram for TAO_DII_Deferred_Reply_Dispatcher:

[legend]List of all members.

Public Member Functions
	TAO_DII_Deferred_Reply_Dispatcher (const CORBA::Request_ptr req, TAO_ORB_Core *orb_core)
virtual int	dispatch_reply (TAO_Pluggable_Reply_Params &param)
	The Reply_Dispatcher methods.
virtual void	connection_closed (void)
virtual void	reply_timed_out (void)
	The following methods are not needed for this class..
virtual long	schedule_timer (CORBA::ULong, const ACE_Time_Value &)
Protected Member Functions
	~TAO_DII_Deferred_Reply_Dispatcher (void)
	Destructor.
Private Attributes
const CORBA::Request_ptr	req_
	Where the reply needs to go.

---

Detailed Description

Reply dispatcher for DII deferred requests.

Definition at line 47 of file DII_Reply_Dispatcher.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_DII_Deferred_Reply_Dispatcher::TAO_DII_Deferred_Reply_Dispatcher	(	const CORBA::Request_ptr	req,
		TAO_ORB_Core *	orb_core
	)

Definition at line 18 of file DII_Reply_Dispatcher.cpp.

  : TAO_Asynch_Reply_Dispatcher_Base (orb_core)
  , req_ (req)
{
}

TAO_DII_Deferred_Reply_Dispatcher::~TAO_DII_Deferred_Reply_Dispatcher

(

void

)

[protected]

Destructor.

Definition at line 27 of file DII_Reply_Dispatcher.cpp.

{
}

---

Member Function Documentation

void TAO_DII_Deferred_Reply_Dispatcher::connection_closed

(

void

)

[virtual]

Implements TAO_Asynch_Reply_Dispatcher_Base.

Definition at line 99 of file DII_Reply_Dispatcher.cpp.

References CORBA::COMPLETED_MAYBE, CORBA::Request::handle_response(), req_, SYSTEM_EXCEPTION, and TAO_debug_level.

{

  try
    {
      // Generate a fake exception....
      CORBA::COMM_FAILURE comm_failure (0, CORBA::COMPLETED_MAYBE);

      TAO_OutputCDR out_cdr;

      comm_failure._tao_encode (out_cdr);

      // Turn into an output CDR
      TAO_InputCDR cdr (out_cdr);

      this->req_->handle_response (cdr, GIOP::SYSTEM_EXCEPTION);
    }
  catch (const ::CORBA::Exception& ex)
    {
      if (TAO_debug_level >= 4)
        {
          ex._tao_print_exception (
            "DII_Deferred_Reply_Dispacher::connection_closed");
        }
    }

  (void) this->decr_refcount ();
}

int TAO_DII_Deferred_Reply_Dispatcher::dispatch_reply

(

TAO_Pluggable_Reply_Params &

param

)

[virtual]

The Reply_Dispatcher methods.

Implements TAO_Asynch_Reply_Dispatcher_Base.

Definition at line 33 of file DII_Reply_Dispatcher.cpp.

References ACE_BIT_DISABLED, ACE_DEBUG, ACE_ERROR, ACE_TEXT, ACE_InputCDR::clone_from(), ACE_Message_Block::DONT_DELETE, ACE_Data_Block::flags(), CORBA::Request::handle_response(), TAO_Pluggable_Reply_Params::input_cdr_, LM_DEBUG, LM_ERROR, TAO_Pluggable_Reply_Params_Base::locate_reply_status(), TAO_Reply_Dispatcher::locate_reply_status_, ACE_Data_Block::release(), TAO_Asynch_Reply_Dispatcher_Base::reply_cdr_, TAO_Asynch_Reply_Dispatcher_Base::reply_service_info_, TAO_Pluggable_Reply_Params_Base::reply_status(), TAO_Reply_Dispatcher::reply_status_, req_, TAO_Pluggable_Reply_Params_Base::svc_ctx_, and TAO_debug_level.

{
  if (params.input_cdr_ == 0)
    return -1;

  this->reply_status_ = params.reply_status ();
  this->locate_reply_status_ = params.locate_reply_status ();

  // Transfer the <params.input_cdr_>'s content to this->reply_cdr_
  ACE_Data_Block *db = this->reply_cdr_.clone_from (*params.input_cdr_);

  if (db == 0)
    {
      if (TAO_debug_level > 2)
        {
          ACE_ERROR ((
            LM_ERROR,
            "TAO (%P|%t) - DII_Deferred_Reply_Dispatcher::dispatch_reply "
            "clone_from failed \n"));
        }
      return -1;
    }

  // See whether we need to delete the data block by checking the
  // flags. We cannot be happy that we initally allocated the
  // datablocks of the stack. If this method is called twice, as is in
  // some cases where the same invocation object is used to make two
  // invocations like forwarding, the release becomes essential.
  if (ACE_BIT_DISABLED (db->flags (),
                        ACE_Message_Block::DONT_DELETE))
    db->release ();

  // Steal the buffer, that way we don't do any unnecesary copies of
  // this data.
  CORBA::ULong max = params.svc_ctx_.maximum ();
  CORBA::ULong len = params.svc_ctx_.length ();
  IOP::ServiceContext* context_list = params.svc_ctx_.get_buffer (1);
  this->reply_service_info_.replace (max, len, context_list, 1);

  if (TAO_debug_level >= 4)
    {
      ACE_DEBUG ((LM_DEBUG,
                  ACE_TEXT ("(%P | %t):TAO_Asynch_Reply_Dispatcher::dispatch_reply:\n")));
    }

  try
    {
      // Call the Request back and send the reply data.
      this->req_->handle_response (this->reply_cdr_, this->reply_status_);
    }
  catch (const ::CORBA::Exception& ex)
    {
      if (TAO_debug_level >= 4)
        {
          ex._tao_print_exception ("Exception during reply handler");
        }
    }

  // This was dynamically allocated. Now the job is done.
  (void) this->decr_refcount ();

  return 1;
}

virtual void TAO_DII_Deferred_Reply_Dispatcher::reply_timed_out

(

void

)

[inline, virtual]

The following methods are not needed for this class..

Implements TAO_Asynch_Reply_Dispatcher_Base.

Definition at line 62 of file DII_Reply_Dispatcher.h.

{}

virtual long TAO_DII_Deferred_Reply_Dispatcher::schedule_timer	(	CORBA::ULong	,
		const ACE_Time_Value &
	)			[inline, virtual]

Implements TAO_Asynch_Reply_Dispatcher_Base.

Definition at line 63 of file DII_Reply_Dispatcher.h.

  {
    return 0;
  }

---

Member Data Documentation

const CORBA::Request_ptr TAO_DII_Deferred_Reply_Dispatcher::req_ [private]

Where the reply needs to go.

Definition at line 74 of file DII_Reply_Dispatcher.h.

Referenced by connection_closed(), and dispatch_reply().

---

The documentation for this class was generated from the following files:

• DII_Reply_Dispatcher.h
• DII_Reply_Dispatcher.cpp

---