/* ----------
* toastrel_valueid_exists -
*
- * Test whether a toast value with the given ID exists in the toast relation
+ * Test whether a toast value with the given ID exists in the toast relation.
+ * For safety, we consider a value to exist if there are either live or dead
+ * toast rows with that ID; see notes for GetNewOid().
* ----------
*/
static bool
int num_indexes;
int validIndex;
Relation *toastidxs;
- SnapshotData SnapshotToast;
/* Fetch a valid index relation */
validIndex = toast_open_indexes(toastrel,
/*
* Is there any such chunk?
*/
- init_toast_snapshot(&SnapshotToast);
toastscan = systable_beginscan(toastrel,
RelationGetRelid(toastidxs[validIndex]),
- true, &SnapshotToast, 1, &toastkey);
+ true, SnapshotAny, 1, &toastkey);
if (systable_getnext(toastscan) != NULL)
result = true;
* managed to cycle through 2^32 OIDs and generate the same OID before we
* finish inserting our row. This seems unlikely to be a problem. Note
* that if we had to *commit* the row to end the race condition, the risk
- * would be rather higher; therefore we use SnapshotDirty in the test,
- * so that we will see uncommitted rows.
+ * would be rather higher; therefore we use SnapshotAny in the test, so that
+ * we will see uncommitted rows. (We used to use SnapshotDirty, but that has
+ * the disadvantage that it ignores recently-deleted rows, creating a risk
+ * of transient conflicts for as long as our own MVCC snapshots think a
+ * recently-deleted row is live. The risk is far higher when selecting TOAST
+ * OIDs, because SnapshotToast considers dead rows as active indefinitely.)
*/
Oid
GetNewOid(Relation relation)
GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
{
Oid newOid;
- SnapshotData SnapshotDirty;
SysScanDesc scan;
ScanKeyData key;
bool collides;
*/
Assert(!IsBinaryUpgrade || RelationGetRelid(relation) != TypeRelationId);
- InitDirtySnapshot(SnapshotDirty);
-
/* Generate new OIDs until we find one not in the table */
do
{
BTEqualStrategyNumber, F_OIDEQ,
ObjectIdGetDatum(newOid));
- /* see notes above about using SnapshotDirty */
+ /* see notes above about using SnapshotAny */
scan = systable_beginscan(relation, indexId, true,
- &SnapshotDirty, 1, &key);
+ SnapshotAny, 1, &key);
collides = HeapTupleIsValid(systable_getnext(scan));