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

This method returns an undefined value.

Parameters:

  • io (IO)
  • data (String) —

    marshaled data



489
490
491
492
 
# File 'lib/parallel_server/prefork.rb', line 489

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

.recv(io) ⇒ Object

Parameters:

  • io (IO)

Returns:

  • (Object) 


496
497
498
499
500
501
502
503
 
# File 'lib/parallel_server/prefork.rb', line 496

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

This method returns an undefined value.

Parameters:

  • io (IO)
  • msg (Object) 


482
483
484
 
# File 'lib/parallel_server/prefork.rb', line 482

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