Function RunMessageLoop

server/exports.go:277–283

RunMessageLoop runs the main message loop for a client connection. It cancels the connection context when the loop exits, ensuring in-flight query contexts (and any gRPC calls derived from them) are cancelled promptly.

(cc *clientConn)

// after the activator installs the executor. A failure there fails the
// activation, which is connection-fatal, matching the eager path's refusal.
//
// Do NOT reach for ApplyConnectionS3CacheOption from inside an activator: at
// that point the executor is still nil, the worker swap silently no-ops, and
// the session flag flips anyway.
func SetPendingS3CacheOption(cc *clientConn, raw string) {
	if cc != nil {
		cc.pendingS3Cache = raw
		cc.hasPendingS3Cache = true
	}
}