X-Git-Url: https://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2FObj%2Fbrisk.phh;h=f38b50418429734299c5827561960437d3bfa2f7;hb=f705d38215e4db73d23542d66b3c057424d28aab;hp=34e08b03e5f03993b3c097536036dbbed7ce15df;hpb=abe1151407fb084089a8dfa12ea081b95630a1fd;p=brisk.git diff --git a/web/Obj/brisk.phh b/web/Obj/brisk.phh index 34e08b0..f38b504 100644 --- a/web/Obj/brisk.phh +++ b/web/Obj/brisk.phh @@ -2,7 +2,7 @@ /* * brisk - brisk.phh * - * Copyright (C) 2006-2011 Matteo Nastasi + * Copyright (C) 2006-2012 Matteo Nastasi * mailto: nastasi@alternativeoutput.it * matteo.nastasi@milug.org * web: http://www.alternativeoutput.it @@ -23,56 +23,66 @@ */ -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, 36); -define(TABLES_AUTH_N, 4); -define(PLAYERS_N, 3); -define(MAX_POINTS, 5); -define(MAX_PLAYERS, (20 + (PLAYERS_N * TABLES_N))); -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); +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', 36); +define('TABLES_AUTH_N', 4); +define('PLAYERS_N', 3); +define('MAX_POINTS', 5); +define('MAX_PLAYERS', (20 + (PLAYERS_N * TABLES_N))); +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('SHM_DIMS_U_MIN', 4096); +define('SHM_DIMS_U_MAX', 65536); +define('SHM_DIMS_U_DLT', 4096); + +define('COMM_N', 18); +define('COMM_GEN_N', 50); + +define('CHAT_N', 3); +define('CHAT_ILL_TIME', 6); +define('CHAT_ENABLED', TRUE); + +define('SESS_LEN', 13); +define('STREAM_TIMEOUT', 60); +/* FIXME: move to sac-a-push .phh */ +/* TIME_RD define the server-side timeout, after half of it a ping request + is sent to client, after this time the client is log out */ +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, 3600); -define(GARBAGE_TIMEOUT, 10); -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(DBG_LMOP, 0x0800); - +define('BAN_TIME', 3600); +define('GARBAGE_TIMEOUT', 10); +define('NICKSERV', "BriskServ"); + +define('LOCK_SHARE_MAX', 10000); + +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('DBG_LMOP', 0x0800); +define('DBG_TRAC', 0x1000); +define('DBG_SHME', 0x2000); // NOTE: BRISK DEBUG must be a numerical constant, not the result of operations on symbols -define(BRISK_DEBUG, 0xffffffbf); +define('BRISK_DEBUG', 0x0800); -define(BRISK_SINGLE_DEBUG,0); -define(BRISK_SINGLE_SESS, ""); -// define(DEBUGGING, "local"); +define('BRISK_SINGLE_DEBUG',0); +define('BRISK_SINGLE_SESS', ""); +define('DEBUGGING', "no-debugging"); require_once("$DOCUMENT_ROOT/Etc/".BRISK_CONF); @@ -120,21 +130,22 @@ $mlang_brisk = array( 'btn_backstand'=> array( 'it' => 'torna in piedi', 'tit_onauth'=>array( 'it' => '(solo aut.)', 'en' => '(only aut.)'), 'tit_onisol'=>array( 'it' => '(isolam.to)', - 'en' => '(isolation)') + 'en' => '(isolation)'), + 'db_failed' =>array('it' => '
Il collegamento al database è fallito.
Temporaneamente tutte le autenticazioni verranno sospese, accederai a Brisk come un utente normale.

