parent
3715850ecc
commit
c4f113e8fe
3 changed files with 4 additions and 6 deletions
|
@ -2656,8 +2656,8 @@ agg_refill_hash_table(AggState *aggstate)
|
||||||
prepare_hash_slot(perhash,
|
prepare_hash_slot(perhash,
|
||||||
aggstate->tmpcontext->ecxt_outertuple,
|
aggstate->tmpcontext->ecxt_outertuple,
|
||||||
hashslot);
|
hashslot);
|
||||||
entry = LookupTupleHashEntryHash(
|
entry = LookupTupleHashEntryHash(perhash->hashtable, hashslot,
|
||||||
perhash->hashtable, hashslot, p_isnew, hash);
|
p_isnew, hash);
|
||||||
|
|
||||||
if (entry != NULL)
|
if (entry != NULL)
|
||||||
{
|
{
|
||||||
|
|
|
@ -2337,8 +2337,7 @@ ReorderBufferProcessTXN(ReorderBuffer *rb, ReorderBufferTXN *txn,
|
||||||
|
|
||||||
case REORDER_BUFFER_CHANGE_INVALIDATION:
|
case REORDER_BUFFER_CHANGE_INVALIDATION:
|
||||||
/* Execute the invalidation messages locally */
|
/* Execute the invalidation messages locally */
|
||||||
ReorderBufferExecuteInvalidations(
|
ReorderBufferExecuteInvalidations(change->data.inval.ninvalidations,
|
||||||
change->data.inval.ninvalidations,
|
|
||||||
change->data.inval.invalidations);
|
change->data.inval.invalidations);
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
|
|
@ -821,8 +821,7 @@ ResolveRecoveryConflictWithBufferPin(void)
|
||||||
* not be so harmful because the period that the buffer is kept pinned
|
* not be so harmful because the period that the buffer is kept pinned
|
||||||
* is basically no so long. But we should fix this?
|
* is basically no so long. But we should fix this?
|
||||||
*/
|
*/
|
||||||
SendRecoveryConflictWithBufferPin(
|
SendRecoveryConflictWithBufferPin(PROCSIG_RECOVERY_CONFLICT_STARTUP_DEADLOCK);
|
||||||
PROCSIG_RECOVERY_CONFLICT_STARTUP_DEADLOCK);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue