X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2FObj%2Fbrisk.phh;h=04d6483985fe232811ae41642d84367b2d499ba9;hb=64c7d34242c417a2a430534717ad2b3850e27602;hp=8136f8f5ee52f72b80e0c66add6fb737ed31cf84;hpb=971fb704f6cb6091d0c597209f5f878c04336d51;p=brisk.git diff --git a/web/Obj/brisk.phh b/web/Obj/brisk.phh index 8136f8f..04d6483 100644 --- a/web/Obj/brisk.phh +++ b/web/Obj/brisk.phh @@ -2,7 +2,7 @@ /* * brisk - brisk.phh * - * Copyright (C) 2006-2007 matteo.nastasi@milug.org + * Copyright (C) 2006-2008 matteo.nastasi@milug.org * * 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 @@ -22,32 +22,49 @@ 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, 20); 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(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, 12); define(COMM_GEN_N, 50); define(SESS_LEN, 13); define(STREAM_TIMEOUT, 20); -// FIXME original: define(EXPIRE_TIME_RD, 180); -define(EXPIRE_TIME_RD, 60); +define(EXPIRE_TIME_RD, 180); define(EXPIRE_TIME_SMAMMA, 360); // BAN_TIME da allineare anche in commons.js define(BAN_TIME, 900); define(GARBAGE_TIMEOUT, 10); define(NICKSERV, "SERVER"); -define(BRISK_DEBUG, FALSE); + +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"); $G_false = FALSE; $G_all_points = array( 11,10,4,3,2, 0,0,0,0,0 ); -$G_brisk_version = "spawn-0.0.3"; +$G_brisk_version = "spawn-0.10.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\': dimensionamento dinamico dell\'area dati e ottimizzazione della stessa, versione beta.', '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.'); @@ -135,7 +152,7 @@ class Card { $this->stat = 'take'; // Card stat $this->owner = $newown; } -} +} // end class Card class Table { var $player; @@ -165,6 +182,9 @@ class Table { var $old_win; var $old_friend; + var $table_token; + var $table_start; + function Table() { } @@ -173,12 +193,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; @@ -191,11 +211,14 @@ class Table { $thiz->briscola = -1; $thiz->friend = -1; $thiz->turn = 0; - $thiz->old_reason = ""; + $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; return ($thiz); } @@ -204,7 +227,7 @@ class Table { { GLOBAL $G_false; - if (($thiz = new Table()) == FALSE) + if (($thiz =& new Table()) == FALSE) return ($G_false); $thiz->player = array(); @@ -236,6 +259,9 @@ 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; + return ($thiz); } @@ -247,7 +273,7 @@ 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; @@ -277,6 +303,9 @@ 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; + return ($thiz); } @@ -305,7 +334,7 @@ class Table { $rn = rand(0, $i); if ($rn == 0) - log_main("RND ZERO", ""); + log_main("RND ZERO"); $id = $rest[$rn]; @@ -330,12 +359,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(); @@ -399,7 +428,7 @@ class Table { $this->player_n--; } else { - log_main($user->sess, "INCONSISTENCY ON TABLE."); + log_main("INCONSISTENCY ON TABLE."); } } @@ -440,7 +469,7 @@ class Table { return ($ct); } -} // End class Table +} // end class Table class User { var $name; // name of the user @@ -499,7 +528,7 @@ class User { { GLOBAL $G_false; - if (($thiz = new User()) == FALSE) + if (($thiz =& new User()) == FALSE) return ($G_false); $thiz->name = $from->name; @@ -550,13 +579,14 @@ 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; @@ -571,6 +601,7 @@ class User { } function stat_set($stat) { + log_main("sess: [".$this->sess. "] NEW STAT: [".$stat."]"); $this->stat = "$stat"; /* @@ -599,8 +630,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'); @@ -612,7 +643,8 @@ class User { return (FALSE); } -} +} // end class User + function step_get($sess) { $fp = FALSE; @@ -633,19 +665,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"); } @@ -656,6 +688,7 @@ 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(); @@ -674,6 +707,8 @@ class Room { { $ismod = FALSE; + log_rd2("garbage_manager START"); + /* Garbage collector degli utenti in timeout */ $curtime = time(); if ($force || $this->garbage_timeout < $curtime) { @@ -682,72 +717,104 @@ class Room { 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) { - if (($bri = &Briskin5::load_data($table_idx)) != FALSE) { - if ($bri->garbage_manager(TRUE) == TRUE) { - // if garbaged you need to save data - Briskin5::save_data(&$bri); - if ($bri->is_abandoned()) { - // FIXME recovery of room and clean of the table - /* - - # - # KILL USERS - # - - if ($user_cur->lacc + EXPIRE_TIME_RD < $curtime) { // Auto logout dell'utente - log_rd2($user_cur->sess, "AUTO LOGOUT."); - - if ($user_cur->stat == 'table' || $user_cur->stat == 'room') { - log_auth($user_cur->sess, "Autologout session."); + log_main("bin5 lock data success"); - $tmp_sess = $user_cur->sess; - $user_cur->sess = ""; - step_unproxy($tmp_sess); - $user_cur->name = ""; - $user_cur->step = 0; - $user_cur->the_end = FALSE; + $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; + } + } - log_rd2($user_cur->sess, "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 ???"); - } - } - - # - # destroy shared - # - - Briskin5::destroy_data($user->table); + 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 = ""; + 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); } - $table_bri = &$bri->table[0]; - for ($i = 0 ; $i < PLAYERS_N ; $i++) { - $this->user[$table_cur->player[$i]]->lacc = - $bri->user[$table_bri->player[$i]]->lacc; + } // 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); - } - } - } + 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."); @@ -758,13 +825,13 @@ class Room { $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 ???"); } } @@ -777,7 +844,7 @@ class Room { } } } - log_rd2($user_cur->sess, "GARBAGE UPDATED!"); + log_rd2("GARBAGE UPDATED!"); $this->garbage_timeout = time() + GARBAGE_TIMEOUT; $ismod = TRUE; @@ -792,17 +859,17 @@ class Room { $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"); @@ -830,16 +897,16 @@ 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)."; "; 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); @@ -862,32 +929,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, $update_lacc = FALSE) + 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 != "") { if ($update_lacc == TRUE) { $user_cur->laccwr = $curtime; } - log_load($user->sess, "cur: ".$user_cur->name." subst: ".$user_cur->subst); + log_main("cur: ".$user_cur->name." subst: ".$user_cur->subst); if ($user_cur->subst == "shutdowned") { $user_cur->stat_set("room"); $user_cur->subst = "sitdown"; @@ -898,6 +967,7 @@ class Room { $user_cur->table = -1; $user_wup[$user_wup_n++] = &$user_cur; } + $user_tab[$user_tab_n++] = &$user_cur; } } @@ -907,19 +977,19 @@ 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)."; "; 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); @@ -927,31 +997,35 @@ class Room { $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] = show_room(&$this, ($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(); } @@ -964,7 +1038,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; @@ -988,12 +1062,12 @@ 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) $table = &$this->table[$table_idx]; @@ -1040,7 +1114,7 @@ class Room { $dt = date("H:i ", $timecur); if (strncmp($user_mesg, "/nick ", 6) == 0) { - log_main($user->sess, "chatt_send BEGIN"); + log_main("chatt_send BEGIN"); if (($name_new = validate_name(substr($user_mesg, 6))) == FALSE) { $user->comm[$user->step % COMM_N] = "gst.st = ".($user->step+1)."; "; @@ -1069,11 +1143,11 @@ class Room { if ($i == MAX_PLAYERS) { $user->name = $name_new; - log_main($user->sess, "chatt_send start set"); + log_main("chatt_send start set"); for ($i = 0 ; $i < MAX_PLAYERS ; $i++) { - log_main($user->sess, "chatt_send set loop"); + log_main("chatt_send set loop"); $user_cur = &$this->user[$i]; if ($user_cur->sess == '') @@ -1084,11 +1158,11 @@ class Room { } else if ($user->stat == 'room' && $user->subst == 'sitdown' || $user->stat == 'table') { - log_main($user->sess, "chatt_send pre table update"); + log_main("chatt_send pre table update"); $this->table_update(&$user); - log_main($user->sess, "chatt_send post table update"); + log_main("chatt_send post table update"); } } else if ($user_cur->stat == 'table' && $user_cur->table == $user->table) { @@ -1143,12 +1217,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); @@ -1211,13 +1285,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]); } @@ -1232,14 +1307,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); 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(); } @@ -1258,34 +1333,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); - $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)); + 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); } - - shm_detach($shm); - $ret = &$room; return ($ret); - } + } while (0); + + if ($doexit) + exit(); return ($G_false); } @@ -1297,29 +1385,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); @@ -1332,7 +1420,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; } @@ -1342,7 +1430,7 @@ class Room { exit; } if (sem_acquire($res)) { - log_only($sess, "LOCK"); + log_lock("LOCK room"); return ($res); } else @@ -1353,7 +1441,7 @@ class Room { { GLOBAL $sess; - log_only($sess, "UNLOCK"); + log_lock("UNLOCK room"); return (sem_release($res)); } @@ -1365,113 +1453,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(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("ONLY: [%s] [%s]\n", $ssess, $log)); + fclose($fp); + } +} + +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_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("MAIN: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_rd($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_rd($log) { + GLOBAL $sess; + + 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("/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("READ: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_rd2($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_rd2($log) { + GLOBAL $sess; + + 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("/tmp/brisk_rd2.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("REA2: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_send($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_send.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) { + fwrite($fp, sprintf("SEND: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_auth($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_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("LOCK: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_lock($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_wr($log) { + GLOBAL $sess; + + 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 (($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("WRIT: [%s] [%s]\n", $ssess, $log)); fclose($fp); } } -function log_wr($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_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_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_load($sess, $log) { - if (BRISK_DEBUG != TRUE) +function log_auth($sess, $log) { + if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_AUTH) == 0) return; - if (($fp = @fopen("/tmp/brisk_load.log", 'a')) != FALSE) { - fwrite($fp, sprintf("SESS: [%s] [%s]\n", $sess, $log)); + 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); @@ -1483,7 +1684,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; } @@ -1543,7 +1744,7 @@ function table_content($room, $user, $table_idx) else { $hilion = ""; $hilioff = ""; } - log_main($user_cur->name, sprintf("IN TABLE [%d]", $table_idx)); + log_main($user_cur->name. sprintf(" IN TABLE [%d]", $table_idx)); $content .= sprintf("%s%s%s
",$hilion, xcape($user_cur->name), $hilioff); } @@ -1606,7 +1807,7 @@ function standup_content(&$room, $user) 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); } @@ -1680,7 +1881,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); @@ -1791,9 +1992,12 @@ function table_wellcome($user) return ($ret); } -function show_room(&$room, &$user) +function show_room(&$room, $user_step, &$user) { - $ret = sprintf('gst.st = %d;', $user->step); + log_main("show_room: username: ".$user->name); + + + $ret = sprintf('gst.st = %d;', $user_step); $ret .= sprintf('stat = "%s";', $user->stat); $ret .= root_wellcome($user); @@ -1835,7 +2039,7 @@ function show_table(&$room, &$user, $sendstep, $is_transition, $is_again) $ret .= sprintf( 'gst.st = %d; stat = "%s"; subst = "%s"; table_pos = %d;', $sendstep, $user->stat, $user->subst, $table_pos); - log_rd($user->sess, sprintf( 'SHOW_TABLE: gst.st = %d; stat = "%s"; subst = "%s"; table_pos = %d;', + log_rd(sprintf( 'SHOW_TABLE: gst.st = %d; stat = "%s"; subst = "%s"; table_pos = %d;', $sendstep, $user->stat, $user->subst, $table_pos)); /* BACKGROUND */ @@ -1876,7 +2080,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 ? @@ -1899,7 +2103,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') { @@ -1910,7 +2114,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 = ""; @@ -2005,7 +2209,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; @@ -2058,7 +2262,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 ! @@ -2086,11 +2290,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; @@ -2139,4 +2343,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); +} + + ?>