|
0
|
1 <?php |
|
|
2 /* Copyright 2010 Ivo Smits <Ivo@UCIS.nl>. All rights reserved. |
|
|
3 Redistribution and use in source and binary forms, with or without modification, are |
|
|
4 permitted provided that the following conditions are met: |
|
|
5 |
|
|
6 1. Redistributions of source code must retain the above copyright notice, this list of |
|
|
7 conditions and the following disclaimer. |
|
|
8 |
|
|
9 2. Redistributions in binary form must reproduce the above copyright notice, this list |
|
|
10 of conditions and the following disclaimer in the documentation and/or other materials |
|
|
11 provided with the distribution. |
|
|
12 |
|
|
13 THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED |
|
|
14 WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND |
|
|
15 FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR |
|
|
16 CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR |
|
|
17 CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR |
|
|
18 SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON |
|
|
19 ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING |
|
|
20 NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF |
|
|
21 ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
|
|
22 |
|
|
23 The views and conclusions contained in the software and documentation are those of the |
|
|
24 authors and should not be interpreted as representing official policies, either expressed |
|
|
25 or implied, of Ivo Smits.*/ |
|
|
26 |
|
|
27 if (defined('APP_LOADED')) return; |
|
|
28 define('APP_LOADED', TRUE); |
|
|
29 if (!defined('CONFIGFILE')) define('CONFIGFILE', './config.php'); |
|
|
30 |
|
|
31 print("UCIS UDPMSG3 Hub (c) 2010 Ivo Smits <Ivo@UCIS.nl>\n"); |
|
|
32 print("More information: http://wiki.ucis.nl/UDPMSG3\n"); |
|
|
33 print("\n"); |
|
|
34 |
|
|
35 class StreamPeer { |
|
|
36 public $socket = NULL; |
|
|
37 public $buffer = ''; |
|
|
38 public function select_read() { |
|
|
39 if ($this->udpmsg_read()) return; |
|
|
40 socket_delete($this); |
|
|
41 socket_close($this->socket); |
|
|
42 fprintf(STDERR, "UDPMSG: Error: closing connection.\n"); |
|
|
43 peer_delete($this); |
|
|
44 $this->closed(); |
|
|
45 } |
|
|
46 public function select_error() { |
|
|
47 socket_delete($this); |
|
|
48 socket_close($this->socket); |
|
|
49 fprintf(STDERR, "UDPMSG: Error: select error.\n"); |
|
|
50 peer_delete($this); |
|
|
51 $this->closed(); |
|
|
52 } |
|
|
53 private function udpmsg_read() { |
|
|
54 $msg = socket_read($this->socket, 1024); |
|
|
55 if (!strlen($msg)) { |
|
|
56 fprintf(STDERR, "UDPMSG: End of file\n"); |
|
|
57 return FALSE; |
|
|
58 } |
|
|
59 $udpmsg_buffer = &$this->buffer; |
|
|
60 $udpmsg_buffer .= $msg; |
|
|
61 while (strlen($udpmsg_buffer) > 2) { |
|
|
62 $len = ord($udpmsg_buffer[0]) * 256 + ord($udpmsg_buffer[1]); |
|
|
63 if ($len <= 0 || $len > 1024) { |
|
|
64 fprintf(STDERR, "UDPMSG: Error: protocol error\n"); |
|
|
65 return FALSE; |
|
|
66 } |
|
|
67 if (strlen($udpmsg_buffer) < 2 + $len) break; |
|
|
68 udpmsg_receive($this, substr($udpmsg_buffer, 2, $len)); |
|
|
69 $udpmsg_buffer = substr($udpmsg_buffer, 2 + $len); |
|
|
70 } |
|
|
71 return TRUE; |
|
|
72 } |
|
|
73 public function send($msg) { |
|
|
74 $len = strlen($msg); |
|
|
75 if ($len > 1024) { |
|
|
76 fprintf(STDERR, "UDPMSG: Error: message too long!\n"); |
|
|
77 return FALSE; |
|
|
78 } |
|
|
79 $lens = chr(floor($len / 256)).chr($len % 256); |
|
|
80 socket_write($this->socket, $lens.$msg); |
|
|
81 return TRUE; |
|
|
82 } |
|
|
83 } |
|
|
84 class StreamServer { |
|
|
85 public $host, $port, $bindhost, $bindport, $ipv6; |
|
|
86 public $socket = NULL; |
|
|
87 function __construct($host, $port, $ipv6 = FALSE) { |
|
|
88 $this->host = $host; $this->port = $port; $this->ipv6 = $ipv6; |
|
|
89 if (!$this->select_timeout()) socket_add_timeout($this); |
|
|
90 } |
|
|
91 public function select_timeout() { |
|
|
92 socket_delete($this); |
|
|
93 $this->socket = socket_create($this->ipv6 ? AF_INET6 : AF_INET, SOCK_STREAM, SOL_TCP); |
|
|
94 socket_set_nonblock($this->socket); |
|
2
|
95 socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, 1); |
|
0
|
96 if (!socket_bind($this->socket, $this->host, $this->port)) return FALSE; |
|
|
97 if (!socket_listen($this->socket)) return FALSE; |
|
|
98 socket_delete($this); |
|
|
99 socket_add_connected($this); |
|
|
100 return TRUE; |
|
|
101 } |
|
|
102 public function select_read() { |
|
|
103 $client = socket_accept($this->socket); |
|
|
104 if (!$client) return; |
|
|
105 if (!socket_getpeername($client, &$addr, &$port)) $addr = 'unknown'; |
|
|
106 fprintf(STDERR, 'UDPMSG: Accepted client '.$addr.':'.$port."\n"); |
|
|
107 new StreamServerClient($client); |
|
|
108 } |
|
|
109 public function select_error() { |
|
|
110 socket_close($this->socket); |
|
|
111 fprintf(STDERR, "UDPMSG: Error: select error on listener. Closing listener.\n"); |
|
|
112 socket_delete($this); |
|
|
113 socket_add_timeout($this); |
|
|
114 } |
|
|
115 } |
|
|
116 class StreamClient extends StreamPeer { |
|
|
117 public $host, $port, $bindhost, $bindport, $ipv6; |
|
|
118 function __construct($host, $port, $ipv6 = FALSE, $bindhost = NULL, $bindport = NULL) { |
|
|
119 $this->host = $host; $this->port = $port; $this->ipv6 = $ipv6; $this->bindhost = $bindhost; $this->bindport = $bindport; |
|
|
120 $this->select_timeout(); |
|
|
121 } |
|
|
122 public function closed() { |
|
|
123 socket_add_timeout($this); |
|
|
124 } |
|
|
125 public function select_timeout() { |
|
|
126 socket_delete($this); |
|
|
127 $this->socket = socket_create($this->ipv6 ? AF_INET6 : AF_INET, SOCK_STREAM, SOL_TCP); |
|
|
128 socket_set_nonblock($this->socket); |
|
|
129 if ($this->bindhost || $this->bindport) socket_bind($this->socket, $this->bindhost, $this->bindport); |
|
|
130 socket_connect($this->socket, $this->host, $this->port); |
|
|
131 socket_add_connecting($this); |
|
|
132 } |
|
|
133 public function select_write() { |
|
|
134 if (!socket_getpeername($this->socket, &$addr, &$port)) $addr = 'unknown'; |
|
|
135 fprintf(STDERR, 'UDPMSG: Connected to '.$addr.':'.$port."\n"); |
|
|
136 socket_delete($this); |
|
|
137 socket_add_connected($this); |
|
|
138 peer_add($this); |
|
|
139 } |
|
|
140 } |
|
|
141 class StreamServerClient extends StreamPeer { |
|
|
142 public function closed() { } |
|
|
143 function __construct($socket) { |
|
|
144 socket_set_nonblock($socket); |
|
|
145 $this->socket = $socket; |
|
|
146 socket_add_connected($this); |
|
|
147 peer_add($this); |
|
|
148 } |
|
|
149 } |
|
|
150 class UDPPeer { |
|
|
151 public $socket = NULL; |
|
|
152 function __construct($host = NULL, $port = NULL, $ipv6 = FALSE, $bindhost = NULL, $bindport = NULL) { |
|
2
|
153 $this->socket = socket_create($ipv6 ? AF_INET6 : AF_INET, SOCK_DGRAM, SOL_UDP); |
|
0
|
154 socket_set_nonblock($this->socket); |
|
|
155 if ($bindhost || $bindport) socket_bind($this->socket, $bindhost, $bindport); |
|
|
156 socket_add_connected($this); |
|
|
157 if ($host) { |
|
|
158 socket_connect($this->socket, $host, $port); |
|
|
159 peer_add($this); |
|
|
160 } |
|
|
161 } |
|
|
162 public function select_read() { |
|
|
163 if ($this->udpmsg_read()) return; |
|
|
164 fprintf(STDERR, "UDPMSG: Error: closing connection.\n"); |
|
|
165 } |
|
|
166 public function select_error() { |
|
|
167 fprintf(STDERR, "UDPMSG: Error: select error.\n"); |
|
|
168 } |
|
|
169 private function udpmsg_read() { |
|
|
170 $msg = socket_read($this->socket, 1024 + 20); |
|
2
|
171 //$msg = ''; |
|
|
172 //if (socket_recvfrom($this->socket, $msg, 1024 + 20, 0, $name, $port) <= 0) return FALSE; |
|
0
|
173 if (!strlen($msg)) { |
|
|
174 fprintf(STDERR, "UDPMSG: End of file\n"); |
|
|
175 return FALSE; |
|
|
176 } |
|
2
|
177 if (strlen($msg) < 20 || substr($msg, 0, 20) != sha1(substr($msg, 20), TRUE)) { |
|
0
|
178 fprintf(STDERR, "UDPMSG: Short message or checksum mismatch\n"); |
|
|
179 return FALSE; |
|
|
180 } |
|
2
|
181 udpmsg_receive($this, substr($msg, 20)); |
|
0
|
182 return TRUE; |
|
|
183 } |
|
|
184 public function send($msg) { |
|
|
185 socket_write($this->socket, sha1($msg, TRUE).$msg); |
|
|
186 return TRUE; |
|
|
187 } |
|
|
188 } |
|
|
189 |
|
|
190 $msgi = 0; |
|
|
191 $msglog = array(); |
|
|
192 |
|
|
193 $sock_fd_connecting = array(); |
|
|
194 $sock_fd_connected = array(); |
|
|
195 $sock_timeout = array(); |
|
|
196 $sock_obj = array(); |
|
|
197 |
|
|
198 $peers = array(); |
|
|
199 |
|
|
200 function peer_add($obj) { |
|
|
201 global $peers; |
|
|
202 $peers[spl_object_hash($obj)] = $obj; |
|
|
203 } |
|
|
204 function peer_delete($obj) { |
|
|
205 global $peers; |
|
|
206 unset($peers[spl_object_hash($obj)]); |
|
|
207 } |
|
|
208 |
|
|
209 function socket_add_timeout($obj) { |
|
|
210 global $sock_timeout; |
|
|
211 $sock_timeout[spl_object_hash($obj)] = $obj; |
|
|
212 } |
|
|
213 function socket_add_connecting($obj) { |
|
|
214 global $sock_fd_connecting, $sock_obj; |
|
|
215 $sock_fd_connecting[(int)$obj->socket] = $obj->socket; |
|
|
216 $sock_obj[(int)$obj->socket] = $obj; |
|
|
217 } |
|
|
218 function socket_add_connected($obj) { |
|
|
219 global $sock_fd_connected, $sock_obj; |
|
|
220 $sock_fd_connected[(int)$obj->socket] = $obj->socket; |
|
|
221 $sock_obj[(int)$obj->socket] = $obj; |
|
|
222 } |
|
|
223 function socket_delete($obj) { |
|
|
224 global $sock_fd_connecting, $sock_fd_connected, $sock_obj, $sock_timeout; |
|
|
225 unset($sock_fd_connecting[(int)$obj->socket]); |
|
|
226 unset($sock_fd_connected[(int)$obj->socket]); |
|
|
227 unset($sock_obj[(int)$obj->socket]); |
|
|
228 unset($sock_timeout[spl_object_hash($obj)]); |
|
|
229 } |
|
|
230 |
|
|
231 print("Loading configuration...\n"); |
|
|
232 if (!isset($config)) require constant('CONFIGFILE'); |
|
|
233 |
|
|
234 $logsize = isset($config['logsize'])?$config['logsize']:512; |
|
|
235 if (isset($config['tcplisten'])) |
|
|
236 foreach ($config['tcplisten'] as $e) |
|
|
237 new StreamServer( |
|
|
238 isset($e['host']) ? $e['host'] : '0.0.0.0', |
|
|
239 isset($e['port']) ? $e['port'] : 15387, |
|
|
240 isset($e['ipv6']) && $e['ipv6']); |
|
|
241 if (isset($config['tcpconnect'])) |
|
|
242 foreach ($config['tcpconnect'] as $e) |
|
|
243 new StreamClient( |
|
|
244 isset($e['host']) ? $e['host'] : '127.0.0.1', |
|
|
245 isset($e['port']) ? $e['port'] : 15387, |
|
|
246 isset($e['ipv6']) && $e['ipv6'], |
|
|
247 isset($e['bindhost']) ? $e['bindhost'] : NULL, |
|
|
248 isset($e['bindport']) ? $e['bindport'] : NULL); |
|
|
249 if (isset($config['udppeer'])) |
|
|
250 foreach ($config['udppeer'] as $e) |
|
2
|
251 new UDPPeer( |
|
0
|
252 isset($e['host']) ? $e['host'] : NULL, |
|
|
253 isset($e['port']) ? $e['port'] : 15387, |
|
|
254 isset($e['ipv6']) && $e['ipv6'], |
|
|
255 isset($e['bindhost']) ? $e['bindhost'] : NULL, |
|
|
256 isset($e['bindport']) ? $e['bindport'] : NULL); |
|
|
257 |
|
|
258 function udpmsg_receive($from, $msg) { |
|
|
259 global $peers, $msgi, $msglog, $logsize; |
|
|
260 $hash = md5($msg); |
|
|
261 if (in_array($hash, $msglog)) return FALSE; |
|
|
262 $msglog[$msgi] = $hash; |
|
|
263 $msgi++; |
|
|
264 if ($msgi >= $logsize) $msgi = 0; |
|
|
265 $count = 0; |
|
|
266 foreach ($peers as $peer) if ($peer !== $from) if ($peer->send($msg)) $count++; |
|
|
267 return $count; |
|
|
268 } |
|
|
269 |
|
|
270 while (TRUE) { |
|
|
271 $selread = $sock_fd_connected; |
|
|
272 $selwrite = $sock_fd_connecting; |
|
|
273 $selerror = array_merge($selread, $selwrite); |
|
|
274 if (count($selerror)) { |
|
|
275 socket_select(&$selread, &$selwrite, &$selerror, 60); |
|
|
276 foreach ($selread as $socket) if (isset($sock_obj[(int)$socket])) $sock_obj[(int)$socket]->select_read($socket); |
|
|
277 foreach ($selwrite as $socket) if (isset($sock_obj[(int)$socket])) $sock_obj[(int)$socket]->select_write($socket); |
|
|
278 foreach ($selerror as $socket) if (isset($sock_obj[(int)$socket])) $sock_obj[(int)$socket]->select_error($socket); |
|
|
279 } else { |
|
|
280 sleep(10); |
|
|
281 } |
|
|
282 foreach ($sock_timeout as $obj) $obj->select_timeout(); |
|
|
283 } |
