Changeset 33290 for lang/perl/tiarra/trunk

Timestamp:

05/14/09 03:10:09 (4 years ago)

Author:

topia

Message:

re-check channel status before send part-and-join.
(but test is not done...)

Files:

• lang/perl/tiarra/trunk/module/Channel/Rejoin.pm (modified) (6 diffs)

lang/perl/tiarra/trunk/module/Channel/Rejoin.pm

@@ -38 +38 @@
         if ($cmd eq 'PART') {
             foreach my $ch_fullname (split /,/,$msg->param(0)) {
-                $this->check_channel(
+                $this->check_and_rejoin_channel(
                     scalar Multicast::detatch($ch_fullname),
                     $sender);
@@ -46 +46 @@
             # RFC2812によると、複数のチャンネルを持つKICKメッセージが
             # クライアントに届く事は無い。
-            $this->check_channel(
+            $this->check_and_rejoin_channel(
                 scalar Multicast::detatch($msg->param(0)),
                 $sender);
@@ -53 +53 @@
             # 註釈affected-channelsに影響のあったチャンネルのリストが入っているはず。
             foreach (@{$msg->remark('affected-channels')}) {
-                $this->check_channel($_,$sender);
+                $this->check_and_rejoin_channel($_,$sender);
             }
         }
@@ -60 +60 @@
     }
     $msg;
+}
+
+sub check_and_rejoin_channel {
+    my ($this,$ch_name,$server) = @_;
+    if ($this->check_channel($ch_name,$server)) {
+        $this->rejoin($ch_name,$server);
+    }
 }
 
@@ -87 +94 @@
         return;
     }
-    $this->rejoin($ch_name,$server);
+    return 1;
 }
 
@@ -185 +192 @@
     my ($this,$session) = @_;
     $session->{got_oper} = 1;
+    if (!$this->check_channel($session->{ch_shortname}, $session->{server})) {
+        # 情報を取得している間に状況が変化した
+        RunLoop->shared->notify_msg(
+            "Channel::Rejoin is cancelled to rejoin to $session->{ch_fullname}.");
+        # part/join をやめたので発行すべきコマンドはない。
+        $session->{cmd_buf} = [];
+        # フラグ類のクリーンアップを行う
+        $this->revive($session);
+        return;
+    }
     foreach (qw/PART JOIN/) {
         $session->{server}->send_message(