From: Matteo Nastasi Date: Sat, 4 Aug 2012 09:53:54 +0000 (+0200) Subject: index_rd_ifra.php removed (all things are moved into User or Bin5_user classes X-Git-Tag: v4.0.0~55 X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=commitdiff_plain;h=27185d840648e6857ab197900e3cb11baf5a3692;p=brisk.git index_rd_ifra.php removed (all things are moved into User or Bin5_user classes --- diff --git a/web/briskin5/index_rd_ifra.php b/web/briskin5/index_rd_ifra.php deleted file mode 100644 index b69c849..0000000 --- a/web/briskin5/index_rd_ifra.php +++ /dev/null @@ -1,560 +0,0 @@ - 0, - 'lL_laccgarb' => 0, - 'wU_lacc_upd' => 0, - 'wR_garbage' => 0, - 'wR_minusone' => 0, - 'wR_the_end' => 0 ); - -// Use of proxies isn't allowed. -// if (is_proxy()) { -// sleep(5); -// exit; -// } - -log_load("LOAD: bin5/index_rd.php ".$QUERY_STRING); - -// $first_loop = TRUE; -$the_end = FALSE; - -if (DEBUGGING == "local" && $_SERVER['REMOTE_ADDR'] != '127.0.0.1') { - echo "Debugging time!"; - exit; -} - -function shutta() -{ - log_rd2("bin5 SHUTTA [".connection_status()."] !"); -} - -register_shutdown_function(shutta); - -function blocking_error($is_unrecoverable) -{ - GLOBAL $is_page_streaming; - - $is_page_streaming = TRUE; - log_rd2("BLOCKING_ERROR UNREC: ".($is_unrecoverable ? "TRUE" : "FALSE")); - return (sprintf(($is_unrecoverable ? 'hstm.stop(); ' : '').'window.onbeforeunload = null; window.onunload = null; document.location.assign("../index.php");')); -} - -function page_sync($sess, $page) -{ - GLOBAL $is_page_streaming; - - $is_page_streaming = TRUE; - log_rd2("PAGE_SYNC"); - return (sprintf('hstm.stop(); window.onbeforeunload = null; window.onunload = null; document.location.assign("%s");', $page)); -} - -function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_subst, &$new_step, $table_idx, $table_token) -{ - GLOBAL $is_page_streaming, $S_load_stat; - // GLOBAL $first_loop; - - $ret = FALSE; - $bri = FALSE; - $user = FALSE; - $curtime = time(); - - if (($proxy_step = Bin5_user::load_step($table_idx, $sess)) == FALSE) { - log_only2("R"); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - - // log_rd2("M"); - /* Sync check (read only without modifications */ - ignore_user_abort(TRUE); - - // shared locking to load info - if (($sem = Bin5::lock_data(FALSE, $table_idx)) == FALSE) { - // wait 20 secs, then restart the xhr - ignore_user_abort(FALSE); - return ("sleep(gst,20000);|hstm.xhr_abort();"); - } - - if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - - /* if lacc time great than STREAM_TIMEOUT or the room garbage_time is expired - switch to exclusive locking and verify again the conditions */ - - if ((($curtime - $user->lacc) > STREAM_TIMEOUT) || Bin5::garbage_time_is_expired($table_idx, $curtime)) { - Bin5::unlock_data($sem); - - // exclusive locking to modify info - if (($sem = Bin5::lock_data(TRUE, $table_idx)) == FALSE) { - // wait 20 secs, then restart the xhr - ignore_user_abort(FALSE); - return ("sleep(gst,20000);|hstm.xhr_abort();"); - } - $S_load_stat['lL_laccgarb']++; - - unset($user); - // load again the user data after new lock - if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - - if (($curtime - $user->lacc) > STREAM_TIMEOUT) { - $S_load_stat['wU_lacc_upd']++; - $user->lacc = $curtime; - // lacc field updated - Bin5_user::save_data($user, $table_idx, $user->idx); - } - - if (Bin5::garbage_time_is_expired($table_idx, $curtime)) { - log_only("F"); - - $S_load_stat['wR_garbage']++; - if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - - $bri->garbage_manager(FALSE); - - Bin5::save_data($bri); - unset($bri); - } - } - log_main("infolock: U"); - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - - -// if ($first_loop == TRUE) { - -// if (($sem = Bin5::lock_data(TRUE, $table_idx)) != FALSE) { -// // Aggiorna l'expire time lato server -// $S_load_stat['rU_first_loop']++; - -// if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) { -// Bin5::unlock_data($sem); -// ignore_user_abort(FALSE); -// return (blocking_error(TRUE)); -// } -// $user->lacc = $curtime; - -// Bin5_user::save_data($user, $table_idx, $user->idx); - -// if (Bin5::garbage_time_is_expired($table_idx, $curtime)) { -// log_only("F"); - -// $S_load_stat['wR_garbage']++; -// if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) { -// Bin5::unlock_data($sem); -// ignore_user_abort(FALSE); -// return (blocking_error(TRUE)); -// } - -// $bri->garbage_manager(FALSE); - -// Bin5::save_data($bri); -// unset($bri); -// } -// log_main("infolock: U"); -// Bin5::unlock_data($sem); -// ignore_user_abort(FALSE); -// } // if (($sem = Bin5::lock_data(TRUE, $table ... -// else { -// ignore_user_abort(FALSE); - -// return ("sleep(gst,20000);|hstm.xhr_abort();"); -// } - -// $first_loop = FALSE; -// } // if ($first_loop == TRUE) { - - if ($cur_step == $proxy_step['s']) { - log_main("infolock: P"); - return (FALSE); - } - else { - log_only2("R"); - } - - $S_load_stat['rU_heavy']++; - if ($user == FALSE) { - do { - ignore_user_abort(TRUE); - if (($sem = Bin5::lock_data(TRUE, $table_idx)) == FALSE) - break; - - log_main("infolock: P"); - if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) { - break; - } - } while (0); - - if ($sem != FALSE) - Bin5::unlock_data($sem); - - ignore_user_abort(FALSE); - if ($user == FALSE) - return (blocking_error(TRUE)); - } - - /* Nothing changed, return. */ - if ($cur_step == $user->step) - return (FALSE); - - log_rd2("do other cur_stat[".$cur_stat."] user->stat[".$user->stat."] cur_step[".$cur_step."] user_step[".$user->step."]"); - - if ($cur_step == -1) { - /* - * if $cur_step == -1 load the current state from the main struct - */ - - /* unset the $user var to reload it from main structure */ - unset($user); - - ignore_user_abort(TRUE); - $sem = Bin5::lock_data(TRUE, $table_idx); - if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - $S_load_stat['wR_minusone']++; - - if (($user = $bri->get_user($sess, $idx)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - if ($user->the_end == TRUE) { - log_rd2("main_check: the end".var_export(debug_backtrace())); - $is_page_streaming = TRUE; - } - - if ($user->trans_step != -1) { - log_rd2("TRANS USATO ".$user->trans_step); - $cur_step = $user->trans_step; - $user->trans_step = -1; - - Bin5::save_data($bri); - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - } - else { - log_rd2("TRANS NON ATTIVATO"); - - // ARRAY_POP DISABLED - // while (array_pop($user->comm) != NULL); - // // $user->step_inc(COMM_N + 1); - // Bin5::save_data($bri); - - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - } - } - - if ($cur_step == -1) { - log_rd2("PRE-NEWSTAT."); - - /*************** - * * - * TABLE * - * * - ***************/ - if ($user->stat == "table") { - $ret = show_table(&$bri,&$user,$user->step,FALSE,FALSE); - - log_rd2("SENDED TO THE STREAM: ".$ret); - } - log_rd2("NEWSTAT: ".$user->stat); - - $new_stat = $user->stat; - $new_subst = $user->subst; - $new_step = $user->step; - } - else { - ignore_user_abort(TRUE); - $sem = Bin5::lock_data(TRUE, $table_idx); - // if (($user = &$bri->get_user($sess, $idx)) == FALSE) { - if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - if ($cur_step < $user->step) { - do { - if ($cur_step + COMM_N < $user->step) { - if (($cur_stat != $user->stat)) { - $to_stat = $user->stat; - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (page_sync($user->sess, $to_stat == "table" ? "index.php" : "../index.php")); - } - log_rd2("lost history, refresh from scratch"); - $new_step = -1; - break; - } - for ($i = $cur_step ; $i < $user->step ; $i++) { - $ii = $i % COMM_N; - log_wr("TRY RET ".$i." COMM_N ".COMM_N." II ".$ii); - $ret .= $user->comm[$ii]; - } - $new_stat = $user->stat; - $new_subst = $user->subst; - $new_step = $user->step; - } while (0); - - log_rd2($user->step, 'bin::index_rd.php: after ret set'); - - if ($user->the_end == TRUE) { - log_rd2("LOGOUT BYE BYE!!"); - log_auth($user->sess, "Explicit logout."); - - unset($user); - - $S_load_stat['wR_the_end']++; - if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - if (($user = $bri->get_user($sess, $idx)) == FALSE) { - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - return (blocking_error(TRUE)); - } - - $tmp_sess = $user->sess; - $user->sess = ""; - Bin5_user::unproxy_step($tmp_sess); - $user->name = ""; - $user->the_end = FALSE; - - /* FIXME - and now ?? - if ($user->subst == 'sitdown') - $bri->room_wakeup($user); - else if ($user->subst == 'standup') - $bri->room_outstandup($user); - else - log_rd2("LOGOUT FROM WHAT ???"); - */ - Bin5::save_data($bri); - } - } - - Bin5::unlock_data($sem); - ignore_user_abort(FALSE); - } - - - return ($ret); -} - -/* - * MAIN - */ - -/* - FROM THE EXTERN - sess - stat - step -*/ - -$is_page_streaming = FALSE; // (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); -// header('Content-type: text/plain; charset="utf-8"',true); -// header('Content-type: text/html; charset="utf-8"',true); -header('Content-type: text/html; charset="utf-8"',true); - -$four_rnd_string = - "GGZDGDRBXDWFXHGPYAAVDXEKFDUWSTEDTDVXBXQPMZAIFPNLRPTWMJAZRHXTIRNZ" -."HTZXAUVJDCLXENDCLIZXSSEQQGUADYEKNNANJWEGRUFHPLUNSEROZQJSLMUYNUVG" -."FPLQAGCMTTGIRRXZFBFQFTRBYPHTWFSXFKHKYBRDAOSOURCMEVGPVXJVUQAOCFPV" -."OQSUBOYWOZLDGRPQQIBNOTHFUHTCRRZOBCUONAXIYUYCJBFTVNWIITVHBYLNMPWR" -."LPMMIROZVRUNYXSJSMJINSXGACXDMJAEPNFFAERHVDJELXSPPJWKMNFGVGAPTIMR" -."VMVMVCLWKMPOAJWZGPSPFEXVNQANXGLZIQSCBIYVFSTXZOODZYCXUVUZFCLFGHUJ" -."TXZWFHSMFJQAZOQRANKZJAUJHFJIKHIIEQUSDXUBRPQBKMIAVTWYQEOIMYKKDTEV" -."EYERPXKFJXWNIMJPOFFMWJCJSLFZKPNRNVXIDLUSRVBGLUCQZCUQCZNAORDXMRSS" -."UBNMPXJDQXXLMQRCTOCCJJWHFSUWBNWXWZHPKWYYKPZIMBXTYAZXJJQSBLNAQGJI" -."AIXZUHNTQYFSGUYMVOWEGUWWRBEMRJHXXOMLRXXWJZLPGLMKEANZWWXIXPIUTURJ" -."TCXYIKIPNTSUIOWBCEVQHLTHYQNGBHAOPREWGJVOQKNUKTXVTMBRHCERDGYWQVXB" -."BCZUGMIJXALLIOSXCYMEIDNTPLGRMKXKVFKWGRFKCBIRASOOYIFTLXFSBEOJSDFN" -."PHSWPGERDYIGUPDXUBSAFCHTPJNBORIRMAOCKGAMFFZUBTVSGEEFMYMEBPUVCRSP" -."DEEAROBQLJHNMCDAFMPLUKNZXTTJJIULUTDTLEZLVMRLKNLXGCQIGFCBHEWDHNPW" -."VRONBYCXVRGNQUMFSRADSIFLNRMQXAZKQUKYXGOAKTSLWVSBJMQYZMULCNYKFFUC" -."LKIPNJOURQLYDHLZYPHEJXPBYTXTGVZOGQUZXAORYINAOTRJCNEDPAXSJIQICWEY" -."UEJPQALSYHKYZLPJTMBLIDNFRFLTIOVZZTEWPSJCUNDWUDZWJKDDRJEXOICJBSYP" -."ZHLECBYVMMYLCCPCSVOVPEHEWQDJYSCOWTKFHTWVTSBCQSFKQFCNTGOQBEPSEXKR" -."AMJIKXZCWLPXMEUBLRJHNEVGMTGARBOBLOYPWUCWSBVTMZBIBRDCNOYXLPSDZODN" -."JSZXXQUCJZKIYOCCRHYALAJSYXFMWBAOIVAJWIAPOECUJAMFPCOCZDBDHRTBUWWJ" -."EJYZESNKIXFEBENSOHLCNSQPWGGJLOMTFEZVWWQAKPIFGUUUMWOKLXDUPFMOEKQG" -."ELOIQAUJPPIJZWKTCYQTJWXCBJMQWIOLQWJIASSXSFLWGUSETHRKEJHCHBOFLJJC" -."KPPLOTKBXSKUOSNSFHOJRCKXOKQHETCGSMABVALDSBAXBQRFNNJGIDZMNUYQYDHX" -."DJAHJBJSUEHADPSHOPOXEIRQPEAJEMEBWNXTOSGEQFUVXVHZDYHRUXCRICUHYUHA" -."FXXGTKWVDDMDSLXEVKZUNTEUKWAGSAWPHGQHEBUMQDHZDVIFVFNDXDUEVZVGSBCQ" -."STWYUOIHBOQQBAIAQJVNDZQVWHNXHMROIMXNCZRHYXUBFYLEZTWFCYOVILASEFSH" -."ZUQSNNTYEOCSTRDJPFHCPTDEWCQNEDFOQCZMXKCFIANKWOVDARXWRUCTPYPGTEZB" -."PERZIMOHRCNBYYJVYFBQJARSULMIAQPILDHEMKNVWMGFQBGZRSQZWZBMSDYKLOTA" -."VUILKBJADGDTEZENLJEOYPXIXJWIJXONTLXBRLIJFQZORAJIIZQRCUOZLVUTIHXI" -."NDRVVDJTEIKVLKZVRWHINEYVRGJHXLRNDCNFIYFRUUWMKKGHCPWLZKFULMJOIGJZ" -."OONOCNPLEJIBKYFDGEQEMMWYBNBWPDRCEIUMFTYAULDBHSHAGPFWVTZXYQGUAXYN" -."JGGOAMNBBFFSCDSXRTPOHBOVZEXYKAENIWSMBOXGQQTDTIBPSXFHMQUMMKNYYWIC" -."MFDWSMZDWHGCEWQHFTIMDGTMCEFKWMBAVPEBTCKHRRTLAYEGZTINIWYCUJRZMBPS" -."TLLEDLEPSAFMQPHYNJWBSSXKEMKLEZIAVNYIOUOTKGYUYJBKBSBQCFRXKOQABUWF" -."YCNLGXGTLWMLEJVSNDIAMYSXSYFLMNGBOZSREPCPQLRCLNYFVKTWUWBNYAPZTJVO" -."ONEPJBVBIOPBGVUNWUWZZBJEBDWUWUNFDBOICCGKXDBQWSWFUMIYRCXHLDWFKDUO" -."PBGTXWNOMUEBENXMARIGPKDETSZNTRODQZYNJJDMYSUBOLPWOEWEVESPLXIKLELG" -."DCIPTCCKJNNDBRCNVNHVZWPKWPUWLSOORQHNXRBZHHIYPJNBIRCZCIGGEMYKNWXV" -."TLCLXTIYRVUXONAJUCNMWHNMUSHRWHOEQTTGYJRJEZKNHLVUXUKQQYREZXWRNQKO" -."BDZTUGIKACSXLRJLESYYPLRFCFVSWJSZYPJBLBTPSEGUZOEXDIXEVWZJEOMOJOIB" -."QNXNFUXBRJYXMDXQOLVWVLZZMTEMTYRZBWUEEFIBOWXAPKEIQIZZCLMWAOBZVFTP" -."QQPBYCCLEYRLXVBPMUUMUDPECMDFSVJNKKAEMBYJJXMZGWYTAHECIXAFGWAOGIWV" -."GAOHCMVHJZVWZCHJWGJJDBZNDXPXOYTDVZEDPWZIIMQVCQPLQIEOSRPVVICTZKGX" -."JXSFDFUHKKOTXTEGLDSCAODMCVGSSEYANCXJDATMRJRIDLLIJHINSOXJQDEABCVU" -."WFXWKXJQEREZDLOVUQHYBESHNJWTESPNDVIKYLCTNQEVVUXAWFNQEYIVZXNMJEPL" -."MFMTOKXXFQYYVBHAXYQVUBALQLSNJSVOTZDDTOZMUEVZJATXQNQVSFXWTGACHUDD" -."QXCPCRLSREKXHKJNUYUJGIGCNWXUSXOGGYPQWFZDJCKKZONXJUSJKBYIPJSMPVIN" -."UFBIFNROMBTKQPBIZYJWLPQIJLNTLHTUEWFINOQQDAHCXXKVADTEDBANOPIJBXXC" -."NAEZOVJAISUQBCBNOYIJBXMRPYPKXBFKFVGQLOEFPOCTZHJXKGUPZQPZOZWXXSSH" -."SLBGVGVPRAFJCVRKWLSWLMHBMYOKVJDCZSQBLTGSOJDJHOVIDEBKJZNAQYLFIEYS" -."AYHOSGGDDJAAVTMBYFREMEPLWZXYZUYYRQWKQBLKAPDXMMHCBWSARJCHPGZFCVJG" -."OXXKCMWTVMKHUUSUMQOGNIHKIIAXNOAHPRIWHDOBJTRKSZAKOMHWTPQQXGZBOPIP" -."FQEVUBULHGESOARVICLMSUSHHTVYLFMLHFGKJNPYIYEMLBAZMLIDDSWRCVFOUSGC" -."TUQHWTUHRJUZHYQOKTWTLRVOSWRPSYBOBSZHZLRZEIZKKCMLNYICCUTIXNXETTKL" -."PYIFTUDCMWRQBZDROXTTVTAOOIQHIWOZESRHKPNGNCSHNAVEWUSGOTZCRNFSIXGF" -."QJUMUFPEZBFPOVGZZDCGDKEODSWAPNDNHVJUQDYLCXWNXSCDFFFPBTDOIZIZLBBP" -."ZXZYWTTPEUUCKXGBTXAJBAXYLMUVWWGWZYTXTKYVRXSOXOBHERLZJPRDXIQZRQLU" -."TXCLIJNKIRWMVQEJTLHZIDTNGBOYSULGWUTSYTKGNMGZFWKXCCZXGOQGZNQFZJUK" -."JMBQPQPZOPYTQMPEFTZUDLIIBZAZSZAPNILMIKMPKXJIRHRQMFSTJKAPIIQWOFYQ" -."HGANJGJSUGDIENDVEQFEMUJBGMZBPHLOARCVGMUUCHLCDDNKSJSCKYSALUAGUZFN" -."YVURVLREBESGXPANIDKGLPJZGXLKFKTPEQBQEINOYYZTBMPFBLBKIKVPAPFDKKRZ" -."YMVUBYCYTRXCIICUPTXKGQOIJSVSWPYVALIROWGVXDXGNSRVZOLEJHNRSUKHNTRJ" -."LQZQKBEFXYKIPXJRZMQMJKUGCNUKBZBWABPLHMAJJZVBCWOQYCLSGDUKJSTHTVXV" -."OUGJVADGJWGVNBNXYRZDSNLOZDIQRKOQAKJJDKXRMMTXRVTLOMTETNROPDYNXAGR"; -?> - - - - - - -\n"); -mop_flush(); - - -if (!isset($from)) - $from = ""; -if (!isset($subst)) - $subst = ""; -log_rd2("FROM OUTSIDE - STAT: ".$stat." SUBST: ".$subst." STEP: ".$step." FROM: ".$from. "IS_PAGE:" . $is_page_streaming."USER_AGENT:".$HTTP_USER_AGENT." TABLE:".$table_idx); - - -$endtime = time() + STREAM_TIMEOUT; -$old_stat = $stat; -$old_subst = $subst; -$old_step = $ext_step = $step; - -$no_data = TRUE; -for ($i = 0, $script_step=0 ; time() < $endtime ; $i++) { - // log_rd("PRE MAIN ".$step);; - $pre_main = gettimeofday(TRUE); - if (($ret = maincheck($sess, $old_stat, $old_subst, $old_step, &$stat, &$subst, &$step, $table_idx, $table_token)) != FALSE) { - $no_data = false; - if(0 == 1) { - echo '@BEGIN@'; - log_rd2(sprintf("\nSESS: [%s]\nOLD_STAT: [%s] OLD_SUBST: [%s] OLD_STEP: [%s] \nSTAT: [%s] SUBST: [%s] STEP: [%s] \nCOMM: [%s]\n", $sess, $old_stat, $old_subst, $old_step, $stat, $subst, $step, $ret)); - echo "$ret"; - echo ' @END@'; - } - printf("", $script_step++, escpush($ret) ); - log_send("EXT_STEP: ".$ext_step." ENDTIME: [".$endtime."] ".$ret); - mop_flush(); - log_rd2(0, 'bin::index_rd.php: after mop_flush (begin: '.sprintf("%f", $pre_main).')'); - if ($is_page_streaming) - break; - } - $old_stat = $stat; - $old_subst = $subst; - $old_step = $step; - // log_rd("POST MAIN ".$step);; - usleep(400000); - if (($i % 10) == 0) { - if ($no_data == TRUE) { - // log_rd2("TIME: ".time()); - printf("", $script_step++); - mop_flush(); - log_crit("flush"); - } - $no_data = TRUE; - - } -} -$s = ""; -$tr = 0; -$tw = 0; -foreach ($S_load_stat as $key => $value) { - $s .= sprintf("%s: %d - ", $key, $value); - if (substr($key, 0, 1) == "w") - $tw += $value; - else if (substr($key, 0, 1) == "r") - $tr += $value; -} -$s = sprintf("briskin5/index_rd.php stats: R: %d W: %d - %s", $tr, $tw, $s); -log_crit($s); - -?> diff --git a/web/index_rd_ifra.php b/web/index_rd_ifra.php deleted file mode 100644 index e246dd8..0000000 --- a/web/index_rd_ifra.php +++ /dev/null @@ -1,666 +0,0 @@ - 0, - 'lL_laccgarb' => 0, - 'wU_lacc_upd' => 0, - 'wR_garbage' => 0, - 'wR_minusone' => 0, - 'wR_the_end' => 0 ); - -$mlang_indrd = array( - 'btn_backtotab' => array('it' => ' torna ai tavoli ', - 'en' => ' back to tables '), - 'btn_btotabsup' => array('it' => ' grazie della donazione, torna ai tavoli ', - 'en' => ' thank you for donation, back to tables ') - ); - -// Use of proxies isn't allowed. -// if (is_proxy()) { -// sleep(5); -// exit; -//} -log_load("index_rd.php"); - -// $first_loop = TRUE; -$the_end = FALSE; - -if (DEBUGGING == "local" && $_SERVER['REMOTE_ADDR'] != '127.0.0.1') { - echo "Debugging time!"; - exit; -} - -function blocking_error($is_unrecoverable) -{ - GLOBAL $is_page_streaming; - - $is_page_streaming = TRUE; - log_crit("BLOCKING_ERROR UNREC: ".($is_unrecoverable ? "TRUE" : "FALSE")); - return (sprintf(($is_unrecoverable ? 'hstm.stop(); ' : '').'window.onbeforeunload = null; window.onunload = null; document.location.assign("index.php");')); -} - -// FIXME TO SUPPORT iframe -function page_sync($sess, $page, $table_idx, $table_token) -{ - GLOBAL $is_page_streaming; - - log_rd2("page_sync:".var_export(debug_backtrace())); - - $is_page_streaming = TRUE; - - log_rd2("PAGE_SYNC"); - return (sprintf('createCookie("table_idx", %d, 24*365, cookiepath); createCookie("table_token", "%s", 24*365, cookiepath); hstm.stop(); window.onunload = null; window.onbeforeunload = null; document.location.assign("%s");', $table_idx, $table_token, $page)); -} - - - - -function maincheck(&$user, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_subst, &$new_step, $splashdate) -{ - GLOBAL $G_lang, $mlang_indrd, $is_page_streaming; - // GLOBAL $first_loop; - GLOBAL $G_with_splash, $G_splash_content, $G_splash_interval, $G_splash_idx; - GLOBAL $G_splash_w, $G_splash_h, $G_splash_timeout; - $CO_splashdate = "CO_splashdate".$G_splash_idx; - $$CO_splashdate = $splashdate; - - GLOBAL $S_load_stat; - - log_rd("maincheck begin"); - - $ret = FALSE; - // $user->room = FALSE; - // $user = FALSE; - $curtime = time(); - - // NOTE: qui forse si potrebbe fallback-are a una User::load_data - // anche se non ce ne dovrebbe essere mai la necessità - /* if (($proxy_step = User::load_step($sess)) == FALSE) { */ - /* log_only2("R"); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - // log_rd2("M"); - /* Sync check (read only without modifications */ - ignore_user_abort(TRUE); - - - /* /\* shared locking to load info *\/ */ - /* if (($sem = Room::lock_data(FALSE)) == FALSE) { */ - /* // wait 20 secs, then restart the xhr */ - /* ignore_user_abort(FALSE); */ - /* return ("sleep(gst,20000);|hstm.xhr_abort();"); */ - /* } */ - - /* // Verifica l'expire time lato server */ - /* if (($user = User::load_data($proxy_step['i'], $sess)) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - /* if lacc time great than STREAM_TIMEOUT or the room garbage_time is expired - switch to exclusive locking and verify again the conditions */ - if ((($curtime - $user->lacc) > STREAM_TIMEOUT) || Room::garbage_time_is_expired($curtime)) { - /* there is some info that require to change data, switch to exclusive locking */ - // Room::unlock_data($sem); - /* if (($sem = Room::lock_data(TRUE)) == FALSE) { */ - /* // wait 20 secs, then restart the xhr */ - /* ignore_user_abort(FALSE); */ - /* return ("sleep(gst,20000);|hstm.xhr_abort();"); */ - /* } */ - $S_load_stat['lL_laccgarb']++; - - // load again the data after locking - // unset($user); - // Verifica l'expire time lato server - /* if (($user = User::load_data($proxy_step['i'], $sess)) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - if (($curtime - $user->lacc) >= STREAM_TIMEOUT) { - $S_load_stat['wU_lacc_upd']++; - $user->lacc = $curtime; - // lacc field updated - /* User::save_data($user, $user->idx); */ - } - - if (Room::garbage_time_is_expired($curtime)) { - log_only("F"); - - $S_load_stat['wR_garbage']++; - /* if (($user->room = Room::load_data()) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - log_main("pre garbage_manager TRE"); - $user->room->garbage_manager(FALSE); - /* Room::save_data($user->room); */ - /* unset($user->room); */ - } - } - log_main("infolock: U"); - /* Room::unlock_data($sem); */ - ignore_user_abort(FALSE); - - - -// if ($first_loop == TRUE) { -// if (($sem = Room::lock_data(TRUE)) != FALSE) { -// // Aggiorna l'expire time lato server -// $S_load_stat['U_first_loop']++; -// if (($user = User::load_data($proxy_step['i'], $sess)) == FALSE) { -// Room::unlock_data($sem); -// ignore_user_abort(FALSE); -// return (blocking_error(TRUE)); -// } -// $user->lacc = $curtime; -// // lacc field updated -// User::save_data($user, $user->idx); - -// if (Room::garbage_time_is_expired($curtime)) { -// log_only("F"); - -// $S_load_stat['R_garbage']++; -// if (($user->room = Room::load_data()) == FALSE) { -// Room::unlock_data($sem); -// ignore_user_abort(FALSE); -// return (blocking_error(TRUE)); -// } -// log_main("pre garbage_manager TRE"); -// $user->room->garbage_manager(FALSE); -// Room::save_data($user->room); -// unset($user->room); -// } -// log_main("infolock: U"); -// Room::unlock_data($sem); -// ignore_user_abort(FALSE); -// } // if (($sem = Room::lock_data(TRUE)) != FALSE) { -// else { -// // wait 20 secs, then restart the xhr -// ignore_user_abort(FALSE); - -// return ("sleep(gst,20000);|hstm.xhr_abort();"); -// } -// $first_loop = FALSE; -// } // if ($first_loop == TRUE) { - - /* if ($cur_step == $proxy_step['s']) { */ - /* log_main("infolock: P"); */ - /* return (FALSE); */ - /* } */ - /* else { */ - /* log_only2("R"); */ - /* } */ - - $S_load_stat['rU_heavy']++; - /* if ($user == FALSE) { */ - /* do { */ - /* ignore_user_abort(TRUE); */ - /* if (($sem = Room::lock_data(FALSE)) == FALSE) */ - /* break; */ - - /* log_main("infolock: P"); */ - /* if (($user = User::load_data($proxy_step['i'], $sess)) == FALSE) { */ - /* break; */ - /* } */ - /* } while (0); */ - - /* if ($sem != FALSE) */ - /* Room::unlock_data($sem); */ - - /* ignore_user_abort(FALSE); */ - /* if ($user == FALSE) { */ - /* return (blocking_error(TRUE)); */ - /* } */ - /* } */ - - /* Nothing changed, return. */ - if ($cur_step == $user->step) - return (FALSE); - - log_rd2("do other cur_stat[".$cur_stat."] user->stat[".$user->stat."] cur_step[".$cur_step."] user_step[".$user->step."]"); - - if ($cur_step == -1) { - /* - * if $cur_step == -1 load the current state from the main struct - */ - - /* unset the $user var to reload it from main structure */ - /* unset($user); */ - - ignore_user_abort(TRUE); - /* $sem = Room::lock_data(TRUE); */ - /* if (($user->room = Room::load_data()) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - $S_load_stat['wR_minusone']++; - - /* if (($user = $user->room->get_user($sess, $idx)) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - if ($user->the_end == TRUE) { - log_rd2("main_check: the end".var_export(debug_backtrace())); - $is_page_streaming = TRUE; - } - - if ($user->trans_step != -1) { - log_rd2("TRANS USATO ".$user->trans_step); - $cur_step = $user->trans_step; - $user->trans_step = -1; - - /* Room::save_data($user->room); */ - /* Room::unlock_data($sem); */ - ignore_user_abort(FALSE); - } - else { - log_rd2("TRANS NON ATTIVATO"); - // ARRAY_POP DISABLED - // log_rd2("TRANS NON ATTIVATO, clean del comm array"); - // while (($el = array_pop($user->comm)) != NULL) { - // log_rd2("clean element [".$el."]"); - // } - // // $user->step_inc(COMM_N + 1); - // Room::save_data($user->room); - // // $new_step = $user->step; - - /* Room::unlock_data($sem); */ - ignore_user_abort(FALSE); - } - } - - - /* this part I suppose is read only on $user->room structure */ - if ($cur_step == -1) { - log_rd2("PRE-NEWSTAT: ".$user->stat); - - if ($user->stat == 'room') { - log_rd("roomma ".$user->step); - $curtime = time(); - - if ($G_with_splash && - ($$CO_splashdate < $curtime - $G_splash_interval || - $$CO_splashdate > $curtime)) { - $is_super = $user->flags & USER_FLAG_TY_SUPER; - $ret .= show_notify_ex(str_replace("\n", " ", $G_splash_content[$G_lang]), - ($is_super ? 0 : $G_splash_timeout), - $mlang_indrd[($is_super ? 'btn_btotabsup' : 'btn_backtotab')][$G_lang], - $G_splash_w, $G_splash_h, true, - ($is_super ? 0 : $G_splash_timeout)); - $ret .= sprintf('|createCookie("CO_splashdate%d", %d, 24*365, cookiepath);', $G_splash_idx, $curtime); - } - $ret .= $user->room->show_room($user->step, $user); - - // TODO uncomment and test - /* NOTE the sets went common */ - $new_stat = $user->stat; - $new_subst = $user->subst; - $new_step = $user->step; - } - /*************** - * * - * TABLE * - * * - ***************/ - else if ($user->stat == 'table') { - log_load("RESYNC"); - 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); */ - $S_load_stat['rU_heavy']++; - /* if (($user = User::load_data($proxy_step['i'], $sess)) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - if ($cur_step < $user->step) { - do { - if ($cur_step + COMM_N < $user->step) { - if (($cur_stat != $user->stat)) { - $to_stat = $user->stat; - /* Room::unlock_data($sem); */ - ignore_user_abort(FALSE); - log_load("RESYNC"); - return (page_sync($user->sess, ($to_stat == "table" ? "briskin5/index.php" : "index.php"), $user->table, $user->table_token)); - } - log_rd2("lost history, refresh from scratch"); - $new_step = -1; - break; - } - for ($i = $cur_step ; $i < $user->step ; $i++) { - $ii = $i % COMM_N; - log_rd2("ADDED TO THE STREAM: ".$user->comm[$ii]); - $ret .= $user->comm[$ii]; - } - $new_stat = $user->stat; - $new_subst = $user->subst; - $new_step = $user->step; - } while (0); - - log_rd2($user->step, 'index_rd.php: after ret set'); - - if ($user->the_end == TRUE) { - /* Room::unlock_data($sem); */ - - /* Switch to exclusive locking */ - /* $sem = Room::lock_data(TRUE); */ - - /* unset($user); */ - - $S_load_stat['wR_the_end']++; - /* if (($user->room = Room::load_data()) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - /* if (($user = $user->room->get_user($sess, $idx)) == FALSE) { */ - /* Room::unlock_data($sem); */ - /* ignore_user_abort(FALSE); */ - /* return (blocking_error(TRUE)); */ - /* } */ - - log_rd2("LOGOUT BYE BYE!!"); - log_auth($user->sess, "Explicit logout."); - - if ($user->the_end == TRUE) { - $user->reset(); - - if ($user->subst == 'sitdown') { - log_load("ROOM WAKEUP"); - $user->room->room_wakeup($user); - } - else if ($user->subst == 'standup') - $user->room->room_outstandup($user); - else - log_rd2("LOGOUT FROM WHAT ???"); - - /* Room::save_data($user->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); -} - -function index_rd_ifra_fini($is_unrecoverable) -{ - GLOBAL $G_four_rnd_string; - - // IF IFRAME THEN: - $body = ""; - $body .= sprintf(" - - - - - -"); - $body .= sprintf("\n", $G_four_rnd_string); - $body .= sprintf("", 0, escpush(blocking_error($is_unrecoverable)) ); - // ELSE IF XHR THEN: - // return (blocking_error($is_unrecoverable)); - return ($body); -} - -/* - * MAIN - */ - -/* - FROM THE EXTERN - sess - stat - step -*/ -function index_rd_ifra_init(&$user, &$header_out, &$body, $get, $post, $cookie) -{ - GLOBAL $G_four_rnd_string; - - $curtime = time(); - - $is_page_streaming = FALSE; // (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_out['Cache-Control'] = 'no-cache, must-revalidate'; // HTTP/1.1 - $header_out['Expires'] = 'Mon, 26 Jul 1997 05:00:00 GMT'; // Date in the past - $header_out['Content-type'] = 'text/html; charset="utf-8"'; - - log_load("index_rd_ifra_init.php"); - - if (($from = gpcs_var('from', $get, $post, $cookie)) === FALSE) - $from = ""; - if (($stat = gpcs_var('stat', $get, $post, $cookie)) === FALSE) - $stat = ""; - if (($subst = gpcs_var('subst', $get, $post, $cookie)) === FALSE) - $subst = ""; - if (($step = gpcs_var('step', $get, $post, $cookie)) === FALSE) - unset($step); - - $user->rd_data_set($curtime, $stat, $subst, $step, $from); - - $body .= sprintf(" - - - - - -"); - $body .= sprintf("\n", $G_four_rnd_string); - - return TRUE; -} - -function index_rd_ifra_main(&$user, &$body, $get, $post, $cookie) -{ - GLOBAL $is_page_streaming, $G_splash_idx; - // FIXME: only to test fwrite - // GLOBAL $G_four_rnd_string; - - $CO_splashdate = "CO_splashdate".$G_splash_idx; - if (($splashdate = gpcs_var("$CO_splashdate", $get, $post, $cookie)) === FALSE) - $splashdate = ""; - - $is_page_streaming = FALSE; - log_rd2("FROM OUTSIDE - STAT: ".$user->rd_stat." SUBST: ".$user->rd_subst." STEP: ".$user->rd_step." FROM: ".$user->rd_from. "IS_PAGE:" . $is_page_streaming); - - - // $no_data = TRUE; - // for ($i = 0, $script_step = 0 ; time() < $endtime ; $i++) { - // log_rd("PRE MAIN ".$step);; - - $pre_main = gettimeofday(TRUE); - - $old_stat = $user->rd_stat; - $old_subst = $user->rd_subst; - $old_step = $user->rd_step; - if (($ret = maincheck($user, $old_stat, $old_subst, $old_step, $user->rd_stat, $user->rd_subst, $user->rd_step, $splashdate)) != FALSE) { - // $no_data = FALSE; - if (0 == 1) { - echo '@BEGIN@'; - // log_rd2(sprintf("\nSESS: [%s]\nOLD_STAT: [%s] OLD_SUBST: [%s] OLD_STEP: [%s] \nSTAT: [%s] SUBST: [%s] STEP: [%s] \nCOMM: [%s]\n", $sess, $old_stat, $old_subst, $old_step, $stat, $subst, $step, $ret)); - echo "$ret"; - echo ' @END@'; - } - - // FIXME only to test fwrite - // for ($u = 0 ; $u < 10 ; $u++) { - // $body .= sprintf("\n", $G_four_rnd_string); - // } - $body .= sprintf("", $user->rd_scristp++, escpush($ret) ); - - // log_send("IS_PAGE: ".($is_page_streaming == TRUE ? "TRUE" : "FALSE")." ENDTIME: [".$endtime."] ".$ret); - // mop_flush(); - log_rd2(0, 'index_rd.php: after mop_flush (begin: '.sprintf("%f", $pre_main).')'); - if ($is_page_streaming) - return TRUE; - } - /* $old_stat = $stat; */ - /* $old_subst = $subst; */ - /* $old_step = $step; */ - // log_rd("POST MAIN ".$step);; - // usleep(400000); -/* if (($i % 10) == 0 && 1 == 0) { // TODO: reenable push(null); */ -/* if ($no_data == TRUE) { */ -/* // log_rd2("TIME: ".time()); */ -/* printf("", $script_step++); */ -/* // mop_flush(); */ -/* log_crit("flush"); */ -/* } */ -/* $no_data = TRUE; */ -/* } */ - // } - - /* $s = ""; */ - /* $tr = 0; */ - /* $tw = 0; */ - /* foreach ($S_load_stat as $key => $value) { */ - /* $s .= sprintf("%s: %d - ", $key, $value); */ - /* if (substr($key, 0, 1) == "w") */ - /* $tw += $value; */ - /* else if (substr($key, 0, 1) == "r") */ - /* $tr += $value; */ - /* } */ - /* $s = sprintf("index_rd.php stats: R: %d W: %d - %s", $tr, $tw, $s); */ - /* log_crit($s); */ - - return TRUE; -} - -function index_rd_ifra_keepalive(&$user) -{ - return (sprintf("", $user->rd_scristp++)); - -} -?>