Annotation of embedaddon/php/ext/sockets/tests/mcast_ipv4_recv.phpt, revision 1.1.1.1
1.1 misho 1: --TEST--
2: Multicast support: IPv4 receive options
3: --SKIPIF--
4: <?php
5: if (!extension_loaded('sockets')) {
6: die('skip sockets extension not available.');
7: }
8: $s = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
9: $br = socket_bind($s, '0.0.0.0', 3000);
10: $so = socket_set_option($s, IPPROTO_IP, MCAST_JOIN_GROUP, array(
11: "group" => '224.0.0.23',
12: "interface" => 'lo',
13: ));
14: if ($so === false) {
15: die('skip interface \'lo\' is unavailable.');
16: }
17: if (!defined("MCAST_BLOCK_SOURCE")) {
18: die('skip source operations are unavailable');
19: }
20: --FILE--
21: <?php
22: include __DIR__."/mcast_helpers.php.inc";
23: $domain = AF_INET;
24: $level = IPPROTO_IP;
25: $interface = "lo";
26: $mcastaddr = '224.0.0.23';
27: $sblock = "127.0.0.1";
28:
29: echo "creating send socket bound to 127.0.0.1\n";
30: $sends1 = socket_create($domain, SOCK_DGRAM, SOL_UDP);
31: $br = socket_bind($sends1, '127.0.0.1');
32: var_dump($br);
33:
34: echo "creating unbound socket and hoping the routing table causes an interface other than lo to be used for sending messages to $mcastaddr\n";
35: $sends2 = socket_create($domain, SOCK_DGRAM, SOL_UDP);
36: var_dump($br);
37:
38: echo "creating receive socket\n";
39: $s = socket_create($domain, SOCK_DGRAM, SOL_UDP);
40: var_dump($s);
41: $br = socket_bind($s, '0.0.0.0', 3000);
42: var_dump($br);
43:
44: $so = socket_set_option($s, $level, MCAST_JOIN_GROUP, array(
45: "group" => $mcastaddr,
46: "interface" => $interface,
47: ));
48: var_dump($so);
49:
50: $r = socket_sendto($sends1, $m = "initial packet", strlen($m), 0, $mcastaddr, 3000);
51: var_dump($r);
52:
53: $i = 0;
54: checktimeout($s, 500);
55: while (($str = socket_read($s, 3000)) !== FALSE) {
56: $i++;
57: echo "$i> ", $str, "\n";
58:
59: if ($i == 1) {
60: echo "leaving group\n";
61: $so = socket_set_option($s, $level, MCAST_LEAVE_GROUP, array(
62: "group" => $mcastaddr,
63: "interface" => $interface,
64: ));
65: var_dump($so);
66: $r = socket_sendto($sends1, $m = "ignored mcast packet", strlen($m), 0, $mcastaddr, 3000);
67: var_dump($r);
68: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "127.0.0.1", 3000);
69: var_dump($r);
70: }
71: if ($i == 2) {
72: echo "re-joining group\n";
73: $so = socket_set_option($s, $level, MCAST_JOIN_GROUP, array(
74: "group" => $mcastaddr,
75: "interface" => $interface,
76: ));
77: var_dump($so);
78: $r = socket_sendto($sends2, $m = "ignored mcast packet (different interface)", strlen($m), 0, $mcastaddr, 3000);
79: var_dump($r);
80: $r = socket_sendto($sends1, $m = "mcast packet", strlen($m), 0, $mcastaddr, 3000);
81: var_dump($r);
82: }
83: if ($i == 3) {
84: echo "blocking source\n";
85: $so = socket_set_option($s, $level, MCAST_BLOCK_SOURCE, array(
86: "group" => $mcastaddr,
87: "interface" => $interface,
88: "source" => $sblock,
89: ));
90: var_dump($so);
91: $r = socket_sendto($sends1, $m = "ignored packet (blocked source)", strlen($m), 0, $mcastaddr, 3000);
92: var_dump($r);
93: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "127.0.0.1", 3000);
94: var_dump($r);
95: }
96: if ($i == 4) {
97: echo "unblocking source\n";
98: $so = socket_set_option($s, $level, MCAST_UNBLOCK_SOURCE, array(
99: "group" => $mcastaddr,
100: "interface" => $interface,
101: "source" => $sblock,
102: ));
103: var_dump($so);
104: $r = socket_sendto($sends1, $m = "mcast packet from 127.0.0.1", strlen($m), 0, $mcastaddr, 3000);
105: var_dump($r);
106: }
107: if ($i == 5) {
108: echo "leaving group\n";
109: $so = socket_set_option($s, $level, MCAST_LEAVE_GROUP, array(
110: "group" => $mcastaddr,
111: "interface" => $interface,
112: ));
113: var_dump($so);
114: $r = socket_sendto($sends1, $m = "ignored mcast packet", strlen($m), 0, $mcastaddr, 3000);
115: var_dump($r);
116: $r = socket_sendto($sends1, $m = "unicast packet", strlen($m), 0, "127.0.0.1", 3000);
117: var_dump($r);
118: }
119: if ($i == 6) {
120: echo "joining source group\n";
121: $so = socket_set_option($s, $level, MCAST_JOIN_SOURCE_GROUP, array(
122: "group" => $mcastaddr,
123: "interface" => $interface,
124: "source" => $sblock,
125: ));
126: var_dump($so);
127: $r = socket_sendto($sends1, $m = "mcast packet from 127.0.0.1", strlen($m), 0, $mcastaddr, 3000);
128: var_dump($r);
129: }
130: if ($i == 7) {
131: echo "leaving source group\n";
132: $so = socket_set_option($s, $level, MCAST_LEAVE_SOURCE_GROUP, array(
133: "group" => $mcastaddr,
134: "interface" => $interface,
135: "source" => $sblock,
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, "127.0.0.1", 3000);
141: var_dump($r);
142: }
143: if ($i == 8) {
144: /* echo "rjsg\n";
145: $so = socket_set_option($s, $level, MCAST_JOIN_GROUP, array(
146: "group" => $mcastaddr,
147: "interface" => $interface,
148: ));
149: var_dump($so);*/
150: break;
151: }
152:
153: }
154: --EXPECTF--
155: creating send socket bound to 127.0.0.1
156: bool(true)
157: creating unbound socket and hoping the routing table causes an interface other than lo to be used for sending messages to 224.0.0.23
158: bool(true)
159: creating receive socket
160: resource(%d) of type (Socket)
161: bool(true)
162: bool(true)
163: int(14)
164: 1> initial packet
165: leaving group
166: bool(true)
167: int(20)
168: int(14)
169: 2> unicast packet
170: re-joining group
171: bool(true)
172: int(42)
173: int(12)
174: 3> mcast packet
175: blocking source
176: bool(true)
177: int(31)
178: int(14)
179: 4> unicast packet
180: unblocking source
181: bool(true)
182: int(27)
183: 5> mcast packet from 127.0.0.1
184: leaving group
185: bool(true)
186: int(20)
187: int(14)
188: 6> unicast packet
189: joining source group
190: bool(true)
191: int(27)
192: 7> mcast packet from 127.0.0.1
193: leaving source group
194: bool(true)
195: int(20)
196: int(14)
197: 8> unicast packet
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mcast_ipv4_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