Commit: 172 - nova.ext (svn)

PHPのフレームワークです。オートローディング、ルーティング、ORマッパ、フォームバリデータ、その他ユーティリティがセットになっています。

Commit MetaInfo

• Revision: 172 (tree)
• Time: 2022-05-27 13:27:07
• Author: tantancode

Log Message

LockInfoのメソッド名変更

Change Summary

• modified: lib/filters/PostValidationFilter.php
• modified: lib/tables/LockInfo.php
• modified: sites/command/cron/IndexAction.php

Incremental Difference

--- lib/filters/PostValidationFilter.php	(revision 171)
+++ lib/filters/PostValidationFilter.php	(revision 172)
@@ -49,7 +49,7 @@
 
             // 取得できた場合のみ同時実行を阻止する。
             if( isset($userId) )
-                class_exists('LockInfo') && LockInfo::enterExclusiveFlow($userId, 'user');
+                class_exists('LockInfo') && LockInfo::lockFor($userId, 'user');
         }
     }
 }

--- lib/tables/LockInfo.php	(revision 171)
+++ lib/tables/LockInfo.php	(revision 172)
@@ -24,8 +24,11 @@
      * param    ロック対象の種別。lock_info.particle_type の値。
      * param    内部的に使っているので指定する必要はない。ロックに使用する接続。
      */
-    public static function enterExclusiveFlow($id, $type='system', $pdo = null) {
+    public static function lockFor($id, $type='system', $pdo = null) {
 
+        if( !isset($id) )
+            throw new ErrorException('ロック対象のIDにnullを指定することは出来ません。');
+
         // パスポート用のレコードはロック用途には使えない。パスポート用のレコードを排他制御でロックしたままパスポートを更新しようとしたら
         // デッドロックになってしまう。
         if($type == 'pass')
@@ -57,7 +60,7 @@
         if($lock === false) {
             $pdo->commit();     // レコードがない場合、粒度の大きなロックになるので速やかに解放する。
             static::insertSolid(array('particle_type'=>$type, 'particle_id'=>$id));
-            static::enterExclusiveFlow($id, $type, $pdo);
+            static::lockFor($id, $type, $pdo);
             return;
         }
 
@@ -73,7 +76,7 @@
      * param    ロック対象のID。lock_info.particle_id の値。
      * param    ロック対象の種別。lock_info.particle_type の値。
      */
-    public static function leaveExclusiveFlow($id, $type='system') {
+    public static function unlockFor($id, $type='system') {
 
         // 指定の排他制御が開始されていないなら何もしない。
         if( !isset(self::$wedges[$type][$id]) )
@@ -153,7 +156,7 @@
     protected static $primaryColumn = array('particle_type', 'particle_id');
 
     // insertRecord() 時、主キー重複エラーを無視するようにする。
-    // これがないと、初めてenterExclusiveFlow()で排他制御に入ろうとする処理が同時に走ったとき、INSERT重複でエラーになる可能性がある。
+    // これがないと、初めてlockFor()で排他制御に入ろうとする処理が同時に走ったとき、INSERT重複でエラーになる可能性がある。
     protected static $insertOption = 'ignore';
 
 
@@ -165,8 +168,8 @@
 }
 
 // 実装メモ
-// leaveExclusiveFlow() を「すべての排他制御を終了させる」という割り切ったものにすれば、接続も一つで済むし、particle_type:pass も user に
+// unlockFor() を「すべての排他制御を終了させる」という割り切ったものにすれば、接続も一つで済むし、particle_type:pass も user に
 // 統合できるのでは？と思ったけど…
 // よく考えると、排他制御に入ってパスポートを更新すると、PHP終了時の自動ロールバックでパスポート更新が巻き戻るんだよね…
 // それを考えるとやっぱり別接続にせざるを得ないわけで…そうなると排他制御レコードとパスポートレコード分けとかないと排他制御中にパスポート更新できなく
-// なるわけで…そこまでやるなら、今の「leaveExclusiveFlow() は個別解放が可能」っていう実装はそんなに難しくないよね、となる。
+// なるわけで…そこまでやるなら、今の「unlockFor() は個別解放が可能」っていう実装はそんなに難しくないよね、となる。

--- sites/command/cron/IndexAction.php	(revision 171)
+++ sites/command/cron/IndexAction.php	(revision 172)
@@ -195,7 +195,7 @@
         $beat = substr($beat, 2);
 
         // 以降の同時実行を防止する。
-        LockInfo::enterExclusiveFlow(LockInfo::CRON);
+        LockInfo::lockFor(LockInfo::CRON);
 
         // 最後にこのタスクを実行したときのスタンプを取得。
         $prop = new UserProperty(0, 'cron_executed');
@@ -211,7 +211,7 @@
         $prop->save();
 
         // 同時実行防止はここまで。後続処理はジョブの実行なのでたぶん長い。ここで手動解放する必要がある。
-        LockInfo::leaveExclusiveFlow(LockInfo::CRON);
+        LockInfo::unlockFor(LockInfo::CRON);
 
         return true;
     }