Class for managing a pool of sockets
Install:
gem install socketpool
Initialize a socket pool:
pool = SocketPool.new("127.0.0.1", "11211") # => a socket pool with a max size of 2, connected via tcp to 127.0.0.1:11211 pool = SocketPool.new("127.0.0.1", "11211", :size => 10) # => a socket pool with a max size of 10, connected via tcp to 127.0.0.1:11211 pool = SocketPool.new("127.0.0.1", "11211", :size => 10, :type => :udp) # => a socket pool with a max size of 10, connected via udp to 127.0.0.1:11211 s = pool.checkout #=> gets socket from pool pool.checkin(s) #=> puts socket back in pool
Initialization Options:
:size #=> determines the max size of the socket pool (number of sockets that can eventually be in the pool) :type #=> the "type" of socket in the pool: must be one of [:udp, :udp6, :tcp, :tcp6, :unix, :unigram] #=> :unigram specifies a datagram unix socket; if using a unix socket then set host and port to the "path" :eager #=> default false, if set to "true" then all sockets will be initialized on pool initialization :timeout #=> defaults to 5.0, the number of seconds to wait for an unused socket from the pool to be freed :socketopts #=> an array of options to be set (via setsockopts) on each socket initialization #=> example: [{:level => Socket::IPPROTO_TCP, :optname => Socket::TCP_NODELAY, :optval => 1}]
-
“socketpool” is heavily influenced by utils/pool.rb from MongoDB (Apache 2.0 licensed).
The socket checkout/checkin functionality is a direct copy, unfortunately all of the functionality I wanted (like eager initialization) was not implemented so I augmented it for “socketpool”.
-
Check out the latest master to make sure the feature hasn’t been implemented or the bug hasn’t been fixed yet
-
Check out the issue tracker to make sure someone already hasn’t requested it and/or contributed it
-
Fork the project
-
Start a feature/bugfix branch
-
Commit and push until you are happy with your contribution
-
Make sure to add tests for it. This is important so I don’t break it in a future version unintentionally.
-
Please try not to mess with the Rakefile, version, or history. If you want to have your own version, or is otherwise necessary, that is fine, but please isolate to its own commit so I can cherry-pick around it.