ACE_AIOCB_Notify_Pipe_Manager Class Reference

This class manages the notify pipe of the AIOCB Proactor. More...

Inheritance diagram for ACE_AIOCB_Notify_Pipe_Manager:

[legend]Collaboration diagram for ACE_AIOCB_Notify_Pipe_Manager:

[legend]List of all members.

Public Member Functions
	ACE_AIOCB_Notify_Pipe_Manager (ACE_POSIX_AIOCB_Proactor *posix_aiocb_proactor)
virtual	~ACE_AIOCB_Notify_Pipe_Manager (void)
	Destructor.
int	notify ()
	Send the result pointer through the notification pipe.
virtual void	handle_read_stream (const ACE_Asynch_Read_Stream::Result &result)
Private Member Functions
	ACE_AIOCB_Notify_Pipe_Manager (void)
	Default constructor. Shouldnt be called.
Private Attributes
ACE_POSIX_AIOCB_Proactor *	posix_aiocb_proactor_
	The implementation proactor class.
ACE_Message_Block	message_block_
	Message block to get ACE_POSIX_Asynch_Result pointer from the pipe.
ACE_Pipe	pipe_
ACE_POSIX_Asynch_Read_Stream	read_stream_
	To do asynch_read on the pipe.

---

Detailed Description

This class manages the notify pipe of the AIOCB Proactor.

This class acts as the Handler for the operations issued on the notify pipe. This class is very useful in implementing operation class for the . This is also useful for implementing for .

class issues a on the pipe, using this class as the Handler. <POSIX_Asynch_Result *>'s are sent through the notify pipe. When <POSIX_Asynch_Result *>'s show up on the notify pipe, the dispatches the completion of the and calls the of this class. This class calls on the <POSIX_Asynch_Result *> and thus calls the application handler. Handling the MessageBlock: We give this message block to read the result pointer through the notify pipe. We expect that to read 4 bytes from the notify pipe, for each call. Before giving this message block to another , we update and put it in its initial position.

Definition at line 629 of file POSIX_Proactor.cpp.

---

Constructor & Destructor Documentation

ACE_AIOCB_Notify_Pipe_Manager::ACE_AIOCB_Notify_Pipe_Manager (  ACE_POSIX_AIOCB_Proactor *  posix_aiocb_proactor  )

