ACE_Asynch_Read_Stream的小问题，特定环境下使用!!!不多说了。

#pragma once
#include
#include

class Fast_Asynch_Read_Stream : public ACE_Asynch_Read_Stream
{
public:
 Fast_Asynch_Read_Stream (void)
 {
 }

 /// Destructor.
 virtual ~Fast_Asynch_Read_Stream (void)
 {
 }

 int open (ACE_Handler &handler,
  ACE_HANDLE handle = ACE_INVALID_HANDLE,
  const void *completion_key = 0,
  ACE_Proactor *proactor = 0)
 {
  if(implementation_==NULL)
  {
   proactor = this->get_proactor (proactor, handler);
   if ((this->implementation_ = proactor->create_asynch_read_stream ()) == 0)
    return -1;
  }

  // Call the method of the base class.
  return ACE_Asynch_Operation::open (handler,
   handle,
   completion_key,
   proactor);
 }
};

class Fast_Asynch_Write_Stream : public ACE_Asynch_Write_Stream
{
public:

 Fast_Asynch_Write_Stream (void){}

 virtual ~Fast_Asynch_Write_Stream (void){}

 int open (ACE_Handler &handler,
  ACE_HANDLE handle = ACE_INVALID_HANDLE,
  const void *completion_key = 0,
  ACE_Proactor *proactor = 0)
 {
  if(implementation_==NULL)
  {
   proactor = this->get_proactor (proactor, handler);

   // Now let us get the implementation initialized.
   if ((this->implementation_ = proactor->create_asynch_write_stream ()) == 0)
    return -1;
  }
  // Call the method of the base class.
  return ACE_Asynch_Operation::open (handler,
   handle,
   completion_key,
   proactor);
 }
};

--------------------next---------------------
5.4的代码在这里，至少这里还检查了一下，能防止泄露。。。



int
ACE_Asynch_Read_Stream::open (ACE_Handler &handler,
ACE_HANDLE handle,
const void *completion_key,
ACE_Proactor *proactor)
{
// Get a proactor for/from the user.
proactor = this->get_proactor (proactor, handler);

// Delete the old implementation.
delete this->implementation_;
this->implementation_ = 0;

// Now let us get the implementation initialized.
ACE_Asynch_Read_Stream_Impl *implementation = proactor->create_asynch_read_stream ();
if (implementation == 0)
return -1;

// Set the implementation class
this->implementation (implementation);

// Call the method of the base class.
return ACE_Asynch_Operation::open (handler,
handle,
completion_key,
proactor);
}

--------------------next---------------------