Ci scusiamo per il disagio.', + 'en' => 'Connection to the database failed
All authentications are suspended temporarly, you login as normal user.
We are about the limitation') ); -$G_false = FALSE; $G_lng = langtolng($G_lang); $G_all_points = array( 11,10,4,3,2, 0,0,0,0,0 ); -$G_brisk_version = "2.5.0"; +$G_brisk_version = "4.3.0"; /* MLANG: ALL THE INFO STRINGS IN brisk.phh */ -$root_wellarr = array( 'it' => array ( 'Brisk (Ver. '.$G_brisk_version.'), NOVITA\': informazioni al tavolo sul chiamante, nuovo stato di supporter del sito.', +$root_wellarr = array( 'it' => array ( 'Brisk (Ver. '.$G_brisk_version.'), NOVITA\': adottato sac-a-push come motore per l\'invio dei dati in tempo reale, nuovo trasporto httpfile per explorer, tanti bug fixati, freeze su disco, fix del calcolo dei punti, nuovo stream dati xhr.', 'Se vuoi iscriverti alla Mailing List, cliccala!' ), - 'en' => array ( 'Brisk (Ver. '.$G_brisk_version.'), NEWS: caller information on the table, new supporter status.', + 'en' => array ( 'Brisk (Ver. '.$G_brisk_version.'), NEWS: usage of reader/writer locking instead of generic exclusive locking.', 'If you want to subscribe our Mailing List, click it!' ) ); $G_room_help = array( 'it' => ' @@ -268,14 +279,96 @@ $G_room_about = array( 'it' => '
briscola chiamata in salsa ajax
version '.$G_brisk_version.'

-Copyright 2006-2009 Matteo Nastasi (aka mop)

', +Copyright 2006-2012 Matteo Nastasi (aka mop)

', 'en' => '
declaration briscola in ajax sauce (Beta)

version '.$G_brisk_version.'

-Copyright 2006-2009 Matteo Nastasi (aka mop)

'); +Copyright 2006-2012 Matteo Nastasi (aka mop)

'); + +function mop_flush() +{ + for ($i = 0; $i < ob_get_level(); $i++) + ob_end_flush(); + ob_implicit_flush(1); + flush(); +} + +function force_no_cache(&$header_out) +{ + $header_out['Pragma'] = 'no-cache, must-revalidate'; + $header_out['Cache-Control'] = 'no-cache'; + $header_out['Expires'] = '-1'; +} + +function file_lock($fname, $is_exclusive) +{ + if (($res = @fopen($fname, "r+")) == FALSE) { + return (FALSE); + } + + if (flock($res, ($is_exclusive ? LOCK_EX : LOCK_SH)) == FALSE) { + fclose($res); + return (FALSE); + } + + return ($res); +} + +function file_unlock($res) +{ + if ($res != FALSE) { + flock($res, LOCK_UN); + fclose($res); + } +} + +function webservers_exceeded() +{ + return(file_exists(PROXY_PATH."/webservers_exceded.flag")); +} + +function webservers_check() +{ + GLOBAL $G_webserver_max; + + /* FIXME: check all procs expirations */ + return (10); + + $ct = 0; + + $dh = opendir('/proc'); + while (($file = readdir($dh)) !== false) { + if (preg_match('/[0-9]+/', $file)) { + $cmdline = explode("\0", file_get_contents('/proc/'.$file.'/cmdline')); + // echo "xxx".$cmdline[0].$n; + if (strstr('/usr/sbin/apache2', $cmdline[0]) != FALSE) { + // echo "yyy".$cmdline[0].$n; + $ct++; + } + } + } + closedir($dh); + + if ($ct >= $G_webserver_max) { + touch(PROXY_PATH."/webservers_exceded.flag"); + } + else { + unlink(PROXY_PATH."/webservers_exceded.flag"); + } + return ($ct); +} + +$escpush_from = array("\\", "\""); +$escpush_to = array("\\\\", "\\\""); +function escpush($s) +{ + GLOBAL $escpush_from, $escpush_to; + + return str_replace($escpush_from, $escpush_to, $s); +} $escinp_from = array( "\"" ); $escinp_to = array( """ ); @@ -358,6 +451,23 @@ function xcapemesg($s) } +class Vect { + function Vect($a) + { + $this->el = $a; + } + + function getbyid($idx) + { + return ($this->el[$idx]); + } + + function setbyid($idx, $v) + { + $this->el[$idx] = $v; + } +} + class Table { var $idx; var $player; @@ -378,19 +488,17 @@ class Table { { } - function &create($idx) + function create($idx) { - GLOBAL $G_false; - - if (($thiz =& new Table()) == FALSE) - return ($G_false); + if (($thiz = new Table()) == FALSE) + return (FALSE); $thiz->idx = $idx; $thiz->player = array(); $thiz->player_n = 0; $thiz->auth_only = FALSE; - $thiz->wag_own = NULL; + $thiz->wag_own = -1; $thiz->wag_com = ""; $thiz->wag_tout = 0; @@ -402,10 +510,8 @@ class Table { return ($thiz); } - function copy(&$from) + function copy($from) { - GLOBAL $G_false; - $this->idx = $from->idx; $this->player = array(); for ($i = 0 ; $i < $from->player_n ; $i++) @@ -426,24 +532,20 @@ class Table { $this->wakeup_time = $from->wakeup_time; } - function &myclone(&$from) + function myclone($from) { - GLOBAL $G_false; - - if (($thiz =& new Table()) == FALSE) - return ($G_false); + if (($thiz = new Table()) == FALSE) + return (FALSE); $this->copy($from); return ($thiz); } - function &spawn(&$from) + function spawn($from) { - GLOBAL $G_false; - - if (($thiz =& new Table()) == FALSE) - return ($G_false); + if (($thiz = new Table()) == FALSE) + return (FALSE); $thiz->idx = $from->idx; $thiz->player = array(); @@ -465,11 +567,11 @@ class Table { return ($thiz); } - function wag_set(&$user, $mesg) + function wag_set($user_idx, $mesg) { log_main("WAG_SET"); - $this->wag_own = &$user; + $this->wag_own = $user_idx; $this->wag_com = $mesg; $this->wag_tout = 0; } @@ -479,17 +581,17 @@ class Table { log_main("WAG_RESET"); unset($this->wag_own); - $this->wag_own = NULL; + $this->wag_own = -1; $this->wag_com = ""; $this->wag_tout = $timeout; } - function getPlayer($idx) + function player_get($idx) { return ($this->player[$idx]); } - function setPlayer($idx, $player) + function player_set($idx, $player) { $this->player[$idx] = $player; } @@ -502,7 +604,7 @@ class Table { return ($this->player_n - 1); } - function user_rem(&$room, &$user) + function user_rem($room, $user) { $tabpos = $user->table_pos; @@ -512,7 +614,7 @@ class Table { /* aggiorna l'array dei giocatori al tavolo. */ for ($i = $tabpos ; $i < $this->player_n-1 ; $i++) { $this->player[$i] = $this->player[$i+1]; - $user_cur = &$room->user[$this->player[$i]]; + $user_cur = $room->user[$this->player[$i]]; $user_cur->table_pos = $i; } $this->player_n--; @@ -528,7 +630,7 @@ class Table { // ($this->table[$i]->auth_only == FALSE ? TRUE : $user->flags & USER_FLAG_AUTH)); // function act_content($isstanding, $sitted, $table, $cur_table, $allowed) - function act_content(&$user) + function act_content($user) { $ret = ""; $isstanding = ($user->subst == 'standup'); @@ -568,373 +670,51 @@ class Table { } // end class Table -// User flags -define(USER_FLAG_AUTH, 0x02); - -define(USER_FLAG_MAP_AUTH, 0x0c); - -define(USER_FLAG_LISTAUTH, 0x04); -define(USER_FLAG_ISOLAUTH, 0x08); - -// user status -define(USER_FLAG_S_NORM, 0x000); // done -define(USER_FLAG_S_PAU, 0x100); // done -define(USER_FLAG_S_OUT, 0x200); // done -define(USER_FLAG_S_DOG, 0x300); // done -define(USER_FLAG_S_EAT, 0x400); // done -define(USER_FLAG_S_WRK, 0x500); // done -define(USER_FLAG_S_SMK, 0x600); // done -define(USER_FLAG_S_EYE, 0x700); // done -define(USER_FLAG_S_RABB, 0x800); // done -define(USER_FLAG_S_SOCC, 0x900); // done -define(USER_FLAG_S_BABY, 0xa00); // done -define(USER_FLAG_S_MOP, 0xb00); // done - -define(USER_FLAG_S_ALL, 0xf00); // done - -/* type of user normal, supporter etc ... */ -define(USER_FLAG_TY_ALL, 0xff0000); // done -define(USER_FLAG_TY_NORM, 0x010000); // done -define(USER_FLAG_TY_SUPER, 0x020000); // done -// ... other usefull status ... -define(USER_FLAG_TY_SUSPEND, 0x400000); // done -define(USER_FLAG_TY_DISABLE, 0x800000); // done - -class User { - var $code; // authentication code - var $name; // name of the user - var $sess; // session of the user - var $ip; // ip of the user - var $lacc; // last access (for the cleanup) - var $laccwr; // last access (for the cleanup) - var $bantime; // timeout to temporary ban - var $stat; // status (outdoor, room, table, game, ...) - var $subst; // substatus for each status - var $step; // step of the current status - var $trans_step; // step to enable transition between pages (disable == -1) - var $comm; // commands array - // var $asta_card; // - // var $asta_pnt; // - // var $handpt; // Total card points at the beginning of the current hand. - // var $exitislock; // Player can exit from the table ? - - // FIXME: the table_orig field must be removed after table field verify of index management (in spawned table - // it is allways ZERO - var $table_orig; // id of the current table (if in table state) - var $table; // id of the current table (if in table state) - var $table_pos; // idx on the table - var $table_token;// token that identify a game on a table - var $flags; // Bitfield with: AUTHENTICATE: 0x02 - 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() { - } - - function &create($name, $sess, $stat = "", $subst = "", $table = -1, $ip="0.0.0.0") { - GLOBAL $G_false; - - if (($thiz =& new User()) == FALSE) - return ($G_false); - - $thiz->code = -1; - $thiz->name = $name; - $thiz->sess = $sess; - $thiz->ip = $ip; - $thiz->lacc = time(); - $thiz->laccwr = time(); - $thiz->bantime = 0; - $thiz->stat = $stat; - $thiz->subst = $subst; - $thiz->step = 1; - $thiz->trans_step = -1; - $thiz->comm = array(); - $thiz->asta_card = -2; - $thiz->asta_pnt = -1; - $thiz->handpt = -1; - $thiz->exitislock = TRUE; - - $thiz->flags = 0x00; - - $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_orig = $table; - $thiz->table = $table; - $thiz->table_pos = -1; - $thiz->table_token = ""; - - return ($thiz); - } - - function copy(&$from) - { - GLOBAL $G_false; - - $this->code = $from->code; - $this->name = $from->name; - $this->sess = $from->sess; - $this->ip = $from->ip; - $this->lacc = $from->lacc; - $this->laccwr = $from->laccwr; - $this->bantime = $from->bantime; - $this->stat = $from->stat; - $this->subst = $from->subst; - $this->step = $from->step; - $this->trans_step = $from->trans_step; - $this->comm = array(); - - $i_start = (1 > ($from->step - COMM_N) ? 1 : ($from->step - COMM_N)); - for ($i = $i_start ; $i < $from->step ; $i++) { - $ii = $i % COMM_N; - $this->comm[$ii] = $from->comm[$ii]; - } - $this->asta_card = $from->asta_card; - $this->asta_pnt = $from->asta_pnt; - $this->handpt = $from->handpt; - $this->exitislock = $from->exitislock; - - $this->flags = $from->flags; - - $this->chattime = array(); - for ($i = 0 ; $i < CHAT_N ; $i++) - $this->chattime[$i] = $from->chattime[$i]; - $this->chat_cur = $from->chat_cur; - $this->chat_lst = $from->chat_lst; - $this->chat_ban = $from->chat_ban; - $this->chat_dlt = $from->chat_dlt; - - $this->table_orig = $from->table_orig; - $this->table = $from->table; - $this->table_pos = $from->table_pos; - $this->table_token = $from->table_token; - $this->the_end = $from->the_end; - - return (TRUE); - } - - - function &myclone(&$from) - { - GLOBAL $G_false; - - if (($thiz =& new User()) == FALSE) - return ($G_false); - - $thiz->copy($from); - - return ($thiz); - } - - function &spawn(&$from, $table, $table_pos) - { - GLOBAL $G_false; - - if (($thiz =& new User()) == FALSE) - return ($G_false); - - $thiz->code = $from->code; - $thiz->name = $from->name; - $thiz->sess = $from->sess; - $thiz->ip = $from->ip; - $thiz->lacc = $from->lacc; - $thiz->laccwr = $from->laccwr; - $thiz->bantime = $from->bantime; - $thiz->stat = $from->stat; - $thiz->subst = $from->subst; - $thiz->step = $from->step; - $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("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->flags = $from->flags; - - $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_orig = $table; - $thiz->table = 0; - $thiz->table_pos = $table_pos; - $thiz->table_token = $from->table_token; - - return ($thiz); - } - - function code_get() { - return ($this->code); - } - - function stat_set($stat) { - log_main("sess: [".$this->sess. "] NEW STAT: [".$stat."]"); - $this->stat = "$stat"; - - /* - if (validate_sess($this->sess)) { - if (file_exists(PROXY_PATH) == FALSE) - mkdir(PROXY_PATH); - $fp = fopen(PROXY_PATH."/".$this->sess.".stat", 'w'); - fwrite($fp, sprintf("%s\n",$this->stat)); - fclose($fp); - } - */ - } - - function step_set($step) { - $this->step = $step; - - do { - if (validate_sess($this->sess) == FALSE) - break; - if (file_exists(PROXY_PATH) == FALSE) - mkdir(PROXY_PATH); - if (($fp = @fopen(PROXY_PATH."/".$this->sess.".step", 'w')) == FALSE) - break; - fwrite($fp, pack("l",$this->step), 4); - fclose($fp); - - return (TRUE); - } while (0); - return (FALSE); - } - function step_inc($delta = 1) { - $this->step += $delta; +class Room +{ + static $delta_t; - if (validate_sess($this->sess)) { - if (file_exists(PROXY_PATH) == FALSE) - mkdir(PROXY_PATH); - $fp = fopen(PROXY_PATH."/".$this->sess.".step", 'w'); - fwrite($fp, pack("l",$this->step), 4); - fclose($fp); - - return (TRUE); - } + var $crystal_filename; + var $user; + var $table; + var $match; + var $comm; // commands for many people + var $step; // current step of the comm array + var $garbage_timeout; + var $shm_sz; - return (FALSE); - } - - function reset() { - $curtime = time(); - log_legal($curtime, $this, "STAT:LOGOUT", ''); - - $tmp_sess = $this->sess; - $this->sess = ""; - step_unproxy($tmp_sess); - $this->name = ""; // OK here - while (array_pop($this->comm) != NULL); - $this->step = 0; - $this->chattime = array_fill(0, CHAT_N, 0); - $this->chat_cur = 0; - $this->chat_lst = ""; - $this->chat_ban = 0; - $this->chat_dlt = 0; - $this->the_end = FALSE; - } -} // end class User - - - - - - - -function step_get($sess) { - $fp = FALSE; - do { - if (validate_sess($sess) == FALSE) - break; - - if (file_exists(PROXY_PATH) == FALSE) - mkdir(PROXY_PATH); - if (($fp = @fopen(PROXY_PATH."/".$sess.".step", 'rb')) == FALSE) - break; - if (($s = fread($fp, 4)) == FALSE) - break; - if (strlen($s) != 4) - break; - $arr = unpack('l', $s); - fclose($fp); - - // log_rd2("A0: ".$arr[0]." A1: ".$arr[1]); - return ($arr[1]); - } while (0); - - if ($fp != FALSE) - fclose($fp); - - log_rd2("STEP_GET: return false "); - - return (FALSE); -} - -function step_unproxy($sess) { - log_rd2("UNPROXY: ".PROXY_PATH."/".$sess.".step"); - if (file_exists(PROXY_PATH) == FALSE) - mkdir(PROXY_PATH); - @unlink(PROXY_PATH."/".$sess.".step"); -} - - -class Room { - var $user; - var $table; - 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("", ""); - } - - for ($i = 0 ; $i < TABLES_N ; $i++) { - $this->table[$i] =& Table::create($i); - /* OLD METHOD - if ($i < 12) { - $row = ( (((int)($i / 4)) % 2) == 0 ); - $col = ($i % 2 == 0); - $this->table[$i]->auth_only = (($row && $col) || (!$row && !$col)); - } - else { - $this->table[$i]->auth_only = FALSE; - } - */ - if ($i < TABLES_AUTH_N) - $this->table[$i]->auth_only = TRUE; - else - $this->table[$i]->auth_only = FALSE; + function Room ($crystal_filename) { + $this->crystal_filename = $crystal_filename; + $this->user = array(); + $this->table = array(); + $this->match = array(); + + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + $this->user[$i] = User::create($this, $i, "", ""); + } + + for ($i = 0 ; $i < TABLES_N ; $i++) { + $this->table[$i] = Table::create($i); + /* OLD METHOD + if ($i < 12) { + $row = ( (((int)($i / 4)) % 2) == 0 ); + $col = ($i % 2 == 0); + $this->table[$i]->auth_only = (($row && $col) || (!$row && !$col)); + } + else { + $this->table[$i]->auth_only = FALSE; + } + */ + if ($i < TABLES_AUTH_N) + $this->table[$i]->auth_only = TRUE; + else + $this->table[$i]->auth_only = FALSE; + } + $this->garbage_timeout = 0; + $this->shm_sz = SHM_DIMS_MIN; } - $this->garbage_timeout = 0; - } function garbage_manager($force) { @@ -946,163 +726,162 @@ class Room { /* Garbage collector degli utenti in timeout */ $curtime = time(); - if ($force || $this->garbage_timeout < $curtime) { - - // FIXME BRISK4: include for each kind of table - require_once("${G_base}briskin5/Obj/briskin5.phh"); - // Before all align times with table timeout - for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { - $table_cur =& $this->table[$table_idx]; + if (!$force && !($this->garbage_timeout < $curtime)) { + return ($ismod); + } + + webservers_check(); + + // 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."); - - $plist = "$table_cur->table_token|$table_cur->idx|$table_cur->player_n"; - for ($i = 0 ; $i < $table_cur->player_n ; $i++) { - $plist .= '|'.$this->user[$table_cur->player[$i]]->sess; + log_main("PLAYERS == N TABLE ".$table_idx); + + + $no_recovery = FALSE; + if (isset($this->match[$table_idx])) { + $bri = $this->match[$table_idx]; + + 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; } - 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; - } - - log_legal($curtime, $user_cur, "STAT:DESTROY_GAME", $plist); - - $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)."; "; - // MLANG
I dati del tavolo n° ".$user_cur->table." sono inconsistenti, verranno resettati.

Torni in piedi.

- $prestr = sprintf($mlang_brisk['tabincon'][$G_lang], $user_cur->table); - $ret .= show_notify($prestr, 2000, $mlang_brisk['btn_close'][$G_lang], 400, 110); - $user_cur->comm[$user_cur->step % COMM_N] = $ret; - $user_cur->step_inc(); - } - - $plist = "$table_cur->table_token|$user_cur->table|$table_cur->player_n"; - for ($i = 0 ; $i < $table_cur->player_n ; $i++) { - $plist .= '|'.$this->user[$table_cur->player[$i]]->sess; - } - log_legal($curtime, $user_cur, "STAT:DESTROY_GAME(RECOVERY)", $plist); - - $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++) { + 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."); + + $plist = "$table_cur->table_token|$table_cur->idx|$table_cur->player_n"; + for ($i = 0 ; $i < $table_cur->player_n ; $i++) { + $plist .= '|'.$this->user[$table_cur->player[$i]]->sess; + } + + 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; + } + + log_legal($curtime, 'xxx', $user_cur, "STAT:DESTROY_GAME", $plist); + + $this->room_join_wakeup($user_cur, FALSE, 0); + $table_cur->table_token = ""; + $table_cur->wakeup_time = $curtime + WAKEUP_TIME; + + $this->match_del($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; + } + } + } // if ($bri == 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)."; "; + // MLANG
I dati del tavolo n° ".$user_cur->table." sono inconsistenti, verranno resettati.

Torni in piedi.

+ $prestr = sprintf($mlang_brisk['tabincon'][$G_lang], $user_cur->table); + $ret .= show_notify($prestr, 2000, $mlang_brisk['btn_close'][$G_lang], 400, 110); + $user_cur->comm[$user_cur->step % COMM_N] = $ret; + $user_cur->step_inc(); + } + + $plist = "$table_cur->table_token|$user_cur->table|$table_cur->player_n"; + for ($i = 0 ; $i < $table_cur->player_n ; $i++) { + $plist .= '|'.$this->user[$table_cur->player[$i]]->sess; + } + log_legal($curtime, 'xxx', $user_cur, "STAT:DESTROY_GAME(RECOVERY)", $plist); + + $this->room_join_wakeup($user_cur, TRUE, -2); + $table_cur->table_token = ""; + } + } + } // 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]; + log_rd2("out new loop."); + + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + $user_cur = $this->user[$i]; log_rd2("User: ".$user_cur->name." stat: ".$user_cur->stat." subst: ".$user_cur->subst); - + if ($user_cur->sess == "") - continue; + continue; 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(); + // 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(); - 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("LOGOUT FROM WHAT ???"); - } + 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("LOGOUT FROM WHAT ???"); + } } if ($user_cur->laccwr + EXPIRE_TIME_SMAMMA < $curtime) { // lo rimettiamo in piedi - if ($user_cur->stat == 'room' && $user_cur->subst == 'sitdown') { - $this->room_wakeup(&$user_cur); - $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; "; - /* MLANG:
Sei stato inattivo per ".(EXPIRE_TIME_SMAMMA/60.0)." minuti.

