Class: MessagePack::RPC::SessionPool

Inherits:
Object
  • Object
show all
Includes:
LoopUtil
Defined in:
lib/msgpack/rpc/session_pool.rb

Overview

SessionPool is usable for connection pooling. You can get pooled Session using get_session method. Note that SessionPool includes LoopUtil.

Direct Known Subclasses

Server

Instance Attribute Summary

Attributes included from LoopUtil

#loop

Instance Method Summary collapse

Methods included from LoopUtil

#run, #start_timer, #stop, #submit

Constructor Details

#initialize(arg1 = nil, arg2 = nil) ⇒ SessionPool

  1. initialize(builder, loop = Loop.new)

  2. initialize(loop = Loop.new)

Creates an SessionPool.



30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/msgpack/rpc/session_pool.rb', line 30

def initialize(arg1=nil, arg2=nil)
  if arg1.respond_to?(:build_transport)
    # 1.
    builder = arg1
    loop    = arg2 || Loop.new
  else
    # 2.
    builder = TCPTransport.new
    loop    = arg1 || Loop.new
  end

  @builder = builder
  @loop = loop
  @pool = {}

  @timer = Timer.new(1, true, &method(:step_timeout))
  loop.attach(@timer)
end

Instance Method Details

#close ⇒ Object 



72
73
74
75
76
77
78
79
 
# File 'lib/msgpack/rpc/session_pool.rb', line 72

def close
  @pool.reject! {|addr, s|
    s.close
    true
  }
  @timer.detach if @timer.attached?
  nil
end

#get_session(arg1, arg2 = nil) ⇒ Object Also known as: get_session_addr

  1. get_session(address)

  2. get_session(host, port)

Returns pooled Session. If there are no pooled Session for the specified address, this method creates the Session and pools it.



55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/msgpack/rpc/session_pool.rb', line 55

def get_session(arg1, arg2=nil)
  if arg2.nil?
    # 1.
    addr = arg1
  else
    # 2.
    host = arg1
    port = arg2
    addr = Address.new(host, port)
  end

  @pool[addr] ||= Session.new(@builder, addr, @loop)
end