---

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 Methods
	ACE_AIOCB_Notify_Pipe_Manager (ACE_POSIX_AIOCB_Proactor *posix_aiocb_proactor)
	Constructor. You need the posix proactor because you need to call <application_specific_code>. More...
virtual	~ACE_AIOCB_Notify_Pipe_Manager (void)
	Destructor. More...
int	notify ()
	Send the result pointer through the notification pipe. More...
virtual void	handle_read_stream (const ACE_Asynch_Read_Stream::Result &result)
	This is the call back method when <Asynch_Read> from the pipe is complete. More...
Private Methods
	ACE_AIOCB_Notify_Pipe_Manager (void)
	Default constructor. Shouldnt be called. More...
Private Attributes
ACE_POSIX_AIOCB_Proactor *	posix_aiocb_proactor_
	The implementation proactor class. More...
ACE_Message_Block	message_block_
	Message block to get ACE_POSIX_Asynch_Result pointer from the pipe. More...
ACE_Pipe	pipe_
	Pipe for the communication between Proactor and the Asynch_Accept/Asynch_Connect and other post_completions. More...
ACE_POSIX_Asynch_Read_Stream	read_stream_
	To do asynch_read on the pipe. More...

---

Detailed Description

This class manages the notify pipe of the AIOCB Proactor.

This class acts as the Handler for the <Asynch_Read> operations issued on the notify pipe. This class is very useful in implementing <Asynch_Accept> operation class for the <AIOCB_Proactor>. This is also useful for implementing <post_completion> for <AIOCB_Proactor>.

<AIOCB_Proactor> class issues a <Asynch_Read> 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 <POSIX_AIOCB_Proactor> dispatches the completion of the <Asynch_Read_Stream> and calls the <handle_read_stream> of this class. This class calls <complete> 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 <accept> call. Before giving this message block to another <accept>, we update <wr_ptr> and put it in its initial position.

Definition at line 602 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 <application_specific_code>. Definition at line 637 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, read_stream_, ACE_Flag_Manip::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); // 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, 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 674 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 <Asynch_Read> from the pipe is complete. Reimplemented from ACE_Handler. Definition at line 726 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 701 of file POSIX_Proactor.cpp. References ACE_ERROR, ACE_LIB_TEXT, EWOULDBLOCK, LM_ERROR, and ACE::send. Referenced by ACE_POSIX_AIOCB_Proactor::notify_completion. { // Send the result pointer through the pipe. char char_send = 0; int 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 624 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 628 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 621 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 631 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

---