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
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
|
/*
* (c) BayCom GmbH, http://www.baycom.de, info@baycom.de
*
* See the COPYING file for copyright information and
* how to reach the author.
*
*/
#ifndef __MLD_H__
#define __MLD_H__
/* Wrappers so we don't have to change the copied stuff ;) */
#define __u8 uint8_t
#define __u16 uint16_t
/* Booleans */
#define false 0
#define true (!false)
/* Determine Endianness */
#if ! defined __LITTLE_ENDIAN_BITFIELD && ! defined __BIG_ENDIAN_BITFIELD
#if BYTE_ORDER == LITTLE_ENDIAN
/* 1234 machines */
#define __LITTLE_ENDIAN_BITFIELD 1
#elif BYTE_ORDER == BIG_ENDIAN
/* 4321 machines */
#define __BIG_ENDIAN_BITFIELD 1
# define WORDS_BIGENDIAN 1
#elif BYTE_ORDER == PDP_ENDIAN
/* 3412 machines */
#error PDP endianness not supported yet!
#else
#error unknown endianness!
#endif
#endif
/* Per RFC */
struct mld1
{
__u8 type;
__u8 code;
__u16 csum;
__u16 mrc;
__u16 resv1;
struct in6_addr mca;
};
/* The timeout for queries */
/* as per RFC3810 MLDv2 "9.2. Query Interval" */
#define ECMH_SUBSCRIPTION_TIMEOUT 15
/* Robustness Factor, per RFC3810 MLDv2 "9.1. Robustness Variable" */
#define ECMH_ROBUSTNESS_FACTOR 2
/* MLDv2 Report */
#ifndef ICMP6_V2_MEMBERSHIP_REPORT
#define ICMP6_V2_MEMBERSHIP_REPORT 143
#endif
/* MLDv2 Report - Experimental Code */
#ifndef ICMP6_V2_MEMBERSHIP_REPORT_EXP
#define ICMP6_V2_MEMBERSHIP_REPORT_EXP 206
#endif
/* MLDv2 Exclude/Include */
#ifndef MLD2_MODE_IS_INCLUDE
#define MLD2_MODE_IS_INCLUDE 1
#endif
#ifndef MLD2_MODE_IS_EXCLUDE
#define MLD2_MODE_IS_EXCLUDE 2
#endif
#ifndef MLD2_CHANGE_TO_INCLUDE
#define MLD2_CHANGE_TO_INCLUDE 3
#endif
#ifndef MLD2_CHANGE_TO_EXCLUDE
#define MLD2_CHANGE_TO_EXCLUDE 4
#endif
#ifndef MLD2_ALLOW_NEW_SOURCES
#define MLD2_ALLOW_NEW_SOURCES 5
#endif
#ifndef MLD2_BLOCK_OLD_SOURCES
#define MLD2_BLOCK_OLD_SOURCES 6
#endif
#ifndef MLD2_ALL_MCR_INIT
#define MLD2_ALL_MCR_INIT { { { 0xff,0x02,0,0,0,0,0,0,0,0,0,0,0,0,0,0x16 } } }
#endif
#ifndef ICMP6_ROUTER_RENUMBERING
#define ICMP6_ROUTER_RENUMBERING 138 /* router renumbering */
#endif
#ifndef ICMP6_NI_QUERY
#define ICMP6_NI_QUERY 139 /* node information request */
#endif
#ifndef ICMP6_NI_REPLY
#define ICMP6_NI_REPLY 140 /* node information reply */
#endif
#ifndef MLD_MTRACE_RESP
#define MLD_MTRACE_RESP 200 /* Mtrace response (to sender) */
#endif
#ifndef MLD_MTRACE
#define MLD_MTRACE 201 /* Mtrace messages */
#endif
#ifndef ICMP6_DST_UNREACH_BEYONDSCOPE
#define ICMP6_DST_UNREACH_BEYONDSCOPE 2 /* Beyond scope of source address */
#endif
#ifndef ICMP6_NI_SUCCESS
#define ICMP6_NI_SUCCESS 0 /* node information successful reply */
#endif
#ifndef ICMP6_NI_REFUSED
#define ICMP6_NI_REFUSED 1 /* node information request is refused */
#endif
#ifndef ICMP6_NI_UNKNOWN
#define ICMP6_NI_UNKNOWN 2 /* unknown Qtype */
#endif
#ifndef ICMP6_ROUTER_RENUMBERING_COMMAND
#define ICMP6_ROUTER_RENUMBERING_COMMAND 0 /* rr command */
#endif
#ifndef ICMP6_ROUTER_RENUMBERING_RESULT
#define ICMP6_ROUTER_RENUMBERING_RESULT 1 /* rr result */
#endif
#ifndef ICMP6_ROUTER_RENUMBERING_SEQNUM_RESET
#define ICMP6_ROUTER_RENUMBERING_SEQNUM_RESET 255 /* rr seq num reset */
#endif
#ifndef ICMP6_MEMBERSHIP_QUERY
#define ICMP6_MEMBERSHIP_QUERY 130
#endif
#ifndef ICMP6_MEMBERSHIP_REPORT
#define ICMP6_MEMBERSHIP_REPORT 131
#endif
#ifndef ICMP6_MEMBERSHIP_REDUCTION
#define ICMP6_MEMBERSHIP_REDUCTION 132
#endif
#ifndef ICMP6_DST_UNREACH_NOTNEIGHBOR
#define ICMP6_DST_UNREACH_NOTNEIGHBOR 2 /* not a neighbor */
#endif
#ifdef __UCLIBC__
#ifndef IP6OPT_PADN
#define IP6OPT_PADN 1
#endif
#ifndef ip6_ext
struct ip6_ext
{
uint8_t ip6e_nxt;
uint8_t ip6e_len;
};
#endif
#endif
#ifdef WIN32
struct ip6_hdr
{
union
{
struct ip6_hdrctl
{
uint32_t ip6_un1_flow; /* 4 bits version, 8 bits TC,
20 bits flow-ID */
uint16_t ip6_un1_plen; /* payload length */
uint8_t ip6_un1_nxt; /* next header */
uint8_t ip6_un1_hlim; /* hop limit */
} ip6_un1;
uint8_t ip6_un2_vfc; /* 4 bits version, top 4 bits tclass */
} ip6_ctlun;
struct in6_addr ip6_src; /* source address */
struct in6_addr ip6_dst; /* destination address */
};
#define ICMP6_DST_UNREACH 1
#define ICMP6_TIME_EXCEEDED 3
#define ICMP6_PARAM_PROB 4
#define ip6_vfc ip6_ctlun.ip6_un2_vfc
#define ip6_plen ip6_ctlun.ip6_un1.ip6_un1_plen
#define ip6_nxt ip6_ctlun.ip6_un1.ip6_un1_nxt
#define ip6_hlim ip6_ctlun.ip6_un1.ip6_un1_hlim
#define IP6OPT_PADN 1
/* Hop-by-Hop options header. */
struct ip6_hbh
{
uint8_t ip6h_nxt; /* next header. */
uint8_t ip6h_len; /* length in units of 8 octets. */
/* followed by options */
};
#endif
/* From linux/net/ipv6/mcast.c */
/*
* These header formats should be in a separate include file, but icmpv6.h
* doesn't have in6_addr defined in all cases, there is no __u128, and no
* other files reference these.
*
* +-DLS 4/14/03
*
* Multicast Listener Discovery version 2 headers
* Modified as they are where not ANSI C compliant
*/
struct mld2_grec
{
__u8 grec_type;
__u8 grec_auxwords;
__u16 grec_nsrcs;
struct in6_addr grec_mca;
/* struct in6_addr grec_src[0]; */
};
struct mld2_report
{
__u8 type;
__u8 resv1;
__u16 csum;
__u16 resv2;
__u16 ngrec;
/* struct mld2_grec grec[0]; */
};
struct mld2_query
{
__u8 type;
__u8 code;
__u16 csum;
__u16 mrc;
__u16 resv1;
struct in6_addr mca;
#if defined(__LITTLE_ENDIAN_BITFIELD)
uint32_t qrv:3, suppress:1, resv2:4;
#elif defined(__BIG_ENDIAN_BITFIELD)
uint32_t resv2:4, suppress:1, qrv:3;
#else
#error "Please fix <asm/byteorder.h>"
#endif
__u8 qqic;
__u16 nsrcs;
/* struct in6_addr srcs[0]; */
};
#define IGMP6_UNSOLICITED_IVAL (10*HZ)
#define MLD_QRV_DEFAULT 2
#define MLD_V1_SEEN(idev) ((idev)->mc_v1_seen && \
time_before(jiffies, (idev)->mc_v1_seen))
#define MLDV2_MASK(value, nb) ((nb)>=32 ? (value) : ((1<<(nb))-1) & (value))
#define MLDV2_EXP(thresh, nbmant, nbexp, value) \
((value) < (thresh) ? (value) : \
((MLDV2_MASK(value, nbmant) | (1<<(nbmant+nbexp))) << \
(MLDV2_MASK((value) >> (nbmant), nbexp) + (nbexp))))
#define MLDV2_QQIC(value) MLDV2_EXP(0x80, 4, 3, value)
#define MLDV2_MRC(value) MLDV2_EXP(0x8000, 12, 3, value)
#define bool int
#define RAW_RX_BUF_SIZE 1024*1024
struct lookup
{
unsigned int num;
const char *desc;
};
/* Our configuration structure */
struct conf
{
unsigned int maxinterfaces; /* The max number of interfaces the array can hold */
struct intnode *ints; /* The interfaces we are watching */
struct mc_group *groups;
bool quit; /* Global Quit signal */
bool promisc; /* Make interfaces promisc? (To be sure to receive all MLD's) */
bool mode; /* Streamer 0 /Client mode 1 */
uint8_t *buffer; /* Our buffer */
unsigned int bufferlen; /* Length of the buffer */
int rawsocket; /* Single RAW socket for sending and receiving everything */
unsigned int stat_packets_received; /* Number of packets received */
unsigned int stat_packets_sent; /* Number of packets forwarded */
unsigned int stat_bytes_received; /* Number of bytes received */
unsigned int stat_bytes_sent; /* Number of bytes forwarded */
unsigned int stat_icmp_received; /* Number of ICMP's received */
unsigned int stat_icmp_sent; /* Number of ICMP's sent */
unsigned int mca_groups;
unsigned int subscribers;
cmdline_t *cmd;
#ifdef SERVER
tuner_t *tuner_parms;
int tuner_number;
satellite_list_t *sat_list;
int sat_list_num;
int readconfig;
pthread_t mld_timer_thread;
pthread_t collect_stats_thread;
pthread_t stream_tca_thread;
pthread_t stream_tra_thread;
int tca_id;
#endif
pthread_mutex_t lock;
};
/* Global Stuff */
extern struct conf *g_conf;
extern struct lookup mld2_grec_types[];
const char *lookup (struct lookup *l, unsigned int num);
const char *icmpv6_type (unsigned int type);
const char *icmpv6_code (unsigned int type, unsigned int code);
uint16_t ipv6_checksum (const struct ip6_hdr *ip6, uint8_t protocol, const void *data, const uint16_t length);
void sendpacket6 (struct intnode *intn, const struct ip6_hdr *iph, const uint16_t len);
//------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
int send_mldv2_report (struct intnode *intn, int grec_number, struct in6_addr *mcas, int srcn, struct in6_addr *sources, int mode);
int start_mld_daemon (void);
#endif
|
