NotificationsYou must be signed in to change notification settings
Fork28
Star151

Commit06fa667

committed

Ensure gatherstate->nextreader is properly initialized.

The previously code worked OK as long as a Gather node was neverrescanned, or if it was rescanned, as long as it got at least asmany workers on rescan as it had originally. But if the numberof workers ever decreased on a rescan, then it could crash.Andreas Seltenreich

1 parentefeb313 commit06fa667Copy full SHA for 06fa667

File tree

1 file changed

-0

lines changed

src/backend/executor
- nodeGather.c

1 file changed

-0

lines changed

`‎src/backend/executor/nodeGather.c`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -172,6 +172,7 @@ ExecGather(GatherState *node)`
`172`	`172`	`if (pcxt->nworkers_launched>0)`
`173`	`173`	`{`
`174`	`174`	`node->nreaders=0;`
	`175`	`+node->nextreader=0;`
`175`	`176`	`node->reader=`
`176`	`177`	`palloc(pcxt->nworkers_launchedsizeof(TupleQueueReader));`
`177`	`178`
`@@ -334,6 +335,7 @@ gather_readnext(GatherState *gatherstate)`
`334`	`335`	`CHECK_FOR_INTERRUPTS();`
`335`	`336`
`336`	`337`	`/* Attempt to read a tuple, but don't block if none is available. */`
	`338`	`+Assert(gatherstate->nextreader<gatherstate->nreaders);`
`337`	`339`	`reader=gatherstate->reader[gatherstate->nextreader];`
`338`	`340`	`tup=TupleQueueReaderNext(reader, true,&readerdone);`
`339`	`341`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit06fa667

File tree

1 file changed

1 file changed

`‎src/backend/executor/nodeGather.c`

0 commit comments