Quindi ritorni tra i Giocatori in piedi.", "torna ai tavoli" */ - $user_cur->comm[$user_cur->step % COMM_N] .= show_notify($mlang_brisk['tabtout_a'][$G_lang].(EXPIRE_TIME_SMAMMA/60.0).$mlang_brisk['tabtout_b'][$G_lang], 0, $mlang_brisk['btn_backstand'][$G_lang], 400, 100); - $user_cur->step_inc(); - } + if ($user_cur->stat == 'room' && $user_cur->subst == 'sitdown') { + $this->room_wakeup($user_cur); + $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; "; + /* MLANG:
Sei stato inattivo per ".(EXPIRE_TIME_SMAMMA/60.0)." minuti.

Quindi ritorni tra i Giocatori in piedi.", "torna ai tavoli" */ + $user_cur->comm[$user_cur->step % COMM_N] .= show_notify($mlang_brisk['tabtout_a'][$G_lang].(EXPIRE_TIME_SMAMMA/60.0).$mlang_brisk['tabtout_b'][$G_lang], 0, $mlang_brisk['btn_backstand'][$G_lang], 400, 100); + $user_cur->step_inc(); + } } - } - log_rd2("GARBAGE UPDATED!"); - - $this->garbage_timeout = time() + GARBAGE_TIMEOUT; - $ismod = TRUE; } + log_rd2("GARBAGE UPDATED!"); + + $this->garbage_timeout = $curtime + GARBAGE_TIMEOUT; + $ismod = TRUE; return ($ismod); } - function show_room($user_step, &$user) + function show_room($user_step, $user) { GLOBAL $G_lang, $mlang_brisk; log_main("show_room: username: ".$user->name); @@ -1127,31 +906,36 @@ class Room { $ret .= sprintf('stat = "%s";', $user->stat); $ret .= root_wellcome($user); + if ($user->flags & USER_FLAG_DBFAILED) { + $ret .= "gst.st = ".($user->step+1)."; "; + $ret .= show_notify($mlang_brisk['db_failed'][$G_lang], 0, $mlang_brisk['btn_close'][$G_lang], 400, 140); + } + $ret .= sprintf('subst = "%s";', $user->subst); - $itin = ($user->flags & USER_FLAG_AUTH ? "" : ""); - $itou = ($user->flags & USER_FLAG_AUTH ? "" : ""); - $ret .= sprintf('$("myname").innerHTML = "%s%s%s";', $itin, xcape($user->name), $itou); + $ret .= $user->myname_innerHTML(); + for ($i = 0 ; $i < TABLES_N ; $i++) { $ret .= $this->table_content($user, $i); // $ret .= table_act_content(($user->subst == 'standup'), $this->table[$i]->player_n, $i, $user->table, // ($this->table[$i]->auth_only == FALSE ? TRUE : $user->flags & USER_FLAG_AUTH)); $ret .= $this->table[$i]->act_content($user); - 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); + if ($this->table[$i]->wag_own != -1) + $ret .= sprintf('tra.add(%d, "%s: %s"); ', $i, $this->user[$this->table[$i]->wag_own]->name, $this->table[$i]->wag_com); else $ret .= sprintf('tra.rem(%d); ', $i); } $ret .= $this->standup_content($user); - + $ret .= "setTimeout(preload_images, 0, g_preload_img_arr, g_imgct); "; + return ($ret); } - function room_wakeup(&$user) + function room_wakeup($user) { $table_idx = $user->table; - $table = &$this->table[$table_idx]; + $table = $this->table[$table_idx]; log_main("WAKEUP: begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); @@ -1162,10 +946,10 @@ class Room { 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]]; + $user_cur = $this->user[$table->player[$i]]; log_main("PREIMPOST: INLOOP name: ".$user_cur->name); - if ($user_cur != $user) { + if ($user->idx_get() != $table->player[$i]) { $user_cur->stat_set("room"); $user_cur->subst = "sitdown"; $user_cur->laccwr = $curtime; @@ -1184,27 +968,26 @@ class Room { $user->laccwr = $curtime; } - $remove_wagon = false; - if($table->wag_own == $user) { - $remove_wagon = true; + $remove_wagon = FALSE; + if($table->wag_own == $user->idx_get()) { $table->wag_reset($curtime); - + $remove_wagon = TRUE; } /* aggiorna l'array dei giocatori al tavolo. */ - $table->user_rem(&$this, &$user); + $table->user_rem($this, $user); for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; 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); $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; window.onbeforeunload = null; document.location.assign("index.php");|'; + if ($from_table && ($user_cur->table == $table_idx || $user->idx_get() == $i)) { + $ret .= 'gst.st_loc++; xstm.stop(); window.onunload = null; window.onbeforeunload = null; document.location.assign("index.php");|'; // $ret .= 'gst.st_loc++; document.location.assign("index.php");|'; log_main("DOCUMENT.index.php: from table"); } @@ -1217,7 +1000,7 @@ class Room { // $ret .= table_act_content(FALSE, 0, $table_idx, $user->table, FALSE); $ret .= $table->act_content($user); - if ($user_cur == $user) { + if ($user->idx_get() == $i) { // set the new status $ret .= 'subst = "standup"; tra.show(); '; // clean the action buttons in other tables @@ -1241,10 +1024,10 @@ class Room { } } - function room_join_wakeup(&$user, $update_lacc = FALSE, $trans_delta) + function room_join_wakeup($user, $update_lacc = FALSE, $trans_delta) { $table_idx = $user->table; - $table = &$this->table[$table_idx]; + $table = $this->table[$table_idx]; log_main("JOIN_WAKEUP: begin function table:".$table_idx." stat: ".$user->stat." subst: ".$user->subst); @@ -1256,7 +1039,7 @@ class Room { 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]]; + $user_cur = $this->user[$table->player[$i]]; log_main("PREIMPOST INLOOP name: ".$user_cur->name); if ($user_cur->sess != "") { if ($update_lacc == TRUE) { @@ -1271,26 +1054,26 @@ class Room { $user_cur->stat_set("room"); $user_cur->subst = "standup"; $user_cur->table = -1; - $user_wup[$user_wup_n++] = &$user_cur; + $user_wup[$user_wup_n++] = $user_cur; - $remove_wagon = false; - if($table->wag_own == $user_cur) { - $remove_wagon = true; + $remove_wagon = FALSE; + if($table->wag_own == $table->player[$i]) { + $remove_wagon = TRUE; $table->wag_reset($curtime); } } - $user_tab[$user_tab_n++] = &$user_cur; + $user_tab[$user_tab_n++] = $table->player[$i]; } } for ($wup_idx = 0 ; $wup_idx < $user_wup_n ; $wup_idx++) - $table->user_rem(&$this, &$user_wup[$wup_idx]); + $table->user_rem($this, $user_wup[$wup_idx]); /* aggiorna l'array dei giocatori al tavolo. */ for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { log_main("START LOOP"); - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; if ($user_cur->sess == '' || $user_cur->stat != 'room') { log_main("name: ".$user_cur->name."skip subst: ".$user_cur->subst); continue; @@ -1312,8 +1095,8 @@ class Room { for ($tab_idx = 0 ; $tab_idx < $user_tab_n ; $tab_idx++) - if ($user_cur == $user_tab[$tab_idx]) - break; + if ($user_tab[$tab_idx] == $i) + break; // for users that wakeup the room will be reconstructed by index_rd.php if ($tab_idx < $user_tab_n) { @@ -1326,7 +1109,7 @@ class Room { $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->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); @@ -1347,23 +1130,23 @@ class Room { } } - function room_outstandup(&$user) + function room_outstandup($user) { - $this->room_sitdown(&$user, -1); + $this->room_sitdown($user, -1); } - function table_update(&$user) + function table_update($user) { log_main("table_update: pre - USER: ".$user->name); $table_idx = $user->table; if ($table_idx > -1) - $table = &$this->table[$table_idx]; + $table = $this->table[$table_idx]; for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { $ret = ""; - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; if ($user_cur->sess == '' || $user_cur->stat != 'room') continue; @@ -1371,10 +1154,8 @@ class Room { if ($table_idx > -1) $ret .= $this->table_content($user_cur, $table_idx); - if ($user_cur == $user) { - $itin = ($user->flags & USER_FLAG_AUTH ? "" : ""); - $itou = ($user->flags & USER_FLAG_AUTH ? "" : ""); - $ret .= sprintf('$("myname").innerHTML = "%s%s%s: ";', $itin, xcape($user->name), $itou); + if ($user->idx_get() == $i) { + $ret .= $user->myname_innerHTML(); } $user_cur->comm[$user_cur->step % COMM_N] = $ret; $user_cur->step_inc(); @@ -1383,31 +1164,30 @@ class Room { log_main("table_update: post"); } - function room_sitdown(&$user, $table_idx) + function room_sitdown($user, $table_idx) { log_main("room_sitdown ".($user == FALSE ? "USER: FALSE" : "USER: ".$user->name)); $train_app = ""; if ($table_idx > -1 && $table_idx < TABLES_N) { - $table = &$this->table[$table_idx]; + $table = $this->table[$table_idx]; // wagon shutdown - if ($table->wag_own != NULL && $table->player_n == PLAYERS_N) { + if ($table->wag_own != -1 && $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; - } + if ($table->wag_own == $table->player[$i]) { + $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]; + $user_cur = $this->user[$i]; if ($user_cur->sess == '' || $user_cur->stat != 'room') continue; @@ -1416,7 +1196,7 @@ class Room { $ret .= $this->table_content($user_cur, $table_idx); $ret .= $this->standup_content($user_cur); - if ($user_cur == $user) { + if ($user->idx_get() == $i) { $ret .= 'subst = "sitdown"; tra.hide(); '; // clean the action buttons in other tables for ($e = 0 ; $e < TABLES_N ; $e++) { @@ -1436,15 +1216,16 @@ class Room { } } - function chatt_send(&$user, $mesg) + function chatt_send($user, $mesg) { GLOBAL $G_base, $G_alarm_passwd, $mlang_brisk, $G_lang; $only_you = FALSE; // common settings - $msg = substr($mesg, 6, 128); + $msg = mb_substr($mesg, 6, 128, "UTF-8"); $curtime = time(); $dt = date("H:i ", $curtime); + $target = ""; // // Compute actions @@ -1469,9 +1250,9 @@ class Room { break; } - $table = &$this->table[$user->table]; + $table = $this->table[$user->table]; - if ($table->wag_own != NULL) { + if ($table->wag_own != -1) { // MLANG
Il messaggio di segnalazione del tavolo è già attivato.

$msg = $mlang_brisk['tickjust'][$G_lang]; $to_user = show_notify($msg, 0, "chiudi", 400, 100); @@ -1491,7 +1272,7 @@ class Room { $msg = substr($msg, 5); - $table->wag_set($user, $msg); + $table->wag_set($user->idx_get(), $msg); $to_user = sprintf('tra.add(%d, "%s");', $user->table, xcape(sprintf("%s: %s", $user->name, $msg))); $to_room = $to_user; /* for old isolation management $is_ticker = TRUE; */ @@ -1592,11 +1373,11 @@ class Room { $msg = "COMMAND ".$msg; for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; if ($user_cur->sess == '') continue; - if ($user_cur->name == $name_new) + if (strcasecmp($user_cur->name,$name_new) == 0) break; } if ($i < MAX_PLAYERS) { @@ -1627,13 +1408,14 @@ class Room { $user->name = $name_new; // OK - nick changed /* se nome gia' in uso, segnala cosa potrebbe capitare */ if (($user->flags & USER_FLAG_AUTH) == 0) { - $bdb = new BriskDB(); - $bdb->users_load(); - /* MLANG: "Il nickname \'%s\' è già registrato, se il suo proprietario si autentificherà verrai rinominato d\'ufficio come ghostN." */ - if ($bdb->login_exists($name_new)) { - $prestr = sprintf($mlang_brisk['nickjust'][$G_lang], xcape($name_new)); - $to_user .= sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $prestr); - } + if (($bdb = BriskDB::create()) != FALSE) { + $bdb->users_load(); + /* MLANG: "Il nickname \'%s\' è già registrato, se il suo proprietario si autentificherà verrai rinominato d\'ufficio come ghostN." */ + if ($bdb->login_exists($name_new)) { + $prestr = sprintf($mlang_brisk['nickjust'][$G_lang], xcape($name_new)); + $to_user .= sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $prestr); + } + } } log_main("chatt_send start set"); @@ -1700,7 +1482,7 @@ class Room { else { // normal chat line $is_normchat = TRUE; - if ($curtime < ($user->chat_ban + $user->chat_dlt)) { + if (CHAT_ENABLED && $curtime < ($user->chat_ban + $user->chat_dlt)) { $only_you = TRUE; $user->chat_dlt = $user->chat_dlt * 2; if ($user->chat_dlt > 120) @@ -1708,7 +1490,7 @@ class Room { } else if ($user->chat_lst == $msg) $only_you = TRUE; - else if ($curtime - $user->chattime[($user->chat_cur + 1) % CHAT_N] < CHAT_ILL_TIME) { + else if (CHAT_ENABLED && $curtime - $user->chattime[($user->chat_cur + 1) % CHAT_N] < CHAT_ILL_TIME) { $user->chat_ban = $curtime; $user->chat_dlt = 5; $only_you = TRUE; @@ -1728,7 +1510,7 @@ class Room { $to_room = $to_user; } - log_legal($curtime, $user, + log_legal($curtime, 'xxx', $user, ($user->stat == 'room' ? 'room' : 'table '.$user->table),$msg); $user->chat_lst = "$msg"; @@ -1753,11 +1535,10 @@ class Room { if ($to_room != FALSE) { for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; if ($target != "" && $user_cur->name != $target) continue; - // if ($user_cur->sess == '' || $user_cur->stat != 'room') - if ($user_cur->sess == '' || $user_cur->stat == 'table' || $user_cur == $user) + if ($user_cur->sess == '' || $user_cur->stat == 'table' || $user->idx_get() == $i) continue; if ($is_normchat == TRUE) { @@ -1783,55 +1564,36 @@ class Room { } if ($to_tabl) { - // FIXME BRISK4: include for each kind of table - require_once("${G_base}briskin5/Obj/briskin5.phh"); - // 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]; + // FIXME BRISK4: include for each kind of table + require_once("${G_base}briskin5/Obj/briskin5.phh"); + // Before all align times with table timeout + for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) { + if (isset($this->match[$table_idx])) { + $bri = $this->match[$table_idx]; + + $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]; - if ($target != "" && $bri_user->name != $target) - continue; - 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 ($target != "" && $bri_user->name != $target) + continue; + 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(); + } + } // if (isset($this->match + } // 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); + $this->standup_update($user); } else if ($user->stat == 'room' && $user->subst == 'sitdown') { log_main("chatt_send pre table update"); - $this->table_update(&$user); + $this->table_update($user); log_main("chatt_send post table update"); } } // if ($update_room ... @@ -1839,16 +1601,16 @@ class Room { return; } // function chatt_send( ... - function &get_user($sess, &$idx) + function get_user($sess, &$idx) { - GLOBAL $PHP_SELF, $G_false; + GLOBAL $PHP_SELF; if (validate_sess($sess)) { for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { if (strcmp($sess, $this->user[$i]->sess) == 0) { // find it $idx = $i; - $ret = &$this->user[$i]; + $ret = $this->user[$i]; return ($ret); } } @@ -1860,13 +1622,11 @@ class Room { log_main(sprintf("get_user: Wrong strlen [%s]",$sess)); } - return ($G_false); + return (FALSE); } - - /* - * function &add_user(&$room, &$sess, &$idx, $name, $pass, $ip) + * function add_user(&$room, &$sess, &$idx, $name, $pass, $ip) * * RETURN VALUE: * if ($idx > -1 && ret == FALSE) => duplicated nick @@ -1874,14 +1634,12 @@ class Room { * if ($idx == -3 && ret == FALSE) => wrong password * if ($idx == -1 && ret == FALSE) => no space left * if ($idx == 0 && ret == user) => SUCCESS - * if ($idx == -$idx && ret == user) => SUCCESS (but the login exists in the auth db + * if ($idx == -$idx && ret == user) => SUCCESS (but the login exists in the auth db) */ - - - function &add_user(&$sess, &$idx, $name, $pass, $ip) + function add_user(&$sess, &$idx, $name, $pass, $ip, $cookie) { - GLOBAL $G_base, $G_false, $CO_list; + GLOBAL $G_base; $idx = 0; @@ -1896,7 +1654,7 @@ class Room { if (($name_new = validate_name($name)) == FALSE) { $idx = -2; - return ($G_false); + return (FALSE); } log_auth("XXX", sprintf("ARRIVA: [%s] pass:[%s]", $sess, ($pass == FALSE ? "FALSE" : $pass))); @@ -1905,23 +1663,29 @@ class Room { /* if pass != FALSE verify the login with pass */ log_auth("XXX", "auth1"); - $bdb = new BriskDB(); - $bdb->users_load(); - if ($pass != FALSE) { - log_auth("XXX", "auth2"); - $authenticate = $bdb->login_verify($name_new, $pass, $code); - log_auth("XXX", "authenticate: ".($authenticate != FALSE ? "TRUE" : "FALSE")); - - if ($authenticate != FALSE) { - $user_type = $authenticate->type_get(); - } - else { - $idx = -3; - return ($G_false); - } + + if (($bdb = BriskDB::create()) != FALSE) { + $bdb->users_load(); + if ($pass != FALSE) { // TODO: here add a method to $bdb to check if the db is available. + log_auth("XXX", "auth2"); + $authenticate = $bdb->login_verify($name_new, $pass, $code); + log_auth("XXX", "authenticate: ".($authenticate != FALSE ? "TRUE" : "FALSE")); + + if ($authenticate != FALSE) { + $user_type = $authenticate->type_get(); + } + else { + $idx = -3; + return (FALSE); + } + } + else { + $login_exists = $bdb->login_exists($name_new); + } } else { - $login_exists = $bdb->login_exists($name_new); + // if db is down, send a warning and verify only current users + // no actions at this moment } for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { /* free user ? */ @@ -1929,7 +1693,7 @@ class Room { if ($idx == -1) $idx = $i; } - if ($idfree == -1 && strcmp("", $this->user[$i]->sess) == 0) { + if ($idfree == -1 && strcmp($this->user[$i]->sess, "") == 0) { $idfree = $i; continue; // NOTE: CHECK IT !! } @@ -1949,11 +1713,14 @@ class Room { log_auth("XXX", sprintf("TROVATO A QUESTO PUNTO [%d] sess [%s] name [%s]", $idx, $sess, $name_new)); + /* there is another user logged with your account and you and him have authenticated => new user + get the session of the old user */ if ($ghost > -1 && $ghost_auth && ($authenticate != FALSE)) { /* swap session */ - $ghost_user =& $this->user[$ghost]; + $ghost_user = $this->user[$ghost]; $curtime = time(); + $ghost_user->comm[$ghost_user->step % COMM_N] = ""; $ghost_user->step_inc(); if ($sess == "") { $sess = uniqid(""); @@ -1966,18 +1733,16 @@ class Room { // If user at the table we need to update the table data too $table_idx = $ghost_user->table; if ($ghost_user->stat == "table" && $this->table[$table_idx]->player_n == PLAYERS_N) { - // FIXME BRISK4: include for each kind of table - require_once("${G_base}briskin5/Obj/briskin5.phh"); - if (($brisem = Briskin5::lock_data($table_idx)) != FALSE) { - if (($bri = &Briskin5::load_data($table_idx)) != FALSE) { - if ($bri->the_end != TRUE) { - $bri->user[$ghost_user->table_pos]->step_inc(); - $bri->user[$ghost_user->table_pos]->sess = $sess; - Briskin5::save_data(&$bri); - } + require_once("${G_base}briskin5/Obj/briskin5.phh"); + if (isset($this->match[$table_idx])) { + $bri = $this->match[$table_idx]; + + if ($bri->the_end != TRUE) { + $bri->user[$ghost_user->table_pos]->comm[$bri->user[$ghost_user->table_pos]->step % COMM_N] = ""; + $bri->user[$ghost_user->table_pos]->step_inc(); + $bri->user[$ghost_user->table_pos]->sess = $sess; + } } - Briskin5::unlock_data($brisem); - } } $idx = $ghost; @@ -2003,8 +1768,9 @@ class Room { $this->user[$idx]->bantime = 0; $this->user[$idx]->ip = $ip; - $this->user[$idx]->flags = ($authenticate != FALSE ? USER_FLAG_AUTH : 0x00) | $user_type; - + $this->user[$idx]->flags = $user_type; + $this->user[$idx]->flags |= ($authenticate != FALSE ? USER_FLAG_AUTH : 0x00); + $this->user[$idx]->flags |= ( ($pass != FALSE && $bdb == FALSE) ? USER_FLAG_DBFAILED : 0x00); log_auth("XXX", sprintf("FLAGS: [%x]", $this->user[$idx]->flags)); @@ -2012,12 +1778,12 @@ class Room { $this->user[$idx]->code = $authenticate->code_get(); $this->user[$idx]->flags |= USER_FLAG_LISTAUTH; - if (isset($CO_list)) { - if (strcmp($CO_list, "auth") == 0) { + if (isset($cookie['CO_list'])) { + if (strcmp($cookie['CO_list'], "auth") == 0) { $this->user[$idx]->flags &= ~USER_FLAG_MAP_AUTH; $this->user[$idx]->flags |= USER_FLAG_LISTAUTH; } - if (strcmp($CO_list, "isolation") == 0) { + if (strcmp($cookie['CO_list'], "isolation") == 0) { $this->user[$idx]->flags &= ~USER_FLAG_MAP_AUTH; $this->user[$idx]->flags |= USER_FLAG_ISOLAUTH; } @@ -2029,7 +1795,7 @@ class Room { if ($ghost > -1) { log_main("ghost: rename!"); - $ghost_user =& $this->user[$ghost]; + $ghost_user = $this->user[$ghost]; if ($ghost_auth == FALSE) { for ($sfx = 1 ; $sfx <= MAX_PLAYERS ; $sfx++) { @@ -2038,7 +1804,7 @@ class Room { if (strcmp("", $this->user[$i]->sess) == 0) continue; - if (strcmp($this->user[$i]->name, $ghostname) == 0) { + if (strcasecmp($this->user[$i]->name, $ghostname) == 0) { $ghostname = ''; break; } @@ -2050,11 +1816,11 @@ class Room { $ghost_user->name = $ghostname; if ($ghost_user->stat == 'room' && $ghost_user->subst == 'standup') { - $this->standup_update(&$ghost_user); + $this->standup_update($ghost_user); } else { log_main("chatt_send pre table update"); - $this->table_update(&$ghost_user); + $this->table_update($ghost_user); log_main("chatt_send post table update"); } } // if ($ghost_auth == FALSE @@ -2075,13 +1841,13 @@ class Room { return ($ret); } - return ($G_false); + return (FALSE); } - function standup_update(&$user) + function standup_update($user) { for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - $user_cur = &$this->user[$i]; + $user_cur = $this->user[$i]; if ($user_cur->sess == '') continue; @@ -2089,12 +1855,8 @@ class Room { if ($user_cur->stat == 'room') { $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; ".$this->standup_content($user_cur); - if ($user_cur == $user) { - $itin = ($user->flags & USER_FLAG_AUTH ? "" : ""); - $itou = ($user->flags & USER_FLAG_AUTH ? "" : ""); - - $user_cur->comm[$user_cur->step % COMM_N] .= sprintf('$("myname").innerHTML = "%s%s%s: ";', - $itin, xcape($user->name), $itou); + if ($user->idx_get() == $i) { + $user_cur->comm[$user_cur->step % COMM_N] .= $user->myname_innerHTML(); } log_main("FROM STANDUP: NAME: ".$user_cur->name." SENDED: ".$user_cur->comm[$user_cur->step % COMM_N]); @@ -2104,22 +1866,28 @@ class Room { } // Static functions - function &init_data() + static function create($crystal_filename) { - $room =& new Room(); - + if (($room_ser = @file_get_contents($crystal_filename)) == FALSE || + ($room = unserialize($room_ser)) == FALSE) { + fprintf(STDERR, "NEW ROOM\n"); + $room = new Room($crystal_filename); + } + else { + fprintf(STDERR, "ROOM FROM FILE\n"); + } + return $room; } - - function &load_data() + + function load_data() { - GLOBAL $G_false, $sess; - $doexit = FALSE; + GLOBAL $sess; + do { - if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) { + if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) { log_main("ftok failed"); - $doexit = TRUE; break; } @@ -2131,37 +1899,51 @@ class Room { $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)); - - 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); + $room = @shm_get_var($shm, $tok); // CHECKED BELOW + + 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)); + + if ($room == FALSE) { + log_only("INIT MAIN DATA"); + shm_detach($shm); + + $room = Room::create(); + + log_shme("Room::create"); + + if (Room::save_data($room) == FALSE) + return FALSE; + + return $room; + } + $room->shm_sz = $shm_sz; + + shm_detach($shm); + + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + if (($room->user[$i] = User::load_data($i, FALSE)) == FALSE) { + log_crit("User::load_data failed"); + break; + } + } + if ($i < MAX_PLAYERS) { + break; + } } - $ret = &$room; - return ($ret); + + // + // SHSPLIT: load users from the shared memory + // + return ($room); } while (0); - if ($doexit) - exit(); - - return ($G_false); + return (FALSE); } - function save_data(&$room) + function save_data_orig($room) { GLOBAL $sess; @@ -2169,7 +1951,7 @@ class Room { // var_dump($room); - if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) + if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) return (FALSE); while ($room->shm_sz < SHM_DIMS_MAX) { @@ -2177,7 +1959,7 @@ class Room { break; // log_only("PUT_VAR DI ".strlen(serialize($room))); - if (shm_put_var($shm, $tok, $room) != FALSE) { + if (@shm_put_var($shm, $tok, $room) != FALSE) { shm_detach($shm); return (TRUE); } @@ -2194,35 +1976,85 @@ class Room { return (FALSE); } - - function lock_data() + function dump_data() { - GLOBAL $sess; - - // echo "LOCK: ".FTOK_PATH."/main"; - // exit; - if (($tok = @ftok(FTOK_PATH."/main", "B")) == -1) { - return (FALSE); - } - // echo "FTOK ".$tok."
"; - if (($res = sem_get($tok)) == FALSE) { + $room_ser = serialize($this); + $room_ser_len = mb_strlen($room_ser, "ASCII"); + if (file_put_contents($this->crystal_filename, $room_ser) == $room_ser_len) { + return (TRUE); + } + return (FALSE); - } - if (sem_acquire($res)) { - log_lock("LOCK room"); - return ($res); - } - else + } + + function save_data($room) + { + GLOBAL $sess; + + $ret = FALSE; + $shm = FALSE; + + if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) + return (FALSE); + + // SHSPLIT: before save the $room you must save users, + // detach from main struct and (then) reattach + $user_park = array(); + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + $user_park[$i] = $room->user[$i]; + $room->user[$i] = FALSE; + } + + while ($room->shm_sz < SHM_DIMS_MAX) { + if (($shm = shm_attach($tok, $room->shm_sz)) == FALSE) + break; + + // log_only("PUT_VAR DI ".strlen(serialize($room))); + if (@shm_put_var($shm, $tok, $room) != FALSE) { + log_shme("Room::save_data"); + $ret = TRUE; + break; + } + if (shm_remove($shm) === FALSE) { + log_only("REMOVE FALLITA"); + break; + } + shm_detach($shm); + $room->shm_sz += SHM_DIMS_DLT; + } + + if ($shm) + shm_detach($shm); + + // SHSPLIT: reattach users to the room class + for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { + User::save_data($user_park[$i], $i); + $room->user[$i] = $user_park[$i]; + } + log_load("FINISH: ".($ret == TRUE ? "TRUE" : "FALSE")); + + return ($ret); + } + + static function lock_data($is_exclusive) + { + if (($res = file_lock(FTOK_PATH."/main", $is_exclusive)) != FALSE) { + self::$delta_t = microtime(TRUE); + log_lock("LOCK room [".self::$delta_t."]"); + + return ($res); + } + return (FALSE); } - function unlock_data($res) + static function unlock_data($res) { GLOBAL $sess; - log_lock("UNLOCK room"); + log_lock("UNLOCK room [".(microtime(TRUE) - (self::$delta_t))."]"); - return (sem_release($res)); + file_unlock($res); } @@ -2234,8 +2066,8 @@ class Room { 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 == "") + for ($i = 0 , $ct = 0 ; $ct < 4 && $i < MAX_PLAYERS ; $i++) { + if ($this->user[$i]->sess == "" || $this->user[$i]->stat != "room" || $this->user[$i]->name == "") continue; $ct++; } @@ -2244,20 +2076,19 @@ class Room { $content = ' j_stand_cont( [ '; - for ($e = 0 , $ct = 0 ; $e < MAX_PLAYERS ; $e++) { - if ($this->user[$e]->sess == "" || $this->user[$e]->stat != "room" || $this->user[$e]->name == "") + for ($i = 0 , $ct = 0 ; $i < MAX_PLAYERS ; $i++) { + if ($this->user[$i]->sess == "" || $this->user[$i]->stat != "room" || $this->user[$i]->name == "") continue; - $flags = $this->user[$e]->flags; + $flags = $this->user[$i]->flags; - if ($this->user[$e]->subst == "standup") { - if ($this->user[$e] == $user) - { - $flags |= 1; + if ($this->user[$i]->subst == "standup") { + if ($user->idx_get() == $i) { + $flags |= 1; } - - $content .= sprintf('%s[ %d, "%s" ]',($ct > 0 ? ', ' : ''), $flags, xcape($this->user[$e]->name)); - $ct++; + + $content .= sprintf('%s[ %d, "%s" ]',($ct > 0 ? ', ' : ''), $flags, xcape($this->user[$i]->name)); + $ct++; } } $content .= ' ]);'; @@ -2275,23 +2106,23 @@ class Room { // $sess = $user->sess; - $table = &$this->table[$table_idx]; + $table = $this->table[$table_idx]; if ($user->stat != 'room') return; $content = "[ "; for ($i = 0 ; $i < $table->player_n ; $i++) { - $user_cur = &$this->user[$table->player[$i]]; - - $flags = $user_cur->flags; - - if ($user_cur == $user) - $flags |= 1; - - log_main($user_cur->name. sprintf(" IN TABLE [%d]", $table_idx)); - - $content .= sprintf('%s[ %d, "%s" ]',($i == 0 ? '' : ', '), $flags, xcape($user_cur->name)); + $user_cur = $this->user[$table->player[$i]]; + + $flags = $user_cur->flags; + + if ($user->idx_get() == $table->player[$i]) + $flags |= 1; + + log_main($user_cur->name. sprintf(" IN TABLE [%d]", $table_idx)); + + $content .= sprintf('%s[ %d, "%s" ]',($i == 0 ? '' : ', '), $flags, xcape($user_cur->name)); } $content .= ' ]'; @@ -2301,287 +2132,493 @@ class Room { return ($ret); } -} // end class Room - -function make_seed() -{ - list($usec, $sec) = explode(' ', microtime()); - return (float) $sec + ((float) $usec * 100000); -} - - -function log_mop($step, $log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LMOP) == 0) - return; - - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; + function request_mgr(&$s_a_p, $header, &$header_out, &$new_socket, $path, $addr, $get, $post, $cookie) + { + printf("NEW_SOCKET (root): %d\n", intval($new_socket)); - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LMOP) == 0) - return; + $enc = get_encoding($header); + if (isset($header['User-Agent']) && strstr($header['User-Agent'], "MSIE")) { + $transp_type = "htmlfile"; + } + else { + $transp_type = "iframe"; + } + force_no_cache($header_out); - if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("LMOP: [%f] [%05d] [%s] [%s]\n", gettimeofday(TRUE), $step, $PHP_SELF, $log)); - fclose($fp); - } -} + switch ($path) { + case "": + case "index.php": + ob_start(); + index_main($this, $transp_type, $header_out, $addr, $get, $post, $cookie); + $content = ob_get_contents(); + ob_end_clean(); + $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content); + return TRUE; -function log_only2($log) { - GLOBAL $sess, $PHP_SELF; + break; + case "index_wr.php": + ob_start(); + index_wr_main($this, $addr, $get, $post, $cookie); + $content = ob_get_contents(); + ob_end_clean(); + + $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content); + return TRUE; - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONL2) == 0) - return; + break; + case "index_rd_ifra.php": + do { + if (!isset($cookie['sess']) + || (($user = $this->get_user($cookie['sess'], $idx)) == FALSE)) { + $content = User::stream_fini($s_a_p->rndstr, TRUE); + + $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content); + return TRUE; + + break; + } + // close a previous opened index_read_ifra socket, if exists + if (($prev = $user->rd_socket_get()) != NULL) { + $s_a_p->socks_unset($user->rd_socket_get()); + fclose($user->rd_socket_get()); + printf("CLOSE AND OPEN AGAIN ON IFRA2\n"); + $user->rd_socket_set(NULL); + } - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; + $content = ""; + $user->stream_init($s_a_p->rndstr, $enc, $header_out, $content, $get, $post, $cookie); + + $response = headers_render($header_out, -1).chunked_content($user->rd_zls_get(), $content); + $response_l = mb_strlen($response, "ASCII"); + + $wret = @fwrite($new_socket, $response, $response_l); + if ($wret < $response_l) { + printf("TROUBLES WITH FWRITE: %d\n", $wret); + $user->rd_cache_set(mb_substr($content, $wret, $response_l - $wret, "ASCII")); + } + else { + $user->rd_cache_set(""); + } + fflush($new_socket); + + + $s_a_p->socks_set($new_socket, $user); + $user->rd_socket_set($new_socket); + printf(" - qui ci siamo - "); + return TRUE; + } while (FALSE); + + return FALSE; + break; - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONL2) == 0) - return; + default: + /* FAR TODO: move all into an array of registered sub-apps */ + $subs = "briskin5/"; + $subs_l = strlen($subs); + if (!strncmp($path, $subs, $subs_l)) { + $ret = Bin5::request_mgr(&$s_a_p, $header, &$header_out, &$new_socket, substr($path, $subs_l) , $addr, $get, $post, $cookie); + return ($ret); + } + break; + } - if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("ONL2: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); + return (FALSE); } -} -function log_crit($log) { - GLOBAL $sess, $PHP_SELF; + function match_add($idx, $match) + { + $this->match[$idx] = $match; + } - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_CRIT) == 0) - return; + function match_del($idx) + { + unset($this->match[$idx]); + } - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; + function match_get($idx, $token) + { + if (isset($this->match[$idx])) { + if ( $token == NULL + || $token == $this->match[$idx]->table_token) { + return ($this->match[$idx]); + } + } + return NULL; + } - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_CRIT) == 0) - return; +} // end class Room - if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("CRIT: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } +function make_seed() +{ + list($usec, $sec) = explode(' ', microtime()); + return (float) $sec + ((float) $usec * 100000); } -function log_only($log) { - GLOBAL $sess, $PHP_SELF; +function btrace_line($ar) +{ + GLOBAL $G_btrace_pref_sub; - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONLY) == 0) - return; + $ret = ""; + for ($i = 0 ; $i < count($ar) ; $i++) { + $with_class = isset($ar[$i]['class']); + $with_file = isset($ar[$i]['file']); + $ret .= sprintf("%s%s%s (%s:%d)", ($i == 0 ? "" : ", "), + ($with_class ? $ar[$i]['class'].$ar[$i]['type'] : ""), + $ar[$i]['function'], ($with_file ? str_replace($G_btrace_pref_sub, "", $ar[$i]['file']) : ""), + ($with_file ? $ar[$i]['line'] : "")); + } + + return ($ret); +} - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; +function trace_ftok($id, $add) +{ + // NOTE: without space to use sed to substitute "= @ftok(" with "= @ftok(" + $tok=@ftok($id, $add); - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONLY) == 0) - return; + log_shme($tok.": ".$id." + ".$add); - if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("ONLY: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } + return ($tok); } -function log_main($log) { +function log_mop($step, $log) +{ GLOBAL $sess, $PHP_SELF; - - 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(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("MAIN: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LMOP) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LMOP) == 0) + return; + + if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LMOP: [%f] [%05d] [%s] [%s]\n", gettimeofday(TRUE), $step, $log, $btrace)); + fclose($fp); + } } -function log_rd($log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_READ) == 0) - return; - 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] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } +function log_only2($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("ONL2: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_rd2($log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_REA2) == 0) - return; - - 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] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } +function log_crit($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("CRIT: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_send($log) { - GLOBAL $sess, $PHP_SELF; - - 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(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SEND: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } +function log_only($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("ONLY: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_lock($log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOCK) == 0) - return; - - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; +function log_main($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("MAIN: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } +} - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LOCK) == 0) - return; +function log_rd($log) +{ + GLOBAL $sess, $PHP_SELF; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_READ) == 0) + return; + + 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("LOCK: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } + if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("READ: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_wr($log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_WRIT) == 0) - return; +function log_rd2($log) +{ + GLOBAL $sess, $PHP_SELF; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_REA2) == 0) + return; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("REA2: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } +} - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; - - if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_WRIT) == 0) - return; +function log_send($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("WRIT: [%s] [%s] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } + if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("SEND: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_load($log) { - GLOBAL $sess, $PHP_SELF; - - if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOAD) == 0) - return; +function log_lock($log) +{ + GLOBAL $sess, $PHP_SELF; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LOCK: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } +} - if (isset($sess) == FALSE) - $ssess = "XXXX"; - else - $ssess = $sess; +function log_wr($log) +{ + GLOBAL $sess, $PHP_SELF; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_WRIT) == 0) + return; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("WRIT: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } +} - 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] [%s]\n", $ssess, $PHP_SELF, $log)); - fclose($fp); - } +function log_load($log) +{ + GLOBAL $sess, $PHP_SELF; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOAD) == 0) + return; + + 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 ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LOAD: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } -function log_auth($sess, $log) { +function log_auth($sess, $log) +{ GLOBAL $PHP_SELF; - 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 (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 ((BRISK_DEBUG | ($sess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("LOAD: [%s] [%d] [%s] [%s]\n", $sess, time(), $log, $btrace)); + fclose($fp); + } +} - if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { - fwrite($fp, sprintf("AUTH: [%s] [%d] [%s] [%s]\n", $sess, time(), $PHP_SELF, $log)); - fclose($fp); - } +function log_shme($log) +{ + GLOBAL $sess, $PHP_SELF; + + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_SHME) == 0) + return; + + if (isset($sess) == FALSE) + $ssess = "XXXX"; + else + $ssess = $sess; + + if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_SHME) == 0) + return; + + if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC) + $btrace = btrace_line(debug_backtrace()); + else + $btrace = ""; + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("SHME: [%s] [%s] [%s]\n", $ssess, $log, $btrace)); + fclose($fp); + } } + // function log_legal($curtime, $sess, $name, $where, $mesg) -function log_legal($curtime, &$user, $where, $mesg) +function log_legal($curtime, $addr, $user, $where, $mesg) { - GLOBAL $_SERVER; 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|%s|\n", $curtime, $user->sess, ($user->flags & USER_FLAG_AUTH ? 'A' : 'N'), - $user->name, $_SERVER['REMOTE_ADDR'], $where , $mesg)); + $user->name, $addr, $where , $mesg)); fclose($fp); } } - -function lock_banlist() -{ - if (($tok = @ftok(FTOK_PATH."/main", "L")) == -1) { - echo "FTOK FAILED"; - exit; - } - if (($res = sem_get($tok)) == FALSE) { - echo "SEM_GET FAILED"; - exit; - } - if (sem_acquire($res)) - return ($res); - else - return (FALSE); -} - -function unlock_banlist($res) -{ - return (sem_release($res)); -} - function table_act_content($isstanding, $sitted, $table, $cur_table, $allowed) { $ret = ""; @@ -2646,7 +2683,7 @@ function validate_sess($sess) function validate_name($name) { - $name_new = str_replace(' ', '_', substr(trim($name),0,12)); + $name_new = str_replace(' ', '_', mb_substr(trim($name),0,12, "UTF-8")); for ($i = 0 ; $i < strlen($name_new) ; $i++) { $c = $name_new[$i]; @@ -2666,6 +2703,8 @@ function secstoword($secs) { GLOBAL $G_lang; + $ret = ""; + $mins = floor($secs / 60); $secs = $secs % 60; if ($G_lang == 'en') { @@ -2694,67 +2733,57 @@ function sharedmem_sz($tok) $shm_sz = shmop_size($shm_id); shmop_close($shm_id); - log_main("shm_sz: ".$shm_sz." SHM_DIMS: ".SHM_DIMS); + // log_main("shm_sz: ".$shm_sz." SHM_DIMS: ".SHM_DIMS); return ($shm_sz); } class Warrant { - function lock_data() + static $delta_t; + + static function lock_data($is_exclusive) { - GLOBAL $sess; - - if (($tok = @ftok(FTOK_PATH."/warrant", "B")) == -1) { - return (FALSE); - } - // echo "FTOK ".$tok."
"; - if (($res = sem_get($tok)) == FALSE) { - return (FALSE); - } - if (sem_acquire($res)) { - log_lock("LOCK warrant"); - return ($res); - } - else + if (($res = file_lock(FTOK_PATH."/warrant", $is_exclusive)) != FALSE) { + self::$delta_t = microtime(TRUE); + log_lock("LOCK warrant [".self::$delta_t."]"); + + return ($res); + } + return (FALSE); } - function unlock_data($res) + static function unlock_data($res) { GLOBAL $sess; - log_lock("UNLOCK warrant"); - - return (sem_release($res)); + log_lock("UNLOCK warrant [".(microtime(TRUE) - (self::$delta_t))."]"); + + file_unlock($res); } } class Poll { - function lock_data() + static $delta_t; + + static function lock_data($is_exclusive) { - GLOBAL $sess; - - if (($tok = @ftok(FTOK_PATH."/poll", "B")) == -1) { - return (FALSE); - } - // echo "FTOK ".$tok."
"; - if (($res = sem_get($tok)) == FALSE) { - return (FALSE); - } - if (sem_acquire($res)) { - log_lock("LOCK poll"); - return ($res); - } - else + if (($res = file_lock(FTOK_PATH."/poll", $is_exclusive)) != FALSE) { + self::$delta_t = microtime(TRUE); + log_lock("LOCK poll [".self::$delta_t."]"); + + return ($res); + } + return (FALSE); } - function unlock_data($res) + static function unlock_data($res) { GLOBAL $sess; - log_lock("UNLOCK poll"); + log_lock("UNLOCK poll [".(microtime(TRUE) - (self::$delta_t))."]"); - return (sem_release($res)); + file_unlock($res); } }