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
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// SOCK_Acceptor.h
//
// = AUTHOR
// Doug Schmidt
//
// ============================================================================
#ifndef ACE_SOCK_ACCEPTOR_H
#define ACE_SOCK_ACCEPTOR_H
#include "ace/SOCK_Stream.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Time_Value.h"
class ACE_Export ACE_SOCK_Acceptor : public ACE_SOCK
{
// = TITLE
// Defines a factory that creates new <ACE_Stream>s passively.
//
// = DESCRIPTION
// The <ACE_SOCK_Acceptor> has its own "passive-mode" socket.
// This serves as a factory to create so-called "data-mode"
// sockets, which are what the <ACE_SOCK_Stream> encapsulates.
// Therefore, by inheriting from <ACE_SOCK>, <ACE_SOCK_Acceptor>
// gets its very own socket.
public:
// = Initialization and termination methods.
ACE_SOCK_Acceptor (void);
// Default constructor.
ACE_SOCK_Acceptor (const ACE_Addr &local_sap,
int reuse_addr = 0,
int protocol_family = PF_INET,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
// Initialize a passive-mode BSD-style acceptor socket (no QoS).
// <local_sap> is the address that we're going to listen for
// connections on. If <reuse_addr> is 1 then we'll use the
// <SO_REUSEADDR> to reuse this address.
ACE_SOCK_Acceptor (const ACE_Addr &local_sap,
ACE_Protocol_Info *protocolinfo,
ACE_SOCK_GROUP g,
u_long flags,
int reuse_addr,
int protocol_family,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
// Initialize a passive-mode QoS-enabled acceptor socket. Returns 0
// on success and -1 on failure.
int open (const ACE_Addr &local_sap,
int reuse_addr = 0,
int protocol_family = PF_INET,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
// Initialize a passive-mode BSD-style acceptor socket (no QoS).
// <local_sap> is the address that we're going to listen for
// connections on. If <reuse_addr> is 1 then we'll use the
// <SO_REUSEADDR> to reuse this address. Returns 0 on success and
// -1 on failure.
int open (const ACE_Addr &local_sap,
ACE_Protocol_Info *protocolinfo,
ACE_SOCK_GROUP g,
u_long flags,
int reuse_addr,
int protocol_family,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
// Initialize a passive-mode QoS-enabled acceptor socket. Returns 0
// on success and -1 on failure.
~ACE_SOCK_Acceptor (void);
// Default dtor.
// = Passive connection <accept> methods.
int accept (ACE_SOCK_Stream &new_stream,
ACE_Addr *remote_addr = 0,
ACE_Time_Value *timeout = 0,
int restart = 1,
int reset_new_handle = 0) const;
// Accept a new <ACE_SOCK_Stream> connection. A <timeout> of 0
// means block forever, a <timeout> of {0, 0} means poll. <restart>
// == 1 means "restart if interrupted," i.e., if errno == EINTR.
int accept (ACE_SOCK_Stream &new_stream,
ACE_Accept_QoS_Params qos_params,
ACE_Addr *remote_addr = 0,
ACE_Time_Value *timeout = 0,
int restart = 1,
int reset_new_handle = 0) const;
// Accept a new <ACE_SOCK_Stream> connection using the QoS
// information in <qos_params>. A <timeout> of 0 means block
// forever, a <timeout> of {0, 0} means poll. <restart> == 1 means
// "restart if interrupted," i.e., if errno == EINTR.
// = Meta-type info
typedef ACE_INET_Addr PEER_ADDR;
typedef ACE_SOCK_Stream PEER_STREAM;
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
protected:
int shared_accept_start (ACE_Time_Value *timeout,
int restart,
int &in_blocking_mode) const;
// Perform operations that must occur before <ACE_OS::accept> is
// called.
int shared_accept_finish (ACE_SOCK_Stream new_stream,
int in_blocking_mode,
int reset_new_handle) const;
// Perform operations that must occur after <ACE_OS::accept> is
// called.
int shared_open (const ACE_Addr &local_sap,
int protocol_family,
int backlog);
// This method factors out the common <open> code and is called by
// both the QoS-enabled <open> method and the BSD-style <open>
// method.
private:
int get_remote_addr (ACE_Addr &) const;
// Do not allow this function to percolate up to this interface...
};
#if !defined (ACE_LACKS_INLINE_FUNCTIONS)
#include "ace/SOCK_Acceptor.i"
#endif /* ACE_LACKS_INLINE_FUNCTIONS */
#endif /* ACE_SOCK_ACCEPTOR_H */
|
