X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2FObj%2Fbrisk.phh;h=a9e8f841eb8cb38d02314ed0e33878b600d552fd;hb=0d462f547c388b20d72a9de96955484636736108;hp=f0f3d750e481b52af9279fb346b564f7662243a2;hpb=a2924d2335ec5325dc322600fe373625575ac8e2;p=brisk.git diff --git a/web/Obj/brisk.phh b/web/Obj/brisk.phh index f0f3d75..a9e8f84 100644 --- a/web/Obj/brisk.phh +++ b/web/Obj/brisk.phh @@ -2,7 +2,10 @@ /* * brisk - brisk.phh * - * Copyright (C) 2006-2007 matteo.nastasi@milug.org + * Copyright (C) 2006-2008 Matteo Nastasi + * mailto: nastasi@alternativeoutput.it + * matteo.nastasi@milug.org + * web: http://www.alternativeoutput.it * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -19,34 +22,62 @@ * */ + +define(BRISK_CONF, "brisk.conf.pho"); define(FTOK_PATH, "/var/lib/brisk"); define(LEGAL_PATH, "/tmp/legal_brisk"); define(PROXY_PATH, "/var/lib/brisk_proxy"); -define(TABLES_N, 12); +define(TABLES_N, 24); define(PLAYERS_N, 3); define(MAX_POINTS, 5); define(MAX_PLAYERS, (20 + (PLAYERS_N * TABLES_N))); -define(SHM_DIMS, (50000 * MAX_PLAYERS)); -// define(COMM_N, 6); -define(COMM_N, 12); +define(SHM_DIMS_MIN, (50000 + 10000 * TABLES_N + 15000 * MAX_PLAYERS)); +define(SHM_DIMS_MAX, SHM_DIMS_MIN + 1048576); +define(SHM_DIMS_DLT, 65536); + +define(COMM_N, 18); define(COMM_GEN_N, 50); + +define(CHAT_N, 3); +define(CHAT_ILL_TIME, 6); + define(SESS_LEN, 13); define(STREAM_TIMEOUT, 20); define(EXPIRE_TIME_RD, 180); define(EXPIRE_TIME_SMAMMA, 360); +define(EXPIRE_TIME_WAG, 10); +define(WAKEUP_TIME, 12); // BAN_TIME da allineare anche in commons.js define(BAN_TIME, 900); define(GARBAGE_TIMEOUT, 10); -define(NICKSERV, "SERVER"); -define(BRISK_DEBUG, FALSE); +define(NICKSERV, "BriskServ"); + +define(DBG_ONL2, 0x0001); +define(DBG_ONLY, 0x0002); +define(DBG_MAIN, 0x0004); +define(DBG_READ, 0x0008); +define(DBG_REA2, 0x0010); +define(DBG_SEND, 0x0020); +define(DBG_LOCK, 0x0040); +define(DBG_WRIT, 0x0080); +define(DBG_LOAD, 0x0100); +define(DBG_AUTH, 0x0200); +define(DBG_CRIT, 0x0400); + +define(BRISK_DEBUG, 0); + +define(BRISK_SINGLE_DEBUG,0); +define(BRISK_SINGLE_SESS, ""); // define(DEBUGGING, "local"); +require_once("$DOCUMENT_ROOT/Etc/".BRISK_CONF); + $G_false = FALSE; $G_all_points = array( 11,10,4,3,2, 0,0,0,0,0 ); -$G_brisk_version = "0.8.2"; +$G_brisk_version = "spawn-0.13.3"; -$root_wellarr = Array ( 'Benvenuto in brisk (Ver. '.$G_brisk_version.'), NOVITA\': nuovo layout che permette più tavoli, più tavoli.', +$root_wellarr = Array ( 'Benvenuto in brisk (Ver. '.$G_brisk_version.'), NOVITA\': comando /tav per annunciare i tavoli attivi - versione Beta4.', 'Se vuoi iscriverti alla Mailing List, cliccala!' ); $table_wellarr = Array ( 'Benvenuto al tavolo. Se almeno tre giocatori non sbloccano l\'uscita cliccando il lucchetto, chi esce non può risedersi a un qualunque tavolo per '.floor(BAN_TIME/60).' minuti.'); @@ -73,7 +104,7 @@ Dopo che è iniziata una partita per uscirne dovete chiedere agli altri gi
Comandi della chat
/nick <nuovo_nickname> - cambio di nickname -
.. to be continue .. +
/tav <frase di invitogt; - invito per gli altri giocatori al tavolo dove si è seduti
'; @@ -134,7 +165,7 @@ class Card { $this->stat = 'take'; // Card stat $this->owner = $newown; } -} +} // end class Card class Table { var $player; @@ -143,6 +174,10 @@ class Table { var $mazzo; var $gstart; var $turn; + + var $wag_own; + var $wag_com; + var $wag_tout; var $asta_pla; var $asta_pla_n; @@ -164,6 +199,11 @@ class Table { var $old_win; var $old_friend; + var $table_token; + var $table_start; + + var $wakeup_time; + function Table() { } @@ -172,12 +212,12 @@ class Table { { GLOBAL $G_false; - if (($thiz = new Table()) == FALSE) + if (($thiz =& new Table()) == FALSE) return ($G_false); $thiz->player = array(); $thiz->player_n = 0; - $thiz->card = &$thiz->bunch_create(); + $thiz->card = FALSE; $thiz->asta_pla = array(); // TRUE: in auction, FALSE: out of the auction $thiz->asta_pla_n= -1; $thiz->asta_card = -1; @@ -190,11 +230,21 @@ class Table { $thiz->briscola = -1; $thiz->friend = -1; $thiz->turn = 0; - $thiz->old_reason = ""; + + $thiz->wag_own = NULL; + $thiz->wag_com = ""; + $thiz->wag_tout = 0; + + $thiz->old_reason = ""; $thiz->old_asta_pnt = -1; $thiz->old_pnt = -1; - $thiz->old_win = -1; - $thiz->old_friend= -1; + $thiz->old_win = -1; + $thiz->old_friend = -1; + + $thiz->table_token = ""; + $thiz->table_start = 0; + + $thiz->wakeup_time = 0; return ($thiz); } @@ -203,7 +253,7 @@ class Table { { GLOBAL $G_false; - if (($thiz = new Table()) == FALSE) + if (($thiz =& new Table()) == FALSE) return ($G_false); $thiz->player = array(); @@ -215,6 +265,10 @@ class Table { $thiz->gstart = $from->gstart; $thiz->turn = $from->turn; + $thiz->wag_own = $from->wag_own; + $thiz->wag_com = $from->wag_com; + $thiz->wag_tout = $from->wag_taut; + $thiz->asta_pla = $from->asta_pla; $thiz->asta_pla_n = $from->asta_pla_n; $thiz->asta_card = $from->asta_card; @@ -235,6 +289,11 @@ class Table { $thiz->old_win = $from->old_win; $thiz->old_friend = $from->old_friend; + $thiz->table_token = $from->table_token; + $thiz->table_start = $from->table_start; + + $thiz->wakeup_time = $from->wakeup_time; + return ($thiz); } @@ -246,11 +305,15 @@ class Table { return ($G_false); $thiz->player_n = $from->player_n; - $thiz->card = $from->card; + $thiz->card = &$thiz->bunch_create(); $thiz->mazzo = $from->mazzo; $thiz->gstart = $from->gstart; $thiz->turn = $from->turn; + $thiz->wag_own = $from->wag_own; + $thiz->wag_com = $from->wag_com; + $thiz->wag_tout = $from->wag_taut; + $thiz->asta_pla = $from->asta_pla; $thiz->asta_pla_n = $from->asta_pla_n; $thiz->asta_card = $from->asta_card; @@ -276,6 +339,11 @@ class Table { for ($i = 0 ; $i < $from->player_n ; $i++) $thiz->player[$i] = $i; + $thiz->table_token = $from->table_token; + $thiz->table_start = $from->table_start; + + $thiz->wakeup_time = $from->wakeup_time; + return ($thiz); } @@ -291,6 +359,25 @@ class Table { return ($oret); } + function wag_set(&$user, $mesg) + { + log_main("WAG_SET"); + + $this->wag_own = &$user; + $this->wag_com = $mesg; + $this->wag_tout = 0; + } + + function wag_reset($timeout) + { + log_main("WAG_RESET"); + + unset($this->wag_own); + $this->wag_own = NULL; + $this->wag_com = ""; + $this->wag_tout = $timeout; + } + function bunch_make() { $ct = array(0,0,0,0,0); @@ -304,7 +391,7 @@ class Table { $rn = rand(0, $i); if ($rn == 0) - log_main("RND ZERO", ""); + log_main("RND ZERO"); $id = $rest[$rn]; @@ -329,12 +416,12 @@ class Table { $user_cur->exitislock = TRUE; } - log_main("table::init","ci siamo"); + log_main("table::init: ci siamo"); } function game_init(&$userarr) { - log_rd2("XXX", "GSTART 4"); + log_rd2("GSTART 4"); $this->gstart = ($this->mazzo+1) % PLAYERS_N; $this->bunch_make(); @@ -398,7 +485,7 @@ class Table { $this->player_n--; } else { - log_main($user->sess, "INCONSISTENCY ON TABLE."); + log_main("INCONSISTENCY ON TABLE."); } } @@ -439,7 +526,7 @@ class Table { return ($ct); } -} // End class Table +} // end class Table class User { var $name; // name of the user @@ -462,6 +549,11 @@ class User { var $table_token;// token that identify a game on a table var $the_end; // Flag to change the end of the session + var $chat_lst; // Last chat line + var $chattime; // Array of chat times + var $chat_cur; // Current chat line number + var $chat_ban; // Time for ban chat + var $chat_dlt; // Delta t for ban function User() { } @@ -487,6 +579,12 @@ class User { $thiz->handpt = -1; $thiz->exitislock = TRUE; + $thiz->chattime = array_fill(0, CHAT_N, 0); + $thiz->chat_cur = 0; + $thiz->chat_lst = ""; + $thiz->chat_ban = 0; + $thiz->chat_dlt = 0; + $thiz->table = $table; $thiz->table_pos = -1; $thiz->table_token = ""; @@ -498,7 +596,7 @@ class User { { GLOBAL $G_false; - if (($thiz = new User()) == FALSE) + if (($thiz =& new User()) == FALSE) return ($G_false); $thiz->name = $from->name; @@ -522,6 +620,15 @@ class User { $thiz->asta_pnt = $from->asta_pnt; $thiz->handpt = $from->handpt; $thiz->exitislock = $from->exitislock; + + $thiz->chattime = array(); + for ($i = 0 ; $i < CHAT_N ; $i++) + $thiz->chattime[$i] = $from->chattime[$i]; + $thiz->chat_cur = $from->chat_cur; + $thiz->chat_lst = $from->chat_lst; + $thiz->chat_ban = $from->chat_ban; + $thiz->chat_dlt = $from->chat_dlt; + $thiz->table = $from->table; $thiz->table_pos = $from->table_pos; $thiz->table_token = $from->table_token; @@ -549,19 +656,26 @@ class User { $thiz->trans_step = $from->trans_step; $thiz->comm = array(); + /* $i_start = (1 > ($from->step - COMM_N) ? 1 : ($from->step - COMM_N)); for ($i = $i_start ; $i < $from->step ; $i++) { - log_wr("XX", "TRY PUSH:".$i); + log_wr("TRY PUSH:".$i); $ii = $i % COMM_N; $thiz->comm[$ii] = $from->comm[$ii]; } - + */ $thiz->asta_card = $from->asta_card; $thiz->asta_pnt = $from->asta_pnt; $thiz->handpt = $from->handpt; $thiz->exitislock = $from->exitislock; $thiz->the_end = $from->the_end; + $thiz->chattime = array_fill(0, CHAT_N, 0); + $thiz->chat_cur = 0; + $thiz->chat_lst = ""; + $thiz->chat_ban = 0; + $thiz->chat_dlt = 0; + $thiz->table = $table; $thiz->table_pos = $table_pos; $thiz->table_token = $from->table_token; @@ -570,6 +684,7 @@ class User { } function stat_set($stat) { + log_main("sess: [".$this->sess. "] NEW STAT: [".$stat."]"); $this->stat = "$stat"; /* @@ -598,8 +713,8 @@ class User { return (FALSE); } - function step_inc() { - $this->step++; + function step_inc($delta = 1) { + $this->step += $delta; if (validate_sess($this->sess)) { $fp = fopen(PROXY_PATH."/".$this->sess.".step", 'w'); @@ -611,7 +726,24 @@ class User { return (FALSE); } -} + + function reset() { + $tmp_sess = $this->sess; + $this->sess = ""; + step_unproxy($tmp_sess); + $this->name = ""; + while (array_pop($this->comm) != NULL); + $this->step = 0; + $this->the_end = FALSE; + + $this->chattime = array_fill(0, CHAT_N, 0); + $this->chat_cur = 0; + $this->chat_lst = ""; + $this->chat_ban = 0; + $this->chat_dlt = 0; + } +} // end class User + function step_get($sess) { $fp = FALSE; @@ -632,19 +764,19 @@ function step_get($sess) { $arr = unpack('l', $s); fclose($fp); - // log_rd2($sess, "A0: ".$arr[0]." A1: ".$arr[1]); + // log_rd2("A0: ".$arr[0]." A1: ".$arr[1]); return ($arr[1]); } while (0); if ($fp != FALSE) fclose($fp); - log_rd2($sess, "STEP_GET: return false ".$ct); + log_rd2("STEP_GET: return false ".$ct); return (FALSE); } function step_unproxy($sess) { - log_rd2($sess, "UNPROXY: ".PROXY_PATH."/".$sess.".step"); + log_rd2("UNPROXY: ".PROXY_PATH."/".$sess.".step"); @unlink(PROXY_PATH."/".$sess.".step"); } @@ -655,9 +787,11 @@ class Room { var $comm; // commands for many people var $step; // current step of the comm array var $garbage_timeout; + var $shm_sz; function Room () { $this->user = array(); + $this->table = array(); for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { $this->user[$i] =& User::create("", ""); @@ -670,35 +804,137 @@ class Room { function garbage_manager($force) { - + $ismod = FALSE; + + log_rd2("garbage_manager START"); + /* Garbage collector degli utenti in timeout */ $curtime = time(); if ($force || $this->garbage_timeout < $curtime) { + // Before all align times with table timeout + for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { + $table_cur =& $this->table[$table_idx]; + // if the table is complete and exists its shared mem we get the info about users lacc + + if ($table_cur->player_n == PLAYERS_N) { + log_main("PLAYERS == N TABLE ".$table_idx); + + if (($sem = Briskin5::lock_data($table_idx)) != FALSE) { + log_main("bin5 lock data success"); + + $no_recovery = FALSE; + if (($bri = &Briskin5::load_data($table_idx)) != FALSE) { + if ($table_cur->table_token != $bri->table_token) { + log_main("ERROR: not matching table_token. Room: ".$table_cur->table_token." Table: ".$bri->table_token); + log_main("ERROR: not matching table_start. Room: ".$table_cur->table_start." Table: ".$bri->table_start); + $no_recovery = TRUE; + $bri = FALSE; + } + } + + if ($bri != FALSE) { + // + // SPAWN: JOIN + // + log_main("garbage_manager: bri loaded successfully."); + $bri->garbage_manager(TRUE); + + $bri_table = &$bri->table[0]; + + // is the end of the table + if ($bri->the_end == TRUE) { + /* + * DESTROY OF FINISHED TABLE && MOVE PLAYER TO ROOM AGAIN + */ + log_main("garbage_manager: INSIDE THE END."); + + for ($i = 0 ; $i < $bri_table->player_n ; $i++) { + // stat must be "table" by definition + $user_cur =& $this->user[$table_cur->player[$i]]; + $bri_user =& $bri->user[$i]; + + $user_cur->subst = $bri_user->subst; + $user_cur->step = $bri_user->step; + $user_cur->lacc = $bri_user->lacc; + $user_cur->laccwr = $bri_user->lacc; + $user_cur->bantime = $bri_user->bantime; + } + + $this->room_join_wakeup(&$user_cur, FALSE, 0); + $table_cur->table_token = ""; + $table_cur->wakeup_time = $curtime + WAKEUP_TIME; + Briskin5::destroy_data($table_idx); + } + else { + log_main("gm:: save_data"); + + for ($i = 0 ; $i < $bri_table->player_n ; $i++) { + $this->user[$table_cur->player[$i]]->lacc = $bri->user[$i]->lacc; + } + + Briskin5::save_data(&$bri); + } + } // else if (($bri = &Briskin5::load_data($table_idx)) != FALSE) { + else if ($no_recovery == FALSE) { + log_crit("ERROR: table ".$table_idx." unrecoverable join"); + + for ($i = 0 ; $i < $table_cur->player_n ; $i++) { + $user_cur = &$this->user[$table_cur->player[$i]]; + $user_cur->subst = "shutdowner"; + $user_cur->step_inc(); + + $ret = sprintf('stat = "%s"; subst = "%s";', $user_cur->stat, $user_cur->subst); + $ret .= "gst.st = ".($user_cur->step+1)."; "; + $ret .= show_notify("
I dati del tavolo n° ".$user_cur->table." sono inconsistenti, verranno resettati.

