$content = ob_get_contents();
ob_end_clean();
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ fprintf(STDERR, "\n\nCONTENT [%s]\n\n", $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
case "index_wr.php":
+ //
+ // Enhance required: in the POST case, after the header you must get content
+ // from the socket, waiting if necessary
+ //
+
+ fprintf(STDERR, "\n\nDENTRO QUI\n\n");
ob_start();
index_wr_main($this, $addr, $get, $post, $cookie);
$content = ob_get_contents();
ob_end_clean();
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
$content = User::stream_fini($transp, $s_a_p->rndstr, TRUE);
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
unset($this->socks[$id]);
}
- function pendpage_try_addflush($enc, &$new_socket, $tout, $header_out, $content)
+ function pendpage_try_addflush(&$new_socket, $tout, $enc, $header_out, $content)
{
- $pgflush = PendingPage::pendingpage_flushing($new_socket, $enc, $this->curtime, $tout, $header_out, $content);
+ $pendpage = PendingPage::pendingpage_flushing($new_socket, $this->curtime, $tout, $enc, $header_out, $content);
- if ($pgflush->try_flush($this->curtime) == FALSE) {
- // Add $pgflush to the pgflush array
- $this->pgflush_add($pgflush);
+ if ($pendpage->try_flush($this->curtime) == FALSE) {
+ // Add $pendpage to the pendpage array
+ $this->pendpage_add($pendpage);
}
}
- function pgflush_add($pgflush)
+ function pendpage_add($pendpage)
{
- array_push($this->pending_pages, $pgflush);
+ array_push($this->pending_pages, $pendpage);
}
function garbage_manager($force)
}
$write = NULL;
$except = NULL;
- $num_changed_sockets = @stream_select($read, $write, $except, 0, 500000);
+ $num_changed_sockets = @stream_select($read, $write, $except, 5, 500000);
if ($num_changed_sockets == 0) {
printf(" no data in 5 secs, splash [%d]\n", $G_with_splash);
$content = ob_get_contents();
ob_end_clean();
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
else {
$content = "Bin5 Load data error";
}
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
|| (($user = $bri->get_user($cookie['sess'], $idx)) == FALSE)) {
$content = Bin5_user::stream_fini($transp_type, $s_a_p->rndstr, TRUE);
- $s_a_p->pendpage_try_addflush($enc, $new_socket, 20, $header_out, $content);
+ $s_a_p->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
return TRUE;
break;
// if timeout or max content dimension is exceeded move to flushing
}
- static function pendingpage_flushing($socket, $enc, $curtime, $kalive, $header_out, $body)
+ static function pendingpage_flushing($socket, $curtime, $kalive, $enc, $header_out, $body)
{
$thiz = new PendingPage($socket);