1 /*
2 +----------------------------------------------------------------------+
3 | PHP Version 5 |
4 +----------------------------------------------------------------------+
5 | Copyright (c) 1997-2015 The PHP Group |
6 +----------------------------------------------------------------------+
7 | This source file is subject to version 3.01 of the PHP license, |
8 | that is bundled with this package in the file LICENSE, and is |
9 | available through the world-wide-web at the following url: |
10 | http://www.php.net/license/3_01.txt |
11 | If you did not receive a copy of the PHP license and are unable to |
12 | obtain it through the world-wide-web, please send a note to |
13 | license@php.net so we can mail you a copy immediately. |
14 +----------------------------------------------------------------------+
15 | Authors: Gustavo Lopes <cataphract@php.net> |
16 +----------------------------------------------------------------------+
17 */
18
19 /* $Id$ */
20
21 #ifdef HAVE_CONFIG_H
22 #include "config.h"
23 #endif
24
25 #include "php.h"
26
27 #include "php_network.h"
28 #ifdef PHP_WIN32
29 # include "windows_common.h"
30 #else
31 #include <sys/socket.h>
32 #include <sys/ioctl.h>
33 #include <net/if.h>
34 #ifdef HAVE_SYS_SOCKIO_H
35 #include <sys/sockio.h>
36 #endif
37 #include <netinet/in.h>
38 #include <arpa/inet.h>
39 #endif
40
41 #include "php_sockets.h"
42 #include "multicast.h"
43 #include "sockaddr_conv.h"
44 #include "main/php_network.h"
45
46
47 enum source_op {
48 JOIN_SOURCE,
49 LEAVE_SOURCE,
50 BLOCK_SOURCE,
51 UNBLOCK_SOURCE
52 };
53
54 static int _php_mcast_join_leave(php_socket *sock, int level, struct sockaddr *group, socklen_t group_len, unsigned int if_index, int join TSRMLS_DC);
55 #ifdef HAS_MCAST_EXT
56 static int _php_mcast_source_op(php_socket *sock, int level, struct sockaddr *group, socklen_t group_len, struct sockaddr *source, socklen_t source_len, unsigned int if_index, enum source_op sop TSRMLS_DC);
57 #endif
58
59 #ifdef RFC3678_API
60 static int _php_source_op_to_rfc3678_op(enum source_op sop);
61 #elif HAS_MCAST_EXT
62 static const char *_php_source_op_to_string(enum source_op sop);
63 static int _php_source_op_to_ipv4_op(enum source_op sop);
64 #endif
65
php_string_to_if_index(const char * val,unsigned * out TSRMLS_DC)66 int php_string_to_if_index(const char *val, unsigned *out TSRMLS_DC)
67 {
68 #if HAVE_IF_NAMETOINDEX
69 unsigned int ind;
70
71 ind = if_nametoindex(val);
72 if (ind == 0) {
73 php_error_docref(NULL TSRMLS_CC, E_WARNING,
74 "no interface with name \"%s\" could be found", val);
75 return FAILURE;
76 } else {
77 *out = ind;
78 return SUCCESS;
79 }
80 #else
81 php_error_docref(NULL TSRMLS_CC, E_WARNING,
82 "this platform does not support looking up an interface by "
83 "name, an integer interface index must be supplied instead");
84 return FAILURE;
85 #endif
86 }
87
php_get_if_index_from_zval(zval * val,unsigned * out TSRMLS_DC)88 static int php_get_if_index_from_zval(zval *val, unsigned *out TSRMLS_DC)
89 {
90 int ret;
91
92 if (Z_TYPE_P(val) == IS_LONG) {
93 if (Z_LVAL_P(val) < 0 || Z_LVAL_P(val) > UINT_MAX) {
94 php_error_docref(NULL TSRMLS_CC, E_WARNING,
95 "the interface index cannot be negative or larger than %u;"
96 " given %ld", UINT_MAX, Z_LVAL_P(val));
97 ret = FAILURE;
98 } else {
99 *out = Z_LVAL_P(val);
100 ret = SUCCESS;
101 }
102 } else {
103 zval_add_ref(&val);
104 convert_to_string_ex(&val);
105 ret = php_string_to_if_index(Z_STRVAL_P(val), out TSRMLS_CC);
106 zval_ptr_dtor(&val);
107 }
108
109 return ret;
110 }
111
112
113
php_get_if_index_from_array(const HashTable * ht,const char * key,php_socket * sock,unsigned int * if_index TSRMLS_DC)114 static int php_get_if_index_from_array(const HashTable *ht, const char *key,
115 php_socket *sock, unsigned int *if_index TSRMLS_DC)
116 {
117 zval **val;
118
119 if (zend_hash_find(ht, key, strlen(key) + 1, (void **)&val) == FAILURE) {
120 *if_index = 0; /* default: 0 */
121 return SUCCESS;
122 }
123
124 return php_get_if_index_from_zval(*val, if_index TSRMLS_CC);
125 }
126
php_get_address_from_array(const HashTable * ht,const char * key,php_socket * sock,php_sockaddr_storage * ss,socklen_t * ss_len TSRMLS_DC)127 static int php_get_address_from_array(const HashTable *ht, const char *key,
128 php_socket *sock, php_sockaddr_storage *ss, socklen_t *ss_len TSRMLS_DC)
129 {
130 zval **val,
131 *valcp;
132
133 if (zend_hash_find(ht, key, strlen(key) + 1, (void **)&val) == FAILURE) {
134 php_error_docref(NULL TSRMLS_CC, E_WARNING, "no key \"%s\" passed in optval", key);
135 return FAILURE;
136 }
137 valcp = *val;
138 zval_add_ref(&valcp);
139 convert_to_string_ex(val);
140 if (!php_set_inet46_addr(ss, ss_len, Z_STRVAL_P(valcp), sock TSRMLS_CC)) {
141 zval_ptr_dtor(&valcp);
142 return FAILURE;
143 }
144 zval_ptr_dtor(&valcp);
145 return SUCCESS;
146 }
147
php_do_mcast_opt(php_socket * php_sock,int level,int optname,zval ** arg4 TSRMLS_DC)148 static int php_do_mcast_opt(php_socket *php_sock, int level, int optname, zval **arg4 TSRMLS_DC)
149 {
150 HashTable *opt_ht;
151 unsigned int if_index;
152 int retval;
153 int (*mcast_req_fun)(php_socket *, int, struct sockaddr *, socklen_t,
154 unsigned TSRMLS_DC);
155 #ifdef HAS_MCAST_EXT
156 int (*mcast_sreq_fun)(php_socket *, int, struct sockaddr *, socklen_t,
157 struct sockaddr *, socklen_t, unsigned TSRMLS_DC);
158 #endif
159
160 switch (optname) {
161 case PHP_MCAST_JOIN_GROUP:
162 mcast_req_fun = &php_mcast_join;
163 goto mcast_req_fun;
164 case PHP_MCAST_LEAVE_GROUP:
165 {
166 php_sockaddr_storage group = {0};
167 socklen_t glen;
168
169 mcast_req_fun = &php_mcast_leave;
170 mcast_req_fun:
171 convert_to_array_ex(arg4);
172 opt_ht = HASH_OF(*arg4);
173
174 if (php_get_address_from_array(opt_ht, "group", php_sock, &group,
175 &glen TSRMLS_CC) == FAILURE) {
176 return FAILURE;
177 }
178 if (php_get_if_index_from_array(opt_ht, "interface", php_sock,
179 &if_index TSRMLS_CC) == FAILURE) {
180 return FAILURE;
181 }
182
183 retval = mcast_req_fun(php_sock, level, (struct sockaddr*)&group,
184 glen, if_index TSRMLS_CC);
185 break;
186 }
187
188 #ifdef HAS_MCAST_EXT
189 case PHP_MCAST_BLOCK_SOURCE:
190 mcast_sreq_fun = &php_mcast_block_source;
191 goto mcast_sreq_fun;
192 case PHP_MCAST_UNBLOCK_SOURCE:
193 mcast_sreq_fun = &php_mcast_unblock_source;
194 goto mcast_sreq_fun;
195 case PHP_MCAST_JOIN_SOURCE_GROUP:
196 mcast_sreq_fun = &php_mcast_join_source;
197 goto mcast_sreq_fun;
198 case PHP_MCAST_LEAVE_SOURCE_GROUP:
199 {
200 php_sockaddr_storage group = {0},
201 source = {0};
202 socklen_t glen,
203 slen;
204
205 mcast_sreq_fun = &php_mcast_leave_source;
206 mcast_sreq_fun:
207 convert_to_array_ex(arg4);
208 opt_ht = HASH_OF(*arg4);
209
210 if (php_get_address_from_array(opt_ht, "group", php_sock, &group,
211 &glen TSRMLS_CC) == FAILURE) {
212 return FAILURE;
213 }
214 if (php_get_address_from_array(opt_ht, "source", php_sock, &source,
215 &slen TSRMLS_CC) == FAILURE) {
216 return FAILURE;
217 }
218 if (php_get_if_index_from_array(opt_ht, "interface", php_sock,
219 &if_index TSRMLS_CC) == FAILURE) {
220 return FAILURE;
221 }
222
223 retval = mcast_sreq_fun(php_sock, level, (struct sockaddr*)&group,
224 glen, (struct sockaddr*)&source, slen, if_index TSRMLS_CC);
225 break;
226 }
227 #endif
228 default:
229 php_error_docref(NULL TSRMLS_CC, E_WARNING,
230 "unexpected option in php_do_mcast_opt (level %d, option %d). "
231 "This is a bug.", level, optname);
232 return FAILURE;
233 }
234
235 if (retval != 0) {
236 if (retval != -2) { /* error, but message already emitted */
237 PHP_SOCKET_ERROR(php_sock, "unable to set socket option", errno);
238 }
239 return FAILURE;
240 }
241 return SUCCESS;
242 }
243
php_do_setsockopt_ip_mcast(php_socket * php_sock,int level,int optname,zval ** arg4 TSRMLS_DC)244 int php_do_setsockopt_ip_mcast(php_socket *php_sock,
245 int level,
246 int optname,
247 zval **arg4 TSRMLS_DC)
248 {
249 unsigned int if_index;
250 struct in_addr if_addr;
251 void *opt_ptr;
252 socklen_t optlen;
253 unsigned char ipv4_mcast_ttl_lback;
254 int retval;
255
256 switch (optname) {
257 case PHP_MCAST_JOIN_GROUP:
258 case PHP_MCAST_LEAVE_GROUP:
259 #ifdef HAS_MCAST_EXT
260 case PHP_MCAST_BLOCK_SOURCE:
261 case PHP_MCAST_UNBLOCK_SOURCE:
262 case PHP_MCAST_JOIN_SOURCE_GROUP:
263 case PHP_MCAST_LEAVE_SOURCE_GROUP:
264 #endif
265 if (php_do_mcast_opt(php_sock, level, optname, arg4 TSRMLS_CC) == FAILURE) {
266 return FAILURE;
267 } else {
268 return SUCCESS;
269 }
270
271 case IP_MULTICAST_IF:
272 if (php_get_if_index_from_zval(*arg4, &if_index TSRMLS_CC) == FAILURE) {
273 return FAILURE;
274 }
275
276 if (php_if_index_to_addr4(if_index, php_sock, &if_addr TSRMLS_CC) == FAILURE) {
277 return FAILURE;
278 }
279 opt_ptr = &if_addr;
280 optlen = sizeof(if_addr);
281 goto dosockopt;
282
283 case IP_MULTICAST_LOOP:
284 convert_to_boolean_ex(arg4);
285 goto ipv4_loop_ttl;
286
287 case IP_MULTICAST_TTL:
288 convert_to_long_ex(arg4);
289 if (Z_LVAL_PP(arg4) < 0L || Z_LVAL_PP(arg4) > 255L) {
290 php_error_docref(NULL TSRMLS_CC, E_WARNING,
291 "Expected a value between 0 and 255");
292 return FAILURE;
293 }
294 ipv4_loop_ttl:
295 ipv4_mcast_ttl_lback = (unsigned char) Z_LVAL_PP(arg4);
296 opt_ptr = &ipv4_mcast_ttl_lback;
297 optlen = sizeof(ipv4_mcast_ttl_lback);
298 goto dosockopt;
299 }
300
301 return 1;
302
303 dosockopt:
304 retval = setsockopt(php_sock->bsd_socket, level, optname, opt_ptr, optlen);
305 if (retval != 0) {
306 PHP_SOCKET_ERROR(php_sock, "unable to set socket option", errno);
307 return FAILURE;
308 }
309
310 return SUCCESS;
311 }
312
php_do_setsockopt_ipv6_mcast(php_socket * php_sock,int level,int optname,zval ** arg4 TSRMLS_DC)313 int php_do_setsockopt_ipv6_mcast(php_socket *php_sock,
314 int level,
315 int optname,
316 zval **arg4 TSRMLS_DC)
317 {
318 unsigned int if_index;
319 void *opt_ptr;
320 socklen_t optlen;
321 int ov;
322 int retval;
323
324 switch (optname) {
325 case PHP_MCAST_JOIN_GROUP:
326 case PHP_MCAST_LEAVE_GROUP:
327 #ifdef HAS_MCAST_EXT
328 case PHP_MCAST_BLOCK_SOURCE:
329 case PHP_MCAST_UNBLOCK_SOURCE:
330 case PHP_MCAST_JOIN_SOURCE_GROUP:
331 case PHP_MCAST_LEAVE_SOURCE_GROUP:
332 #endif
333 if (php_do_mcast_opt(php_sock, level, optname, arg4 TSRMLS_CC) == FAILURE) {
334 return FAILURE;
335 } else {
336 return SUCCESS;
337 }
338
339 case IPV6_MULTICAST_IF:
340 if (php_get_if_index_from_zval(*arg4, &if_index TSRMLS_CC) == FAILURE) {
341 return FAILURE;
342 }
343
344 opt_ptr = &if_index;
345 optlen = sizeof(if_index);
346 goto dosockopt;
347
348 case IPV6_MULTICAST_LOOP:
349 convert_to_boolean_ex(arg4);
350 goto ipv6_loop_hops;
351 case IPV6_MULTICAST_HOPS:
352 convert_to_long_ex(arg4);
353 if (Z_LVAL_PP(arg4) < -1L || Z_LVAL_PP(arg4) > 255L) {
354 php_error_docref(NULL TSRMLS_CC, E_WARNING,
355 "Expected a value between -1 and 255");
356 return FAILURE;
357 }
358 ipv6_loop_hops:
359 ov = (int) Z_LVAL_PP(arg4);
360 opt_ptr = &ov;
361 optlen = sizeof(ov);
362 goto dosockopt;
363 }
364
365 return 1; /* not handled */
366
367 dosockopt:
368 retval = setsockopt(php_sock->bsd_socket, level, optname, opt_ptr, optlen);
369 if (retval != 0) {
370 PHP_SOCKET_ERROR(php_sock, "unable to set socket option", errno);
371 return FAILURE;
372 }
373
374 return SUCCESS;
375 }
376
php_mcast_join(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,unsigned int if_index TSRMLS_DC)377 int php_mcast_join(
378 php_socket *sock,
379 int level,
380 struct sockaddr *group,
381 socklen_t group_len,
382 unsigned int if_index TSRMLS_DC)
383 {
384 return _php_mcast_join_leave(sock, level, group, group_len, if_index, 1 TSRMLS_CC);
385 }
386
php_mcast_leave(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,unsigned int if_index TSRMLS_DC)387 int php_mcast_leave(
388 php_socket *sock,
389 int level,
390 struct sockaddr *group,
391 socklen_t group_len,
392 unsigned int if_index TSRMLS_DC)
393 {
394 return _php_mcast_join_leave(sock, level, group, group_len, if_index, 0 TSRMLS_CC);
395 }
396
397 #ifdef HAS_MCAST_EXT
php_mcast_join_source(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,struct sockaddr * source,socklen_t source_len,unsigned int if_index TSRMLS_DC)398 int php_mcast_join_source(
399 php_socket *sock,
400 int level,
401 struct sockaddr *group,
402 socklen_t group_len,
403 struct sockaddr *source,
404 socklen_t source_len,
405 unsigned int if_index TSRMLS_DC)
406 {
407 return _php_mcast_source_op(sock, level, group, group_len, source, source_len, if_index, JOIN_SOURCE TSRMLS_CC);
408 }
409
php_mcast_leave_source(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,struct sockaddr * source,socklen_t source_len,unsigned int if_index TSRMLS_DC)410 int php_mcast_leave_source(
411 php_socket *sock,
412 int level,
413 struct sockaddr *group,
414 socklen_t group_len,
415 struct sockaddr *source,
416 socklen_t source_len,
417 unsigned int if_index TSRMLS_DC)
418 {
419 return _php_mcast_source_op(sock, level, group, group_len, source, source_len, if_index, LEAVE_SOURCE TSRMLS_CC);
420 }
421
php_mcast_block_source(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,struct sockaddr * source,socklen_t source_len,unsigned int if_index TSRMLS_DC)422 int php_mcast_block_source(
423 php_socket *sock,
424 int level,
425 struct sockaddr *group,
426 socklen_t group_len,
427 struct sockaddr *source,
428 socklen_t source_len,
429 unsigned int if_index TSRMLS_DC)
430 {
431 return _php_mcast_source_op(sock, level, group, group_len, source, source_len, if_index, BLOCK_SOURCE TSRMLS_CC);
432 }
433
php_mcast_unblock_source(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,struct sockaddr * source,socklen_t source_len,unsigned int if_index TSRMLS_DC)434 int php_mcast_unblock_source(
435 php_socket *sock,
436 int level,
437 struct sockaddr *group,
438 socklen_t group_len,
439 struct sockaddr *source,
440 socklen_t source_len,
441 unsigned int if_index TSRMLS_DC)
442 {
443 return _php_mcast_source_op(sock, level, group, group_len, source, source_len, if_index, UNBLOCK_SOURCE TSRMLS_CC);
444 }
445 #endif /* HAS_MCAST_EXT */
446
447
_php_mcast_join_leave(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,unsigned int if_index,int join TSRMLS_DC)448 static int _php_mcast_join_leave(
449 php_socket *sock,
450 int level,
451 struct sockaddr *group, /* struct sockaddr_in/sockaddr_in6 */
452 socklen_t group_len,
453 unsigned int if_index,
454 int join TSRMLS_DC)
455 {
456 #ifdef RFC3678_API
457 struct group_req greq = {0};
458
459 memcpy(&greq.gr_group, group, group_len);
460 assert(greq.gr_group.ss_family != 0); /* the caller has set this */
461 greq.gr_interface = if_index;
462
463 return setsockopt(sock->bsd_socket, level,
464 join ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP, (char*)&greq,
465 sizeof(greq));
466 #else
467 if (sock->type == AF_INET) {
468 struct ip_mreq mreq = {0};
469 struct in_addr addr;
470
471 assert(group_len == sizeof(struct sockaddr_in));
472
473 if (if_index != 0) {
474 if (php_if_index_to_addr4(if_index, sock, &addr TSRMLS_CC) ==
475 FAILURE)
476 return -2; /* failure, but notice already emitted */
477 mreq.imr_interface = addr;
478 } else {
479 mreq.imr_interface.s_addr = htonl(INADDR_ANY);
480 }
481 mreq.imr_multiaddr = ((struct sockaddr_in*)group)->sin_addr;
482 return setsockopt(sock->bsd_socket, level,
483 join ? IP_ADD_MEMBERSHIP : IP_DROP_MEMBERSHIP, (char*)&mreq,
484 sizeof(mreq));
485 }
486 #if HAVE_IPV6
487 else if (sock->type == AF_INET6) {
488 struct ipv6_mreq mreq = {0};
489
490 assert(group_len == sizeof(struct sockaddr_in6));
491
492 mreq.ipv6mr_multiaddr = ((struct sockaddr_in6*)group)->sin6_addr;
493 mreq.ipv6mr_interface = if_index;
494
495 return setsockopt(sock->bsd_socket, level,
496 join ? IPV6_JOIN_GROUP : IPV6_LEAVE_GROUP, (char*)&mreq,
497 sizeof(mreq));
498 }
499 #endif
500 else {
501 php_error_docref(NULL TSRMLS_CC, E_WARNING,
502 "Option %s is inapplicable to this socket type",
503 join ? "MCAST_JOIN_GROUP" : "MCAST_LEAVE_GROUP");
504 return -2;
505 }
506 #endif
507 }
508
509 #ifdef HAS_MCAST_EXT
_php_mcast_source_op(php_socket * sock,int level,struct sockaddr * group,socklen_t group_len,struct sockaddr * source,socklen_t source_len,unsigned int if_index,enum source_op sop TSRMLS_DC)510 static int _php_mcast_source_op(
511 php_socket *sock,
512 int level,
513 struct sockaddr *group,
514 socklen_t group_len,
515 struct sockaddr *source,
516 socklen_t source_len,
517 unsigned int if_index,
518 enum source_op sop TSRMLS_DC)
519 {
520 #ifdef RFC3678_API
521 struct group_source_req gsreq = {0};
522
523 memcpy(&gsreq.gsr_group, group, group_len);
524 assert(gsreq.gsr_group.ss_family != 0);
525 memcpy(&gsreq.gsr_source, source, source_len);
526 assert(gsreq.gsr_source.ss_family != 0);
527 gsreq.gsr_interface = if_index;
528
529 return setsockopt(sock->bsd_socket, level,
530 _php_source_op_to_rfc3678_op(sop), (char*)&gsreq, sizeof(gsreq));
531 #else
532 if (sock->type == AF_INET) {
533 struct ip_mreq_source mreqs = {0};
534 struct in_addr addr;
535
536 mreqs.imr_multiaddr = ((struct sockaddr_in*)group)->sin_addr;
537 mreqs.imr_sourceaddr = ((struct sockaddr_in*)source)->sin_addr;
538
539 assert(group_len == sizeof(struct sockaddr_in));
540 assert(source_len == sizeof(struct sockaddr_in));
541
542 if (if_index != 0) {
543 if (php_if_index_to_addr4(if_index, sock, &addr TSRMLS_CC) ==
544 FAILURE)
545 return -2; /* failure, but notice already emitted */
546 mreqs.imr_interface = addr;
547 } else {
548 mreqs.imr_interface.s_addr = htonl(INADDR_ANY);
549 }
550
551 return setsockopt(sock->bsd_socket, level,
552 _php_source_op_to_ipv4_op(sop), (char*)&mreqs, sizeof(mreqs));
553 }
554 #if HAVE_IPV6
555 else if (sock->type == AF_INET6) {
556 php_error_docref(NULL TSRMLS_CC, E_WARNING,
557 "This platform does not support %s for IPv6 sockets",
558 _php_source_op_to_string(sop));
559 return -2;
560 }
561 #endif
562 else {
563 php_error_docref(NULL TSRMLS_CC, E_WARNING,
564 "Option %s is inapplicable to this socket type",
565 _php_source_op_to_string(sop));
566 return -2;
567 }
568 #endif
569 }
570
571 #if RFC3678_API
_php_source_op_to_rfc3678_op(enum source_op sop)572 static int _php_source_op_to_rfc3678_op(enum source_op sop)
573 {
574 switch (sop) {
575 case JOIN_SOURCE:
576 return MCAST_JOIN_SOURCE_GROUP;
577 case LEAVE_SOURCE:
578 return MCAST_LEAVE_SOURCE_GROUP;
579 case BLOCK_SOURCE:
580 return MCAST_BLOCK_SOURCE;
581 case UNBLOCK_SOURCE:
582 return MCAST_UNBLOCK_SOURCE;
583 }
584
585 assert(0);
586 return 0;
587 }
588 #else
_php_source_op_to_string(enum source_op sop)589 static const char *_php_source_op_to_string(enum source_op sop)
590 {
591 switch (sop) {
592 case JOIN_SOURCE:
593 return "MCAST_JOIN_SOURCE_GROUP";
594 case LEAVE_SOURCE:
595 return "MCAST_LEAVE_SOURCE_GROUP";
596 case BLOCK_SOURCE:
597 return "MCAST_BLOCK_SOURCE";
598 case UNBLOCK_SOURCE:
599 return "MCAST_UNBLOCK_SOURCE";
600 }
601
602 assert(0);
603 return "";
604 }
605
_php_source_op_to_ipv4_op(enum source_op sop)606 static int _php_source_op_to_ipv4_op(enum source_op sop)
607 {
608 switch (sop) {
609 case JOIN_SOURCE:
610 return IP_ADD_SOURCE_MEMBERSHIP;
611 case LEAVE_SOURCE:
612 return IP_DROP_SOURCE_MEMBERSHIP;
613 case BLOCK_SOURCE:
614 return IP_BLOCK_SOURCE;
615 case UNBLOCK_SOURCE:
616 return IP_UNBLOCK_SOURCE;
617 }
618
619 assert(0);
620 return 0;
621 }
622 #endif
623
624 #endif /* HAS_MCAST_EXT */
625
626 #if PHP_WIN32
php_if_index_to_addr4(unsigned if_index,php_socket * php_sock,struct in_addr * out_addr TSRMLS_DC)627 int php_if_index_to_addr4(unsigned if_index, php_socket *php_sock, struct in_addr *out_addr TSRMLS_DC)
628 {
629 MIB_IPADDRTABLE *addr_table;
630 ULONG size;
631 DWORD retval;
632 DWORD i;
633
634 (void) php_sock; /* not necessary */
635
636 if (if_index == 0) {
637 out_addr->s_addr = INADDR_ANY;
638 return SUCCESS;
639 }
640
641 size = 4 * (sizeof *addr_table);
642 addr_table = emalloc(size);
643 retry:
644 retval = GetIpAddrTable(addr_table, &size, 0);
645 if (retval == ERROR_INSUFFICIENT_BUFFER) {
646 efree(addr_table);
647 addr_table = emalloc(size);
648 goto retry;
649 }
650 if (retval != NO_ERROR) {
651 php_error_docref(NULL TSRMLS_CC, E_WARNING,
652 "GetIpAddrTable failed with error %lu", retval);
653 return FAILURE;
654 }
655 for (i = 0; i < addr_table->dwNumEntries; i++) {
656 MIB_IPADDRROW r = addr_table->table[i];
657 if (r.dwIndex == if_index) {
658 out_addr->s_addr = r.dwAddr;
659 return SUCCESS;
660 }
661 }
662 php_error_docref(NULL TSRMLS_CC, E_WARNING,
663 "No interface with index %u was found", if_index);
664 return FAILURE;
665 }
666
php_add4_to_if_index(struct in_addr * addr,php_socket * php_sock,unsigned * if_index TSRMLS_DC)667 int php_add4_to_if_index(struct in_addr *addr, php_socket *php_sock, unsigned *if_index TSRMLS_DC)
668 {
669 MIB_IPADDRTABLE *addr_table;
670 ULONG size;
671 DWORD retval;
672 DWORD i;
673
674 (void) php_sock; /* not necessary */
675
676 if (addr->s_addr == INADDR_ANY) {
677 *if_index = 0;
678 return SUCCESS;
679 }
680
681 size = 4 * (sizeof *addr_table);
682 addr_table = emalloc(size);
683 retry:
684 retval = GetIpAddrTable(addr_table, &size, 0);
685 if (retval == ERROR_INSUFFICIENT_BUFFER) {
686 efree(addr_table);
687 addr_table = emalloc(size);
688 goto retry;
689 }
690 if (retval != NO_ERROR) {
691 php_error_docref(NULL TSRMLS_CC, E_WARNING,
692 "GetIpAddrTable failed with error %lu", retval);
693 return FAILURE;
694 }
695 for (i = 0; i < addr_table->dwNumEntries; i++) {
696 MIB_IPADDRROW r = addr_table->table[i];
697 if (r.dwAddr == addr->s_addr) {
698 *if_index = r.dwIndex;
699 return SUCCESS;
700 }
701 }
702
703 {
704 char addr_str[17] = {0};
705 inet_ntop(AF_INET, addr, addr_str, sizeof(addr_str));
706 php_error_docref(NULL TSRMLS_CC, E_WARNING,
707 "The interface with IP address %s was not found", addr_str);
708 }
709 return FAILURE;
710 }
711
712 #else
713
php_if_index_to_addr4(unsigned if_index,php_socket * php_sock,struct in_addr * out_addr TSRMLS_DC)714 int php_if_index_to_addr4(unsigned if_index, php_socket *php_sock, struct in_addr *out_addr TSRMLS_DC)
715 {
716 struct ifreq if_req;
717
718 if (if_index == 0) {
719 out_addr->s_addr = INADDR_ANY;
720 return SUCCESS;
721 }
722
723 #if !defined(ifr_ifindex) && defined(ifr_index)
724 #define ifr_ifindex ifr_index
725 #endif
726
727 #if defined(SIOCGIFNAME)
728 if_req.ifr_ifindex = if_index;
729 if (ioctl(php_sock->bsd_socket, SIOCGIFNAME, &if_req) == -1) {
730 #elif defined(HAVE_IF_INDEXTONAME)
731 if (if_indextoname(if_index, if_req.ifr_name) == NULL) {
732 #else
733 #error Neither SIOCGIFNAME nor if_indextoname are available
734 #endif
735 php_error_docref(NULL TSRMLS_CC, E_WARNING,
736 "Failed obtaining address for interface %u: error %d", if_index, errno);
737 return FAILURE;
738 }
739
740 if (ioctl(php_sock->bsd_socket, SIOCGIFADDR, &if_req) == -1) {
741 php_error_docref(NULL TSRMLS_CC, E_WARNING,
742 "Failed obtaining address for interface %u: error %d", if_index, errno);
743 return FAILURE;
744 }
745
746 memcpy(out_addr, &((struct sockaddr_in *) &if_req.ifr_addr)->sin_addr,
747 sizeof *out_addr);
748 return SUCCESS;
749 }
750
751 int php_add4_to_if_index(struct in_addr *addr, php_socket *php_sock, unsigned *if_index TSRMLS_DC)
752 {
753 struct ifconf if_conf = {0};
754 char *buf = NULL,
755 *p;
756 int size = 0,
757 lastsize = 0;
758 size_t entry_len;
759
760 if (addr->s_addr == INADDR_ANY) {
761 *if_index = 0;
762 return SUCCESS;
763 }
764
765 for(;;) {
766 size += 5 * sizeof(struct ifreq);
767 buf = ecalloc(size, 1);
768 if_conf.ifc_len = size;
769 if_conf.ifc_buf = buf;
770
771 if (ioctl(php_sock->bsd_socket, SIOCGIFCONF, (char*)&if_conf) == -1 &&
772 (errno != EINVAL || lastsize != 0)) {
773 php_error_docref(NULL TSRMLS_CC, E_WARNING,
774 "Failed obtaining interfaces list: error %d", errno);
775 goto err;
776 }
777
778 if (if_conf.ifc_len == lastsize)
779 /* not increasing anymore */
780 break;
781 else {
782 lastsize = if_conf.ifc_len;
783 efree(buf);
784 buf = NULL;
785 }
786 }
787
788 for (p = if_conf.ifc_buf;
789 p < if_conf.ifc_buf + if_conf.ifc_len;
790 p += entry_len) {
791 struct ifreq *cur_req;
792
793 /* let's hope the pointer is aligned */
794 cur_req = (struct ifreq*) p;
795
796 #ifdef HAVE_SOCKADDR_SA_LEN
797 entry_len = cur_req->ifr_addr.sa_len + sizeof(cur_req->ifr_name);
798 #else
799 /* if there's no sa_len, assume the ifr_addr field is a sockaddr */
800 entry_len = sizeof(struct sockaddr) + sizeof(cur_req->ifr_name);
801 #endif
802 entry_len = MAX(entry_len, sizeof(*cur_req));
803
804 if ((((struct sockaddr*)&cur_req->ifr_addr)->sa_family == AF_INET) &&
805 (((struct sockaddr_in*)&cur_req->ifr_addr)->sin_addr.s_addr ==
806 addr->s_addr)) {
807 #if defined(SIOCGIFINDEX)
808 if (ioctl(php_sock->bsd_socket, SIOCGIFINDEX, (char*)cur_req)
809 == -1) {
810 #elif defined(HAVE_IF_NAMETOINDEX)
811 unsigned index_tmp;
812 if ((index_tmp = if_nametoindex(cur_req->ifr_name)) == 0) {
813 #else
814 #error Neither SIOCGIFINDEX nor if_nametoindex are available
815 #endif
816 php_error_docref(NULL TSRMLS_CC, E_WARNING,
817 "Error converting interface name to index: error %d",
818 errno);
819 goto err;
820 } else {
821 #if defined(SIOCGIFINDEX)
822 *if_index = cur_req->ifr_ifindex;
823 #else
824 *if_index = index_tmp;
825 #endif
826 efree(buf);
827 return SUCCESS;
828 }
829 }
830 }
831
832 {
833 char addr_str[17] = {0};
834 inet_ntop(AF_INET, addr, addr_str, sizeof(addr_str));
835 php_error_docref(NULL TSRMLS_CC, E_WARNING,
836 "The interface with IP address %s was not found", addr_str);
837 }
838
839 err:
840 if (buf != NULL)
841 efree(buf);
842 return FAILURE;
843 }
844 #endif
845
