---

ACE_POSIX_CB_Proactor Class Reference

Implementation of Callback-based Proactor };. More...

#include <POSIX_CB_Proactor.h>

Inheritance diagram for ACE_POSIX_CB_Proactor:

[legend]Collaboration diagram for ACE_POSIX_CB_Proactor:

[legend]List of all members.

Public Methods
virtual Proactor_Type	get_impl_type (void)
virtual	~ACE_POSIX_CB_Proactor (void)
	Destructor. More...
	ACE_POSIX_CB_Proactor (size_t max_aio_operations=ACE_AIO_DEFAULT_SIZE)
	Constructor defines max number asynchronous operations that can be started at the same time. More...
Protected Methods
virtual int	handle_events (ACE_Time_Value &wait_time)
virtual int	handle_events (void)
virtual ssize_t	allocate_aio_slot (ACE_POSIX_Asynch_Result *result)
	Find free slot to store result and aiocb pointer. More...
virtual int	notify_completion (int sig_num)
	Notify queue of "post_completed" ACE_POSIX_Asynch_Results called from post_completion method. More...
int	handle_events_i (u_long milli_seconds)
Static Protected Methods
void	aio_completion_func (sigval_t cb_data)
Protected Attributes
ACE_SYNCH_SEMAPHORE	sema_
	semaphore variable to notify used to wait the first AIO start. More...

---

Detailed Description

Implementation of Callback-based Proactor };.

Definition at line 32 of file POSIX_CB_Proactor.h.

---

Constructor & Destructor Documentation

ACE_POSIX_CB_Proactor::~ACE_POSIX_CB_Proactor (  void    )  [virtual]

Destructor. Definition at line 29 of file POSIX_CB_Proactor.cpp. References ACE_POSIX_AIOCB_Proactor::close. { this->close (); }

ACE_POSIX_CB_Proactor::ACE_POSIX_CB_Proactor (  size_t    max_aio_operations = ACE_AIO_DEFAULT_SIZE )

Constructor defines max number asynchronous operations that can be started at the same time. Definition at line 17 of file POSIX_CB_Proactor.cpp. References ACE_POSIX_Proactor::get_asynch_pseudo_task, and ACE_Asynch_Pseudo_Task::start. : ACE_POSIX_AIOCB_Proactor (max_aio_operations, ACE_POSIX_Proactor::PROACTOR_CB), sema_ (0) { // we should start pseudo-asynchronous accept task // one per all future acceptors this->get_asynch_pseudo_task ().start (); }

---

Member Function Documentation

void ACE_POSIX_CB_Proactor::aio_completion_func (  sigval_t    cb_data )  [static, protected]

Definition at line 34 of file POSIX_CB_Proactor.cpp. References notify_completion. Referenced by allocate_aio_slot. { #if defined (__FreeBSD__) ACE_POSIX_CB_Proactor * impl = ACE_static_cast (ACE_POSIX_CB_Proactor *, cb_data.sigval_ptr); #else ACE_POSIX_CB_Proactor * impl = ACE_static_cast (ACE_POSIX_CB_Proactor *, cb_data.sival_ptr); #endif if ( impl != 0 ) impl->notify_completion (0); }

ssize_t ACE_POSIX_CB_Proactor::allocate_aio_slot (  ACE_POSIX_Asynch_Result *    result )  [protected, virtual]

Find free slot to store result and aiocb pointer. Reimplemented from ACE_POSIX_AIOCB_Proactor. Definition at line 70 of file POSIX_CB_Proactor.cpp. References aio_completion_func, ACE_POSIX_AIOCB_Proactor::allocate_aio_slot, and ssize_t. { ssize_t slot = ACE_POSIX_AIOCB_Proactor::allocate_aio_slot (result); if (slot == -1) return -1; // setup OS notification methods for this aio // store index!!, not pointer in signal info // need to figure out correct thing to do here when we are not on SGI #if defined(__sgi) result->aio_sigevent.sigev_notify = SIGEV_CALLBACK; result->aio_sigevent.sigev_func = aio_completion_func ; #else result->aio_sigevent.sigev_notify = SIGEV_SIGNAL; #endif /* __sgi */ #if defined (__FreeBSD__) result->aio_sigevent.sigev_value.sigval_ptr = this ; #else result->aio_sigevent.sigev_value.sival_ptr = this ; #endif /* __FreeBSD__ */ return slot; }

virtual Proactor_Type ACE_POSIX_CB_Proactor::get_impl_type (  void    )  [virtual]

Reimplemented from ACE_POSIX_AIOCB_Proactor.

int ACE_POSIX_CB_Proactor::handle_events (  void    )  [protected, virtual]

Block indefinitely until at least one event is dispatched. Dispatch a single set of events. If <wait_time> elapses before any events occur, return 0. Return 1 on success i.e., when a completion is dispatched, non-zero (-1) on errors and errno is set accordingly. Reimplemented from ACE_POSIX_AIOCB_Proactor. Definition at line 55 of file POSIX_CB_Proactor.cpp. References ACE_INFINITE, and handle_events_i. { return this->handle_events_i (ACE_INFINITE); }

int ACE_POSIX_CB_Proactor::handle_events (  ACE_Time_Value &    wait_time )  [protected, virtual]

Dispatch a single set of events. If <wait_time> elapses before any events occur, return 0. Return 1 on success i.e., when a completion is dispatched, non-zero (-1) on errors and errno is set accordingly. Reimplemented from ACE_POSIX_AIOCB_Proactor. Definition at line 47 of file POSIX_CB_Proactor.cpp. References handle_events_i, and ACE_Time_Value::msec. { // Decrement <wait_time> with the amount of time spent in the method ACE_Countdown_Time countdown (&wait_time); return this->handle_events_i (wait_time.msec ()); }

int ACE_POSIX_CB_Proactor::handle_events_i (  u_long    milli_seconds )  [protected]

Dispatch a single set of events. If <milli_seconds> elapses before any events occur, return 0. Return 1 if a completion is dispatched. Return -1 on errors. Reimplemented from ACE_POSIX_AIOCB_Proactor. Referenced by handle_events.

int ACE_POSIX_CB_Proactor::notify_completion (  int    sig_num )  [protected, virtual]

Notify queue of "post_completed" ACE_POSIX_Asynch_Results called from post_completion method. Reimplemented from ACE_POSIX_AIOCB_Proactor. Definition at line 61 of file POSIX_CB_Proactor.cpp. References sema_. Referenced by aio_completion_func. { ACE_UNUSED_ARG (sig_num); return this->sema_.release(); }

---

Member Data Documentation

ACE_SYNCH_SEMAPHORE ACE_POSIX_CB_Proactor::sema_ [protected]

semaphore variable to notify used to wait the first AIO start. Definition at line 82 of file POSIX_CB_Proactor.h. Referenced by notify_completion.

---

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

• POSIX_CB_Proactor.h
• POSIX_CB_Proactor.cpp

---