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