Class: Baykit::BayServer::Docker::Http::H1::H1CommandUnPacker

Inherits:
Protocol::CommandUnPacker
  • Object
show all
Includes:
Agent, Command
Defined in:
lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cmd_handler, svr_mode) ⇒ H1CommandUnPacker

Returns a new instance of H1CommandUnPacker.



20
21
22
23
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 20

def initialize(cmd_handler, svr_mode)
  @cmd_handler = cmd_handler
  @server_mode = svr_mode
end

Instance Attribute Details

#command_handler ⇒ Object (readonly)

Returns the value of attribute command_handler.



17
18
19
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 17

def command_handler
  @command_handler
end

#server_mode ⇒ Object (readonly)

Returns the value of attribute server_mode.



18
19
20
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 18

def server_mode
  @server_mode
end

Instance Method Details

#finished ⇒ Object 



48
49
50
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 48

def finished()
  return @cmd_handler.req_finished()
end

#packet_received(pkt) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 29

def packet_received(pkt)
  BayLog.debug("h1: read packet type=%d length=%d", pkt.type, pkt.data_len())

  case pkt.type
  when H1Type::HEADER
    cmd = CmdHeader.new(@server_mode)

  when H1Type::CONTENT
    cmd = CmdContent.new()

  else
    reset
    raise Sink.new("IllegalState")
  end

  cmd.unpack pkt
  return cmd.handle(@cmd_handler)
end

#reset ⇒ Object 



25
26
27
 
# File 'lib/baykit/bayserver/docker/http/h1/h1_command_unpacker.rb', line 25

def reset

end