Constructor. You need the posix proactor because you need to call Definition at line 664 of file POSIX_Proactor.cpp. References ACE_ERROR, ACE_NONBLOCK, LM_ERROR, ACE_POSIX_Asynch_Operation::open(), ACE_Pipe::open(), pipe_, posix_aiocb_proactor_, ACE_POSIX_Asynch_Read_Stream::read(), ACE_Pipe::read_handle(), read_stream_, ACE::set_flags(), and ACE_POSIX_AIOCB_Proactor::set_notify_handle(). : posix_aiocb_proactor_ (posix_aiocb_proactor), message_block_ (sizeof (2)), read_stream_ (posix_aiocb_proactor) { // Open the pipe. this->pipe_.open (); // Set write side in NONBLOCK mode ACE::set_flags (this->pipe_.write_handle (), ACE_NONBLOCK); // Set read side in NONBLOCK mode ACE::set_flags (this->pipe_.read_handle (), ACE_NONBLOCK); // Let AIOCB_Proactor know about our handle posix_aiocb_proactor_->set_notify_handle (this->pipe_.read_handle ()); // Open the read stream. if (this->read_stream_.open (this->proxy (), this->pipe_.read_handle (), 0, // Completion Key 0) // Proactor == -1) ACE_ERROR ((LM_ERROR, "%N:%l:%p\n", "ACE_AIOCB_Notify_Pipe_Manager::ACE_AIOCB_Notify_Pipe_Manager:" "Open on Read Stream failed")); // Issue an asynch_read on the read_stream of the notify pipe. if (this->read_stream_.read (this->message_block_, 1, // enough to read 1 byte 0, // ACT 0) // Priority == -1) ACE_ERROR ((LM_ERROR, "%N:%l:%p\n", "ACE_AIOCB_Notify_Pipe_Manager::ACE_AIOCB_Notify_Pipe_Manager:" "Read from pipe failed")); }

ACE_AIOCB_Notify_Pipe_Manager::~ACE_AIOCB_Notify_Pipe_Manager (  void   )  [virtual]

Destructor. Definition at line 704 of file POSIX_Proactor.cpp. References ACE_POSIX_Asynch_Operation::cancel(), ACE_OS::closesocket(), pipe_, ACE_Pipe::read_handle(), read_stream_, and ACE_Pipe::write_handle(). { // 1. try to cancel pending aio this->read_stream_.cancel (); // 2. close both handles // Destuctor of ACE_Pipe does not close handles. // We can not use ACE_Pipe::close() as it // closes read_handle and than write_handle. // In some systems close() may wait for // completion for all asynch. pending requests. // So we should close write_handle firstly // to force read completion ( if 1. does not help ) // and then read_handle and not vice versa ACE_HANDLE h = this->pipe_.write_handle (); if (h != ACE_INVALID_HANDLE) ACE_OS::closesocket (h); h = this->pipe_.read_handle (); if ( h != ACE_INVALID_HANDLE) ACE_OS::closesocket (h); }

ACE_AIOCB_Notify_Pipe_Manager::ACE_AIOCB_Notify_Pipe_Manager (  void   )  [private]

Default constructor. Shouldnt be called.

---

Member Function Documentation

void ACE_AIOCB_Notify_Pipe_Manager::handle_read_stream (  const ACE_Asynch_Read_Stream::Result &  result  )  [virtual]

This is the call back method when from the pipe is complete. Reimplemented from ACE_Handler. Definition at line 756 of file POSIX_Proactor.cpp. References ACE_ERROR, ACE_LIB_TEXT, and LM_ERROR. { // 1. Start new read to avoid pipe overflow // Set the message block properly. Put the <wr_ptr> back in the // initial position. if (this->message_block_.length () > 0) this->message_block_.wr_ptr (this->message_block_.rd_ptr ()); // One accept has completed. Issue a read to handle any // <post_completion>s in the future. if (-1 == this->read_stream_.read (this->message_block_, 1, // enough to read 1 byte 0, // ACT 0)) // Priority ACE_ERROR ((LM_ERROR, ACE_LIB_TEXT ("%N:%l:(%P | %t):%p\n"), ACE_LIB_TEXT ("ACE_AIOCB_Notify_Pipe_Manager::handle_read_stream:") ACE_LIB_TEXT ("Read from pipe failed"))); // 2. Do the upcalls // this->posix_aiocb_proactor_->process_result_queue (); }

int ACE_AIOCB_Notify_Pipe_Manager::notify (   )

Send the result pointer through the notification pipe. Definition at line 731 of file POSIX_Proactor.cpp. References ACE_ERROR, ACE_LIB_TEXT, EWOULDBLOCK, LM_ERROR, ACE::send(), and ssize_t. Referenced by ACE_POSIX_AIOCB_Proactor::notify_completion(). { // Send the result pointer through the pipe. char char_send = 0; ssize_t ret_val = ACE::send (this->pipe_.write_handle (), &char_send, sizeof (char_send)); if (ret_val < 0) { if (errno != EWOULDBLOCK) #if 0 ACE_ERROR ((LM_ERROR, ACE_LIB_TEXT ("(%P %t):%p\n"), ACE_LIB_TEXT ("ACE_AIOCB_Notify_Pipe_Manager::notify") ACE_LIB_TEXT ("Error:Writing on to notify pipe failed"))); #endif /* 0 */ return -1; } return 0; }

---

Member Data Documentation

ACE_Message_Block ACE_AIOCB_Notify_Pipe_Manager::message_block_ [private]

Message block to get ACE_POSIX_Asynch_Result pointer from the pipe. Definition at line 651 of file POSIX_Proactor.cpp.

ACE_Pipe ACE_AIOCB_Notify_Pipe_Manager::pipe_ [private]

Pipe for the communication between Proactor and the Asynch_Accept/Asynch_Connect and other post_completions Definition at line 655 of file POSIX_Proactor.cpp. Referenced by ACE_AIOCB_Notify_Pipe_Manager(), and ~ACE_AIOCB_Notify_Pipe_Manager().

ACE_POSIX_AIOCB_Proactor* ACE_AIOCB_Notify_Pipe_Manager::posix_aiocb_proactor_ [private]

The implementation proactor class. Definition at line 648 of file POSIX_Proactor.cpp. Referenced by ACE_AIOCB_Notify_Pipe_Manager().

ACE_POSIX_Asynch_Read_Stream ACE_AIOCB_Notify_Pipe_Manager::read_stream_ [private]

To do asynch_read on the pipe. Definition at line 658 of file POSIX_Proactor.cpp. Referenced by ACE_AIOCB_Notify_Pipe_Manager(), and ~ACE_AIOCB_Notify_Pipe_Manager().

---

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

• POSIX_Proactor.cpp

---