Asynch_Queued_Message.cpp File Reference

#include "tao/Asynch_Queued_Message.h"
#include "tao/debug.h"
#include "tao/ORB_Core.h"
#include "ace/OS_Memory.h"
#include "ace/OS_NS_string.h"
#include "ace/os_include/sys/os_uio.h"
#include "ace/Log_Msg.h"
#include "ace/Message_Block.h"
#include "ace/Malloc_Base.h"
#include "ace/High_Res_Timer.h"

Include dependency graph for Asynch_Queued_Message.cpp:

Go to the source code of this file.

Functions
	ACE_RCSID (tao, Asynch_Queued_Message,"$Id: Asynch_Queued_Message.cpp 85406 2009-05-20 09:07:56Z johnnyw $") 1 TAO_Asynch_Queued_Message

---

Function Documentation

ACE_RCSID	(	tao	,
		Asynch_Queued_Message	,
		"$Id: Asynch_Queued_Message.cpp 85406 2009-05-20 09:07:56Z johnnyw $"
	)

Definition at line 13 of file Asynch_Queued_Message.cpp.

               : Asynch_Queued_Message.cpp 85406 2009-05-20 09:07:56Z johnnyw $")

TAO_BEGIN_VERSIONED_NAMESPACE_DECL

TAO_Asynch_Queued_Message::TAO_Asynch_Queued_Message (
  const ACE_Message_Block *contents,
  TAO_ORB_Core *oc,
  ACE_Time_Value *timeout,
  ACE_Allocator *alloc,
  bool is_heap_allocated)
  : TAO_Queued_Message (oc, alloc, is_heap_allocated)
  , size_ (contents->total_length ())
  , offset_ (0)
  , abs_timeout_ (ACE_Time_Value::zero)
{
  if (timeout != 0)// && *timeout != ACE_Time_Value::zero)
    {
      this->abs_timeout_ = ACE_High_Res_Timer::gettimeofday_hr () + *timeout;
    }
  // @@ Use a pool for these guys!!
  ACE_NEW (this->buffer_, char[this->size_]);

  size_t copy_offset = 0;
  for (const ACE_Message_Block *i = contents;
       i != 0;
       i = i->cont ())
    {
      ACE_OS::memcpy (this->buffer_ + copy_offset,
                      i->rd_ptr (),
                      i->length ());
      copy_offset += i->length ();
    }
}