Jubatus クライアントから TCP 接続を切る方法

どうやってクライアント側からコネクションを close させるか検討する。

背景

Jubatus サーバは、アイドル状態が 10 秒続くと TCP 接続を自動切断するが、クライアントは切断を検知できないため、クライアントが次のリクエストを投げるタイミングでタイムアウトエラーが発生する
- jubatus/jubatus#244
このタイムアウト機能は本家 MsgPack-RPC サーバにはなく、 jubatus-msgpack-rpc で独自に実装したもの。
2013/02/12 の打合せで、以下の方針が決まった
- 「タイムアウト機能が不要であれば --timeout 0 を利用すること」を FAQ に記述する
- --timeout 0 を使う場合、クライアントが自らコネクションを close できる機能が必要。だが、現状ではできない

クライアントクラス内の mprpc クライアントのフィールドを private から public に変更して直接 close() を呼べるようにする
- pros
  - mprpc クライアントの全機能にアクセス可能
- cons
  - マナーが悪い
mprpc クライアントのインスタンスの参照を返す get_client() メソッドをクライアントクラスに用意する
- pros
  - mprpc クライアントの全機能にアクセス可能
- cons
  - get_client というメソッドが IDL で定義されていた時にどうするか考える必要あり
close() メソッドをクライアントクラスに用意 (proxyパターン的な方法)
- pros
  - 各言語でメソッド名が統一できる
  - マナーは最良
- cons:
  - mprpc クライアントの一部の機能にしかアクセスできない
  - 同じように内部インスタンスに触りたいケースが発生する度に、クライアントクラスを再生成する必要あり
  - close というメソッドが IDL で定義されていた時にどうするか考える必要あり

個人的には「get_client() メソッドを用意する」案が筋が良いのではと思う.

まとめると、close / タイムアウト値の変更を行うためには:

である。

C++
- 現状: mprpc クライアントが private なので close 不可
- mprpc クライアントの機能: get_timeout(), set_timeout(), イベントループ
  - TCP 接続を close するインタフェースは無い (jubatus-msgpack-rpc を改造する必要あり)
Java
- 現状: mprpc クライアントが private なので close 不可
- mprpc クライアントの機能: close(), getRequestTimeout(), setRequestTimeout(), イベントループ　など
Python
- 現状: jubaClient.client.close() など内部の mprpc クライアント(client)を直接触れば close 可能
- mprpc クライアントの機能: close() メソッド, _timeout フィールド, イベントループなど
Ruby
- 現状: mprpc クライアント (@cli) にアクセサが無いので close 不可
- mprpc クライアントの提供する機能: close() メソッド, timeout フィールド, イベントループなど