function request_mgr(&$s_a_p, $header, &$header_out, &$new_socket, $path, $addr, $get, $post, $cookie)
{
- printf("NEW_SOCKET (root): %d\n", intval($new_socket));
+ printf("NEW_SOCKET (root): %d PATH [%s]\n", intval($new_socket), $path);
$enc = get_encoding($header);
if (isset($header['User-Agent'])) {
fflush($new_socket);
- $s_a_p->socks_set($new_socket, $user);
+ $s_a_p->socks_set($new_socket, $user, NULL);
$user->rd_socket_set($new_socket);
printf(" - qui ci siamo - ");
return TRUE;
var $file_socket;
var $unix_socket;
var $socks;
- var $s2u;
+ var $s2u; // user associated with input socket
+ var $s2p; // pending page associated with input socket
var $pending_pages;
var $list;
$thiz->debug = $debug;
$thiz->socks = array();
$thiz->s2u = array();
+ $thiz->s2p = array();
$thiz->pending_pages = array();
// create a couple of sockets for control management
return ($thiz);
}
- function socks_set($sock, $user)
+ function socks_set($sock, $user, $pendpage)
{
$id = intval($sock);
- $this->s2u[$id] = $user;
$this->socks[$id] = $sock;
+ if ($user != NULL)
+ $this->s2u[$id] = $user;
+ if ($pendpage != NULL)
+ $this->s2p[$id] = $pendpage;
}
function socks_unset($sock)
{
$id = intval($sock);
- unset($this->s2u[$id]);
+ if (isset($this->s2u[$id]))
+ unset($this->s2u[$id]);
+ if (isset($this->s2p[$id]))
+ unset($this->s2p[$id]);
unset($this->socks[$id]);
}
$this->app->garbage_manager($force);
foreach ($this->socks as $k => $sock) {
- if ($this->s2u[intval($sock)]->sess == '') {
- if ($this->s2u[intval($sock)]->rd_socket_get() != NULL) {
- $this->s2u[intval($sock)]->rd_socket_set(NULL);
+ $id = intval($sock);
+ if (isset($this->s2u[$id])) {
+ if ($this->s2u[$id]->sess == '') {
+ if ($this->s2u[$id]->rd_socket_get() != NULL) {
+ $this->s2u[$id]->rd_socket_set(NULL);
+ }
+ unset($this->socks[$id]);
+ unset($this->s2u[$id]);
+ fclose($sock);
+ printf("CLOSE ON GARBAGE MANAGER\n");
}
- unset($this->socks[intval($sock)]);
- unset($this->s2u[intval($sock)]);
- fclose($sock);
- printf("CLOSE ON GARBAGE MANAGER\n");
}
}
}
}
/* At least at one of the sockets something interesting happened */
foreach ($read as $i => $sock) {
+ $id = intval($sock);
+ $manage_page = FALSE;
/* is_resource check is required because there is the possibility that
during new request an old connection is closed */
if (!is_resource($sock)) {
// $s_a_p (this), $new_socket, substr($path, SITE_PREFIX_LEN),
// $addr
}
+ else {
+ $manage_page = TRUE;
+ }
print_r($header);
printf("GET:\n");
print_r($get);
return(22);
}
else {
- // $user_a[$s2u[intval($sock)]]->disable();
- if ($this->s2u[intval($sock)]->rd_socket_get() != NULL) {
- $this->s2u[intval($sock)]->rd_socket_set(NULL);
+ unset($this->socks[$id]);
+ if (isset($this->s2u[$id])) {
+ // $user_a[$s2u[$id]]->disable();
+ if ($this->s2u[$id]->rd_socket_get() != NULL) {
+ $this->s2u[$id]->rd_socket_set(NULL);
+ }
+ unset($this->s2u[$id]);
}
- unset($this->socks[intval($sock)]);
- unset($this->s2u[intval($sock)]);
}
fclose($sock);
printf("CLOSE ON READ\n");
/* manage open streaming */
foreach ($this->socks as $k => $sock) {
- if (isset($this->s2u[intval($sock)])) {
- $user = $this->s2u[intval($sock)];
+ $id = intval($sock);
+ if (isset($this->s2u[$id])) {
+ $user = $this->s2u[$id];
$response = $user->rd_cache_get();
$do_ping = FALSE;
if (($this->curtime - $user->lacc) > (EXPIRE_TIME_RD / 3)) {
// close socket after a while to prevent client memory consumption
if ($user->rd_endtime_is_expired($this->curtime)) {
- if ($this->s2u[intval($sock)]->rd_socket_get() != NULL) {
- $this->s2u[intval($sock)]->rd_socket_set(NULL);
+ if ($this->s2u[$id]->rd_socket_get() != NULL) {
+ $this->s2u[$id]->rd_socket_set(NULL);
}
- unset($this->socks[intval($sock)]);
- unset($this->s2u[intval($sock)]);
+ unset($this->socks[$id]);
+ unset($this->s2u[$id]);
fclose($sock);
printf("CLOSE ON LOOP\n");
}