Search code, repositories, users, issues, pull requests...

Lines 111 to 113 in 242d13b

    
           	} 
        
           	v.err = v.observer.leaveNode(name, plan) 
        
           }()

in pkg/sql.(*planVisitor).visitInternal.func1

Lines 296 to 298 in 242d13b

in pkg/sql.(*planVisitor).visitInternal

Lines 78 to 80 in 242d13b

    
           } 
        
           v.visitInternal(plan, name) 
        
           return plan

in pkg/sql.(*planVisitor).visit

cockroach/pkg/sql/plan.go

Lines 42 to 44 in 242d13b

    
           v := makePlanVisitor(ctx, observer) 
        
           v.visit(plan) 
        
           return v.err

in pkg/sql.walkPlan

Lines 518 to 520 in 242d13b

    
           	} 
        
           	return walkPlan(params.ctx, plan, o) 
        
           }

in pkg/sql.startExec

cockroach/pkg/sql/plan_node_to_row_source.go

Lines 145 to 147 in 242d13b

    
           // This starts all of the nodes below this node. 
        
           if err := startExec(p.params, p.node); err != nil { 
        
           	p.MoveToDraining(err)

in pkg/sql.(*planNodeToRowSource).Start

cockroach/pkg/sql/colexec/columnarizer.go

Lines 157 to 159 in 242d13b

    
           ctx = c.StartInternalNoSpan(ctx) 
        
           c.input.Start(ctx) 
        
           if execStatsHijacker, ok := c.input.(execinfra.ExecStatsForTraceHijacker); ok {

in pkg/sql/colexec.(*Columnarizer).Init

cockroach/pkg/sql/colflow/stats.go

Lines 89 to 91 in 242d13b

    
           func (bic *batchInfoCollector) Init(ctx context.Context) { 
        
           	bic.Operator.Init(ctx) 
        
           	bic.mu.Lock()

in pkg/sql/colflow.(*batchInfoCollector).Init

cockroach/pkg/sql/colflow/flow_coordinator.go

Lines 234 to 236 in 242d13b

    
           return colexecerror.CatchVectorizedRuntimeError(func() { 
        
           	f.input.Root.Init(ctx) 
        
           })

in pkg/sql/colflow.(*BatchFlowCoordinator).init.func1

cockroach/pkg/sql/colexecerror/error.go

Lines 90 to 92 in 242d13b

    
           }() 
        
           operation() 
        
           return retErr

in pkg/sql/colexecerror.CatchVectorizedRuntimeError

cockroach/pkg/sql/colflow/flow_coordinator.go

Lines 233 to 235 in 242d13b

    
           func (f *BatchFlowCoordinator) init(ctx context.Context) error { 
        
           	return colexecerror.CatchVectorizedRuntimeError(func() { 
        
           		f.input.Root.Init(ctx)

in pkg/sql/colflow.(*BatchFlowCoordinator).init

cockroach/pkg/sql/colflow/flow_coordinator.go

Lines 278 to 280 in 242d13b

    
           if err := f.init(ctx); err != nil { 
        
           	f.pushError(err)

in pkg/sql/colflow.(*BatchFlowCoordinator).Run

cockroach/pkg/sql/colflow/vectorized_flow.go

Lines 259 to 261 in 242d13b

    
           	log.VEvent(ctx, 1, "running the batch flow coordinator in the flow's goroutine") 
        
           	f.batchFlowCoordinator.Run(ctx) 
        
           }

in pkg/sql/colflow.(*vectorizedFlow).Run

cockroach/pkg/sql/distsql_running.go

Lines 596 to 598 in 242d13b

    
           // TODO(radu): this should go through the flow scheduler. 
        
           flow.Run(ctx, func() {})

in pkg/sql.(*DistSQLPlanner).Run

cockroach/pkg/sql/distsql_running.go

Lines 1444 to 1446 in 242d13b

    
           recv.expectedRowsRead = int64(physPlan.TotalEstimatedScannedRows) 
        
           runCleanup := dsp.Run(ctx, planCtx, txn, physPlan, recv, evalCtx, nil /* finishedSetupFn */) 
        
           return func() {

in pkg/sql.(*DistSQLPlanner).PlanAndRun

Lines 1466 to 1468 in 242d13b

    
           // the planner whether or not to plan remote table readers. 
        
           cleanup := ex.server.cfg.DistSQLPlanner.PlanAndRun( 
        
           	ctx, evalCtx, planCtx, planner.txn, planner.curPlan.main, recv,

in pkg/sql.(*connExecutor).execWithDistSQLEngine

Lines 1142 to 1144 in 242d13b

    
           ex.sessionTracing.TraceExecStart(ctx, "distributed") 
        
           stats, err := ex.execWithDistSQLEngine( 
        
           	ctx, planner, stmt.AST.StatementReturnType(), res, distribute, progAtomic,

in pkg/sql.(*connExecutor).dispatchToExecutionEngine

Lines 685 to 687 in 242d13b

    
           if err := ex.dispatchToExecutionEngine(stmtCtx, p, res); err != nil { 
        
           	stmtThresholdSpan.Finish()

in pkg/sql.(*connExecutor).execStmtInOpenState

Lines 142 to 144 in 242d13b

    
           } else { 
        
           	ev, payload, err = ex.execStmtInOpenState(ctx, parserStmt, prepared, pinfo, res, canAutoCommit) 
        
           }

in pkg/sql.(*connExecutor).execStmt

Lines 230 to 232 in 242d13b

    
           } 
        
           ev, payload, err = ex.execStmt(ctx, portal.Stmt.Statement, portal.Stmt, pinfo, stmtRes, canAutoCommit) 
        
           // Portal suspension is supported via a "side" state machine

in pkg/sql.(*connExecutor).execPortal

Lines 1951 to 1953 in 242d13b

    
           canAutoCommit := ex.implicitTxn() && tcmd.FollowedBySync 
        
           ev, payload, err = ex.execPortal(ctx, portal, portalName, stmtRes, pinfo, canAutoCommit) 
        
           return err

in pkg/sql.(*connExecutor).execCmd.func2

Lines 1953 to 1955 in 242d13b

    
           	return err 
        
           }() 
        
           // Note: we write to ex.statsCollector.phaseTimes, instead of ex.phaseTimes,

in pkg/sql.(*connExecutor).execCmd

Lines 1799 to 1801 in 242d13b

    
           var err error 
        
           if err = ex.execCmd(); err != nil { 
        
           	if errors.IsAny(err, io.EOF, errDrainingComplete) {

in pkg/sql.(*connExecutor).run