class ParallelServer::Prefork::Conversation
Public Class Methods
_send(io, data)
click to toggle source
@param io [IO] @param data [String] marshaled data @return [void]
# File lib/parallel_server/prefork.rb, line 545 def self._send(io, data) io.puts data.length io.write data end
recv(io)
click to toggle source
@param io [IO] @return [Object]
# File lib/parallel_server/prefork.rb, line 552 def self.recv(io) len = io.gets return unless len && len =~ /\A\d+\n/ len = len.to_i data = io.read(len) return unless data && data.size == len Marshal.load(data) end
send(io, msg)
click to toggle source
@param io [IO] @param msg [Object] @return [void]
# File lib/parallel_server/prefork.rb, line 538 def self.send(io, msg) _send(io, Marshal.dump(msg)) end