postgres
diff --git a/‎src/backend/utils/sort/sharedtuplestore.c
Lines changed: 3 additions & 2 deletions b/‎src/backend/utils/sort/sharedtuplestore.c
Lines changed: 3 additions & 2 deletions
@@ -160,6 +160,7 @@ sts_initialize(SharedTuplestore *sts, int participants,
 		LWLockInitialize(&sts->participants[i].lock,
 						 LWTRANCHE_SHARED_TUPLESTORE);
 		sts->participants[i].read_page = 0;
+		sts->participants[i].npages = 0;
 		sts->participants[i].writing = false;
 	}
 
@@ -321,7 +322,7 @@ sts_puttuple(SharedTuplestoreAccessor *accessor, void *meta_data,
 
 	/* Do we have space? */
 	size = accessor->sts->meta_data_size + tuple->t_len;
-	if (accessor->write_pointer + size >= accessor->write_end)
+	if (accessor->write_pointer + size > accessor->write_end)
 	{
 		if (accessor->write_chunk == NULL)
 		{
@@ -341,7 +342,7 @@ sts_puttuple(SharedTuplestoreAccessor *accessor, void *meta_data,
 		}
 
 		/* It may still not be enough in the case of a gigantic tuple. */
-		if (accessor->write_pointer + size >= accessor->write_end)
+		if (accessor->write_pointer + size > accessor->write_end)
 		{
 			size_t		written;
Original file line number	Diff line number	Diff line change
`@@ -160,6 +160,7 @@ sts_initialize(SharedTuplestore *sts, int participants,`
`160`	`160`	`LWLockInitialize(&sts->participants[i].lock,`
`161`	`161`	`LWTRANCHE_SHARED_TUPLESTORE);`
`162`	`162`	`sts->participants[i].read_page = 0;`
	`163`	`+ sts->participants[i].npages = 0;`
`163`	`164`	`sts->participants[i].writing = false;`
`164`	`165`	`}`
`165`	`166`
`@@ -321,7 +322,7 @@ sts_puttuple(SharedTuplestoreAccessor accessor, void meta_data,`
`321`	`322`
`322`	`323`	`/* Do we have space? */`
`323`	`324`	`size = accessor->sts->meta_data_size + tuple->t_len;`
`324`		`- if (accessor->write_pointer + size >= accessor->write_end)`
	`325`	`+ if (accessor->write_pointer + size > accessor->write_end)`
`325`	`326`	`{`
`326`	`327`	`if (accessor->write_chunk == NULL)`
`327`	`328`	`{`
`@@ -341,7 +342,7 @@ sts_puttuple(SharedTuplestoreAccessor accessor, void meta_data,`
`341`	`342`	`}`
`342`	`343`
`343`	`344`	`/* It may still not be enough in the case of a gigantic tuple. */`
`344`		`- if (accessor->write_pointer + size >= accessor->write_end)`
	`345`	`+ if (accessor->write_pointer + size > accessor->write_end)`
`345`	`346`	`{`
`346`	`347`	`size_t written;`
`347`	`348`