[ruby-list:25510] Re: net/imap.rb

前田です。

何かもったいないので勝手にruby-listにふりますm(__)m
# ruby-devの方がよいのかな?

At Wed, 18 Oct 2000 20:20:16 +0900,
akira yamada / やまだあきら <[e-mail]> wrote:
> >> IMAP4rev1 では非同期にコマンドを送ることができるそうですが, 
> S> RFC読むとそんな感じがするのですが、複数のリクエストの処理中にタグ
> S> のついてないレスポンスが来た場合に、それがどのリクエストへの応答
> S> なのか判断できなさそうに思えたのでこういう実装にしています。
> S> 何かよいアイデアがあれば教えてください(^_^;
> 
> わたしも RFC と本を読みはじめたばかりなのでアレなんすが, 
> 一方的に送られるくるタグなし応答って EXPUNGE だけでないすかね?
> EXPUNGE 以外はなんらかのコマンドに対する応答として
> 返されるような気がします. 

いや、一方的におくられてくるのは考えてないです。

私の勘違いかもしれませんけど、たとえばFETCHとかSTOREを何個か並行
して実行したとして、タグなしのFETCHレスポンスが来た時にどっちのコ
マンドへの応答なのかわからない気がします。
# FETCHレスポンスの内容まで見てコマンドとの整合性をしらべればわか
# るケースもあるかなとか思ったりしましたけど、オーバーへッドが…
RFC実はちゃんと読みきれてないんですが、こういう場合は最初のレスポ
ンスの応答が完了するまで他のレスポンスはかえさないもんなんでしょ
うか?
# だったら並行にしてもあんまり意味がないような気がしますが。

その問題がクリアできれば、

    def async_fetch(set, attr)
      return Thread.start {
        @mutex.synchonize {
           tag = send_cmd(...)
           until command_completed?(tag)
             @cond.wait(@mutex)
           end
           get_response("FETCH")
        }
      }
    end

みたいに実装して、

resp1 = imap.async_fetch(1..-1, "ENVELOPE")
imap.select("other")
resp2 = imap.async_fetch(1..-1, "ENVELOPE")
....
x = resp1.value # レスポンスの値がほしい時

とかするとかっこいいような気がするんですけど、UW-IMAPDとかの挙動
を見てると、結局、送った順番に一個ずつレスポンスを返してるだけの
ような気がするので、苦労の割に得るものは少ないんじゃないかなとか
思ったりします。

というわけで当面はもっと他のことに労力を費やしたいです。
# たとえばENVELOPEやBODYSTRUCTUREに対応するクラスを用意したりとか。

しかし、imap.rb書いて思ったのですが、IMAPって実装者にやさしくない
プロトコルですね。

* 1 EXISTS

とかを

* MESSAGES 1

にしてくれれば、2番目のトークンでレスポンスの種類がわかるのにー。

> で, ここからちょっと先走ります(^_^;
> 
> 先の質問の意図は, わたしの要望というか
> 利用時のイメージを言った方がわかりやすいと思うんですが, 
> それはこういうことです. 
> 
>  ・完全に手続き的なインタフェースがほしい
> 
>    今だと「コマンド送ってレスポンスを受け取る」を
>    全部やってくれています. これはこれでうれしいのですが, 
>    それとは別に「コマンドを送る」, 「レスポンスを受け取る」
>    というメソッドもほしい気がしています. 
> 
>  ・同期モードと非同期モードを作る
> 
>    ここでいう同期モードというのは, 
>    現在の imap.rb のようなふるまいを期待しています. 
> 
>    一方, 非同期モードの方はこういう感じですかね
> 
>      x = Net::IMAP.new(...)
> 
>      tag = x.select('inbox')
>      # ↑はコマンドをキューにいれるだけ
>      # 別スレッドで(?)キューからとり出して送信している
> 
>      r = x.wait(tag)
>      # ↑は(他のコマンドがあればそれも待つけど)特に
>      # tag で指定されたコマンドへの応答があるまで待つ
>      if r
>        begin
> 	 tags = []
> 	 tags << x.fetch(...) # コマンドをキューにいれるだけ
> 	 tags << x.store(...) # コマンドをキューにいれるだけ
> 	 tags << x.fetch(...) # コマンドをキューにいれるだけ
> 	    …
> 	 x.wait { |tag, response|
> 	   # 応答のあったものからブロックを適用
> 	 }
> 
>        rescue Net::IMAP::UNTAGGED_EXPUNGE
>          # x.finished に完了したコマンドが
>          # x.unfinished に未完のコマンドが
>        end
>      end
> 
>    うまく利用イメージが伝わるかわかりませんが, 
>    なんかこんなようなやり方ができるとうれしいです. 
> 
> 非同期モードにおいてはコマンドに対応するメソッドは
> 内部のキューにいれるだけで実行はせず, 
> 内部的に動いている別スレッドでコマンドの送信を
> 行う形になるのではないかと思っています. 
> 
> ただ, レスポンスを待たなきゃ送れないコマンドもあるようなので
> その点に注意しなくてはならないように思います. 
> うーん, こんなんかなあ. 
> 
>   class Net::IMAP
>     def queueing(command)
> 
>       # RFC2060 section 5.5: Therefore, if the client sends any
>       # command other than FETCH, STORE, or SEARCH, it MUST wait for a
>       # response before sending a command with message sequence
>       # numbers.
>       raise PLEASE_WAIT if must_i_wait_now?
> 
>       @queue.lock
>       @queue.put(command)
>       @queue.unlock
> 
>       return command.tag
>     end
> 
>     def fetch(arg)
>       queueing(Command.new(:FETCH, arg, arg, ...))
>     end
> 
>     def copy(arg)
>       queueing(Command.new(:COPY, arg, arg, ...))
>     end
> 
>     …
> 
>     def wait(tag = nil, &block)
>       @queue.lock # queue をロックして queueing がブロックするようになる
>       if !tag
>         responses = []
>         # @response は完了したコマンドのレスポンスがはき出されて
>         # なんらかの処理がされるのを待つキュー
>         while r = @response.get(nil)
>           if block
>             block.call(r.tag, r)
>           else
>             responses << r
>           end
>         end
>         return responses
>       else
>         if block
>           r = @response.get(tag)
>           block.call(r.tag, r)
>         else
>           return @response.get(tag)
>         end
>       end
>     end
>   end
> 
> 
> 非同期モードは net/imap.rb の範囲を
> 超えてしまっているかもしれませんが
> これがあるとうれしいというか, これを実装したいというか, 
> そんなところです. 
> 
> 
> # ちょっと発散ぎみのメールになっちゃいました, ごめんなさい. 
> 
> -- 
> 
>  やまだ あきら <URL:http://arika.org/>
>  ([e-mail], [e-mail] or [e-mail])
> 
>  
> 

-- 
前田 修吾