Class: ParallelServer::Prefork::Conversation

Inherits:
Object
  • Object
show all
Defined in:
lib/parallel_server/prefork.rb

Class Method Summary collapse

Class Method Details

._send(io, data) ⇒ void 



545
546
547
548
 
# File 'lib/parallel_server/prefork.rb', line 545

def self._send(io, data)
  io.puts data.length
  io.write data
end

.recv(io) ⇒ Object 



552
553
554
555
556
557
558
559
 
# 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) ⇒ void 



538
539
540
 
# File 'lib/parallel_server/prefork.rb', line 538

def self.send(io, msg)
  _send(io, Marshal.dump(msg))
end