X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2Findex_rd.php;h=51986e1e82b7f6c5d0e3090414a66317b6c2d8e5;hb=f402ea85540dde36f860954f4e8ae3c5c9313a84;hp=a335462979f308a06b231523d0ef23688d945da4;hpb=3a38798bd66e565b82f3e53f7f12aef7e70e2c82;p=brisk.git diff --git a/web/index_rd.php b/web/index_rd.php index a335462..51986e1 100644 --- a/web/index_rd.php +++ b/web/index_rd.php @@ -51,15 +51,16 @@ function unrecerror() return (sprintf('the_end=true; window.onunload = null; document.location.assign("index.php");')); } -function page_sync($sess, $page) +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('the_end=true; window.onunload = null; document.location.assign("%s");', $page)); + return (sprintf('createCookie("table_idx", %d, 24*365, cookiepath); createCookie("table_token", "%s", 24*365, cookiepath); the_end=true; window.onunload = null; document.location.assign("%s");', $table_idx, $table_token, $page)); } @@ -88,13 +89,14 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su log_auth($sess, "update lacc"); $user->lacc = time(); + log_main("pre garbage_manager TRE"); $room->garbage_manager(FALSE); Room::save_data($room); $first_loop = FALSE; } - log_only("U"); + log_lock("U"); Room::unlock_data($sem); ignore_user_abort(FALSE); } @@ -106,7 +108,7 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su // log_rd2("Postget".$proxy_step."zizi"); if ($cur_step == $proxy_step) { - log_only2("P"); + log_lock("P"); return (FALSE); } else { @@ -123,7 +125,7 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su if (($sem = Room::lock_data()) == FALSE) break; - log_only("P"); + log_lock("P"); if (($room = &Room::load_data()) == FALSE) break; } while (0); @@ -142,7 +144,7 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su /* Nothing changed, return. */ if ($cur_step == $user->step) - return; + return (FALSE); log_rd2("do other ++".$cur_stat."++".$user->stat."++".$cur_step."++".$user->step); @@ -182,9 +184,14 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su log_rd2("PRE-NEWSTAT: ".$user->stat); if ($user->stat == 'room') { - log_rd("roomma"); - $ret .= show_room(&$room, &$user); - + log_rd("roomma ".$user->step); + $ret .= show_room(&$room, $user->step, &$user); + + // TODO uncomment and test + // while (array_pop($user->comm) != NULL); + // $new_step = -1; + // $user->step_inc(COMM_N + 1); + // Room::save_data($room); /* NOTE the sets went common */ $new_stat = $user->stat; $new_subst = $user->subst; @@ -195,25 +202,11 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su * TABLE * * * ***************/ - else if ($user->stat == 'table') { - /* FIXME we need to decide what do in this case - - if ($user->subst != "shutdowned" && $user->subst != "shutdowner") - $ret = show_table(&$room,&$user,$user->step,FALSE,FALSE); - - log_rd2("SENDED TO THE STREAM: ".$ret); - - - $new_stat = $user->stat; - $new_subst = $user->subst; - $new_step = $user->step; - */ - log_rd2("ALL COMMENTED: ".$ret); - - + 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); - } else { ignore_user_abort(TRUE); @@ -232,10 +225,10 @@ function maincheck($sess, $cur_stat, $cur_subst, $cur_step, &$new_stat, &$new_su Room::unlock_data($sem); ignore_user_abort(FALSE); log_load("RESYNC"); - return (page_sync($user->sess, $to_stat == "table" ? "table.php" : "index.php")); + 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; + $new_step = -1; break; } for ($i = $cur_step ; $i < $user->step ; $i++) {