Mon Feb 26 18:10:24 2002 Jaiganesh Balasubramanian <jai@kelvar.ece.uci.edu

1 files changed, 71 insertions, 0 deletions

diff --git a/TAO/tao/Asynch_Reply_Dispatcher_Base.cpp b/TAO/tao/Asynch_Reply_Dispatcher_Base.cpp
new file mode 100644
index 00000000000..f69693d0838
--- /dev/null
+++ b/TAO/tao/Asynch_Reply_Dispatcher_Base.cpp
@@ -0,0 +1,71 @@
+// $Id$
+
+#include "tao/Asynch_Reply_Dispatcher_Base.h"
+
+#include "tao/Pluggable_Messaging_Utils.h"
+#include "tao/ORB_Core.h"
+#include "tao/debug.h"
+#include "tao/ORB_Core.h"
+#include "tao/Transport.h"
+
+#if !defined (__ACE_INLINE__)
+#include "tao/Asynch_Reply_Dispatcher_Base.i"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(tao, Asynch_Reply_Dispatcher_Base, "$Id$")
+
+// Constructor.
+TAO_Asynch_Reply_Dispatcher_Base::TAO_Asynch_Reply_Dispatcher_Base (TAO_ORB_Core *orb_core)
+  : db_ (sizeof buf_,
+         ACE_Message_Block::MB_DATA,
+         this->buf_,
+         orb_core->message_block_buffer_allocator (),
+         orb_core->locking_strategy (),
+         ACE_Message_Block::DONT_DELETE,
+         orb_core->message_block_dblock_allocator ()),
+    reply_cdr_ (&db_,
+                ACE_Message_Block::MB_DATA,
+                TAO_ENCAP_BYTE_ORDER,
+                TAO_DEF_GIOP_MAJOR,
+                TAO_DEF_GIOP_MINOR,
+                orb_core),
+    transport_ (0)
+{
+}
+
+// Destructor.
+TAO_Asynch_Reply_Dispatcher_Base::~TAO_Asynch_Reply_Dispatcher_Base (void)
+{
+  if (this->transport_ != 0)
+    {
+      this->transport_->idle_after_reply ();
+      TAO_Transport::release (this->transport_);
+    }
+}
+
+// Must override pure virtual method in TAO_Reply_Dispatcher.
+int
+TAO_Asynch_Reply_Dispatcher_Base::dispatch_reply (
+    TAO_Pluggable_Reply_Params & /*params*/
+  )
+{
+  return 0;
+}
+
+
+void
+TAO_Asynch_Reply_Dispatcher_Base::connection_closed (void)
+{
+}
+
+void
+TAO_Asynch_Reply_Dispatcher_Base::reply_timed_out (void)
+{
+}
+
+long
+TAO_Asynch_Reply_Dispatcher_Base::schedule_timer (CORBA::ULong /*request_id */,
+                                                  const ACE_Time_Value & /*max_wait_time*/)
+{
+  return 0;
+}