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



549
550
551
552
 
# File 'lib/parallel_server/prefork.rb', line 549

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

.recv(io) ⇒ Object

Parameters:

  • io (IO)

Returns:

  • (Object) 


556
557
558
559
560
561
562
563
 
# File 'lib/parallel_server/prefork.rb', line 556

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) 


542
543
544
 
# File 'lib/parallel_server/prefork.rb', line 542

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