web/briskin5/index_rd_ifra.php

   1 <?php
   2 /*
   3  *  brisk - briskin5/index_rd.php
   4  *
   5  *  Copyright (C) 2006-2011 Matteo Nastasi
   6  *                          mailto: nastasi@alternativeoutput.it
   7  *                                  matteo.nastasi@milug.org
   8  *                          web: http://www.alternativeoutput.it
   9  *
  10  * This program is free software; you can redistribute it and/or modify
  11  * it under the terms of the GNU General Public License as published by
  12  * the Free Software Foundation; either version 2 of the License, or
  13  * (at your option) any later version.
  14  *
  15  * This program is distributed in the hope that it will be useful, but
  16  * WITHOUT ANY WARRANTY; without even the implied warranty of
  17  * MERCHANTABLILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  18  * General Public License for more details. You should have received a
  19  * copy of the GNU General Public License along with this program; if
  20  * not, write to the Free Software Foundation, Inc, 59 Temple Place -
  21  * Suite 330, Boston, MA 02111-1307, USA.
  22  *
  23  */
  24
  25 $G_base = "../";
  26
  27 require_once("../Obj/brisk.phh");
  28 // require_once("../Obj/proxyscan.phh");
  29 require_once("Obj/briskin5.phh");
  30
  31 $S_load_stat = array( 'rU_heavy'      => 0,
  32                       'lL_laccgarb'   => 0,
  33                       'wU_lacc_upd'   => 0,
  34                       'wR_garbage'    => 0,
  35                       'wR_minusone'   => 0,
  36                       'wR_the_end'    => 0 );
  37
  38 // Use of proxies isn't allowed.
  39 // if (is_proxy()) {
  40 //   sleep(5);
  41 //   exit;
  42 // }
  43
  44 log_load("LOAD: bin5/index_rd.php ".$QUERY_STRING);
  45
  46 // $first_loop = TRUE;
  47 $the_end = FALSE;
  48
  49 if (DEBUGGING == "local" && $_SERVER['REMOTE_ADDR'] != '127.0.0.1') {
  50   echo "Debugging time!";
  51   exit;
  52 }
  53
  54 function shutta()
  55 {
  56   log_rd2("bin5 SHUTTA [".connection_status()."] !");
  57 }
  58
  59 register_shutdown_function(shutta);
  60
  61 function blocking_error($is_unrecoverable)
  62 {
  63   GLOBAL $is_page_streaming;
  64
  65   $is_page_streaming = TRUE;
  66   log_rd2("BLOCKING_ERROR UNREC: ".($is_unrecoverable ? "TRUE" : "FALSE"));
  67   return (sprintf(($is_unrecoverable ? 'hstm.stop(); ' : '').'window.onbeforeunload = null; window.onunload = null; document.location.assign("../index.php");'));
  68 }
  69
  70 function page_sync($sess, $page)
  71 {
  72   GLOBAL $is_page_streaming;
  73
  74   $is_page_streaming = TRUE;
  75   log_rd2("PAGE_SYNC");
  76   return (sprintf('hstm.stop(); window.onbeforeunload = null; window.onunload = null; document.location.assign("%s");', $page));
  77 }
  78
  79 function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_subst, &$new_step, $table_idx, $table_token)
  80 {
  81     GLOBAL $is_page_streaming, $S_load_stat;
  82     // GLOBAL $first_loop;
  83
  84     $ret = FALSE;
  85     $bri = FALSE;
  86     $user = FALSE;
  87     $curtime = time();
  88
  89     if (($proxy_step = Bin5_user::load_step($table_idx, $sess)) == FALSE) {
  90         log_only2("R");
  91         ignore_user_abort(FALSE);
  92         return (blocking_error(TRUE));
  93     }
  94
  95     // log_rd2("M");
  96     /* Sync check (read only without modifications */
  97     ignore_user_abort(TRUE);
  98
  99     // shared locking to load info
 100     if (($sem = Bin5::lock_data(FALSE, $table_idx)) == FALSE) {
 101         // wait 20 secs, then restart the xhr
 102         ignore_user_abort(FALSE);
 103         return ("sleep(gst,20000);|hstm.xhr_abort();");
 104     }
 105
 106     if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) {
 107         Bin5::unlock_data($sem);
 108         ignore_user_abort(FALSE);
 109         return (blocking_error(TRUE));
 110     }
 111
 112     /* if lacc time great than STREAM_TIMEOUT or the room garbage_time is expired
 113         switch to exclusive locking and verify again the conditions */
 114
 115     if ((($curtime - $user->lacc) > STREAM_TIMEOUT) || Bin5::garbage_time_is_expired($table_idx, $curtime)) {
 116         Bin5::unlock_data($sem);
 117
 118         // exclusive locking to modify info
 119         if (($sem = Bin5::lock_data(TRUE, $table_idx)) == FALSE) {
 120             // wait 20 secs, then restart the xhr
 121             ignore_user_abort(FALSE);
 122             return ("sleep(gst,20000);|hstm.xhr_abort();");
 123         }
 124         $S_load_stat['lL_laccgarb']++;
 125
 126         unset($user);
 127         // load again the user data after new lock
 128         if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) {
 129             Bin5::unlock_data($sem);
 130             ignore_user_abort(FALSE);
 131             return (blocking_error(TRUE));
 132         }
 133
 134         if (($curtime - $user->lacc) > STREAM_TIMEOUT) {
 135             $S_load_stat['wU_lacc_upd']++;
 136             $user->lacc = $curtime;
 137             // lacc field updated
 138             Bin5_user::save_data($user, $table_idx, $user->idx);
 139         }
 140
 141         if (Bin5::garbage_time_is_expired($table_idx, $curtime)) {
 142             log_only("F");
 143
 144             $S_load_stat['wR_garbage']++;
 145             if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) {
 146                 Bin5::unlock_data($sem);
 147                 ignore_user_abort(FALSE);
 148                 return (blocking_error(TRUE));
 149             }
 150
 151             $bri->garbage_manager(FALSE);
 152
 153             Bin5::save_data($bri);
 154             unset($bri);
 155         }
 156     }
 157     log_main("infolock: U");
 158     Bin5::unlock_data($sem);
 159     ignore_user_abort(FALSE);
 160
 161
 162 //     if  ($first_loop == TRUE) {
 163
 164 //         if (($sem = Bin5::lock_data(TRUE, $table_idx)) != FALSE) {
 165 //             // Aggiorna l'expire time lato server
 166 //             $S_load_stat['rU_first_loop']++;
 167
 168 //             if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) {
 169 //                 Bin5::unlock_data($sem);
 170 //                 ignore_user_abort(FALSE);
 171 //                 return (blocking_error(TRUE));
 172 //             }
 173 //             $user->lacc = $curtime;
 174
 175 //             Bin5_user::save_data($user, $table_idx, $user->idx);
 176
 177 //             if (Bin5::garbage_time_is_expired($table_idx, $curtime)) {
 178 //                 log_only("F");
 179
 180 //                 $S_load_stat['wR_garbage']++;
 181 //                 if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) {
 182 //                     Bin5::unlock_data($sem);
 183 //                     ignore_user_abort(FALSE);
 184 //                     return (blocking_error(TRUE));
 185 //                 }
 186
 187 //                 $bri->garbage_manager(FALSE);
 188
 189 //                 Bin5::save_data($bri);
 190 //                 unset($bri);
 191 //             }
 192 //             log_main("infolock: U");
 193 //             Bin5::unlock_data($sem);
 194 //             ignore_user_abort(FALSE);
 195 //         } // if (($sem = Bin5::lock_data(TRUE, $table ...
 196 //         else {
 197 //             ignore_user_abort(FALSE);
 198
 199 //             return ("sleep(gst,20000);|hstm.xhr_abort();");
 200 //         }
 201
 202 //         $first_loop = FALSE;
 203 //     } // if  ($first_loop == TRUE) {
 204
 205     if ($cur_step == $proxy_step['s']) {
 206         log_main("infolock: P");
 207         return (FALSE);
 208     }
 209     else {
 210         log_only2("R");
 211     }
 212
 213     $S_load_stat['rU_heavy']++;
 214     if ($user == FALSE) {
 215         do {
 216             ignore_user_abort(TRUE);
 217             if (($sem = Bin5::lock_data(TRUE, $table_idx)) == FALSE)
 218                 break;
 219
 220             log_main("infolock: P");
 221             if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) {
 222                 break;
 223             }
 224         } while (0);
 225
 226         if ($sem != FALSE)
 227             Bin5::unlock_data($sem);
 228
 229         ignore_user_abort(FALSE);
 230         if ($user == FALSE)
 231             return (blocking_error(TRUE));
 232     }
 233
 234     /* Nothing changed, return. */
 235     if ($cur_step == $user->step)
 236         return (FALSE);
 237
 238     log_rd2("do other cur_stat[".$cur_stat."] user->stat[".$user->stat."] cur_step[".$cur_step."] user_step[".$user->step."]");
 239
 240     if ($cur_step == -1) {
 241         /*
 242          *  if $cur_step == -1 load the current state from the main struct
 243          */
 244
 245         /* unset the $user var to reload it from main structure */
 246         unset($user);
 247
 248         ignore_user_abort(TRUE);
 249         $sem = Bin5::lock_data(TRUE, $table_idx);
 250         if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) {
 251             Bin5::unlock_data($sem);
 252             ignore_user_abort(FALSE);
 253             return (blocking_error(TRUE));
 254         }
 255         $S_load_stat['wR_minusone']++;
 256
 257         if (($user = $bri->get_user($sess, $idx)) == FALSE) {
 258             Bin5::unlock_data($sem);
 259             ignore_user_abort(FALSE);
 260             return (blocking_error(TRUE));
 261         }
 262         if ($user->the_end == TRUE) {
 263             log_rd2("main_check: the end".var_export(debug_backtrace()));
 264             $is_page_streaming = TRUE;
 265         }
 266
 267         if ($user->trans_step != -1) {
 268             log_rd2("TRANS USATO ".$user->trans_step);
 269             $cur_step = $user->trans_step;
 270             $user->trans_step = -1;
 271
 272             Bin5::save_data($bri);
 273             Bin5::unlock_data($sem);
 274             ignore_user_abort(FALSE);
 275         }
 276         else {
 277             log_rd2("TRANS NON ATTIVATO");
 278
 279             //       ARRAY_POP DISABLED
 280             //       while (array_pop($user->comm) != NULL);
 281             //       // $user->step_inc(COMM_N + 1);
 282             //       Bin5::save_data($bri);
 283
 284             Bin5::unlock_data($sem);
 285             ignore_user_abort(FALSE);
 286         }
 287     }
 288
 289     if ($cur_step == -1) {
 290         log_rd2("PRE-NEWSTAT.");
 291
 292         /***************
 293          *             *
 294          *    TABLE    *
 295          *             *
 296          ***************/
 297         if ($user->stat == "table") {
 298             $ret = show_table(&$bri,&$user,$user->step,FALSE,FALSE);
 299
 300             log_rd2("SENDED TO THE STREAM: ".$ret);
 301         }
 302         log_rd2("NEWSTAT: ".$user->stat);
 303
 304         $new_stat =  $user->stat;
 305         $new_subst = $user->subst;
 306         $new_step =  $user->step;
 307     }
 308     else {
 309         ignore_user_abort(TRUE);
 310         $sem = Bin5::lock_data(TRUE, $table_idx);
 311         // if (($user = &$bri->get_user($sess, $idx)) == FALSE) {
 312         if (($user = Bin5_user::load_data($table_idx, $proxy_step['i'], $sess)) == FALSE) {
 313             Bin5::unlock_data($sem);
 314             ignore_user_abort(FALSE);
 315             return (blocking_error(TRUE));
 316         }
 317         if ($cur_step < $user->step) {
 318             do {
 319                 if ($cur_step + COMM_N < $user->step) {
 320                     if (($cur_stat != $user->stat)) {
 321                         $to_stat = $user->stat;
 322                         Bin5::unlock_data($sem);
 323                         ignore_user_abort(FALSE);
 324                         return (page_sync($user->sess, $to_stat == "table" ? "index.php" : "../index.php"));
 325                     }
 326                     log_rd2("lost history, refresh from scratch");
 327                     $new_step = -1;
 328                     break;
 329                 }
 330                 for ($i = $cur_step ; $i < $user->step ; $i++) {
 331                     $ii = $i % COMM_N;
 332                     log_wr("TRY RET ".$i."  COMM_N ".COMM_N."  II ".$ii);
 333                     $ret .= $user->comm[$ii];
 334                 }
 335                 $new_stat =  $user->stat;
 336                 $new_subst = $user->subst;
 337                 $new_step =  $user->step;
 338             } while (0);
 339
 340             log_rd2($user->step, 'bin::index_rd.php: after ret set');
 341
 342             if ($user->the_end == TRUE) {
 343                 log_rd2("LOGOUT BYE BYE!!");
 344                 log_auth($user->sess, "Explicit logout.");
 345
 346                 unset($user);
 347
 348                 $S_load_stat['wR_the_end']++;
 349                 if (($bri = Bin5::load_data($table_idx, $table_token)) == FALSE) {
 350                     Bin5::unlock_data($sem);
 351                     ignore_user_abort(FALSE);
 352                     return (blocking_error(TRUE));
 353                 }
 354                 if (($user = $bri->get_user($sess, $idx)) == FALSE) {
 355                     Bin5::unlock_data($sem);
 356                     ignore_user_abort(FALSE);
 357                     return (blocking_error(TRUE));
 358                 }
 359
 360                 $tmp_sess = $user->sess;
 361                 $user->sess = "";
 362                 Bin5_user::unproxy_step($tmp_sess);
 363                 $user->name = "";
 364                 $user->the_end = FALSE;
 365
 366                 /* FIXME - and now ??
 367                 if ($user->subst == 'sitdown')
 368                     $bri->room_wakeup($user);
 369                 else if ($user->subst == 'standup')
 370                     $bri->room_outstandup($user);
 371                 else
 372                     log_rd2("LOGOUT FROM WHAT ???");
 373                 */
 374                 Bin5::save_data($bri);
 375             }
 376         }
 377
 378         Bin5::unlock_data($sem);
 379         ignore_user_abort(FALSE);
 380   }
 381
 382
 383   return ($ret);
 384 }
 385
 386 /*
 387  *  MAIN
 388  */
 389
 390 /*
 391    FROM THE EXTERN
 392    sess
 393    stat
 394    step
 395 */
 396
 397 $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);
 398
 399 header("Cache-Control: no-cache, must-revalidate"); // HTTP/1.1
 400 header("Expires: Mon, 26 Jul 1997 05:00:00 GMT"); // Date in the past
 401 // header('Content-type: application/xml; charset="utf-8"',true);
 402 // header('Content-type: text/plain; charset="utf-8"',true);
 403 // header('Content-type: text/html; charset="utf-8"',true);
 404 header('Content-type: text/html; charset="utf-8"',true);
 405
 406 $four_rnd_string =
 407  "GGZDGDRBXDWFXHGPYAAVDXEKFDUWSTEDTDVXBXQPMZAIFPNLRPTWMJAZRHXTIRNZ"
 408 ."HTZXAUVJDCLXENDCLIZXSSEQQGUADYEKNNANJWEGRUFHPLUNSEROZQJSLMUYNUVG"
 409 ."FPLQAGCMTTGIRRXZFBFQFTRBYPHTWFSXFKHKYBRDAOSOURCMEVGPVXJVUQAOCFPV"
 410 ."OQSUBOYWOZLDGRPQQIBNOTHFUHTCRRZOBCUONAXIYUYCJBFTVNWIITVHBYLNMPWR"
 411 ."LPMMIROZVRUNYXSJSMJINSXGACXDMJAEPNFFAERHVDJELXSPPJWKMNFGVGAPTIMR"
 412 ."VMVMVCLWKMPOAJWZGPSPFEXVNQANXGLZIQSCBIYVFSTXZOODZYCXUVUZFCLFGHUJ"
 413 ."TXZWFHSMFJQAZOQRANKZJAUJHFJIKHIIEQUSDXUBRPQBKMIAVTWYQEOIMYKKDTEV"
 414 ."EYERPXKFJXWNIMJPOFFMWJCJSLFZKPNRNVXIDLUSRVBGLUCQZCUQCZNAORDXMRSS"
 415 ."UBNMPXJDQXXLMQRCTOCCJJWHFSUWBNWXWZHPKWYYKPZIMBXTYAZXJJQSBLNAQGJI"
 416 ."AIXZUHNTQYFSGUYMVOWEGUWWRBEMRJHXXOMLRXXWJZLPGLMKEANZWWXIXPIUTURJ"
 417 ."TCXYIKIPNTSUIOWBCEVQHLTHYQNGBHAOPREWGJVOQKNUKTXVTMBRHCERDGYWQVXB"
 418 ."BCZUGMIJXALLIOSXCYMEIDNTPLGRMKXKVFKWGRFKCBIRASOOYIFTLXFSBEOJSDFN"
 419 ."PHSWPGERDYIGUPDXUBSAFCHTPJNBORIRMAOCKGAMFFZUBTVSGEEFMYMEBPUVCRSP"
 420 ."DEEAROBQLJHNMCDAFMPLUKNZXTTJJIULUTDTLEZLVMRLKNLXGCQIGFCBHEWDHNPW"
 421 ."VRONBYCXVRGNQUMFSRADSIFLNRMQXAZKQUKYXGOAKTSLWVSBJMQYZMULCNYKFFUC"
 422 ."LKIPNJOURQLYDHLZYPHEJXPBYTXTGVZOGQUZXAORYINAOTRJCNEDPAXSJIQICWEY"
 423 ."UEJPQALSYHKYZLPJTMBLIDNFRFLTIOVZZTEWPSJCUNDWUDZWJKDDRJEXOICJBSYP"
 424 ."ZHLECBYVMMYLCCPCSVOVPEHEWQDJYSCOWTKFHTWVTSBCQSFKQFCNTGOQBEPSEXKR"
 425 ."AMJIKXZCWLPXMEUBLRJHNEVGMTGARBOBLOYPWUCWSBVTMZBIBRDCNOYXLPSDZODN"
 426 ."JSZXXQUCJZKIYOCCRHYALAJSYXFMWBAOIVAJWIAPOECUJAMFPCOCZDBDHRTBUWWJ"
 427 ."EJYZESNKIXFEBENSOHLCNSQPWGGJLOMTFEZVWWQAKPIFGUUUMWOKLXDUPFMOEKQG"
 428 ."ELOIQAUJPPIJZWKTCYQTJWXCBJMQWIOLQWJIASSXSFLWGUSETHRKEJHCHBOFLJJC"
 429 ."KPPLOTKBXSKUOSNSFHOJRCKXOKQHETCGSMABVALDSBAXBQRFNNJGIDZMNUYQYDHX"
 430 ."DJAHJBJSUEHADPSHOPOXEIRQPEAJEMEBWNXTOSGEQFUVXVHZDYHRUXCRICUHYUHA"
 431 ."FXXGTKWVDDMDSLXEVKZUNTEUKWAGSAWPHGQHEBUMQDHZDVIFVFNDXDUEVZVGSBCQ"
 432 ."STWYUOIHBOQQBAIAQJVNDZQVWHNXHMROIMXNCZRHYXUBFYLEZTWFCYOVILASEFSH"
 433 ."ZUQSNNTYEOCSTRDJPFHCPTDEWCQNEDFOQCZMXKCFIANKWOVDARXWRUCTPYPGTEZB"
 434 ."PERZIMOHRCNBYYJVYFBQJARSULMIAQPILDHEMKNVWMGFQBGZRSQZWZBMSDYKLOTA"
 435 ."VUILKBJADGDTEZENLJEOYPXIXJWIJXONTLXBRLIJFQZORAJIIZQRCUOZLVUTIHXI"
 436 ."NDRVVDJTEIKVLKZVRWHINEYVRGJHXLRNDCNFIYFRUUWMKKGHCPWLZKFULMJOIGJZ"
 437 ."OONOCNPLEJIBKYFDGEQEMMWYBNBWPDRCEIUMFTYAULDBHSHAGPFWVTZXYQGUAXYN"
 438 ."JGGOAMNBBFFSCDSXRTPOHBOVZEXYKAENIWSMBOXGQQTDTIBPSXFHMQUMMKNYYWIC"
 439 ."MFDWSMZDWHGCEWQHFTIMDGTMCEFKWMBAVPEBTCKHRRTLAYEGZTINIWYCUJRZMBPS"
 440 ."TLLEDLEPSAFMQPHYNJWBSSXKEMKLEZIAVNYIOUOTKGYUYJBKBSBQCFRXKOQABUWF"
 441 ."YCNLGXGTLWMLEJVSNDIAMYSXSYFLMNGBOZSREPCPQLRCLNYFVKTWUWBNYAPZTJVO"
 442 ."ONEPJBVBIOPBGVUNWUWZZBJEBDWUWUNFDBOICCGKXDBQWSWFUMIYRCXHLDWFKDUO"
 443 ."PBGTXWNOMUEBENXMARIGPKDETSZNTRODQZYNJJDMYSUBOLPWOEWEVESPLXIKLELG"
 444 ."DCIPTCCKJNNDBRCNVNHVZWPKWPUWLSOORQHNXRBZHHIYPJNBIRCZCIGGEMYKNWXV"
 445 ."TLCLXTIYRVUXONAJUCNMWHNMUSHRWHOEQTTGYJRJEZKNHLVUXUKQQYREZXWRNQKO"
 446 ."BDZTUGIKACSXLRJLESYYPLRFCFVSWJSZYPJBLBTPSEGUZOEXDIXEVWZJEOMOJOIB"
 447 ."QNXNFUXBRJYXMDXQOLVWVLZZMTEMTYRZBWUEEFIBOWXAPKEIQIZZCLMWAOBZVFTP"
 448 ."QQPBYCCLEYRLXVBPMUUMUDPECMDFSVJNKKAEMBYJJXMZGWYTAHECIXAFGWAOGIWV"
 449 ."GAOHCMVHJZVWZCHJWGJJDBZNDXPXOYTDVZEDPWZIIMQVCQPLQIEOSRPVVICTZKGX"
 450 ."JXSFDFUHKKOTXTEGLDSCAODMCVGSSEYANCXJDATMRJRIDLLIJHINSOXJQDEABCVU"
 451 ."WFXWKXJQEREZDLOVUQHYBESHNJWTESPNDVIKYLCTNQEVVUXAWFNQEYIVZXNMJEPL"
 452 ."MFMTOKXXFQYYVBHAXYQVUBALQLSNJSVOTZDDTOZMUEVZJATXQNQVSFXWTGACHUDD"
 453 ."QXCPCRLSREKXHKJNUYUJGIGCNWXUSXOGGYPQWFZDJCKKZONXJUSJKBYIPJSMPVIN"
 454 ."UFBIFNROMBTKQPBIZYJWLPQIJLNTLHTUEWFINOQQDAHCXXKVADTEDBANOPIJBXXC"
 455 ."NAEZOVJAISUQBCBNOYIJBXMRPYPKXBFKFVGQLOEFPOCTZHJXKGUPZQPZOZWXXSSH"
 456 ."SLBGVGVPRAFJCVRKWLSWLMHBMYOKVJDCZSQBLTGSOJDJHOVIDEBKJZNAQYLFIEYS"
 457 ."AYHOSGGDDJAAVTMBYFREMEPLWZXYZUYYRQWKQBLKAPDXMMHCBWSARJCHPGZFCVJG"
 458 ."OXXKCMWTVMKHUUSUMQOGNIHKIIAXNOAHPRIWHDOBJTRKSZAKOMHWTPQQXGZBOPIP"
 459 ."FQEVUBULHGESOARVICLMSUSHHTVYLFMLHFGKJNPYIYEMLBAZMLIDDSWRCVFOUSGC"
 460 ."TUQHWTUHRJUZHYQOKTWTLRVOSWRPSYBOBSZHZLRZEIZKKCMLNYICCUTIXNXETTKL"
 461 ."PYIFTUDCMWRQBZDROXTTVTAOOIQHIWOZESRHKPNGNCSHNAVEWUSGOTZCRNFSIXGF"
 462 ."QJUMUFPEZBFPOVGZZDCGDKEODSWAPNDNHVJUQDYLCXWNXSCDFFFPBTDOIZIZLBBP"
 463 ."ZXZYWTTPEUUCKXGBTXAJBAXYLMUVWWGWZYTXTKYVRXSOXOBHERLZJPRDXIQZRQLU"
 464 ."TXCLIJNKIRWMVQEJTLHZIDTNGBOYSULGWUTSYTKGNMGZFWKXCCZXGOQGZNQFZJUK"
 465 ."JMBQPQPZOPYTQMPEFTZUDLIIBZAZSZAPNILMIKMPKXJIRHRQMFSTJKAPIIQWOFYQ"
 466 ."HGANJGJSUGDIENDVEQFEMUJBGMZBPHLOARCVGMUUCHLCDDNKSJSCKYSALUAGUZFN"
 467 ."YVURVLREBESGXPANIDKGLPJZGXLKFKTPEQBQEINOYYZTBMPFBLBKIKVPAPFDKKRZ"
 468 ."YMVUBYCYTRXCIICUPTXKGQOIJSVSWPYVALIROWGVXDXGNSRVZOLEJHNRSUKHNTRJ"
 469 ."LQZQKBEFXYKIPXJRZMQMJKUGCNUKBZBWABPLHMAJJZVBCWOQYCLSGDUKJSTHTVXV"
 470 ."OUGJVADGJWGVNBNXYRZDSNLOZDIQRKOQAKJJDKXRMMTXRVTLOMTETNROPDYNXAGR";
 471 ?><html>
 472 <head>
 473 <script type="text/javascript" src="../commons.js"></script>
 474 <script type="text/javascript" src="../xynt-http-streaming-ifra.js"></script>
 475 <script type="text/javascript">
 476 var http_streaming = "ready";
 477 <?php
 478 if (isset($st)) {
 479         printf("last_clean = %d;\n", $st);
 480     }
 481 ?>
 482 window.onload = function () { if (http_streaming != "ready") { http_streaming.reload(); } };
 483 </script>
 484 </head>
 485 <body>
 486 <?php
 487
 488 echo("<!-- ");
 489 echo($four_rnd_string);
 490 echo(" -->\n");
 491 mop_flush();
 492
 493
 494 if (!isset($from))
 495      $from = "";
 496 if (!isset($subst))
 497      $subst = "";
 498 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);
 499
 500
 501 $endtime = time() + STREAM_TIMEOUT;
 502 $old_stat =  $stat;
 503 $old_subst = $subst;
 504 $old_step =  $ext_step = $step;
 505
 506 $no_data = TRUE;
 507 for ($i = 0, $script_step=0 ; time() < $endtime ; $i++) {
 508     // log_rd("PRE MAIN ".$step);;
 509     $pre_main = gettimeofday(TRUE);
 510     if (($ret = maincheck($sess, $old_stat, $old_subst, $old_step, &$stat, &$subst, &$step, $table_idx, $table_token)) != FALSE) {
 511         $no_data = false;
 512         if(0 == 1) {
 513             echo '@BEGIN@';
 514             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));
 515             echo "$ret";
 516             echo ' @END@';
 517         }
 518         printf("<script id='hs%d' type='text/javascript'><!--
 519 push(\"%s\");
 520 // -->
 521 </script>", $script_step++, escpush($ret) );
 522         log_send("EXT_STEP: ".$ext_step." ENDTIME: [".$endtime."] ".$ret);
 523         mop_flush();
 524         log_rd2(0, 'bin::index_rd.php: after mop_flush (begin: '.sprintf("%f", $pre_main).')');
 525         if ($is_page_streaming)
 526             break;
 527     }
 528     $old_stat =  $stat;
 529     $old_subst = $subst;
 530     $old_step =  $step;
 531     // log_rd("POST MAIN ".$step);;
 532     usleep(400000);
 533     if (($i % 10) == 0) {
 534         if ($no_data == TRUE) {
 535             // log_rd2("TIME: ".time());
 536             printf("<script id='hs%d' type='text/javascript'><!--
 537 push(null);
 538 // -->
 539 </script>", $script_step++);
 540             mop_flush();
 541             log_crit("flush");
 542         }
 543         $no_data = TRUE;
 544
 545     }
 546 }
 547 $s = "";
 548 $tr = 0;
 549 $tw = 0;
 550 foreach ($S_load_stat as $key => $value) {
 551     $s .= sprintf("%s: %d - ", $key, $value);
 552     if (substr($key, 0, 1) == "w")
 553         $tw += $value;
 554     else if (substr($key, 0, 1) == "r")
 555         $tr += $value;
 556 }
 557 $s = sprintf("briskin5/index_rd.php stats:  R: %d W: %d - %s", $tr, $tw, $s);
 558 log_crit($s);
 559
 560 ?>