Add handler to catch IO events while waiting for HttpSM to shutdown

Author: shinrich

proxy/http/Http1ClientSession.cc

@@ -286,6 +286,8 @@ Http1ClientSession::do_io_close(int alerrno)
     _reader->consume(_reader->read_avail());
   } else {
     read_state = HCS_CLOSED;
+    SET_HANDLER(&Http1ClientSession::state_wait_for_sm_shutdown);
+    ka_vio = client_vc->do_io_read(this, INT64_MAX, read_buffer);
     HttpSsnDebug("[%" PRId64 "] session closed", con_id);
     HTTP_SUM_DYN_STAT(http_transactions_per_client_con, transact_count);
     HTTP_DECREMENT_DYN_STAT(http_current_client_connections_stat);
@@ -296,6 +298,17 @@ Http1ClientSession::do_io_close(int alerrno)
   }
 }
 
+int
+Http1ClientSession::state_wait_for_sm_shutdown(int event, void *data)
+{
+  STATE_ENTER(&Http1ClientSession::state_wait_for_sm_shutdown, event, data);
+  ink_assert(data == ka_vio);
+  ink_assert(read_state == HCS_CLOSED);
+
+  // Just eat IO events until the state machine has finished
+  return 0;
+}
+
 int
 Http1ClientSession::state_wait_for_close(int event, void *data)
 {

proxy/http/Http1ClientSession.h

@@ -99,6 +99,7 @@ class Http1ClientSession : public ProxySession
   int state_keep_alive(int event, void *data);
   int state_slave_keep_alive(int event, void *data);
   int state_wait_for_close(int event, void *data);
+  int state_wait_for_sm_shutdown(int event, void *data);
 
   enum C_Read_State {
     HCS_INIT,