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
|
// -*- C++ -*-
//=============================================================================
/**
* @file XTI_ATM_Mcast.h
*
* $Id$
*
* @author Joe Hoffert
*/
//=============================================================================
#ifndef ACE_XTI_ATM_MCAST_H
#define ACE_XTI_ATM_MCAST_H
#include /**/ "ace/pre.h"
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_XTI_ATM)
#include "ace/TLI_Connector.h"
#include "ace/ATM_Addr.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
/**
* @class ACE_XTI_ATM_Mcast
*
* @brief Defines an active connection factory for the ACE_TLI C++
* wrappers to support XTI/ATM multicast.
*/
class ACE_Export ACE_XTI_ATM_Mcast : public ACE_TLI_Connector
{
public:
// = Initialization methods.
/// Default constructor.
ACE_XTI_ATM_Mcast (void);
/**
* 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 <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_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.
*/
ACE_XTI_ATM_Mcast (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_XTI_ATM_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 <remote_sap> is the address that we are trying to connect
* with. 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_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 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_XTI_ATM_DEVICE,
struct t_info *info = 0,
int rw_flag = 1,
struct netbuf *udata = 0,
struct netbuf *opt = 0);
/**
* Actively add a leaf to the currently connected stream (i.e.,
* multicast). The <remote_sap> is the address of the leaf that we
* are trying to add. 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>.
*/
int add_leaf (ACE_TLI_Stream ¤t_stream,
const ACE_Addr &remote_sap,
ACE_INT32 leaf_id,
ACE_Time_Value *timeout = 0);
// = Meta-type info
typedef ACE_ATM_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/XTI_ATM_Mcast.inl"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_XTI_ATM */
#include /**/ "ace/post.h"
#endif /* ACE_XTI_ATM_MCAST_H */
|
