Method logQueryStarted

server/conn.go:455–466

(query string)

// queryContext returns a cancellable context for query execution.
// The cancel function is registered with the server so it can be invoked
// via a cancel request from another connection.
// The caller must call the returned cleanup function when the query completes.
//
// A disconnect monitor goroutine runs for the duration of the query. It uses
// bufio.Reader.Peek to detect client disconnects (TCP FIN/RST) while the
// query is in-flight, without consuming any bytes from the stream. When a
// disconnect is detected, the connection context (c.ctx) is cancelled,
// propagating cancellation to gRPC calls on Flight SQL workers.
//
// In child worker processes, the context is also cancelled when the server's
// externalCancelCh is closed (triggered by SIGUSR1 signal).
func (c *clientConn) queryContext() (context.Context, func()) {
	return c.queryContextInner(true)
}