/*
* brisk - index_rd.php
*
- * Copyright (C) 2006-2011 Matteo Nastasi
+ * Copyright (C) 2006-2012 Matteo Nastasi
* mailto: nastasi@alternativeoutput.it
* matteo.nastasi@milug.org
* web: http://www.alternativeoutput.it
$is_page_streaming = TRUE;
log_crit("BLOCKING_ERROR UNREC: ".($is_unrecoverable ? "TRUE" : "FALSE"));
- return (sprintf(($is_unrecoverable ? 'the_end=true; ' : '').'window.onbeforeunload = null; window.onunload = null; document.location.assign("index.php");'));
+ return (sprintf(($is_unrecoverable ? 'xstm.stop(); ' : '').'window.onbeforeunload = null; window.onunload = null; document.location.assign("index.php");'));
}
function page_sync($sess, $page, $table_idx, $table_token)
$is_page_streaming = TRUE;
log_rd2("PAGE_SYNC");
- return (sprintf('createCookie("table_idx", %d, 24*365, cookiepath); createCookie("table_token", "%s", 24*365, cookiepath); the_end=true; window.onunload = null; window.onbeforeunload = null; document.location.assign("%s");', $table_idx, $table_token, $page));
+ return (sprintf('createCookie("table_idx", %d, 24*365, cookiepath); createCookie("table_token", "%s", 24*365, cookiepath); xstm.stop(); window.onunload = null; window.onbeforeunload = null; document.location.assign("%s");', $table_idx, $table_token, $page));
}
if (($sem = Room::lock_data(FALSE)) == FALSE) {
// wait 20 secs, then restart the xhr
ignore_user_abort(FALSE);
- return ("sleep(gst,20000);|xhr_rd_abort(xhr_rd);");
+ return ("sleep(gst,20000);|xstm.xhr_abort();");
}
// Verifica l'expire time lato server
if (($sem = Room::lock_data(TRUE)) == FALSE) {
// wait 20 secs, then restart the xhr
ignore_user_abort(FALSE);
- return ("sleep(gst,20000);|xhr_rd_abort(xhr_rd);");
+ return ("sleep(gst,20000);|xstm.xhr_abort();");
}
$S_load_stat['lL_laccgarb']++;
// // wait 20 secs, then restart the xhr
// ignore_user_abort(FALSE);
-// return ("sleep(gst,20000);|xhr_rd_abort(xhr_rd);");
+// return ("sleep(gst,20000);|xstm.xhr_abort();");
// }
// $first_loop = FALSE;
// } // if ($first_loop == TRUE) {
return (blocking_error(TRUE));
}
- if ($user->the_end) {
+ if ($user->the_end == TRUE) {
log_rd2("main_check: the end".var_export(debug_backtrace()));
$is_page_streaming = TRUE;
}
return (page_sync($user->sess, "briskin5/index.php", $user->table, $user->table_token));
}
log_rd2("NEWSTAT: ".$user->stat);
- }
+ } /* if ($cur_step == -1) { */
else {
ignore_user_abort(TRUE);
$sem = Room::lock_data(FALSE);
$new_step = $user->step;
} while (0);
- log_mop($user->step, 'index_rd.php: after ret set');
+ log_rd2($user->step, 'index_rd.php: after ret set');
if ($user->the_end == TRUE) {
Room::unlock_data($sem);
log_rd2("LOGOUT FROM WHAT ???");
Room::save_data($room);
- }
- }
- }
+ } /* if ($user->the_end == TRUE) { ... */
+ } /* if ($user->the_end == TRUE) { ... */
+ } /* if ($cur_step < $user->step) { */
Room::unlock_data($sem);
ignore_user_abort(FALSE);
- }
+ } /* else of if ($cur_step == -1) { */
return ($ret);
step
*/
-$is_page_streaming = (webservers_exceeded() || stristr($HTTP_USER_AGENT, "MSIE") || stristr($HTTP_USER_AGENT, "CHROME") ? TRUE : FALSE);
+$is_page_streaming = (webservers_exceeded() || stristr($HTTP_USER_AGENT, "Mozilla/5.0 (Windows NT 6.1; rv:5.0)") || stristr($HTTP_USER_AGENT, "MSIE") || stristr($HTTP_USER_AGENT, "CHROME") ? TRUE : FALSE);
header("Cache-Control: no-cache, must-revalidate"); // HTTP/1.1
header("Expires: Mon, 26 Jul 1997 05:00:00 GMT"); // Date in the past
header('Content-type: application/xml; charset="utf-8"',true);
-if (!isset($myfrom))
- $myfrom = "";
+if (!isset($from))
+ $from = "";
if (!isset($subst))
$subst = "";
-log_rd2("FROM OUTSIDE - STAT: ".$stat." SUBST: ".$subst." STEP: ".$step." MYFROM: ".$myfrom. "IS_PAGE:" . $is_page_streaming);
+log_rd2("FROM OUTSIDE - STAT: ".$stat." SUBST: ".$subst." STEP: ".$step." FROM: ".$from. "IS_PAGE:" . $is_page_streaming);
$endtime = time() + STREAM_TIMEOUT;
echo "$ret";
echo ' @END@';
log_send("IS_PAGE: ".($is_page_streaming == TRUE ? "TRUE" : "FALSE")."EXT_STEP: ".$ext_step." ENDTIME: [".$endtime."] ".$ret);
- flush();
- log_mop(0, 'index_rd.php: after flush (begin: '.sprintf("%f", $pre_main).')');
- if ($is_page_streaming)
- break;
+ mop_flush();
+ log_rd2(0, 'index_rd.php: after mop_flush (begin: '.sprintf("%f", $pre_main).')');
+ if ($is_page_streaming)
+ break;
}
$old_stat = $stat;
$old_subst = $subst;
if (($i % 10) == 0) {
// log_rd2("TIME: ".time());
echo '_';
- flush();
+ mop_flush();
+ log_crit("flush");
}
}
}
$s = sprintf("index_rd.php stats: R: %d W: %d - %s", $tr, $tw, $s);
log_crit($s);
-
?>