Changeset 12403

Timestamp:

05/26/08 03:08:14 (5 years ago)

Author:

topia

Message:

* add implementation of ->{mod_disposables}, ->add_module_object, ->remove_module_object.

Files:

• lang/perl/tiarra/branches/module-reload/main/ModuleManager.pm (modified) (10 diffs)

lang/perl/tiarra/branches/module-reload/main/ModuleManager.pm

@@ -10 +10 @@
 use warnings;
 use UNIVERSAL;
-#use RunLoop;
+use Scalar::Util qw(refaddr);
 use Tiarra::SharedMixin qw(shared shared_manager);
 use Tiarra::ShorthandConfMixin;
@@ -23 +23 @@
 
 sub _new {
-    shift->new(shift || RunLoop->shared);
+    shift->new(shift || do { require RunLoop && RunLoop->shared });
 }
 
@@ -37 +37 @@
         mod_blacklist => {}, # 過去に正常動作しなかったモジュール。
         updated_once => 0, # 過去にupdate_modulesが実行された事があるか。
+        mod_disposables => {}, # モジュールに関連づけられているタイマーとか。アンロードした後で全部捨てる。
     };
     bless $obj,$class;
@@ -160 +161 @@
 }
 
+sub add_module_object {
+    my $this = shift->_this;
+    my ($modname, @disposables) = @_;
+    $modname = ref($modname) || $modname;
+
+    push @{$this->{mod_disposables}->{$modname}}, @disposables;
+
+    $this;
+}
+
+sub remove_module_object {
+    my $this = shift->_this;
+    my ($modname, @disposables) = @_;
+    $modname = ref($modname) || $modname;
+
+    return unless $this->{mod_disposables}->{$modname};
+
+    my %targets = map { refaddr($_) => 1 } @disposables;
+    @{$this->{mod_disposables}->{$modname}} =
+        grep { !$targets{refaddr($_)} } @{$this->{mod_disposables}->{$modname}};
+
+    $this;
+}
+
+sub _destruct_module_object {
+    my $this = shift->_this;
+    my $module = shift; # module instance or module name
+    my $modname = ref($module) || $module;
+
+    my $arr = delete $this->{mod_disposables}->{$modname};
+
+    return unless $arr;
+
+    foreach my $object (@$arr) {
+        eval {
+            $object->module_destruct($module);
+        }; if ($@) {
+            $this->_runloop->notify_error($@);
+        }
+    }
+
+    $this;
+}
+
 sub update_modules {
     # +で指定されたモジュール一覧を読み、modulesを再構成する。
@@ -271 +316 @@
         # 先に destruct して回る
         foreach my $modname (reverse @mods_load_order) {
-            my $idx = $loaded_mods_idx{$modname};
-            if (defined $idx) {
+            my $mod = $loaded_mods{$modname};
+            if ($mod) {
                 eval {
-                    $this->{modules}->[$idx]->destruct;
+                    $mod->destruct;
                 }; if ($@) {
                     $this->_runloop->notify_error($@);
                 }
+                $this->_destruct_module_object($mod);
             } else {
                 eval {
@@ -284 +330 @@
                     $this->_runloop->notify_error($@);
                 }
+                $this->_destruct_module_object($modname);
             }
         }
@@ -359 +406 @@
         # %loaded_modsに古い物が入っている場合は破棄した上、アンロードする。
         my $modname = $_;
+        my $mod = $loaded_mods{$modname};
         $show_msg->("Module ".$modname." will be unloaded.");
-        if (defined $loaded_mods{$modname}) {
+        if (defined $mod) {
             eval {
-                $loaded_mods{$modname}->destruct;
+                $mod->destruct;
             }; if ($@) {
                 $this->_runloop->notify_error($@);
             }
+            $this->_destruct_module_object($mod);
         }
         $this->_unload($_);
@@ -526 +575 @@
         # 念のため古いやつは destruct しておく。エラーは無視。
         eval { $oldmod->destruct };
+        $this->_destruct_module_object($oldmod);
         return undef;
     }
@@ -535 +585 @@
         # 念のため古いやつは destruct しておく。エラーは無視。
         eval { $oldmod->destruct };
+        $this->_destruct_module_object($oldmod);
         return undef;
     }
@@ -655 +706 @@
                 $key->destruct;
             };
+            $this->_destruct_module_object($key);
 
             $this->_runloop->notify_msg(