Annotation of embedaddon/php/ext/sockets/tests/mcast_ipv6_recv.phpt, revision 1.1
1.1 ! misho 1: --TEST--
! 2: Multicast support: IPv6 receive options
! 3: --SKIPIF--
! 4: <?php
! 5: if (!extension_loaded('sockets')) {
! 6: die('skip sockets extension not available.');
! 7: }
! 8: if (!defined('IPPROTO_IPV6')) {
! 9: die('skip IPv6 not available.');
! 10: }
! 11: $s = socket_create(AF_INET6, SOCK_DGRAM, SOL_UDP);
! 12: $br = socket_bind($s, '::', 3000);
! 13: /* On Linux, there is no route ff00::/8 by default on lo, which makes it
! 14: * troublesome to send multicast traffic from lo, which we must since
! 15: * we're dealing with interface-local traffic... */
! 16: $so = socket_set_option($s, IPPROTO_IPV6, MCAST_JOIN_GROUP, array(
! 17: "group" => 'ff01::114',
! 18: "interface" => 0,
! 19: ));
! 20: if ($so === false) {
! 21: die('skip unable to join multicast group on any interface.');
! 22: }
! 23: $r = socket_sendto($s, $m = "testing packet", strlen($m), 0, 'ff01::114', 3000);
! 24: if ($r === false) {
! 25: die('skip unable to send multicast packet.');
! 26: }
! 27:
! 28: if (!defined("MCAST_JOIN_SOURCE_GROUP"))
! 29: die('skip source operations are unavailable');
! 30:
! 31: $so = socket_set_option($s, IPPROTO_IPV6, MCAST_LEAVE_GROUP, array(
! 32: "group" => 'ff01::114',
! 33: "interface" => 0,
! 34: ));
! 35: $so = socket_set_option($s, IPPROTO_IPV6, MCAST_JOIN_SOURCE_GROUP, array(
! 36: "group" => 'ff01::114',
! 37: "interface" => 0,
! 38: "source" => '2001::dead:beef',
! 39: ));
! 40: if ($so === false) {
! 41: die('skip protocol independent multicast API is unavailable.');
! 42: }
! 43:
! 44: --FILE--
! 45: <?php
! 46: include __DIR__."/mcast_helpers.php.inc";
! 47: $domain = AF_INET6;
! 48: $level = IPPROTO_IPV6;
! 49: $interface = 0;
! 50: $mcastaddr = 'ff01::114';
! 51: $sblock = "?";
! 52:
! 53: echo "creating send socket\n";
! 54: $sends1 = socket_create($domain, SOCK_DGRAM, SOL_UDP) or die("err");
! 55: var_dump($sends1);
! 56:
! 57: echo "creating receive socket\n";
! 58: $s = socket_create($domain, SOCK_DGRAM, SOL_UDP) or die("err");
! 59: var_dump($s);
! 60: $br = socket_bind($s, '::0', 3000) or die("err");
! 61: var_dump($br);
! 62:
! 63: $so = socket_set_option($s, $level, MCAST_JOIN_GROUP, array(
! 64: "group" => $mcastaddr,
! 65: "interface" => $interface,
! 66: )) or die("err");
! 67: var_dump($so);
! 68:
! 69: $r = socket_sendto($sends1, $m = "testing packet", strlen($m), 0, $mcastaddr, 3000);
! 70: var_dump($r);
! 71: checktimeout($s, 500);
! 72: $r = socket_recvfrom($s, $str, 2000, 0, $from, $fromPort);
! 73: var_dump($r, $str, $from);
! 74: $sblock = $from;
! 75:
! 76: $r = socket_sendto($sends1, $m = "initial packet", strlen($m), 0, $mcastaddr, 3000);
! 77: var_dump($r);
! 78:
! 79: $i = 0;
! 80: checktimeout($s, 500);
! 81: while (($str = socket_read($s, 3000)) !== FALSE) {
! 82: $i++;
! 83: echo "$i> ", $str, "\n";
! 84:
! 85: if ($i == 1) {
! 86: echo "leaving group\n";
! 87: $so = socket_set_option($s, $level, MCAST_LEAVE_GROUP, array(
! 88: "group" => $mcastaddr,
! 89: "interface" => $interface,
! 90: ));
! 91: var_dump($so);
! 92: $r = socket_sendto($sends1, $m = "ignored mcast packet", strlen($m), 0, $mcastaddr, 3000);
! 93: var_dump($r);
! 94: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "::1", 3000);
! 95: var_dump($r);
! 96: }
! 97: if ($i == 2) {
! 98: echo "re-joining group\n";
! 99: $so = socket_set_option($s, $level, MCAST_JOIN_GROUP, array(
! 100: "group" => $mcastaddr,
! 101: "interface" => $interface,
! 102: ));
! 103: var_dump($so);
! 104: $r = socket_sendto($sends1, $m = "mcast packet", strlen($m), 0, $mcastaddr, 3000);
! 105: var_dump($r);
! 106: }
! 107: if ($i == 3) {
! 108: echo "blocking source\n";
! 109: $so = socket_set_option($s, $level, MCAST_BLOCK_SOURCE, array(
! 110: "group" => $mcastaddr,
! 111: "interface" => $interface,
! 112: "source" => $sblock,
! 113: ));
! 114: var_dump($so);
! 115: $r = socket_sendto($sends1, $m = "ignored packet (blocked source)", strlen($m), 0, $mcastaddr, 3000);
! 116: var_dump($r);
! 117: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "::1", 3000);
! 118: var_dump($r);
! 119: }
! 120: if ($i == 4) {
! 121: echo "unblocking source\n";
! 122: $so = socket_set_option($s, $level, MCAST_UNBLOCK_SOURCE, array(
! 123: "group" => $mcastaddr,
! 124: "interface" => $interface,
! 125: "source" => $sblock,
! 126: ));
! 127: var_dump($so);
! 128: $r = socket_sendto($sends1, $m = "mcast packet", strlen($m), 0, $mcastaddr, 3000);
! 129: var_dump($r);
! 130: }
! 131: if ($i == 5) {
! 132: echo "leaving group\n";
! 133: $so = socket_set_option($s, $level, MCAST_LEAVE_GROUP, array(
! 134: "group" => $mcastaddr,
! 135: "interface" => $interface,
! 136: ));
! 137: var_dump($so);
! 138: $r = socket_sendto($sends1, $m = "ignored mcast packet", strlen($m), 0, $mcastaddr, 3000);
! 139: var_dump($r);
! 140: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "::1", 3000);
! 141: var_dump($r);
! 142: }
! 143: if ($i == 6) {
! 144: echo "joining source group\n";
! 145: $so = socket_set_option($s, $level, MCAST_JOIN_SOURCE_GROUP, array(
! 146: "group" => $mcastaddr,
! 147: "interface" => $interface,
! 148: "source" => $sblock,
! 149: ));
! 150: var_dump($so);
! 151: $r = socket_sendto($sends1, $m = "mcast packet from desired source", strlen($m), 0, $mcastaddr, 3000);
! 152: var_dump($r);
! 153: }
! 154: if ($i == 7) {
! 155: echo "leaving source group\n";
! 156: $so = socket_set_option($s, $level, MCAST_LEAVE_SOURCE_GROUP, array(
! 157: "group" => $mcastaddr,
! 158: "interface" => $interface,
! 159: "source" => $sblock,
! 160: ));
! 161: var_dump($so);
! 162: $r = socket_sendto($sends1, $m = "ignored mcast packet", strlen($m), 0, $mcastaddr, 3000);
! 163: var_dump($r);
! 164: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "::1", 3000);
! 165: var_dump($r);
! 166: }
! 167: if ($i == 8) {
! 168: /*echo "joining source group\n";
! 169: $so = socket_set_option($s, $level, MCAST_JOIN_SOURCE_GROUP, array(
! 170: "group" => $mcastaddr,
! 171: "interface" => $interface,
! 172: "source" => $sblock,
! 173: ));
! 174: var_dump($so);*/
! 175: break;
! 176: }
! 177:
! 178: }
! 179: --EXPECTF--
! 180: creating send socket
! 181: resource(%d) of type (Socket)
! 182: creating receive socket
! 183: resource(%d) of type (Socket)
! 184: bool(true)
! 185: bool(true)
! 186: int(14)
! 187: int(14)
! 188: string(14) "testing packet"
! 189: string(%d) "%s"
! 190: int(14)
! 191: 1> initial packet
! 192: leaving group
! 193: bool(true)
! 194: int(20)
! 195: int(14)
! 196: 2> unicast packet
! 197: re-joining group
! 198: bool(true)
! 199: int(12)
! 200: 3> mcast packet
! 201: blocking source
! 202: bool(true)
! 203: int(31)
! 204: int(14)
! 205: 4> unicast packet
! 206: unblocking source
! 207: bool(true)
! 208: int(12)
! 209: 5> mcast packet
! 210: leaving group
! 211: bool(true)
! 212: int(20)
! 213: int(14)
! 214: 6> unicast packet
! 215: joining source group
! 216: bool(true)
! 217: int(32)
! 218: 7> mcast packet from desired source
! 219: leaving source group
! 220: bool(true)
! 221: int(20)
! 222: int(14)
! 223: 8> unicast packet
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mcast_ipv6_recv.phpt CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / sockets / tests