X-Git-Url: https://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2Fbriskin5%2FObj%2Fbriskin5.phh;h=0987e47fa3b1510fc5631d6ef4ad4dcdfba718a9;hb=7edf76e645812c232f8090b96b5a68a182ab96bc;hp=fffd6921170dae06ce168123cff76ac22002c29f;hpb=8e6645e3502b269d768bbb43e30b70bf96a2cdaf;p=brisk.git diff --git a/web/briskin5/Obj/briskin5.phh b/web/briskin5/Obj/briskin5.phh index fffd692..0987e47 100644 --- a/web/briskin5/Obj/briskin5.phh +++ b/web/briskin5/Obj/briskin5.phh @@ -992,34 +992,20 @@ class Bin5 { return ($ret); } - function lock_data($table_idx) + static function lock_data($is_exclusive, $table_idx) { - GLOBAL $sess; - - log_main("lockinfo: DATA ".FTOK_PATH."/bin5/table".$table_idx."/table"); - // echo "LOCK: ".FTOK_PATH."/main"; - // exit; - // WARNING monitor this step - if (($tok = @ftok(FTOK_PATH."/bin5/table".$table_idx."/table", "B")) == -1) { - return (FALSE); - } - // WARNING monitor this step - if (($res = @sem_get($tok)) == FALSE) { + if (($res = file_lock(FTOK_PATH."/bin5/table".$table_idx."/table", $is_exclusive)) != FALSE) { + self::$delta_t = microtime(TRUE); + log_lock("LOCK table [".$table_idx."] [".self::$delta_t[$table_idx]."]"); + + return (new Vect(array('res' => $res, 'tab' => $table_idx))); + } + return (FALSE); - } - if (sem_acquire($res)) { - self::$delta_t[$table_idx] = microtime(TRUE); - log_lock("LOCK table [".$table_idx."] [".self::$delta_t[$table_idx]."]"); - - return (new Vect(array('res' => $res, 'tab' => $table_idx))); - } - else { - log_lock("LOCK table ".$table_idx.":FAILED"); - return (FALSE); - } } + - function unlock_data($res_vect) + static function unlock_data($res_vect) { GLOBAL $sess; @@ -1028,7 +1014,7 @@ class Bin5 { log_lock("UNLOCK table [".$tab."] [".(microtime(TRUE) - (self::$delta_t[$tab]))."]"); - return (sem_release($res)); + file_unlock($res); }