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
|
// -*- C++ -*-
//=============================================================================
/**
* @file TLI_Connector.h
*
* $Id$
*
* @author Doug Schmidt
*/
//=============================================================================
#ifndef ACE_TLI_CONNECTOR_H
#define ACE_TLI_CONNECTOR_H
#include /**/ "ace/pre.h"
#include "ace/TLI_Stream.h"
#include "ace/Log_Msg.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_TLI)
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
/**
* @class ACE_TLI_Connector
*
* @brief Defines an active connection factory for the ACE_TLI C++
* wrappers.
*/
class ACE_Export ACE_TLI_Connector
{
public:
// = Initialization methods.
/// Default constructor.
ACE_TLI_Connector (void);
/**
* Actively connect and produce a <new_stream> if things go well.
* The @a remote_sap is the address that we are trying to connect
* with. The @a 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 @c errno == EWOULDBLOCK. If *timeout > {0, 0} then
* this is the maximum amount of time to wait before timing out. If the
* time expires before the connection is made @c errno == ETIME. The
* @a local_sap is the value of local address to bind to. If it's
* the default value of ACE_Addr::sap_any then the user is letting
* the OS do the binding. If @a reuse_addr == 1 then the
* <local_addr> is reused, even if it hasn't been cleanedup yet.
*/
ACE_TLI_Connector (ACE_TLI_Stream &new_stream,
const ACE_Addr &remote_sap,
ACE_Time_Value *timeout = 0,
const ACE_Addr &local_sap = ACE_Addr::sap_any,
int reuse_addr = 0,
int flags = O_RDWR,
int perms = 0,
const char device[] = ACE_TLI_TCP_DEVICE,
struct t_info *info = 0,
int rw_flag = 1,
struct netbuf *udata = 0,
struct netbuf *opt = 0);
/**
* Actively connect and produce a <new_stream> if things go well.
* The @a remote_sap is the address that we are trying to connect
* with. The @a 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 @c errno == EWOULDBLOCK. If *timeout > {0, 0} then
* this is the maximum amount of time to wait before timing out. If the
* time expires before the connection is made @c errno == ETIME. The
* @a local_sap is the value of local address to bind to. If it's
* the default value of ACE_Addr::sap_any then the user is letting
* the OS do the binding. If @a reuse_addr == 1 then the
* <local_addr> is reused, even if it hasn't been cleanedup yet.
*/
int connect (ACE_TLI_Stream &new_stream,
const ACE_Addr &remote_sap,
ACE_Time_Value *timeout = 0,
const ACE_Addr &local_sap = ACE_Addr::sap_any,
int reuse_addr = 0,
int flags = O_RDWR,
int perms = 0,
const char device[] = ACE_TLI_TCP_DEVICE,
struct t_info *info = 0,
int rw_flag = 1,
struct netbuf *udata = 0,
struct netbuf *opt = 0);
/**
* Try to complete a non-blocking connection.
* If connection completion is successful then @a new_stream contains
* the connected ACE_SOCK_Stream. If @a remote_sap is non-NULL then it
* will contain the address of the connected peer.
*/
int complete (ACE_TLI_Stream &new_stream,
ACE_Addr *remote_sap,
ACE_Time_Value *tv);
/// Resets any event associations on this handle
bool reset_new_handle (ACE_HANDLE handle);
// = Meta-type info
typedef ACE_INET_Addr PEER_ADDR;
typedef ACE_TLI_Stream PEER_STREAM;
/// Dump the state of an object.
void dump (void) const;
/// Declare the dynamic allocation hooks.
ACE_ALLOC_HOOK_DECLARE;
};
ACE_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "ace/TLI_Connector.inl"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_TLI */
#include /**/ "ace/post.h"
#endif /* ACE_TLI_CONNECTOR_H */
|
