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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// ATM_Connector.h
//
// = AUTHOR
// Joe Hoffert
//
// ============================================================================
#ifndef ACE_ATM_CONNECTOR_H
#define ACE_ATM_CONNECTOR_H
#include "ace/ATM_Stream.h"
#include "ace/ATM_Params.h"
#include "ace/ATM_QoS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_ATM)
#if defined (ACE_WIN32)
#include "SOCK_Connector.h"
typedef ACE_SOCK_Connector ATM_Connector;
#else
#include "XTI_ATM_Mcast.h"
typedef ACE_XTI_ATM_Mcast ATM_Connector;
#endif
class ACE_Export ACE_ATM_Connector
{
// = TITLE
// Defines an active connection factory for the ACE_ATM C++
// wrappers.
public:
// = Initialization methods.
ACE_ATM_Connector (void);
// Default constructor.
ACE_ATM_Connector (ACE_ATM_Stream &new_stream,
const ACE_ATM_Addr &remote_sap,
ACE_ATM_Params params = ACE_ATM_Params(),
ACE_ATM_QoS options = ACE_ATM_QoS(),
ACE_Time_Value *timeout = 0,
const ACE_ATM_Addr &local_sap = ACE_ATM_Addr( "", 0 ),
int reuse_addr = 0,
#if defined (ACE_WIN32)
int flags = 0,
#else
int flags = O_RDWR,
#endif /* ACE_WIN32 */
int perms = 0);
// Actively connect and produce a <new_stream> if things go well.
// The <remote_sap> is the address that we are trying to connect
// with. The <params> are the parameters needed for either socket
// or XTI/ATM connections. The <timeout> is the amount of time to
// wait to connect. If it's 0 then we block indefinitely. If
// *timeout == {0, 0} then the connection is done using non-blocking
// mode. In this case, if the connection can't be made immediately
// the value of -1 is returned with <errno == EWOULDBLOCK>. If
// *timeout > {0, 0} then this is the amount of time to wait before
// timing out. If the time expires before the connection is made
// <errno == ETIME>. The <local_sap> is the value of local address
// to bind to. If it's the default value of <ACE_ATM_Addr::sap_any> then
// the user is letting the OS do the binding. If <reuse_addr> == 1
// then the <local_addr> is reused, even if it hasn't been cleanedup yet.
connect (ACE_ATM_Stream &new_stream,
const ACE_ATM_Addr &remote_sap,
ACE_ATM_Params params = ACE_ATM_Params(),
ACE_ATM_QoS options = ACE_ATM_QoS(),
ACE_Time_Value *timeout = 0,
const ACE_ATM_Addr &local_sap = ACE_ATM_Addr( "", 0 ),
int reuse_addr = 0,
#if defined (ACE_WIN32)
int flags = 0,
#else
int flags = O_RDWR,
#endif /* ACE_WIN32 */
int perms = 0);
// Actively connect and produce a <new_stream> if things go well.
// The <remote_sap> is the address that we are trying to connect
// with. The <params> are the parameters needed for either socket
// or XTI/ATM connections. The <timeout> is the amount of time to
// wait to connect. If it's 0 then we block indefinitely. If
// *timeout == {0, 0} then the connection is done using non-blocking
// mode. In this case, if the connection can't be made immediately
// the value of -1 is returned with <errno == EWOULDBLOCK>. If
// *timeout > {0, 0} then this is the amount of time to wait before
// timing out. If the time expires before the connection is made
// <errno == ETIME>. The <local_sap> is the value of local address
// to bind to. If it's the default value of <ACE_ATM_Addr::sap_any> then
// the user is letting the OS do the binding. If <reuse_addr> == 1
// then the <local_addr> is reused, even if it hasn't been cleanedup yet.
int complete (ACE_ATM_Stream &new_stream,
ACE_ATM_Addr *remote_sap,
ACE_Time_Value *tv);
// Try to complete a non-blocking connection.
// If connection completion is successful then <new_stream> contains
// the connected ACE_SOCK_Stream. If <remote_sap> is non-NULL then it
// will contain the address of the connected peer.
//int add_leaf (ACE_ATM_Stream ¤t_stream,
// const ACE_Addr &remote_sap,
// ACE_INT32 leaf_id,
// ACE_Time_Value *timeout = 0);
int add_leaf (ACE_ATM_Stream ¤t_stream,
const ACE_Addr &remote_sap,
ACE_ATM_QoS &qos);
// Actively add a leaf to the root (i.e., point-to-multipoint). The
// <remote_sap> is the address of the leaf that we
// are trying to add.
int reset_new_handle (ACE_HANDLE handle);
// Resets any event associations on this handle
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
private:
ATM_Connector connector_;
};
#if defined (__ACE_INLINE__)
#include "ace/ATM_Connector.i"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_ATM */
#endif /* ACE_ATM_CONNECTOR_H */
|
