1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file SUN_Proactor.h
*
* $Id$
*
* @author Alexander Libman <alibman@baltimore.com>
*/
//=============================================================================
#ifndef ACE_SUN_PROACTOR_H
#define ACE_SUN_PROACTOR_H
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_AIO_CALLS) && defined (sun)
#include "ace/POSIX_Proactor.h"
#include "sys/asynch.h" // Sun native aio calls
/**
* @class ACE_SUN_Proactor
*
* @brief Implementation of the fast and reliable Proactor
* for SunOS 5.6, 5.7, etc.
*
* This proactor, based on <ACE_POSIX_AIOCB_Proactor>,
* works with Sun native interface for aio calls.
* POSIX_API Native SUN_API
* aio_read aioread
* aio_write aiowrite
* aio_suspend aiowait
* aio_error aio_result_t.errno
* aio_return aio_result_t.return
* On Solaris, the Sun <aio*()> native implementation is more
* reliable and efficient than POSIX <aio_*()> implementation.
* There is a problem of lost RT signals with POSIX, if we start
* more than SIGQUEUEMAX asynchronous operations at the same
* time.
* The Sun <aiocb> it is not the standard POSX <aiocb>, instead,
* it has the following structure:
* typedef struct aiocb
* {
* int aio_fildes; File descriptor
* void *aio_buf; buffer location
* size_t aio_nbytes; length of transfer
* off_t aio_offset; file offset
* int aio_reqprio; request priority offset
* sigevent aio_sigevent; signal number and offset
* int aio_lio_opcode; listio operation
* aio_result_t aio_resultp; results
* int aio_state; state flag for List I/O
* int aio__pad[1]; extension padding
* };
*/
class ACE_Export ACE_SUN_Proactor : public ACE_POSIX_AIOCB_Proactor
{
public:
virtual Proactor_Type get_impl_type (void);
/// Destructor.
virtual ~ACE_SUN_Proactor (void);
/// Constructor defines max number asynchronous operations that can
/// be started at the same time.
ACE_SUN_Proactor (size_t max_aio_operations = ACE_AIO_DEFAULT_SIZE);
protected:
/**
* 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.
*/
virtual int handle_events (ACE_Time_Value &wait_time);
/**
* 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.
*/
virtual int handle_events (u_long milli_seconds);
/**
* 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.
*/
virtual int handle_events (void);
/// From ACE_POSIX_AIOCB_Proactor.
virtual int start_aio (ACE_POSIX_Asynch_Result *result);
/// Check AIO for completion, error and result status
/// Return: 1 - AIO completed , 0 - not completed yet
virtual int get_result_status (ACE_POSIX_Asynch_Result* asynch_result,
int &error_status,
size_t &transfer_count);
/// Extract the results of aio.
ACE_POSIX_Asynch_Result *find_completed_aio (aio_result_t *result,
int &error_status,
size_t &transfer_count);
/// From ACE_POSIX_AIOCB_Proactor.
/// Attempt to cancel running request
virtual int cancel_aiocb (ACE_POSIX_Asynch_Result *result);
virtual int cancel_aio (ACE_HANDLE handle);
/// Specific Sun aiowait
int wait_for_start (ACE_Time_Value * abstime);
/// Condition variable .
/// used to wait the first AIO start
ACE_SYNCH_CONDITION condition_;
};
#if defined (__ACE_INLINE__)
#include "ace/SUN_Proactor.i"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_AIO_CALLS && sun */
#endif /* ACE_SUN_PROACTOR_H*/
|
