Method removeWaiterLocked

controlplane/session_mgr.go:316–325

(waiter *connectionWaiter)

// CreateSession acquires a worker from the configured pool, creates a session
// on it, and rebalances memory/thread limits across all active sessions.
// If pid is 0, a new one is generated.
func (sm *SessionManager) CreateSession(ctx context.Context, username string, pid int32, memoryLimit string, threads int, profile *WorkerProfile) (int32, *flightclient.FlightExecutor, error) {
	return sm.CreateSessionWithProtocol(ctx, username, pid, memoryLimit, threads, "postgres", profile)
}

func (sm *SessionManager) CreateSessionWithProtocol(ctx context.Context, username string, pid int32, memoryLimit string, threads int, protocol string, profile *WorkerProfile) (resultPID int32, resultExecutor *flightclient.FlightExecutor, resultErr error) {
	ctx, finishCreation, err := sm.beginSessionCreation(ctx)
	if err != nil {
		return 0, nil, err
	}
	defer func() {
		if !finishCreation() {
			return