| 1987 | } |
| 1988 | |
| 1989 | void |
| 1990 | Http2ConnectionState::cleanup_streams() |
| 1991 | { |
| 1992 | Http2Stream *s = stream_list.head; |
| 1993 | while (s) { |
| 1994 | Http2Stream *next = static_cast<Http2Stream *>(s->link.next); |
| 1995 | if (this->rx_error_code.cls != ProxyErrorClass::NONE) { |
| 1996 | s->set_rx_error_code(this->rx_error_code); |
| 1997 | } |
| 1998 | if (this->tx_error_code.cls != ProxyErrorClass::NONE) { |
| 1999 | s->set_tx_error_code(this->tx_error_code); |
| 2000 | } |
| 2001 | s->initiating_close(); |
| 2002 | ink_assert(s != next); |
| 2003 | s = next; |
| 2004 | } |
| 2005 | |
| 2006 | if (!is_state_closed()) { |
| 2007 | SCOPED_MUTEX_LOCK(lock, this->session->get_mutex(), this_ethread()); |
| 2008 | |
| 2009 | UnixNetVConnection *vc = static_cast<UnixNetVConnection *>(session->get_netvc()); |
| 2010 | if (vc && vc->active_timeout_in == 0) { |
| 2011 | vc->add_to_keep_alive_queue(); |
| 2012 | } |
| 2013 | } |
| 2014 | } |
| 2015 | |
| 2016 | bool |
| 2017 | Http2ConnectionState::delete_stream(Http2Stream *stream) |
nothing calls this directly
no test coverage detected