Class DRb::HTTP0::ClientSide < Object

# File sample/drb/http0.rb, line 39
def initialize(uri, config)
  @uri = uri
  @res = nil
  @config = config
  @msg = DRbMessage.new(config)
  @proxy = ENV['HTTP_PROXY']
end

# File sample/drb/http0.rb, line 48
def alive?; false; end

# File sample/drb/http0.rb, line 47
def close; end

# File sample/drb/http0.rb, line 61
def post(url, data)
  it = URI.parse(url)
  path = [(it.path=='' ? '/' : it.path), it.query].compact.join('?')
  http = Net::HTTP.new(it.host, it.port)
  sio = StrStream.new
  http.post(path, data, {'Content-Type'=>'application/octetstream;'}) do |str|
    sio.write(str)
    if @config[:load_limit] < sio.buf.size
      raise TypeError, 'too large packet'
    end
  end
  @reply_stream = sio
end

# File sample/drb/http0.rb, line 57
def recv_reply
  @msg.recv_reply(@reply_stream)
end

# File sample/drb/http0.rb, line 50
def send_request(ref, msg_id, *arg, &b)
  stream = StrStream.new
  @msg.send_request(stream, ref, msg_id, *arg, &b)
  @reply_stream = StrStream.new
  post(@uri, stream.buf)
end