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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// SOCK_Dgram_Mcast.h
//
// = AUTHORS
// Irfan Pyrali <irfan@cs.wustl.edu>,
// Tim Harrison <harrison@cs.wustl.edu>, and
// Douglas C. Schmidt <schmidt@cs.wustl.edu>
//
// ============================================================================
#ifndef ACE_SOCK_DGRAM_MCAST_H
#define ACE_SOCK_DGRAM_MCAST_H
#include "ace/pre.h"
#include "ace/SOCK_Dgram.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/INET_Addr.h"
class ACE_Export ACE_SOCK_Dgram_Mcast : public ACE_SOCK_Dgram
{
// = TITLE
// Defines the member functions for the ACE socket wrapper
// for UDP/IP multicast.
public:
// = Initialization routine.
ACE_SOCK_Dgram_Mcast (void);
// Note that there is no public <open> method. Therefore, this
// class cannot be used unless you <subscribe> to a multicast group.
// If you just want to send (and not listen) to a multicast group,
// use <ACE_SOCK_Dgram> or <ACE_SOCK_CODgram> instead.
~ACE_SOCK_Dgram_Mcast (void);
// Default dtor.
// = Multicast group management routines.
int subscribe (const ACE_INET_Addr &mcast_addr,
int reuse_addr = 1,
const ACE_TCHAR *net_if = 0,
int protocol_family = PF_INET,
int protocol = 0);
// This is a BSD-style method (i.e., no QoS) for joining a multicast
// group. The network interface device driver is instructed to
// accept datagrams with <mcast_addr> multicast addresses. If the
// socket has already been opened, <subscribe> closes the socket and
// opens a new socket bound to the <mcast_addr>.
//
// The <net_if> interface is hardware specific, e.g., use "netstat
// -i" to find whether your interface is, such as "le0" or something
// else. If net_if == 0, <subscribe> uses the default mcast
// interface. Returns: -1 if the call fails.
//
// Note that some platforms, such as pSoS, support only number, not
// names, for network interfaces. For these platforms, just give
// these numbers in alphanumeric form and <subscribe> will convert
// them into numbers via <ACE_OS::atoi>.
int unsubscribe (const ACE_INET_Addr &mcast_addr,
const ACE_TCHAR *net_if = 0,
int protocol_family = PF_INET,
int protocol = 0);
// Leave a multicast group identified by <mcast_addr>. The <net_if>
// interface is hardware specific. Use something like "netstat -i"
// to find whether your interface is, such as "le0" or something
// else. If <net_if> == 0, <subscribe> uses the default mcast
// interface. Returns: -1 if the call fails.
//
// Note that some platforms, such as pSoS, support only number, not
// names, for network interfaces. For these platforms, just give
// these numbers in alphanumeric form and <subscribe> will convert
// them into numbers via <ACE_OS::atoi>.
int unsubscribe (void);
// Unsubscribe from a multicast group. Returns -1 if the call
// fails.
// = Data transfer routines.
ssize_t send (const void *buf,
size_t n,
int flags = 0) const;
// Send <n> bytes in <buf>.
ssize_t send (const iovec iov[],
size_t n,
int flags = 0) const;
// Send <n> <iovecs>.
// = Options.
int set_option (int option,
char optval);
// Set an ip option that takes a char as input, such as
// <IP_MULTICAST_LOOP> or <IP_MULTICAST_TTL>. This is just a more
// concise nice interface to a subset of possible
// <ACE_SOCK::set_option> calls. Returns 0 on success, -1 on
// failure.
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
private:
// = Disable public <open> method to ensure class used properly.
int open (const ACE_Addr &mcast_addr,
int protocol_family = PF_INET,
int protocol = 0,
int reuse_addr = 0);
// Not publically visible.
int open (const ACE_Addr &mcast_addr,
const ACE_QoS_Params &qos_params,
int protocol_family = PF_INET,
int protocol = 0,
ACE_Protocol_Info *protocolinfo = 0,
ACE_SOCK_GROUP g = 0,
u_long flags = 0,
int reuse_addr = 0);
// Not publically visible.
int subscribe_ifs (const ACE_INET_Addr &mcast_addr,
const ACE_TCHAR *net_if,
int protocol_family,
int protocol,
int reuse_addr);
// Subscribe to the multicast interface using BSD-style semantics
// (no QoS).
int unsubscribe_ifs (const ACE_INET_Addr &mcast_addr,
const ACE_TCHAR *net_if = 0,
int protocol_family = PF_INET,
int protocol = 0);
// Unsubscribe to multicast interfaces subscribed to previously by
// <subscribe_ifs>.
// = Disable public use of <ACE_SOCK_Dgram::send>s
// This forces <ACE_SOCK_Dgram_Mcast::send>s inline.
ssize_t send (const void *buf,
size_t n,
const ACE_Addr &addr,
int flags = 0) const;
ssize_t send (const iovec iov[],
size_t n,
const ACE_Addr &addr,
int flags = 0) const;
protected:
int make_multicast_address (const ACE_INET_Addr &mcast_addr,
const ACE_TCHAR *net_if = ACE_LIB_TEXT ("le0"));
// Initialize the <multicast_address_> IP address.
int make_multicast_address_i (const ACE_INET_Addr &mcast_addr,
ip_mreq& multicast_address,
const ACE_TCHAR *net_if = ACE_LIB_TEXT ("le0"));
// Initialize a multicast address. This method factors out common
// code called by <make_multicast_address> and <subscribe>.
ACE_INET_Addr mcast_addr_;
// A copy of the address that we use to <send> multicasts.
ip_mreq mcast_request_if_;
// IP address of the interface upon which we're receiving
// multicasts.
};
#if !defined (ACE_LACKS_INLINE_FUNCTIONS)
#include "ace/SOCK_Dgram_Mcast.i"
#endif /* ACE_LACKS_INLINE_FUNCTIONS */
#include "ace/post.h"
#endif /* ACE_SOCK_DGRAM_MCAST_H */
|
