Method PassServerTransport

internal/xds/server/conn_wrapper.go:127–135

PassServerTransport drains the passed in ServerTransport if draining is set, or persists it to be drained once drained is called.

(st transport.ServerTransport)

// PassServerTransport drains the passed in ServerTransport if draining is set,
// or persists it to be drained once drained is called.
func (c *connWrapper) PassServerTransport(st transport.ServerTransport) {
	c.mu.Lock()
	defer c.mu.Unlock()
	if c.draining {
		st.Drain("draining")
	} else {
		c.st = st
	}
}

// Drain drains the associated ServerTransport, or sets draining to true so it
// will be drained after it is created.