Method Shutdown

kv/memberlist/tcp_transport.go:627–652

Shutdown is called when memberlist is shutting down; this gives the transport a chance to clean up any listeners. This will avoid log spam about errors when we shut down.

()

// transport a chance to clean up any listeners.
// This will avoid log spam about errors when we shut down.
func (t *TCPTransport) Shutdown() error {
	t.shutdownMu.Lock()
	// This will avoid log spam about errors when we shut down.
	if t.shutdown {
		t.shutdownMu.Unlock()
		return nil // already shut down
	}

	// Set the shutdown flag and close the write channel.
	t.shutdown = true
	close(t.writeCh)
	t.shutdownMu.Unlock()

	// Rip through all the connections and shut them down.
	for _, conn := range t.tcpListeners {
		_ = conn.Close()
	}

	// Wait until all write workers have finished.
	t.writeWG.Wait()

	// Block until all the listener threads have died.
	t.wg.Wait()

	return nil
}

func (t *TCPTransport) registerMetrics(registerer prometheus.Registerer) {
	const subsystem = "memberlist_tcp_transport"