Torni in piedi.

", 2000, "Chiudi.", 400, 110); + $user_cur->comm[$user_cur->step % COMM_N] = $ret; + $user_cur->step_inc(); + } + + $this->room_join_wakeup(&$user_cur, TRUE, -2); + $table_cur->table_token = ""; + } + + Briskin5::unlock_data($sem); + } // bri::lock_data + } // if ($table_cur->player_n == PLAYERS_N) { + } // for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { + + log_rd2("out new loop."); + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { $user_cur = &$this->user[$i]; - if ($user_cur->sess == "") + + log_rd2("User: ".$user_cur->name." stat: ".$user_cur->stat." subst: ".$user_cur->subst); + + if ($user_cur->sess == "") continue; - if ($user_cur->lacc + EXPIRE_TIME_RD < $curtime) { // Auto logout dell'utente - log_rd2($user_cur->sess, "AUTO LOGOUT."); - + if ($user_cur->lacc + EXPIRE_TIME_RD < $curtime) { + // Auto logout dell'utente + log_rd2("AUTO LOGOUT.".($user_cur->lacc + EXPIRE_TIME_RD)." curtime ".$curtime); + if ($user_cur->stat == 'table' || $user_cur->stat == 'room') { log_auth($user_cur->sess, "Autologout session."); + $user_cur->reset(); + /* factorized with ->reset() $tmp_sess = $user_cur->sess; $user_cur->sess = ""; step_unproxy($tmp_sess); $user_cur->name = ""; + while (array_pop($user_cur->comm) != NULL); + $user_cur->step = 0; $user_cur->the_end = FALSE; + */ - log_rd2($user_cur->sess, "AUTO LOGOUT."); + log_rd2("AUTO LOGOUT."); if ($user_cur->subst == 'sitdown' || $user_cur->stat == 'table') $this->room_wakeup(&$user_cur); else if ($user_cur->subst == 'standup') $this->room_outstandup(&$user_cur); else - log_rd2($sess, "LOGOUT FROM WHAT ???"); + log_rd2("LOGOUT FROM WHAT ???"); } } @@ -711,32 +947,63 @@ class Room { } } } - log_rd2($user_cur->sess, "GARBAGE UPDATED!"); + log_rd2("GARBAGE UPDATED!"); $this->garbage_timeout = time() + GARBAGE_TIMEOUT; + $ismod = TRUE; } - // BAN_IP_CLEAN - + return ($ismod); } + function show_room($user_step, &$user) + { + log_main("show_room: username: ".$user->name); + + + $ret = sprintf('gst.st = %d; ', $user_step); + if ($user->subst == 'standup') + $ret .= "tra.show(); "; + else + $ret .= "tra.hide(); "; + + $ret .= sprintf('stat = "%s";', $user->stat); + + $ret .= root_wellcome($user); + $ret .= sprintf('subst = "%s";', $user->subst); + $ret .= sprintf('$("myname").innerHTML = "%s";', xcape($user->name)); + for ($i = 0 ; $i < TABLES_N ; $i++) { + $ret .= $this->table_content($user, $i); + $act_content = table_act_content(($user->subst == 'standup'), + $this->table[$i]->player_n, $i, $user->table); + $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $i, $act_content); + if ($this->table[$i]->wag_own != NULL) + $ret .= sprintf('tra.add(%d, "%s: %s"); ', $i, $this->table[$i]->wag_own->name, $this->table[$i]->wag_com); + else + $ret .= sprintf('tra.rem(%d); ', $i); + } + $ret .= $this->standup_content($user); + + return ($ret); + } + function room_wakeup(&$user) { $table_idx = $user->table; $table = &$this->table[$table_idx]; - log_main("WAKEUP", "begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); + log_main("WAKEUP: begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); $curtime = time(); $from_table = ($user->stat == "table"); if ($from_table) { - log_main("WAKEUP", "from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n); + log_main("WAKEUP: from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n); for ($i = 0 ; $i < $table->player_n ; $i++) { $user_cur = &$this->user[$table->player[$i]]; - log_main("PREIMPOST", "INLOOP name: ".$user_cur->name); + log_main("PREIMPOST: INLOOP name: ".$user_cur->name); if ($user_cur != $user) { $user_cur->stat_set("room"); @@ -756,6 +1023,15 @@ class Room { $user->subst = "standup"; $user->laccwr = $curtime; } + + $remove_wagon = false; + if($table->wag_own == $user) { + $remove_wagon = true; + $table->wag_reset($curtime); + + } + + /* aggiorna l'array dei giocatori al tavolo. */ $table->user_rem(&$this, &$user); @@ -764,19 +1040,19 @@ class Room { if ($user_cur->sess == '' || $user_cur->stat != 'room') continue; - log_main("VALORI", "name: ".$user_cur->name."from_table: ".$from_table." tab: ".$user_cur->table." taix: ".$table_idx." ucur: ".$user_cur." us: ".$user); + log_main("VALORI: name: ".$user_cur->name."from_table: ".$from_table." tab: ".$user_cur->table." taix: ".$table_idx." ucur: ".$user_cur." us: ".$user); - $ret = "gst.st = ".($user_cur->step+1)."; "; + $ret = "gst.st = ".($user_cur->step+1)."; ".($remove_wagon ? sprintf("tra.rem(%d);",$table_idx) : ""); if ($from_table && ($user_cur->table == $table_idx || $user_cur == $user)) { $ret .= 'gst.st_loc++; the_end=true; window.onunload = null; document.location.assign("index.php");|'; // $ret .= 'gst.st_loc++; document.location.assign("index.php");|'; - log_main("DOCUMENT.index.php", "from table"); + log_main("DOCUMENT.index.php: from table"); } else if ($user_cur->stat == "room") { - log_main("DOCUMENT.index.php", "from table"); + log_main("DOCUMENT.index.php: from table"); - $ret .= table_content($this, $user_cur, $table_idx); - $ret .= standup_content($this, $user_cur); + $ret .= $this->table_content($user_cur, $table_idx); + $ret .= $this->standup_content($user_cur); $act_content = table_act_content(FALSE, 0, $table_idx, $user->table); $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $table_idx, $act_content); @@ -784,7 +1060,7 @@ class Room { if ($user_cur == $user) { // set the new status - $ret .= 'subst = "standup"; '; + $ret .= 'subst = "standup"; tra.show(); '; // clean the action buttons in other tables for ($e = 0 ; $e < TABLES_N ; $e++) { if ($this->table[$e]->player_n < PLAYERS_N) @@ -796,30 +1072,34 @@ class Room { $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $table_idx, $act_content); } } - log_wr($user_cur->sess, "ROOM_WAKEUP: ".$ret); + log_wr("ROOM_WAKEUP: ".$ret); $user_cur->comm[$user_cur->step % COMM_N] = $ret; $user_cur->step_inc(); } } - function room_join_wakeup(&$user) + function room_join_wakeup(&$user, $update_lacc = FALSE, $trans_delta) { $table_idx = $user->table; $table = &$this->table[$table_idx]; - - log_main($user->sess, "JOIN_WAKEUP: begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); + + log_main("JOIN_WAKEUP: begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); $curtime = time(); $user_wup = array(); $user_wup_n = 0; - log_main($user->sess, "JOIN WAKEUP: from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n); + $user_tab = array(); + $user_tab_n = 0; + log_main("JOIN WAKEUP: from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n); for ($i = 0 ; $i < $table->player_n ; $i++) { $user_cur = &$this->user[$table->player[$i]]; - log_main($user->sess, "PREIMPOST INLOOP name: ".$user_cur->name); + log_main("PREIMPOST INLOOP name: ".$user_cur->name); if ($user_cur->sess != "") { - $user_cur->laccwr = $curtime; - log_load($user->sess, "cur: ".$user_cur->name." subst: ".$user_cur->subst); + if ($update_lacc == TRUE) { + $user_cur->laccwr = $curtime; + } + log_main("cur: ".$user_cur->name." subst: ".$user_cur->subst); if ($user_cur->subst == "shutdowned") { $user_cur->stat_set("room"); $user_cur->subst = "sitdown"; @@ -829,7 +1109,14 @@ class Room { $user_cur->subst = "standup"; $user_cur->table = -1; $user_wup[$user_wup_n++] = &$user_cur; + + $remove_wagon = false; + if($table->wag_own == $user_cur) { + $remove_wagon = true; + $table->wag_reset($curtime); + } } + $user_tab[$user_tab_n++] = &$user_cur; } } @@ -839,51 +1126,55 @@ class Room { /* aggiorna l'array dei giocatori al tavolo. */ for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - log_main($user_cur->sess, "START LOOP"); + log_main("START LOOP"); $user_cur = &$this->user[$i]; if ($user_cur->sess == '' || $user_cur->stat != 'room') { - log_main($user_cur->sess, "name: ".$user_cur->name."skip subst: ".$user_cur->subst); + log_main("name: ".$user_cur->name."skip subst: ".$user_cur->subst); continue; } - log_main($user->sess, "___"); - log_main($user->sess, "VALORI name: ".$user_cur->name." tab: ".$user_cur->table." taix: ".$table_idx." ucur: ".$user_cur." us: ".$user); + log_main("___"); + log_main("VALORI name: ".$user_cur->name." tab: ".$user_cur->table." taix: ".$table_idx." ucur: ".$user_cur." us: ".$user); - $ret = "gst.st = ".($user_cur->step+1)."; "; + $ret = "gst.st = ".($user_cur->step+1)."; ".($remove_wagon ? sprintf("tra.rem(%d);",$table_idx) : ""); if ($user_cur->stat == "room") { - log_main($user->sess, "DOCUMENT.index.php from table"); + log_main("DOCUMENT.index.php from table"); - $ret .= table_content($this, $user_cur, $table_idx); - $ret .= standup_content($this, $user_cur); + $ret .= $this->table_content($user_cur, $table_idx); + $ret .= $this->standup_content($user_cur); $act_content = table_act_content(FALSE, 0, $table_idx, $user_cur->table); $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $table_idx, $act_content); - for ($wup_idx = 0 ; $wup_idx < $user_wup_n ; $wup_idx++) - if ($user_cur == $user_wup[$wup_idx]) + for ($tab_idx = 0 ; $tab_idx < $user_tab_n ; $tab_idx++) + if ($user_cur == $user_tab[$tab_idx]) break; - log_main($user->sess, "JOIN_WAKEUP wup_idx ".$wup_idx." wup_n ".$user_wup_n); + // for users that wakeup the room will be reconstructed by index_rd.php + if ($tab_idx < $user_tab_n) { + log_main("PRE show_room username: ".$user_cur->name." STEP: ".$user_cur->step); - if ($wup_idx < $user_wup_n) { - log_main($user->sess, "JOIN_WAKEUP less"); - // set the new status - $ret .= 'subst = "standup"; '; - // clean the action buttons in other tables - for ($e = 0 ; $e < TABLES_N ; $e++) { - if ($this->table[$e]->player_n < PLAYERS_N) - $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $e, table_act_content(TRUE, 0, $e, $user_cur->table)); - } - log_main($user->sess, "JOIN_WAKEUP end less"); - } - else { - log_main($user->sess, "JOIN_WAKEUP more"); - $act_content = table_act_content(($user_cur->subst == 'standup'), $table->player_n, $table_idx, $user_cur->table); - $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $table_idx, $act_content); - log_main($user->sess, "JOIN_WAKEUP end more"); +// ARRAY_POP DISABLED +// if ($trans_delta == 0) +// while (array_pop($user_cur->comm) != NULL); + + $user_cur->trans_step = $user_cur->step + 1 + $trans_delta; + $user_cur->comm[$user_cur->step % COMM_N] = ""; + $user_cur->step_inc(); + $user_cur->comm[$user_cur->step % COMM_N] = $this->show_room(($user_cur->step + 1), &$user_cur); + $user_cur->step_inc(); + log_main("POST show_room username: ".$user_cur->name." STEP: ".$user_cur->step); + + continue; } + log_main("JOIN_WAKEUP wup_idx ".$wup_idx." wup_n ".$user_wup_n); + + log_main("JOIN_WAKEUP more"); + $act_content = table_act_content(($user_cur->subst == 'standup'), $table->player_n, $table_idx, $user_cur->table); + $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $table_idx, $act_content); + log_main("JOIN_WAKEUP end more"); } - log_wr($user->sess, "ROOM_JOIN_WAKEUP: ".$ret); + log_wr("ROOM_JOIN_WAKEUP: ".$ret); $user_cur->comm[$user_cur->step % COMM_N] = $ret; $user_cur->step_inc(); } @@ -896,7 +1187,7 @@ class Room { function table_update(&$user) { - log_main("table_update", "pre - USER: ".$user->name); + log_main("table_update: pre - USER: ".$user->name); $table_idx = $user->table; @@ -911,7 +1202,7 @@ class Room { $ret = "gst.st = ".($user_cur->step+1)."; "; if ($table_idx > -1) - $ret .= table_content($this, $user_cur, $table_idx); + $ret .= $this->table_content($user_cur, $table_idx); if ($user_cur == $user) { $ret .= sprintf('$("myname").innerHTML = "%s: ";', xcape($user->name)); @@ -920,29 +1211,44 @@ class Room { $user_cur->step_inc(); } - log_main("table_update", "post"); + log_main("table_update: post"); } function room_sitdown(&$user, $table_idx) { - log_main("room_sitdown", ($user == FALSE ? "USER: FALSE" : "USER: ".$user->name)); + log_main("room_sitdown ".($user == FALSE ? "USER: FALSE" : "USER: ".$user->name)); - if ($table_idx > -1) + $train_app = ""; + + if ($table_idx > -1 && $table_idx < TABLES_N) { $table = &$this->table[$table_idx]; - + + // wagon shutdown + if ($table->wag_own != NULL && $table->player_n == PLAYERS_N) { + for ($i = 0 ; $i < TABLES_N ; $i++) { + $user_cur =& $this->user[$table->player[$i]]; + if ($user_cur == $table->wag_own) { + $train_app = sprintf("tra.rem(%d); ", $table_idx); + $table->wag_reset(time()); + break; + } + } + } + } + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { $ret = ""; $user_cur = &$this->user[$i]; if ($user_cur->sess == '' || $user_cur->stat != 'room') continue; - $ret = "gst.st = ".($user_cur->step+1)."; "; + $ret = "gst.st = ".($user_cur->step+1)."; ".$train_app; if ($table_idx > -1) - $ret .= table_content($this, $user_cur, $table_idx); - $ret .= standup_content($this, $user_cur); + $ret .= $this->table_content($user_cur, $table_idx); + $ret .= $this->standup_content($user_cur); if ($user_cur == $user) { - $ret .= 'subst = "sitdown"; '; + $ret .= 'subst = "sitdown"; tra.hide(); '; // clean the action buttons in other tables for ($e = 0 ; $e < TABLES_N ; $e++) { $act_content = table_act_content(FALSE, 0, $e, $user_cur->table); @@ -962,105 +1268,227 @@ class Room { function chatt_send(&$user, $mesg) { - if ($user->stat == 'table') { - $table = &$this->table[$user->table]; - } - - $user_mesg = substr($mesg,6); + GLOBAL $G_alarm_passwd; + $only_you = FALSE; + // common settings + $msg = substr($mesg,6); $timecur = time(); - $dt = date("H:i ", $timecur); - if (strncmp($user_mesg, "/nick ", 6) == 0) { - log_main($user->sess, "chatt_send BEGIN"); - if (($name_new = validate_name(substr($user_mesg, 6))) == FALSE) { - $user->comm[$user->step % COMM_N] = "gst.st = ".($user->step+1)."; "; - $user->comm[$user->step % COMM_N] .= sprintf('chatt_sub("%s","Il nickname deve contenere almeno una lettera o una cifra.");', $dt.NICKSERV, xcape($name_new)); - $user->step_inc(); + // + // Compute actions + // + + $to_user = FALSE; + $to_all = FALSE; + $to_room = FALSE; + $to_tabl = FALSE; + $update_room = FALSE; + + if (strcmp($msg, "/tav") == 0 || + strncmp($msg, "/tav ", 5) == 0) { + do { + if ($user->stat != 'room' || $user->subst != 'sitdown') { + $msg = "
Per attivare il messaggio di segnalazione del tavolo occorre essere seduti.

"; + $to_user = show_notify($msg, 0, "chiudi", 400, 100); + + break; + } + + $table = &$this->table[$user->table]; + + if ($table->wag_own != NULL) { + $msg = "
Il messaggio di segnalazione del tavolo è già attivato.

"; + $to_user = show_notify($msg, 0, "chiudi", 400, 100); + + break; + } + + $dtime = $timecur - $table->wag_tout; + if ($dtime < EXPIRE_TIME_WAG) { + $msg = sprintf("
Il messaggio di segnalazione del tavolo
è disattivato ancora per %d second%s.

", + EXPIRE_TIME_WAG - $dtime, (EXPIRE_TIME_WAG - $dtime == 1 ? "o" : "i")); + $to_user = show_notify($msg, 0, "chiudi", 400, 100); + + break; + } + + $msg = substr($msg, 5); + + $table->wag_set($user, $msg); + $to_user = sprintf('tra.add(%d, "%s");', $user->table, xcape(sprintf("%s: %s", $user->name, $msg))); + $to_room = $to_user; + + } while (0); + } // /tav chat command + + else if (strncmp($msg, "/alarm ", 7) == 0) { + $alarm_check = "/alarm ".$G_alarm_passwd." "; + do { + if (strncmp($msg, $alarm_check, strlen($alarm_check)) != 0) { + $msg = "
La password digitata non è corretta.

"; + $to_user = show_notify($msg, 0, "chiudi", 400, 100); + + break; + } + + $to_user = sprintf('chatt_sub("%s","Alarm %s inviato a tutti.");', + $dt.NICKSERV, xcape(substr($msg, strlen($alarm_check)))); + + // $msg = "
".$dt.NICKSERV."

".xcape(substr($msg, strlen($alarm_check)))."


"; + $msg = sprintf("
%s%s

%s


", + $dt, NICKSERV, xcape(substr($msg, strlen($alarm_check)))); + $to_all = show_notify($msg, 0, "chiudi", 400, 120); + } while (0); + } // /alarm chat command + + else if (strncmp($msg, "/nick ", 6) == 0) { + log_main("chatt_send BEGIN"); + + do { + if (($name_new = validate_name(substr($msg, 6))) == FALSE) { + $to_user = sprintf('chatt_sub("%s","Il nickname deve contenere almeno una lettera o una cifra.");', $dt.NICKSERV, xcape($name_new)); + break; + } + + $msg = "COMMAND ".$msg; + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + $user_cur = &$this->user[$i]; + + if ($user_cur->sess == '') + continue; + if ($user_cur->name == $name_new) + break; + } + if ($i < MAX_PLAYERS) { + $to_user = sprintf('chatt_sub("%s","Nickname %s già in uso.");', $dt.NICKSERV, xcape($name_new)); + break; + } + + $user->name = $name_new; + + log_main("chatt_send start set"); + + $update_room = TRUE; + } while (0); + } // nick chat command + + else { // normal chat line + if ($timecur < ($user->chat_ban + $user->chat_dlt)) { + $only_you = TRUE; + $user->chat_dlt = $user->chat_dlt * 2; + if ($user->chat_dlt > 120) + $user->chat_dlt = 120; + } + else if ($user->chat_lst == $msg) + $only_you = TRUE; + else if ($timecur - $user->chattime[($user->chat_cur + 1) % CHAT_N] < CHAT_ILL_TIME) { + $user->chat_ban = $timecur; + $user->chat_dlt = 5; + $only_you = TRUE; + } + else { + $user->chat_ban = 0; + $user->chat_dlt = 0; + } - return; + if ($only_you) { + $to_user = sprintf('chatt_sub("%s","%s");', $dt.xcape($user->name), xcape("== chat ban ==")); } - $user_mesg = "COMMAND ".$user_mesg; - // Search dup name - // change - // update local graph - // update remote graphs - for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - $user_cur = &$this->user[$i]; - // if ($user_cur->sess == '' || $user_cur->stat != 'room') - if ($user_cur->sess == '') - continue; - if ($user_cur->name == $name_new) { - $user->comm[$user->step % COMM_N] = "gst.st = ".($user->step+1)."; "; - $user->comm[$user->step % COMM_N] .= sprintf('chatt_sub("%s","Nickname %s già in uso.");', $dt.NICKSERV, xcape($name_new)); - $user->step_inc(); - break; - } + else { + $to_user = sprintf('chatt_sub("%s","%s");', $dt.xcape($user->name), xcape($msg)); + $to_room = $to_user; } - if ($i == MAX_PLAYERS) { - $user->name = $name_new; - log_main($user->sess, "chatt_send start set"); - + log_legal($timecur, $user->sess, $user->name, + ($user->stat == 'room' ? 'room' : 'table '.$user->table),$msg); + + $user->chat_lst = "$msg"; + $user->chattime[$user->chat_cur % CHAT_N] = $timecur; + $user->chat_cur++; + } - for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - log_main($user->sess, "chatt_send set loop"); - - $user_cur = &$this->user[$i]; - if ($user_cur->sess == '') - continue; - if ($user_cur->stat == 'room') { - if ($user->stat == 'room' && $user->subst == 'standup') { - $this->standup_update(&$user); - } - else if ($user->stat == 'room' && $user->subst == 'sitdown' || - $user->stat == 'table') { - log_main($user->sess, "chatt_send pre table update"); + if ($to_all) { + $to_room = $to_all; + $to_tabl = $to_all; + } - $this->table_update(&$user); + // + // Output to clients + // - log_main($user->sess, "chatt_send post table update"); - } - } - else if ($user_cur->stat == 'table' && $user_cur->table == $user->table) { - $table = &$this->table[$user->table]; - - $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; "; - $user_cur->comm[$user_cur->step % COMM_N] .= sprintf('set_names(" %s", " %s", " %s", " %s", " %s"); ', - xcape($this->user[$table->player[($user_cur->table_pos)%PLAYERS_N]]->name), - xcape($this->user[$table->player[($user_cur->table_pos+1)%PLAYERS_N]]->name), - xcape($this->user[$table->player[($user_cur->table_pos+2)%PLAYERS_N]]->name), - (PLAYERS_N == 3 ? "" : xcape($this->user[$table->player[($user_cur->table_pos+3)%PLAYERS_N]]->name)), - (PLAYERS_N == 3 ? "" : xcape($this->user[$table->player[($user_cur->table_pos+4)%PLAYERS_N]]->name))); - if ($user_cur == $user) - $user_cur->comm[$user_cur->step % COMM_N] .= sprintf('$("myname").innerHTML = "%s";', - xcape($user->name,ENT_COMPAT,"UTF-8")); - $user_cur->step_inc(); - } - } - } + if ($to_user != FALSE) { + $user->comm[$user->step % COMM_N] = "gst.st = ".($user->step+1)."; "; + $user->comm[$user->step % COMM_N] .= $to_user; + $user->step_inc(); } - else { - for ($i = 0 ; $i < ($user->stat == 'room' ? MAX_PLAYERS : PLAYERS_N) ; $i++) { - if ($user->stat == 'room') { - $user_cur = &$this->user[$i]; - if ($user_cur->sess == '' || $user_cur->stat != 'room') - continue; - } - else { - $user_cur = &$this->user[$table->player[$i]]; - } - - $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; "; - $user_cur->comm[$user_cur->step % COMM_N] .= sprintf('chatt_sub("%s","%s");', - $dt.xcape($user->name), xcape($user_mesg)); - $user_cur->step_inc(); + + if ($to_room != FALSE) { + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + $user_cur = &$this->user[$i]; + // if ($user_cur->sess == '' || $user_cur->stat != 'room') + if ($user_cur->sess == '' || $user_cur->stat == 'table' || $user_cur == $user) + continue; + + $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; "; + $user_cur->comm[$user_cur->step % COMM_N] .= $to_room; + $user_cur->step_inc(); } - log_legal($timecur, $user->sess, $user->name, - ($user->stat == 'room' ? 'room' : 'table '.$user->table),$user_mesg); } - } + + if ($to_tabl) { + // Before all align times with table timeout + for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { + $table_cur =& $this->table[$table_idx]; + // if the table is complete and exists its shared mem we get the info about users lacc + + if ($table_cur->player_n == PLAYERS_N) { + log_main("PLAYERS == N TABLE ".$table_idx); + + if (($sem = Briskin5::lock_data($table_idx)) != FALSE) { + log_main("bin5 lock data success"); + + $no_recovery = FALSE; + if (($bri = &Briskin5::load_data($table_idx)) != FALSE) { + if ($table_cur->table_token != $bri->table_token) { + log_main("ERROR: not matching table_token. Room: ".$table_cur->table_token." Table: ".$bri->table_token); + $bri = FALSE; + } + } + + if ($bri != FALSE) { + $bri_table = &$bri->table[0]; + for ($i = 0 ; $i < $bri_table->player_n ; $i++) { + // stat must be "table" by definition + $bri_user =& $bri->user[$i]; + + log_main("writa: ".$user_mesg); + $bri_user->comm[$bri_user->step % COMM_N] = "gst.st = ".($bri_user->step+1)."; "; + $bri_user->comm[$bri_user->step % COMM_N] .= $to_tabl; + $bri_user->step_inc(); + } + Briskin5::save_data(&$bri); + } + Briskin5::unlock_data($sem); + } // bri::lock_data + } // if ($table_cur->player_n == PLAYERS_N) { + } // for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { + } // if ($to_tabl == true ... + + if ($update_room) { + if ($user->stat == 'room' && $user->subst == 'standup') { + $this->standup_update(&$user); + } + else if ($user->stat == 'room' && $user->subst == 'sitdown') { + log_main("chatt_send pre table update"); + $this->table_update(&$user); + log_main("chatt_send post table update"); + } + } // if ($update_room ... + + return; + } // function chatt_send( ... function &get_user($sess, &$idx) { @@ -1075,12 +1503,12 @@ class Room { return ($ret); } } - log_main($sess, sprintf("get_user: Wrong sess from page [%s]",$PHP_SELF)); + log_main(sprintf("get_user: Wrong sess from page [%s]",$PHP_SELF)); // for ($i = 0 ; $i < MAX_PLAYERS ; $i++) - // log_main($sess, sprintf("get_user: Wrong sess compared with [%s]",$this->user[$i]->sess)); + // log_main(sprintf("get_user: Wrong sess compared with [%s]",$this->user[$i]->sess)); } else { - log_main($sess, sprintf("get_user: Wrong strlen [%s]",$sess)); + log_main(sprintf("get_user: Wrong strlen [%s]",$sess)); } return ($G_false); @@ -1143,13 +1571,14 @@ class Room { } $this->user[$idx]->name = $name_new; $this->user[$idx]->stat_set("room"); - // MOP $this->user[$idx]->step_set(0); + $this->user[$idx]->step_set(0); + while (array_pop($this->user[$idx]->comm) != NULL); $this->user[$idx]->subst = "standup"; $this->user[$idx]->lacc = $curtime; $this->user[$idx]->laccwr = $curtime; $this->user[$idx]->bantime = 0; $this->user[$idx]->ip = $ip; - log_main("XXX", sprintf("TROVATO LIBERO A [%d] sess [%s] name [%s]", $idx, $sess, $name_new)); + log_main(sprintf("TROVATO LIBERO A [%d] sess [%s] name [%s]", $idx, $sess, $name_new)); return ($this->user[$idx]); } @@ -1164,14 +1593,14 @@ class Room { if ($user_cur->sess == '') continue; - log_main("STANDUP START", $user_cur->stat); + log_main("STANDUP START: ".$user_cur->stat); if ($user_cur->stat == 'room') { - $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; ".standup_content($this, $user_cur); + $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; ".$this->standup_content($user_cur); if ($user_cur == $user) $user_cur->comm[$user_cur->step % COMM_N] .= sprintf('$("myname").innerHTML = "%s: ";', xcape($user->name)); - log_main("FROM STANDUP", "NAME: ".$user_cur->name." SENDED: ".$user_cur->comm[$user_cur->step % COMM_N]); + log_main("FROM STANDUP: NAME: ".$user_cur->name." SENDED: ".$user_cur->comm[$user_cur->step % COMM_N]); $user_cur->step_inc(); } @@ -1190,34 +1619,47 @@ class Room { function &load_data() { GLOBAL $G_false, $sess; + $doexit = FALSE; + do { + if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) { + log_main("ftok failed"); + $doexit = TRUE; + break; + } - if (($tok = ftok(FTOK_PATH."/main", "B")) == -1) { - echo "FTOK FAILED"; - exit; - } - - if ($shm = shm_attach($tok, SHM_DIMS)) { - $room = @shm_get_var($shm, $tok); - - log_only($sess, "bri == ".($room == FALSE ? "FALSE" : "TRUE")." bri === ".($room === FALSE ? "FALSE" : "TRUE")." bri isset ".(isset($room) ? "TRUE" : "FALSE")); - if (isset($room)) - log_only($sess, "bri count ".count($room)); - - if ($room == FALSE) { - log_only($sess, "INIT MAIN DATA"); + if (($shm_sz = sharedmem_sz($tok)) == -1) { + log_main("shmop_open failed"); + } + + if ($shm_sz == -1) + $shm_sz = SHM_DIMS_MIN; + + if ($shm = shm_attach($tok, $shm_sz)) { + $room = @shm_get_var($shm, $tok); + + log_only("bri == ".($room == FALSE ? "FALSE" : "TRUE")." bri === ".($room === FALSE ? "FALSE" : "TRUE")." bri isset ".(isset($room) ? "TRUE" : "FALSE")); + if (isset($room)) + log_only("bri count ".count($room)); - $room =& Room::init_data(); - if (shm_put_var($shm, $tok, $room) == FALSE) { - log_only($sess, "PUT_VAR FALLITA ".strlen(serialize($room))); - log_only($sess, serialize($room)); + if ($room == FALSE) { + log_only("INIT MAIN DATA"); + + $room =& Room::init_data(); + if (@shm_put_var($shm, $tok, $room) == FALSE) { + log_only("PUT_VAR FALLITA ".strlen(serialize($room))); + log_only(serialize($room)); + } } + $room->shm_sz = $shm_sz; + + shm_detach($shm); } - - shm_detach($shm); - $ret = &$room; return ($ret); - } + } while (0); + + if ($doexit) + exit(); return ($G_false); } @@ -1229,29 +1671,29 @@ class Room { $ret = FALSE; $shm = FALSE; - $isacq = FALSE; // var_dump($room); - if (($tok = ftok(FTOK_PATH."/main", "B")) == -1) + if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) return (FALSE); - do { - $isacq = TRUE; - - if (($shm = shm_attach($tok, SHM_DIMS)) == FALSE) + while ($room->shm_sz < SHM_DIMS_MAX) { + if (($shm = shm_attach($tok, $room->shm_sz)) == FALSE) break; - // log_only($sess, "PUT_VAR DI ".strlen(serialize($room))); - if (shm_put_var($shm, $tok, $room) == FALSE) { - log_only($sess, "PUT_VAR FALLITA ".strlen(serialize($room))); - log_only($sess, serialize($room)); + // log_only("PUT_VAR DI ".strlen(serialize($room))); + if (shm_put_var($shm, $tok, $room) != FALSE) { + shm_detach($shm); + return (TRUE); + } + if (shm_remove($shm) === FALSE) { + log_only("REMOVE FALLITA"); break; } - // log_main("XXX", "QUI CI ARRIVA [".$room->user[0]->name."]"); - $ret = TRUE; - } while (0); - + shm_detach($shm); + $room->shm_sz += SHM_DIMS_DLT; + } + if ($shm) shm_detach($shm); @@ -1264,7 +1706,7 @@ class Room { // echo "LOCK: ".FTOK_PATH."/main"; // exit; - if (($tok = ftok(FTOK_PATH."/main", "B")) == -1) { + if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) { echo "FTOK FAILED"; exit; } @@ -1274,7 +1716,7 @@ class Room { exit; } if (sem_acquire($res)) { - log_only($sess, "LOCK"); + log_lock("LOCK room"); return ($res); } else @@ -1285,10 +1727,95 @@ class Room { { GLOBAL $sess; - log_only($sess, "UNLOCK"); + log_lock("UNLOCK room"); return (sem_release($res)); } + + function standup_content($user) + { + $ret = ""; + $content = ""; + + if ($user->stat != 'room') + return; + + for ($e = 0 , $ct = 0 ; $ct < 4 && $e < MAX_PLAYERS ; $e++) { + if ($this->user[$e]->sess == "" || $this->user[$e]->stat != "room" || $this->user[$e]->name == "") + continue; + $ct++; + } + + $content .= sprintf('', $ct); + + for ($e = 0 , $ct = 0 ; $e < MAX_PLAYERS ; $e++) { + if ($this->user[$e]->sess == "" || $this->user[$e]->stat != "room" || $this->user[$e]->name == "") + continue; + + + if ($this->user[$e]->subst == "standup") { + if (($ct % 4) == 0) { + $content .= ''; + } + if ($this->user[$e] == $user) + { $hilion = ""; $hilioff = ""; } + else + { $hilion = ""; $hilioff = ""; } + + $content .= sprintf('',$hilion, xcape($this->user[$e]->name), $hilioff); + if (($ct % 4) == 3) { + $content .= ''; + } + $ct++; + } + } + $content .= '
%s%s%s
'; + + $content2 = ''; + $ret .= sprintf('$("standup").innerHTML = "%s"; $("esco").innerHTML = "%s";', + $content, $content2); + + return ($ret); + } + + function table_content($user, $table_idx) + { + $content = ""; + $ret = ""; + // TODO + // + // Si possono usare i dati nella classe table + // + + $sess = $user->sess; + $table = &$this->table[$table_idx]; + + if ($user->stat != 'room') + return; + + for ($i = 0 ; $i < $table->player_n ; $i++) { + $user_cur = &$this->user[$table->player[$i]]; + + if ($user_cur == $user) + { $hilion = ""; $hilioff = ""; } + else + { $hilion = ""; $hilioff = ""; } + + log_main($user_cur->name. sprintf(" IN TABLE [%d]", $table_idx)); + + $content .= sprintf("%s%s%s
",$hilion, xcape($user_cur->name), $hilioff); + } + /* + for ( ; $i < PLAYERS_N ; $i++) + $content .= "
"; + */ + + $ret .= sprintf('$("table%d").innerHTML = "%s";', $table_idx, $content); + + return ($ret); + } + + } // end class Room function make_seed() @@ -1297,113 +1824,226 @@ function make_seed() return (float) $sec + ((float) $usec * 100000); } -function log_only2($sess, $log) { - if (BRISK_DEBUG != TRUE) + +function log_only2($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONL2) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONL2) == 0) return; - - if (($fp = @fopen("/tmp/brisk_only2.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("ONL2: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_only($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_crit($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_CRIT) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_CRIT) == 0) return; - - if (($fp = @fopen("/tmp/brisk_only.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("CRIT: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_main($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_only($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONLY) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONLY) == 0) return; - if (($fp = @fopen("/tmp/brisk_main.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("ONLY: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_rd($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_main($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_MAIN) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_MAIN) == 0) return; - if (($fp = @fopen("/tmp/brisk_rd.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("MAIN: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_rd2($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_rd($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_READ) == 0) return; - if (($fp = @fopen("/tmp/brisk_rd2.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_READ) == 0) + return; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("READ: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_send($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_rd2($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_REA2) == 0) return; - if (($fp = @fopen("/tmp/brisk_send.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_REA2) == 0) + return; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("REA2: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_auth($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_send($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_SEND) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_SEND) == 0) return; - if (($fp = @fopen("/tmp/brisk_auth.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%d] [%s] [%s]\n", time(), $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("SEND: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_lock($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_lock($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOCK) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LOCK) == 0) return; - if (($fp = @fopen("/tmp/brisk_lock.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%d] [%s] [%s]\n", time(), $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LOCK: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_wr($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_wr($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_WRIT) == 0) return; - if (($fp = @fopen("/tmp/brisk_wr.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_WRIT) == 0) + return; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("WRIT: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_load($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_load($log) { + GLOBAL $sess; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOAD) == 0) return; - if (($fp = @fopen("/tmp/brisk_load.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LOAD) == 0) + return; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LOAD: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } +function log_auth($sess, $log) { + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_AUTH) == 0) + return; + + if (( (BRISK_DEBUG | ($sess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_AUTH) == 0) + return; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("AUTH: [%s] [%d] [%s]\n", $sess, time(), $log)); + fclose($fp); + } +} + + function log_legal($timecur, $sess, $name, $where, $mesg) { GLOBAL $_SERVER; - if (($fp = @fopen(LEGAL_PATH, 'a')) != FALSE) { + if (($fp = @fopen(LEGAL_PATH."/legal.log", 'a')) != FALSE) { /* Unix time | session | nickname | IP | where was | mesg */ fwrite($fp, sprintf("%ld|%s|%s|%s|%s|%s|\n", $timecur, $sess, $name, $_SERVER['REMOTE_ADDR'], $where , $mesg)); fclose($fp); @@ -1415,7 +2055,7 @@ function log_legal($timecur, $sess, $name, $where, $mesg) function lock_banlist() { - if (($tok = ftok(FTOK_PATH."/main", "L")) == -1) { + if (($tok = @ftok(FTOK_PATH."/main", "L")) == -1) { echo "FTOK FAILED"; exit; } @@ -1452,93 +2092,10 @@ function table_act_content($isstanding, $sitted, $table, $cur_table) return ($ret); } -function table_content($room, $user, $table_idx) -{ - $content = ""; - $ret = ""; - // TODO - // - // Si possono usare i dati nella classe table - // - - $sess = $user->sess; - $table = &$room->table[$table_idx]; - - if ($user->stat != 'room') - return; - - for ($i = 0 ; $i < $table->player_n ; $i++) { - $user_cur = &$room->user[$table->player[$i]]; - - if ($user_cur == $user) - { $hilion = ""; $hilioff = ""; } - else - { $hilion = ""; $hilioff = ""; } - - log_main($user_cur->name, sprintf("IN TABLE [%d]", $table_idx)); - - $content .= sprintf("%s%s%s
",$hilion, xcape($user_cur->name), $hilioff); - } - /* - for ( ; $i < PLAYERS_N ; $i++) - $content .= "
"; - */ - - $ret .= sprintf('$("table%d").innerHTML = "%s";', $table_idx, $content); - - return ($ret); -} - -function standup_content(&$room, $user) -{ - $ret = ""; - $content = ""; - - if ($user->stat != 'room') - return; - - for ($e = 0 , $ct = 0 ; $ct < 4 && $e < MAX_PLAYERS ; $e++) { - if ($room->user[$e]->sess == "" || $room->user[$e]->stat != "room" || $room->user[$e]->name == "") - continue; - $ct++; - } - - $content .= sprintf('', $ct); - - for ($e = 0 , $ct = 0 ; $e < MAX_PLAYERS ; $e++) { - if ($room->user[$e]->sess == "" || $room->user[$e]->stat != "room" || $room->user[$e]->name == "") - continue; - - - if ($room->user[$e]->subst == "standup") { - if (($ct % 4) == 0) { - $content .= ''; - } - if ($room->user[$e] == $user) - { $hilion = ""; $hilioff = ""; } - else - { $hilion = ""; $hilioff = ""; } - - $content .= sprintf('',$hilion, xcape($room->user[$e]->name), $hilioff); - if (($ct % 4) == 3) { - $content .= ''; - } - $ct++; - } - } - $content .= '
%s%s%s
'; - - $content2 = ''; - $ret .= sprintf('$("standup").innerHTML = "%s"; $("esco").innerHTML = "%s";', - $content, $content2); - - return ($ret); -} - function show_notify($text, $tout, $butt, $w, $h) { - log_main("SHOW_NOTIFY", $text); + log_main("SHOW_NOTIFY: ".$text); return sprintf('var noti = new notify(gst,"%s",%d,"%s",%d,%d);', $text, $tout, $butt, $w, $h); } @@ -1612,7 +2169,7 @@ function show_table_info(&$room, &$table, $table_pos) $noty .= sprintf(""); // Points. - log_main("show_table_info", "pnt_min: ".$pnt_min." Points_n: ".$table->points_n); + log_main("show_table_info: pnt_min: ".$pnt_min." Points_n: ".$table->points_n); for ($i = $pnt_min ; $i < $table->points_n ; $i++) { $noty .= sprintf('%d', $i+1); @@ -1706,8 +2263,11 @@ function root_wellcome($user) GLOBAL $root_wellarr; $ret = ""; + $timecur = time(); + $dt = date("H:i ", $timecur); + for ($i = 0 ; $i < count($root_wellarr) ; $i++) - $ret .= sprintf('chatt_sub("ChanServ: ","%s");', str_replace('"', '\"', $root_wellarr[$i])); + $ret .= sprintf('chatt_sub("%s","%s");', $dt.NICKSERV, str_replace('"', '\"', $root_wellarr[$i])); return ($ret); } @@ -1723,25 +2283,6 @@ function table_wellcome($user) return ($ret); } -function show_room(&$room, &$user) -{ - $ret = sprintf('gst.st = %d;', $user->step); - $ret .= sprintf('stat = "%s";', $user->stat); - - $ret .= root_wellcome($user); - $ret .= sprintf('subst = "%s";', $user->subst); - $ret .= sprintf('$("myname").innerHTML = "%s";', xcape($user->name,ENT_COMPAT,"UTF-8")); - for ($i = 0 ; $i < TABLES_N ; $i++) { - $ret .= table_content($room, $user, $i); - $act_content = table_act_content(($user->subst == 'standup'), - $room->table[$i]->player_n, $i, $user->table); - $ret .= sprintf('$("table_act%d").innerHTML = "%s";', $i, $act_content); - } - $ret .= standup_content($room, $user); - - return ($ret); -} - /* show table @@ -1766,11 +2307,15 @@ function show_table(&$room, &$user, $sendstep, $is_transition, $is_again) /* GENERAL STATUS */ $ret .= sprintf( 'gst.st = %d; stat = "%s"; subst = "%s"; table_pos = %d;', $sendstep, $user->stat, $user->subst, $table_pos); + + log_rd(sprintf( 'SHOW_TABLE: gst.st = %d; stat = "%s"; subst = "%s"; table_pos = %d;', + $sendstep, $user->stat, $user->subst, $table_pos)); + /* BACKGROUND */ $ret .= "background_set();"; /* USERS INFO */ - $ret .= sprintf('$("myname").innerHTML = "%s";', xcape($user->name,ENT_COMPAT,"UTF-8")); + $ret .= sprintf('$("myname").innerHTML = "%s";', xcape($user->name)); $ret .= sprintf('set_names(" %s", " %s", " %s", " %s", " %s"); ', xcape($room->user[$table->player[($table_pos)%PLAYERS_N]]->name), xcape($room->user[$table->player[($table_pos+1)%PLAYERS_N]]->name), @@ -1804,7 +2349,7 @@ function show_table(&$room, &$user, $sendstep, $is_transition, $is_again) break; } } - log_rd($user->sess, "O ".$o." VAL ".$table->card[$o]->value." Owner: ".$table->card[$o]->owner); + log_rd("O ".$o." VAL ".$table->card[$o]->value." Owner: ".$table->card[$o]->owner); $ret .= sprintf( ' card_send(%d,%d,%d,%8.2f,%d);|', ($table->gstart + $e) % PLAYERS_N, $i, ((($e + PLAYERS_N - $table_pos + $table->gstart) % PLAYERS_N) == 0 ? @@ -1827,7 +2372,7 @@ function show_table(&$room, &$user, $sendstep, $is_transition, $is_again) $inhand[$table->card[$i]->owner]++; } else if ($table->card[$i]->stat == 'take') { - log_main("Card taked:", $table->card[$i]->value."OWN: ".$table->card[$i]->owner); + log_main("Card taked: ".$table->card[$i]->value."OWN: ".$table->card[$i]->owner); $taked[$table->card[$i]->owner]++; } else if ($table->card[$i]->stat == 'table') { @@ -1838,7 +2383,7 @@ function show_table(&$room, &$user, $sendstep, $is_transition, $is_again) for ($i = 0 ; $i < PLAYERS_N ; $i++) { $logg .= sprintf("INHAND: %d IN TABLE %d TAKED %d\n", $inhand[$i], $ontabl[$i], $taked[$i]); } - log_main("Stat table:", $logg); + log_main("Stat table: ".$logg); /* Set ours cards. */ $oursarg = ""; @@ -1933,7 +2478,7 @@ function calculate_winner(&$table) if ($table->card[$i]->stat != "table") continue; - log_wr($sess, sprintf("Card On table: [%d]", $i)); + log_wr(sprintf("Card On table: [%d]", $i)); $v = $table->card[$i]->value; $ontab[$table->card[$i]->owner] = $v; @@ -1986,7 +2531,7 @@ function calculate_points(&$table) $pro += $G_all_points[$ctt]; } - log_wr("XXX", sprintf("PRO: [%d]", $pro)); + log_wr(sprintf("PRO: [%d]", $pro)); if ($table->asta_pnt == 61 && $pro == 60) { // PATTA ! @@ -2014,11 +2559,11 @@ function calculate_points(&$table) else $pt = -1; - log_wr("XXX", sprintf("PRO: pt[%d][%d] = %d", $table->points_n % MAX_POINTS, $i, $pt)); + log_wr(sprintf("PRO: pt[%d][%d] = %d", $table->points_n % MAX_POINTS, $i, $pt)); $pt = $pt * $sig * $table->mult * ($pro == 120 ? 2 : 1); - log_wr("XXX", sprintf("PRO:[%d][%d][%d]", $sig, $table->mult, ($pro == 120 ? 2 : 1))); + log_wr(sprintf("PRO:[%d][%d][%d]", $sig, $table->mult, ($pro == 120 ? 2 : 1))); $table->points[$table->points_n % MAX_POINTS][$i] = $pt; $table->total[$i] += $pt; @@ -2067,4 +2612,18 @@ function secstoword($secs) return ($ret); } +function sharedmem_sz($tok) +{ + if (($shm_id = @shmop_open($tok, 'a', 0, 0)) == FALSE) { + log_main("shmop_open failed"); + return (-1); + } + $shm_sz = shmop_size($shm_id); + shmop_close($shm_id); + + log_main("shm_sz: ".$shm_sz." SHM_DIMS: ".SHM_DIMS); + return ($shm_sz); +} + + ?>