Changeset 37269 for lang/perl/tiarra/trunk

Timestamp:

04/25/10 03:22:51 (3 years ago)

Author:

topia

Message:

implement resume connecting.

Files:

• lang/perl/tiarra/trunk/main/Tiarra/Socket/Connect.pm (modified) (2 diffs)

lang/perl/tiarra/trunk/main/Tiarra/Socket/Connect.pm

@@ -42 +42 @@
 #               attach($connector->current_addr, $connector->current_port,
 #                      $msg_or_sock);
+#               # その後上手く行かなかったので再開したいとき
+#               # まず、いらなくなったソケットをクローズ
+#               $msg_or_sock->close;
+#               # このサーバは失敗したものとして、次のサーバから再試行
+#               $connector->resume;
 #           # timeout を指定したときは実装するようにしてください。
 #           } elsif ($genre eq 'timeout') {
@@ -505 +510 @@
 }
 
+sub resume {
+    my ($this) = @_;
+
+    if (defined $this->sock) {
+        $this->detach;
+    }
+    $this->_connect_try_next;
+}
+
+sub want_to_read {
+    0;
+}
+
 sub want_to_write {
     1;