No OneTemporary
Actions

Size

40 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/library/rating_server.php b/library/rating_server.php
	index 2d1e3e5..74f225b 100644
	--- a/library/rating_server.php
	+++ b/library/rating_server.php
	@@ -1,709 +1,705 @@
	-<?
	+<?php

	declare(ticks = 1);

	function signalHandler($sig)
	{
	- $log=sprintf("Received signal %s",$sig);
	- syslog(LOG_NOTICE,$log);
	-
	- switch ($sig) {
	- case SIGTERM:
	- syslog(LOG_NOTICE,"Rating Engine is exiting ...");
	- exit(0);
	- case SIGKILL:
	- syslog(LOG_NOTICE,"Rating Engine is exiting ...");
	- exit(0);
	- case SIGUSR1:
	- break;
	- default:
	- // handle all other signals
	+ $log = sprintf("Received signal %s", $sig);
	+ syslog(LOG_NOTICE, $log);
	+
	+ switch ($sig) {
	+ case SIGTERM:
	+ syslog(LOG_NOTICE, "Rating Engine is exiting ...");
	+ exit(0);
	+ case SIGKILL:
	+ syslog(LOG_NOTICE, "Rating Engine is exiting ...");
	+ exit(0);
	+ case SIGUSR1:
	+ break;
	+ default:
	+ // handle all other signals
	}
	}

	class Daemon {

	- function Daemon($pidFile=false) {
	+ public function Daemon($pidFile = false)
	+ {
	$this->pidFile = $pidFile;
	}

	- function start() {
	- if ($this->pidFile!==false && file_exists($this->pidFile)) {
	+ public function start()
	+ {
	+ if ($this->pidFile !== false && file_exists($this->pidFile)) {
	$pf = fopen($this->pidFile, 'r');
	if (!$pf) {
	-
	- $log=sprintf("Error: Unable to read pidfile %s\n",$this->pidFile);
	- syslog(LOG_NOTICE,$log);
	+ $log = sprintf("Error: Unable to read pidfile %s\n", $this->pidFile);
	+ syslog(LOG_NOTICE, $log);
	print $log;

	exit(-1);
	}

	$c = fgets($pf);
	fclose($pf);

	- if ($c===false) {
	-
	- $log=sprintf("Error: Unable to read pidfile %s\n",$this->pidFile);
	- syslog(LOG_NOTICE,$log);
	+ if ($c === false) {
	+ $log = sprintf("Error: Unable to read pidfile %s\n", $this->pidFile);
	+ syslog(LOG_NOTICE, $log);
	print $log;

	exit(-1);
	}

	$pid = intval($c);
	- if (posix_kill($pid, 0)===true) {
	-
	- $log=sprintf("Error: Another process is already running on pid %d\n",$pid);
	- syslog(LOG_NOTICE,$log);
	+ if (posix_kill($pid, 0) === true) {
	+ $log = sprintf("Error: Another process is already running on pid %d\n", $pid);
	+ syslog(LOG_NOTICE, $log);
	print $log;

	exit(-1);
	}
	}

	// do the Unix double fork magic
	$pid = pcntl_fork();
	if ($pid == -1) {
	$log=sprintf("Error: Couldn't fork!\n");
	- syslog(LOG_NOTICE,$log);
	+ syslog(LOG_NOTICE, $log);
	print $log;
	exit(-1);
	}

	if ($pid > 0) {
	// this is the parent. nothing to do
	exit(0);
	}

	// decouple from the parent environment
	chdir('/');
	if (posix_setsid() == -1) {
	$log=sprintf("Error: Could not detach from terminal\n");
	- syslog(LOG_NOTICE,$log);
	+ syslog(LOG_NOTICE, $log);
	print $log;
	exit(-1);
	}

	umask(022);

	// and now the second fork
	$pid = pcntl_fork();
	if ($pid == -1) {
	- $log=sprintf("Error: Couldn't fork!\n");
	- syslog(LOG_NOTICE,$log);
	+ $log = sprintf("Error: Couldn't fork!\n");
	+ syslog(LOG_NOTICE, $log);
	print $log;
	exit(-1);
	}
	if ($pid > 0) {
	// this is the parent. nothing to do
	exit(0);
	}

	// this doesn't really work. it seems php is unable to close these
	//fclose(STDIN);
	//fclose(STDOUT);
	//fclose(STDERR);

	if ($this->pidFile) {
	$pf = fopen($this->pidFile, 'w');
	- if ($pf===false) {
	- $log=sprintf("Error: Unable to write pidfile %s\n",$this->pidFile);
	- syslog(LOG_NOTICE,$log);
	+ if ($pf === false) {
	+ $log = sprintf("Error: Unable to write pidfile %s\n", $this->pidFile);
	+ syslog(LOG_NOTICE, $log);
	print $log;
	exit(-1);
	}

	fwrite($pf, sprintf("%d\n", posix_getpid()));
	fclose($pf);
	register_shutdown_function(array(&$this, "removePid"));
	}

	- //pcntl_signal(SIGCHLD, array(&$this, 'signalHandler'));
	- //pcntl_signal(SIGTERM, array(&$this, 'signalHandler'));
	- //pcntl_signal(SIGKILL, array(&$this, 'signalHandler'));
	+ //pcntl_signal(SIGCHLD, array(&$this, 'signalHandler'));
	+ //pcntl_signal(SIGTERM, array(&$this, 'signalHandler'));
	+ //pcntl_signal(SIGKILL, array(&$this, 'signalHandler'));

	// for some reason these interfere badly with socket_select()
	pcntl_signal(SIGTERM, "signalHandler", true);
	pcntl_signal(SIGKILL, "signalHandler", true);
	pcntl_signal(SIGUSR1, "signalHandler", true);
	-
	}

	- function removePid() {
	+ private function removePid()
	+ {
	if (file_exists($this->pid)) unlink($this->pid);
	}
	}

	/*
	phpSocketDaemon 1.0
	Copyright (C) 2006 Chris Chabot <chabotc@xs4all.nl>
	See http://www.chabotc.nl/ for more information

	This library is free software; you can redistribute it and/or
	modify it under the terms of the GNU Lesser General Public
	License as published by the Free Software Foundation; either
	version 2.1 of the License, or (at your option) any later version.

	This library is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	Lesser General Public License for more details.

	You should have received a copy of the GNU Lesser General Public
	License along with this library; if not, write to the Free Software
	Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
	*/


	class socketClient extends socket {
	- public $remote_address = null;
	- public $remote_port = null;
	- public $connecting = false;
	- public $disconnected = false;
	- public $read_buffer = '';
	- public $write_buffer = '';
	-
	- public function connect($remote_address, $remote_port)
	- {
	- $this->connecting = true;
	- try {
	- parent::connect($remote_address, $remote_port);
	- } catch (socketException $e) {
	- echo "Caught exception: ".$e->getMessage()."\n";
	- }
	- }
	-
	- public function write($buffer, $length = 4096)
	- {
	- $this->write_buffer .= $buffer;
	- $this->do_write();
	- }
	-
	- public function do_write()
	- {
	- $length = strlen($this->write_buffer);
	- try {
	- $written = parent::write($this->write_buffer, $length);
	- if ($written < $length) {
	- $this->write_buffer = substr($this->write_buffer, $written);
	- } else {
	- $this->write_buffer = '';
	- }
	- $this->on_write();
	- return true;
	- } catch (socketException $e) {
	- $old_socket = (int)$this->socket;
	- $this->close();
	- $this->socket = $old_socket;
	- $this->disconnected = true;
	- $this->on_disconnect();
	- return false;
	- }
	- return false;
	- }
	-
	- public function read($length = 4096)
	- {
	- try {
	- $this->read_buffer .= parent::read($length);
	- $this->on_read();
	- } catch (socketException $e) {
	- $old_socket = (int)$this->socket;
	- $this->close();
	- $this->socket = $old_socket;
	- $this->disconnected = true;
	- $this->on_disconnect();
	- }
	- }
	-
	- public function on_connect() {}
	- public function on_disconnect() {}
	- public function on_read() {}
	- public function on_write() {}
	- public function on_timer() {}
	+ public $remote_address = null;
	+ public $remote_port = null;
	+ public $connecting = false;
	+ public $disconnected = false;
	+ public $read_buffer = '';
	+ public $write_buffer = '';
	+
	+ public function connect($remote_address, $remote_port)
	+ {
	+ $this->connecting = true;
	+ try {
	+ parent::connect($remote_address, $remote_port);
	+ } catch (socketException $e) {
	+ echo "Caught exception: ".$e->getMessage()."\n";
	+ }
	+ }
	+
	+ public function write($buffer, $length = 4096)
	+ {
	+ $this->write_buffer .= $buffer;
	+ $this->do_write();
	+ }
	+
	+ public function do_write()
	+ {
	+ $length = strlen($this->write_buffer);
	+ try {
	+ $written = parent::write($this->write_buffer, $length);
	+ if ($written < $length) {
	+ $this->write_buffer = substr($this->write_buffer, $written);
	+ } else {
	+ $this->write_buffer = '';
	+ }
	+ $this->on_write();
	+ return true;
	+ } catch (socketException $e) {
	+ $old_socket = (int)$this->socket;
	+ $this->close();
	+ $this->socket = $old_socket;
	+ $this->disconnected = true;
	+ $this->on_disconnect();
	+ return false;
	+ }
	+ return false;
	+ }
	+
	+ public function read($length = 4096)
	+ {
	+ try {
	+ $this->read_buffer .= parent::read($length);
	+ $this->on_read();
	+ } catch (socketException $e) {
	+ $old_socket = (int)$this->socket;
	+ $this->close();
	+ $this->socket = $old_socket;
	+ $this->disconnected = true;
	+ $this->on_disconnect();
	+ }
	+ }
	+
	+ public function on_connect() {}
	+ public function on_disconnect() {}
	+ public function on_read() {}
	+ public function on_write() {}
	+ public function on_timer() {}
	}

	class socketServer extends socket {
	- protected $client_class;
	+ protected $client_class;

	- public function __construct($client_class, $bind_address = 0, $bind_port = 0, $domain = AF_INET, $type = SOCK_STREAM, $protocol = SOL_TCP)
	- {
	- parent::__construct($bind_address, $bind_port, $domain, $type, $protocol);
	- $this->client_class = $client_class;
	- $this->listen();
	+ public function __construct($client_class, $bind_address = 0, $bind_port = 0, $domain = AF_INET, $type = SOCK_STREAM, $protocol = SOL_TCP)
	+ {
	+ parent::__construct($bind_address, $bind_port, $domain, $type, $protocol);
	+ $this->client_class = $client_class;
	+ $this->listen();
	if (!$bind_address) {
	- $bind_address_print='0.0.0.0';
	+ $bind_address_print='0.0.0.0';
	} else {
	- $bind_address_print=$bind_address;
	+ $bind_address_print=$bind_address;
	}
	$this->startTime=time();
	- $log=sprintf("Rating Engine listening on %s:%s",$bind_address_print, $bind_port);
	- syslog(LOG_NOTICE,$log);
	- }
	-
	- public function accept()
	- {
	- $client = new $this->client_class(parent::accept(),$this);
	- if (!is_subclass_of($client, 'socketServerClient')) {
	- throw new socketException("Invalid serverClient class specified! Has to be a subclass of socketServerClient");
	- }
	- $this->on_accept($client);
	- return $client;
	- }
	-
	- // override if desired
	- public function on_accept(socketServerClient $client) {}
	+ $log=sprintf("Rating Engine listening on %s:%s", $bind_address_print, $bind_port);
	+ syslog(LOG_NOTICE, $log);
	+ }
	+
	+ public function accept()
	+ {
	+ $client = new $this->client_class(parent::accept(),$this);
	+ if (!is_subclass_of($client, 'socketServerClient')) {
	+ throw new socketException("Invalid serverClient class specified! Has to be a subclass of socketServerClient");
	+ }
	+ $this->on_accept($client);
	+ return $client;
	+ }
	+
	+ // override if desired
	+ public function on_accept(socketServerClient $client) {}
	}

	class socketServerClient extends socketClient {
	- public $socket;
	- public $remote_address;
	- public $remote_port;
	- public $local_addr;
	- public $local_port;
	-
	- public function __construct($socket,$parentServer)
	- {
	+ public $socket;
	+ public $remote_address;
	+ public $remote_port;
	+ public $local_addr;
	+ public $local_port;
	+
	+ public function __construct($socket, $parentServer)
	+ {
	$this->socket = $socket;
	$this->parentServer = &$parentServer;

	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!socket_getsockname($this->socket, $this->local_addr, $this->local_port)) {
	- throw new socketException("Could not retrieve local address & port: ".socket_strerror(socket_last_error($this->socket)));
	- } elseif (!socket_getpeername($this->socket, $this->remote_address, $this->remote_port)) {
	- throw new socketException("Could not retrieve remote address & port: ".socket_strerror(socket_last_error($this->socket)));
	- }
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!socket_getsockname($this->socket, $this->local_addr, $this->local_port)) {
	+ throw new socketException("Could not retrieve local address & port: ".socket_strerror(socket_last_error($this->socket)));
	+ } elseif (!socket_getpeername($this->socket, $this->remote_address, $this->remote_port)) {
	+ throw new socketException("Could not retrieve remote address & port: ".socket_strerror(socket_last_error($this->socket)));
	+ }

	global $RatingEngineServer, $RatingEngine;

	$this->ratingEngine = & $RatingEngineServer;
	$this->ratingEngineSettings = $RatingEngine;

	- $this->set_non_block();
	- $this->on_connect();
	-
	- }
	+ $this->set_non_block();
	+ $this->on_connect();
	+ }
	}

	class socketDaemon {
	- public $servers = array();
	- public $clients = array();
	-
	- public function create_server($server_class, $client_class, $bind_address = 0, $bind_port = 0)
	- {
	- $server = new $server_class($client_class, $bind_address, $bind_port);
	- if (!is_subclass_of($server, 'socketServer')) {
	- throw new socketException("Invalid server class specified! Has to be a subclass of socketServer");
	- }
	- $this->servers[(int)$server->socket] = $server;
	- return $server;
	- }
	-
	- public function create_client($client_class, $remote_address, $remote_port, $bind_address = 0, $bind_port = 0)
	- {
	- $client = new $client_class($bind_address, $bind_port);
	- if (!is_subclass_of($client, 'socketClient')) {
	- throw new socketException("Invalid client class specified! Has to be a subclass of socketClient");
	- }
	- $client->set_non_block(true);
	- $client->connect($remote_address, $remote_port);
	- $this->clients[(int)$client->socket] = $client;
	- return $client;
	- }
	-
	- private function create_read_set()
	- {
	- $ret = array();
	- foreach ($this->clients as $socket) {
	- $ret[] = $socket->socket;
	- }
	- foreach ($this->servers as $socket) {
	- $ret[] = $socket->socket;
	- }
	- return $ret;
	- }
	-
	- private function create_write_set()
	- {
	- $ret = array();
	- foreach ($this->clients as $socket) {
	- if (!empty($socket->write_buffer) \|\| $socket->connecting) {
	- $ret[] = $socket->socket;
	- }
	- }
	- foreach ($this->servers as $socket) {
	- if (!empty($socket->write_buffer)) {
	- $ret[] = $socket->socket;
	- }
	- }
	- return $ret;
	- }
	-
	- private function create_exception_set()
	- {
	- $ret = array();
	- foreach ($this->clients as $socket) {
	- $ret[] = $socket->socket;
	- }
	- foreach ($this->servers as $socket) {
	- $ret[] = $socket->socket;
	- }
	- return $ret;
	- }
	-
	- private function clean_sockets()
	- {
	- foreach ($this->clients as $socket) {
	- if ($socket->disconnected \|\| !is_resource($socket->socket)) {
	- if (isset($this->clients[(int)$socket->socket])) {
	- unset($this->clients[(int)$socket->socket]);
	- }
	- }
	- }
	- }
	-
	- private function get_class($socket)
	- {
	- if (isset($this->clients[(int)$socket])) {
	- return $this->clients[(int)$socket];
	- } elseif (isset($this->servers[(int)$socket])) {
	- return $this->servers[(int)$socket];
	- } else {
	- throw (new socketException("Could not locate socket class for $socket"));
	- }
	- }
	-
	- public function process()
	- {
	- // if socketClient is in write set, and $socket->connecting === true, set connecting to false and call on_connect
	- $read_set = $this->create_read_set();
	- $write_set = $this->create_write_set();
	- $exception_set = $this->create_exception_set();
	- $event_time = time();
	- while (($events = socket_select($read_set, $write_set, $exception_set, 2)) !== false) {
	- if ($events > 0) {
	- foreach ($read_set as $socket) {
	- $socket = $this->get_class($socket);
	- if (is_subclass_of($socket,'socketServer')) {
	- $client = $socket->accept();
	- $this->clients[(int)$client->socket] = $client;
	- } elseif (is_subclass_of($socket, 'socketClient')) {
	- // regular on_read event
	- $socket->read();
	- }
	- }
	- foreach ($write_set as $socket) {
	- $socket = $this->get_class($socket);
	- if (is_subclass_of($socket, 'socketClient')) {
	- if ($socket->connecting === true) {
	- $socket->on_connect();
	- $socket->connecting = false;
	- }
	- $socket->do_write();
	- }
	- }
	- foreach ($exception_set as $socket) {
	- $socket = $this->get_class($socket);
	- if (is_subclass_of($socket, 'socketClient')) {
	- $socket->on_disconnect();
	- if (isset($this->clients[(int)$socket->socket])) {
	- unset($this->clients[(int)$socket->socket]);
	- }
	- }
	- }
	- }
	- if (time() - $event_time > 1) {
	- // only do this if more then a second passed, else we'd keep looping this for every bit received
	- foreach ($this->clients as $socket) {
	- $socket->on_timer();
	- }
	- $event_time = time();
	- }
	- $this->clean_sockets();
	- $read_set = $this->create_read_set();
	- $write_set = $this->create_write_set();
	- $exception_set = $this->create_exception_set();
	- }
	- }
	+ public $servers = array();
	+ public $clients = array();
	+
	+ public function create_server($server_class, $client_class, $bind_address = 0, $bind_port = 0)
	+ {
	+ $server = new $server_class($client_class, $bind_address, $bind_port);
	+ if (!is_subclass_of($server, 'socketServer')) {
	+ throw new socketException("Invalid server class specified! Has to be a subclass of socketServer");
	+ }
	+ $this->servers[(int)$server->socket] = $server;
	+ return $server;
	+ }
	+
	+ public function create_client($client_class, $remote_address, $remote_port, $bind_address = 0, $bind_port = 0)
	+ {
	+ $client = new $client_class($bind_address, $bind_port);
	+ if (!is_subclass_of($client, 'socketClient')) {
	+ throw new socketException("Invalid client class specified! Has to be a subclass of socketClient");
	+ }
	+ $client->set_non_block(true);
	+ $client->connect($remote_address, $remote_port);
	+ $this->clients[(int)$client->socket] = $client;
	+ return $client;
	+ }
	+
	+ private function create_read_set()
	+ {
	+ $ret = array();
	+ foreach ($this->clients as $socket) {
	+ $ret[] = $socket->socket;
	+ }
	+ foreach ($this->servers as $socket) {
	+ $ret[] = $socket->socket;
	+ }
	+ return $ret;
	+ }
	+
	+ private function create_write_set()
	+ {
	+ $ret = array();
	+ foreach ($this->clients as $socket) {
	+ if (!empty($socket->write_buffer) \|\| $socket->connecting) {
	+ $ret[] = $socket->socket;
	+ }
	+ }
	+ foreach ($this->servers as $socket) {
	+ if (!empty($socket->write_buffer)) {
	+ $ret[] = $socket->socket;
	+ }
	+ }
	+ return $ret;
	+ }
	+
	+ private function create_exception_set()
	+ {
	+ $ret = array();
	+ foreach ($this->clients as $socket) {
	+ $ret[] = $socket->socket;
	+ }
	+ foreach ($this->servers as $socket) {
	+ $ret[] = $socket->socket;
	+ }
	+ return $ret;
	+ }
	+
	+ private function clean_sockets()
	+ {
	+ foreach ($this->clients as $socket) {
	+ if ($socket->disconnected \|\| !is_resource($socket->socket)) {
	+ if (isset($this->clients[(int)$socket->socket])) {
	+ unset($this->clients[(int)$socket->socket]);
	+ }
	+ }
	+ }
	+ }
	+
	+ private function get_class($socket)
	+ {
	+ if (isset($this->clients[(int)$socket])) {
	+ return $this->clients[(int)$socket];
	+ } elseif (isset($this->servers[(int)$socket])) {
	+ return $this->servers[(int)$socket];
	+ } else {
	+ throw (new socketException("Could not locate socket class for $socket"));
	+ }
	+ }
	+
	+ public function process()
	+ {
	+ // if socketClient is in write set, and $socket->connecting === true, set connecting to false and call on_connect
	+ $read_set = $this->create_read_set();
	+ $write_set = $this->create_write_set();
	+ $exception_set = $this->create_exception_set();
	+ $event_time = time();
	+ while (($events = socket_select($read_set, $write_set, $exception_set, 2)) !== false) {
	+ if ($events > 0) {
	+ foreach ($read_set as $socket) {
	+ $socket = $this->get_class($socket);
	+ if (is_subclass_of($socket,'socketServer')) {
	+ $client = $socket->accept();
	+ $this->clients[(int)$client->socket] = $client;
	+ } elseif (is_subclass_of($socket, 'socketClient')) {
	+ // regular on_read event
	+ $socket->read();
	+ }
	+ }
	+ foreach ($write_set as $socket) {
	+ $socket = $this->get_class($socket);
	+ if (is_subclass_of($socket, 'socketClient')) {
	+ if ($socket->connecting === true) {
	+ $socket->on_connect();
	+ $socket->connecting = false;
	+ }
	+ $socket->do_write();
	+ }
	+ }
	+ foreach ($exception_set as $socket) {
	+ $socket = $this->get_class($socket);
	+ if (is_subclass_of($socket, 'socketClient')) {
	+ $socket->on_disconnect();
	+ if (isset($this->clients[(int)$socket->socket])) {
	+ unset($this->clients[(int)$socket->socket]);
	+ }
	+ }
	+ }
	+ }
	+ if (time() - $event_time > 1) {
	+ // only do this if more then a second passed, else we'd keep looping this for every bit received
	+ foreach ($this->clients as $socket) {
	+ $socket->on_timer();
	+ }
	+ $event_time = time();
	+ }
	+ $this->clean_sockets();
	+ $read_set = $this->create_read_set();
	+ $write_set = $this->create_write_set();
	+ $exception_set = $this->create_exception_set();
	+ }
	+ }
	}

	class socketException extends Exception {
	}

	class socket {
	- public $socket;
	- public $bind_address;
	- public $bind_port;
	- public $domain;
	- public $type;
	- public $protocol;
	- public $local_addr;
	- public $local_port;
	- public $read_buffer = '';
	- public $write_buffer = '';
	-
	- public function __construct($bind_address = 0, $bind_port = 0, $domain = AF_INET, $type = SOCK_STREAM, $protocol = SOL_TCP)
	- {
	- $this->bind_address = $bind_address;
	- $this->bind_port = $bind_port;
	- $this->domain = $domain;
	- $this->type = $type;
	- $this->protocol = $protocol;
	- if (($this->socket = @socket_create($domain, $type, $protocol)) === false) {
	- throw new socketException("Could not create socket: ".socket_strerror(socket_last_error($this->socket)));
	- }
	- if (!@socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, 1)) {
	- throw new socketException("Could not set SO_REUSEADDR: ".$this->get_error());
	- }
	- if (!@socket_bind($this->socket, $bind_address, $bind_port)) {
	- throw new socketException("Could not bind socket to [$bind_address - $bind_port]: ".socket_strerror(socket_last_error($this->socket)));
	- }
	- if (!@socket_getsockname($this->socket, $this->local_addr, $this->local_port)) {
	- throw new socketException("Could not retrieve local address & port: ".socket_strerror(socket_last_error($this->socket)));
	- }
	- $this->set_non_block(true);
	- }
	-
	- public function __destruct()
	- {
	- if (is_resource($this->socket)) {
	- $this->close();
	- }
	- }
	-
	- public function get_error()
	- {
	- $error = socket_strerror(socket_last_error($this->socket));
	- socket_clear_error($this->socket);
	- return $error;
	- }
	-
	- public function close()
	- {
	- if (is_resource($this->socket)) {
	- @socket_shutdown($this->socket, 2);
	- @socket_close($this->socket);
	- }
	- $this->socket = (int)$this->socket;
	- }
	-
	- public function write($buffer, $length = 4096)
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (($ret = @socket_write($this->socket, $buffer, $length)) === false) {
	- throw new socketException("Could not write to socket: ".$this->get_error());
	- }
	- return $ret;
	- }
	-
	- public function read($length = 4096)
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (($ret = @socket_read($this->socket, $length, PHP_BINARY_READ)) == false) {
	- throw new socketException("Could not read from socket: ".$this->get_error());
	- }
	- return $ret;
	- }
	-
	- public function connect($remote_address, $remote_port)
	- {
	- $this->remote_address = $remote_address;
	- $this->remote_port = $remote_port;
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_connect($this->socket, $remote_address, $remote_port)) {
	- throw new socketException("Could not connect to {$remote_address} - {$remote_port}: ".$this->get_error());
	- }
	- }
	-
	- public function listen($backlog = 128)
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_listen($this->socket, $backlog)) {
	- throw new socketException("Could not listen to {$this->bind_address} - {$this->bind_port}: ".$this->get_error());
	- }
	- }
	-
	- public function accept()
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (($client = socket_accept($this->socket)) === false) {
	- throw new socketException("Could not accept connection to {$this->bind_address} - {$this->bind_port}: ".$this->get_error());
	- }
	- return $client;
	- }
	-
	- public function set_non_block()
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_set_nonblock($this->socket)) {
	- throw new socketException("Could not set socket non_block: ".$this->get_error());
	- }
	- }
	-
	- public function set_block()
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_set_block($this->socket)) {
	- throw new socketException("Could not set socket non_block: ".$this->get_error());
	- }
	- }
	-
	- public function set_recieve_timeout($sec, $usec)
	- {
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_set_option($this->socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => $sec, "usec" => $usec))) {
	- throw new socketException("Could not set socket recieve timeout: ".$this->get_error());
	- }
	- }
	-
	- public function set_reuse_address($reuse = true)
	- {
	- $reuse = $reuse ? 1 : 0;
	- if (!is_resource($this->socket)) {
	- throw new socketException("Invalid socket or resource");
	- } elseif (!@socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, $reuse)) {
	- throw new socketException("Could not set SO_REUSEADDR to '$reuse': ".$this->get_error());
	- }
	- }
	+ public $socket;
	+ public $bind_address;
	+ public $bind_port;
	+ public $domain;
	+ public $type;
	+ public $protocol;
	+ public $local_addr;
	+ public $local_port;
	+ public $read_buffer = '';
	+ public $write_buffer = '';
	+
	+ public function __construct($bind_address = 0, $bind_port = 0, $domain = AF_INET, $type = SOCK_STREAM, $protocol = SOL_TCP)
	+ {
	+ $this->bind_address = $bind_address;
	+ $this->bind_port = $bind_port;
	+ $this->domain = $domain;
	+ $this->type = $type;
	+ $this->protocol = $protocol;
	+ if (($this->socket = @socket_create($domain, $type, $protocol)) === false) {
	+ throw new socketException("Could not create socket: ".socket_strerror(socket_last_error($this->socket)));
	+ }
	+ if (!@socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, 1)) {
	+ throw new socketException("Could not set SO_REUSEADDR: ".$this->get_error());
	+ }
	+ if (!@socket_bind($this->socket, $bind_address, $bind_port)) {
	+ throw new socketException("Could not bind socket to [$bind_address - $bind_port]: ".socket_strerror(socket_last_error($this->socket)));
	+ }
	+ if (!@socket_getsockname($this->socket, $this->local_addr, $this->local_port)) {
	+ throw new socketException("Could not retrieve local address & port: ".socket_strerror(socket_last_error($this->socket)));
	+ }
	+ $this->set_non_block(true);
	+ }
	+
	+ public function __destruct()
	+ {
	+ if (is_resource($this->socket)) {
	+ $this->close();
	+ }
	+ }
	+
	+ public function get_error()
	+ {
	+ $error = socket_strerror(socket_last_error($this->socket));
	+ socket_clear_error($this->socket);
	+ return $error;
	+ }
	+
	+ public function close()
	+ {
	+ if (is_resource($this->socket)) {
	+ @socket_shutdown($this->socket, 2);
	+ @socket_close($this->socket);
	+ }
	+ $this->socket = (int)$this->socket;
	+ }
	+
	+ public function write($buffer, $length = 4096)
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (($ret = @socket_write($this->socket, $buffer, $length)) === false) {
	+ throw new socketException("Could not write to socket: ".$this->get_error());
	+ }
	+ return $ret;
	+ }
	+
	+ public function read($length = 4096)
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (($ret = @socket_read($this->socket, $length, PHP_BINARY_READ)) == false) {
	+ throw new socketException("Could not read from socket: ".$this->get_error());
	+ }
	+ return $ret;
	+ }
	+
	+ public function connect($remote_address, $remote_port)
	+ {
	+ $this->remote_address = $remote_address;
	+ $this->remote_port = $remote_port;
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_connect($this->socket, $remote_address, $remote_port)) {
	+ throw new socketException("Could not connect to {$remote_address} - {$remote_port}: ".$this->get_error());
	+ }
	+ }
	+
	+ public function listen($backlog = 128)
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_listen($this->socket, $backlog)) {
	+ throw new socketException("Could not listen to {$this->bind_address} - {$this->bind_port}: ".$this->get_error());
	+ }
	+ }
	+
	+ public function accept()
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (($client = socket_accept($this->socket)) === false) {
	+ throw new socketException("Could not accept connection to {$this->bind_address} - {$this->bind_port}: ".$this->get_error());
	+ }
	+ return $client;
	+ }
	+
	+ public function set_non_block()
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_set_nonblock($this->socket)) {
	+ throw new socketException("Could not set socket non_block: ".$this->get_error());
	+ }
	+ }
	+
	+ public function set_block()
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_set_block($this->socket)) {
	+ throw new socketException("Could not set socket non_block: ".$this->get_error());
	+ }
	+ }
	+
	+ public function set_recieve_timeout($sec, $usec)
	+ {
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_set_option($this->socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => $sec, "usec" => $usec))) {
	+ throw new socketException("Could not set socket recieve timeout: ".$this->get_error());
	+ }
	+ }
	+
	+ public function set_reuse_address($reuse = true)
	+ {
	+ $reuse = $reuse ? 1 : 0;
	+ if (!is_resource($this->socket)) {
	+ throw new socketException("Invalid socket or resource");
	+ } elseif (!@socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, $reuse)) {
	+ throw new socketException("Could not set SO_REUSEADDR to '$reuse': ".$this->get_error());
	+ }
	+ }
	}

	class ratingEngineServer extends socketServer {
	- var $requests=array();
	+ var $requests=array();
	var $connected_clients=array();
	}

	class ratingEngineClient extends socketServerClient {

	- private function handle_request($request)
	- {
	- $this->parentServer->requests[$this->remote_address]++;
	+ private function handle_request($request)
	+ {
	+ $this->parentServer->requests[$this->remote_address]++;

	$b = microtime(true);
	$output = $this->ratingEngine->processNetworkInput($request);
	$output .= "\n\n";

	if ($this->ratingEngineSettings['log_delay']) {
	$e=microtime(true);
	$d=$e-$b;
	if ($d >= $this->ratingEngineSettings['log_delay']) {
	- $log=sprintf("%s request took %.4f seconds",$this->ratingEngine->method,$d);
	- syslog(LOG_NOTICE,$log);
	+ $log = sprintf("%s request took %.4f seconds", $this->ratingEngine->method, $d);
	+ syslog(LOG_NOTICE, $log);
	}
	}

	- return $output;
	- }
	+ return $output;
	+ }

	- public function on_read()
	- {
	+ public function on_read()
	+ {
	$tinput = trim($this->read_buffer);
	if ($tinput == 'exit' \|\| $tinput =='quit') {
	$this->on_disconnect();
	$this->close();
	} else if (strtolower($tinput) == 'showclients') {
	- $output='';
	+ $output='';
	$j=0;

	$uptime=time()-$this->parentServer->startTime;

	if (count($this->parentServer->connected_clients)) {
	$output .= "\nClients:\n\n";
	foreach ($this->parentServer->connected_clients as $_client) {
	$j++;
	$myself=$this->remote_address.":".$this->remote_port;
	if ($_client == $myself) {
	- $output .= sprintf ("%d. %s (myself)\n",$j,$_client);
	+ $output .= sprintf("%d. %s (myself)\n", $j, $_client);
	} else {
	- $output .= sprintf ("%d. %s\n",$j,$_client);
	+ $output .= sprintf("%d. %s\n", $j, $_client);
	}
	}
	}

	if (count($this->parentServer->requests)) {
	$output .= "\nRequests:\n\n";

	$requests=0;
	foreach (array_keys($this->parentServer->requests) as $_client_ip) {
	- $output .= sprintf ("%d requests from %s\n",$this->parentServer->requests[$_client_ip],$_client_ip);
	- $requests=$requests+$this->parentServer->requests[$_client_ip];
	+ $output .= sprintf("%d requests from %s\n", $this->parentServer->requests[$_client_ip], $_client_ip);
	+ $requests = $requests + $this->parentServer->requests[$_client_ip];
	}
	}

	$output .= "\nStatistics:\n\n";

	- $output .= sprintf ("Total requests: %d\n",$requests);
	- $output .= sprintf ("Uptime: %d seconds\n",$uptime);
	- if ($uptime) $output .= sprintf ("Load: %0.2f/s\n",$requests/$uptime);
	+ $output .= sprintf("Total requests: %d\n", $requests);
	+ $output .= sprintf("Uptime: %d seconds\n", $uptime);
	+ if ($uptime) $output .= sprintf("Load: %0.2f/s\n", $requests / $uptime);

	$output .= "\n\n";
	- $this->write($output);
	- $this->read_buffer = '';
	-
	+ $this->write($output);
	+ $this->read_buffer = '';
	} elseif ($tinput) {
	- $this->write($this->handle_request($tinput));
	- $this->read_buffer = '';
	+ $this->write($this->handle_request($tinput));
	+ $this->read_buffer = '';
	}
	- }
	+ }

	- public function on_connect() {
	+ public function on_connect() {

	- if ($this->remote_address != '127.0.0.1') {
	+ if ($this->remote_address != '127.0.0.1') {
	if (is_array($this->ratingEngineSettings['allow'])) {
	- $allow_connection=false;
	+ $allow_connection = false;
	foreach ($this->ratingEngineSettings['allow'] as $_allow) {
	- if (preg_match("/^$_allow/",$this->remote_address)) {
	- $allow_connection=true;
	+ if (preg_match("/^$_allow/", $this->remote_address)) {
	+ $allow_connection = true;
	break;
	}
	}
	if (!$allow_connection) {
	- $log=sprintf("Client %s disallowed by server configuration",$this->remote_address);
	- syslog(LOG_NOTICE,$log);
	+ $log = sprintf("Client %s disallowed by server configuration", $this->remote_address);
	+ syslog(LOG_NOTICE, $log);
	$this->close();
	return true;
	}
	-
	}
	}

	- $_client=$this->remote_address.":".$this->remote_port;
	+ $_client = $this->remote_address.":".$this->remote_port;

	- $this->parentServer->connected_clients[]=$_client;
	- $this->parentServer->connected_clients=array_unique($this->parentServer->connected_clients);
	+ $this->parentServer->connected_clients[] = $_client;
	+ $this->parentServer->connected_clients = array_unique($this->parentServer->connected_clients);

	- $log=sprintf("Client connection from %s:%s",$this->remote_address,$this->remote_port);
	- syslog(LOG_NOTICE,$log);
	- }
	+ $log = sprintf("Client connection from %s:%s", $this->remote_address, $this->remote_port);
	+ syslog(LOG_NOTICE, $log);
	+ }

	- public function on_disconnect() {
	+ public function on_disconnect() {

	- $new_clients=array();
	+ $new_clients = array();
	foreach ($this->parentServer->connected_clients as $_client) {
	$_connected_client=$this->remote_address.":".$this->remote_port;
	if ($_connected_client == $_client) continue;
	$new_clients[]=$_client;
	}

	$this->parentServer->connected_clients=array_unique($new_clients);

	- $log=sprintf("Client disconnection from %s:%s",$this->remote_address,$this->remote_port);
	- syslog(LOG_NOTICE,$log);
	- }
	+ $log = sprintf("Client disconnection from %s:%s", $this->remote_address, $this->remote_port);
	+ syslog(LOG_NOTICE, $log);
	+ }

	- public function on_write() {
	- }
	+ public function on_write() {
	+ }

	- public function on_timer() {
	- }
	+ public function on_timer() {
	+ }
	}
	?>

File Metadata

Mime Type: text/x-diff
Expires: Sat, Nov 23, 2:17 AM (12 h, 45 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3407832
Default Alt Text: (40 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions