Merge 9ff4a9c into 020de4d

lib/reel/connection.rb

@@ -124,6 +124,8 @@ def respond(response, headers_or_body = {}, body = nil)
       # The client disconnected early, or there is no request
       @keepalive = false
       @request_fsm.transition :closed
+      @parser.reset
+      @current_request = nil
     end
 
     # Close the connection

spec/reel/connection_spec.rb

@@ -156,6 +156,25 @@ def test_chunked_response(request, client)
     end
   end
 
+  it "resets if client dropped connection" do
+    with_socket_pair do |client, peer|
+      connection = Reel::Connection.new(peer)
+      example_request = ExampleRequest.new
+      client << example_request
+
+      expect(connection.request).not_to be_nil
+
+      client.close # client drops connection
+      # now send more than the send buffer can hold, triggering a
+      # error (ECONNRESET or EPIPE)
+      connection.respond :ok, ("Some Big Response sent"*100000)
+
+      # connection should be at end
+      expect(connection.request).to be_nil
+    end
+  end
+
+
   it "raises an error trying to read two pipelines without responding first" do
     with_socket_pair do |client, peer|
       connection = Reel::Connection.new(peer)