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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// MEM_Aceeptor.h
//
// = AUTHOR
// Nanbor Wang
//
// ============================================================================
#ifndef ACE_MEM_ACCEPTOR_H
#define ACE_MEM_ACCEPTOR_H
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/SOCK_Acceptor.h"
#include "ace/MEM_Stream.h"
// Forward decl.
class ACE_Reactor;
class ACE_Export ACE_MEM_Acceptor : public ACE_SOCK_Acceptor
{
// = TITLE
// Defines the format and interface for the acceptor side of the
// local mmap stream. I should probably designed the class
// to prevent user passing a non-localhost endpoint as the acceptor
// listen point because it doesn't make any sense at all to make
// the listening endpoint visible (or connectable) anywhere outside
// of this machine. However, I decided to leave the type of endpoint
// as <ACE_Addr> so we can later changed to use UNIX sockets with
// mmap stream if so desired. (Currently, using UNIX socket with
// this class will not work.)
public:
// = Initialization methods.
ACE_MEM_Acceptor (void);
// Default constructor.
ACE_MEM_Acceptor (const u_short local_port,
int reuse_addr = 0,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
// Initiate a passive mode socket.
int open (const u_short local_port,
int reuse_addr = 0,
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 accept (ACE_MEM_Stream &new_ipc_sap,
u_short * = 0,
ACE_Time_Value *timeout = 0,
int restart = 1,
int reset_new_handle = 0) const;
// Accept a new data transfer connection.
int shared_accept_finish (ACE_MEM_Stream new_stream,
int in_blocking_mode,
int reset_new_handle) const;
// Perform operations that must occur after <ACE_OS::accept> is
// called.
// = Meta-type info
typedef u_short PEER_ADDR;
typedef ACE_MEM_Stream PEER_STREAM;
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
protected:
// = The following methods should not be accessable externally.
int open (const ACE_Addr &local_sap,
int reuse_addr = 0,
int protocol_family = PF_INET,
int backlog = ACE_DEFAULT_BACKLOG,
int protocol = 0);
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);
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;
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;
};
#if defined (__ACE_INLINE__)
#include "ace/MEM_Acceptor.i"
#endif /* __ACE_INLINE__ */
#endif /* ACE_MEM_ACCEPTOR_H */
|
