Class: EventMachine::Protocols::HeaderAndContentProtocol

Inherits:
Connection
  • Object
show all
Includes:
LineText2
Defined in:
lib/protocols/header_and_content.rb

Overview

Originally, this subclassed LineAndTextProtocol, which in turn relies on BufferedTokenizer, which doesn’t gracefully handle the transitions between lines and binary text. Changed 13Sep08 by FCianfrocca.

Constant Summary collapse

ContentLengthPattern = 
/Content-length:\s*(\d+)/i

Constants included from LineText2

LineText2::MaxBinaryLength, LineText2::MaxLineLength

Instance Attribute Summary

Attributes inherited from Connection

#signature

Class Method Summary collapse

Instance Method Summary collapse

Methods included from LineText2

#receive_data, #receive_end_of_binary_data, #set_binary_mode, #set_delimiter, #set_line_mode, #set_text_mode, #unbind

Methods inherited from Connection

#associate_callback_target, #close_connection, #close_connection_after_writing, #comm_inactivity_timeout, #comm_inactivity_timeout=, #connection_completed, #detach, #error?, #get_outbound_data_size, #get_peername, #get_pid, #get_sockname, #get_status, new, #post_init, #receive_data, #reconnect, #send_data, #send_datagram, #send_file_data, #set_comm_inactivity_timeout, #start_tls, #stream_file_data, #unbind

Constructor Details

#initialize(*args) ⇒ HeaderAndContentProtocol

Returns a new instance of HeaderAndContentProtocol.



41
42
43
44
 
# File 'lib/protocols/header_and_content.rb', line 41

def initialize *args
    super
    init_for_request
end

Class Method Details

.headers_2_hash(hdrs) ⇒ Object 



114
115
116
117
118
119
120
121
122
123
 
# File 'lib/protocols/header_and_content.rb', line 114

def headers_2_hash hdrs
    hash = {}
    hdrs.each {|h|
  if /\A([^\s:]+)\s*:\s*/ =~ h
      tail = $'.dup
      hash[ $1.downcase.gsub(/-/,"_").intern ] = tail
  end
    }
    hash
end

Instance Method Details

#headers_2_hash(hdrs) ⇒ Object

Basically a convenience method. We might create a subclass that does this automatically. But it’s such a performance killer.



109
110
111
 
# File 'lib/protocols/header_and_content.rb', line 109

def headers_2_hash hdrs
    self.class.headers_2_hash hdrs
end

#receive_binary_data(text) ⇒ Object 



82
83
84
85
 
# File 'lib/protocols/header_and_content.rb', line 82

def receive_binary_data text
    @hc_content = text
    dispatch_request
end

#receive_line(line) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/protocols/header_and_content.rb', line 46

def receive_line line
    case @hc_mode
    when :discard_blanks
 unless line == ""
      @hc_mode = :headers
      receive_line line
 end
    when :headers
 if line == ""
      raise "unrecognized state" unless @hc_headers.length > 0
      if respond_to?(:receive_headers)
  receive_headers @hc_headers
      end
      # @hc_content_length will be nil, not 0, if there was no content-length header.
      if @hc_content_length.to_i > 0
  set_binary_mode @hc_content_length
      else
  dispatch_request
      end
 else
      @hc_headers << line
      if ContentLengthPattern =~ line
  # There are some attacks that rely on sending multiple content-length
  # headers. This is a crude protection, but needs to become tunable.
  raise "extraneous content-length header" if @hc_content_length
  @hc_content_length = $1.to_i
      end
      if @hc_headers.length == 1 and respond_to?(:receive_first_header_line)
  receive_first_header_line line
      end
 end
    else
 raise "internal error, unsupported mode"
    end
end