s.mu must be held by the caller.
()
| 2006 | |
| 2007 | // s.mu must be held by the caller. |
| 2008 | func (s *Server) drainAllServerTransportsLocked() { |
| 2009 | if !s.drain { |
| 2010 | for _, conns := range s.conns { |
| 2011 | for st := range conns { |
| 2012 | st.Drain("graceful_stop") |
| 2013 | } |
| 2014 | } |
| 2015 | s.drain = true |
| 2016 | } |
| 2017 | } |
| 2018 | |
| 2019 | // s.mu must be held by the caller. |
| 2020 | func (s *Server) closeListenersLocked() { |