diff options
Diffstat (limited to 'src/backend/commands')
-rw-r--r-- | src/backend/commands/async.c | 10 | ||||
-rw-r--r-- | src/backend/commands/cluster.c | 4 | ||||
-rw-r--r-- | src/backend/commands/command.c | 4 | ||||
-rw-r--r-- | src/backend/commands/copy.c | 8 | ||||
-rw-r--r-- | src/backend/commands/proclang.c | 2 | ||||
-rw-r--r-- | src/backend/commands/purge.c | 4 | ||||
-rw-r--r-- | src/backend/commands/recipe.c | 5 | ||||
-rw-r--r-- | src/backend/commands/remove.c | 18 | ||||
-rw-r--r-- | src/backend/commands/trigger.c | 10 | ||||
-rw-r--r-- | src/backend/commands/vacuum.c | 16 | ||||
-rw-r--r-- | src/backend/commands/view.c | 6 |
11 files changed, 43 insertions, 44 deletions
diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c index 021d00e4c9e..257be8a1e9a 100644 --- a/src/backend/commands/async.c +++ b/src/backend/commands/async.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.23 1997/11/05 21:18:54 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.24 1997/11/20 23:20:56 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -206,7 +206,7 @@ Async_Notify(char *relname) lRel = heap_openr(ListenerRelationName); tdesc = RelationGetTupleDescriptor(lRel); RelationSetLockForWrite(lRel); - sRel = heap_beginscan(lRel, 0, NowTimeQual, 1, &key); + sRel = heap_beginscan(lRel, 0, false, 1, &key); nulls[0] = nulls[1] = nulls[2] = ' '; repl[0] = repl[1] = repl[2] = ' '; @@ -287,7 +287,7 @@ Async_NotifyAtCommit() Int32GetDatum(1)); lRel = heap_openr(ListenerRelationName); RelationSetLockForWrite(lRel); - sRel = heap_beginscan(lRel, 0, NowTimeQual, 1, &key); + sRel = heap_beginscan(lRel, 0, false, 1, &key); tdesc = RelationGetTupleDescriptor(lRel); ourpid = getpid(); @@ -441,7 +441,7 @@ Async_Listen(char *relname, int pid) /* is someone already listening. One listener per relation */ tdesc = RelationGetTupleDescriptor(lDesc); - s = heap_beginscan(lDesc, 0, NowTimeQual, 0, (ScanKey) NULL); + s = heap_beginscan(lDesc, 0, false, 0, (ScanKey) NULL); while (HeapTupleIsValid(htup = heap_getnext(s, 0, &b))) { d = heap_getattr(htup, b, Anum_pg_listener_relname, tdesc, @@ -599,7 +599,7 @@ Async_NotifyFrontEnd() lRel = heap_openr(ListenerRelationName); RelationSetLockForWrite(lRel); tdesc = RelationGetTupleDescriptor(lRel); - sRel = heap_beginscan(lRel, 0, NowTimeQual, 2, key); + sRel = heap_beginscan(lRel, 0, false, 2, key); nulls[0] = nulls[1] = nulls[2] = ' '; repl[0] = repl[1] = repl[2] = ' '; diff --git a/src/backend/commands/cluster.c b/src/backend/commands/cluster.c index 9e93388f729..3bfdb961541 100644 --- a/src/backend/commands/cluster.c +++ b/src/backend/commands/cluster.c @@ -14,7 +14,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/cluster.c,v 1.15 1997/09/08 02:21:55 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/cluster.c,v 1.16 1997/11/20 23:20:58 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -355,7 +355,7 @@ rebuildheap(Oid OIDNewHeap, Oid OIDOldHeap, Oid OIDOldIndex) { HeapTid = &ScanResult->heap_iptr; - LocalHeapTuple = heap_fetch(LocalOldHeap, 0, HeapTid, &LocalBuffer); + LocalHeapTuple = heap_fetch(LocalOldHeap, false, HeapTid, &LocalBuffer); OIDNewHeapInsert = heap_insert(LocalNewHeap, LocalHeapTuple); pfree(ScanResult); diff --git a/src/backend/commands/command.c b/src/backend/commands/command.c index 1f80e9e2e0d..d33edbb7f9b 100644 --- a/src/backend/commands/command.c +++ b/src/backend/commands/command.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/Attic/command.c,v 1.20 1997/10/27 08:55:16 vadim Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/Attic/command.c,v 1.21 1997/11/20 23:21:00 momjian Exp $ * * NOTES * The PortalExecutorHeapMemory crap needs to be eliminated @@ -440,7 +440,7 @@ PerformAddAttribute(char *relationName, * XXX use syscache here as an optimization */ key[1].sk_argument = (Datum) colDef->colname; - attsdesc = heap_beginscan(attrdesc, 0, NowTimeQual, 2, key); + attsdesc = heap_beginscan(attrdesc, 0, false, 2, key); tup = heap_getnext(attsdesc, 0, (Buffer *) NULL); diff --git a/src/backend/commands/copy.c b/src/backend/commands/copy.c index 8593aa3f25a..fdc998b9418 100644 --- a/src/backend/commands/copy.c +++ b/src/backend/commands/copy.c @@ -6,7 +6,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/copy.c,v 1.34 1997/09/12 04:07:25 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/copy.c,v 1.35 1997/11/20 23:21:03 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -224,7 +224,7 @@ CopyTo(Relation rel, bool binary, bool oids, FILE *fp, char *delim) int32 ntuples; TupleDesc tupDesc; - scandesc = heap_beginscan(rel, 0, NULL, 0, NULL); + scandesc = heap_beginscan(rel, 0, false, 0, NULL); attr_count = rel->rd_att->natts; attr = rel->rd_att->attrs; @@ -921,7 +921,7 @@ GetIndexRelations(Oid main_relation_oid, bool isnull; pg_index_rel = heap_openr(IndexRelationName); - scandesc = heap_beginscan(pg_index_rel, 0, NULL, 0, NULL); + scandesc = heap_beginscan(pg_index_rel, 0, false, 0, NULL); tupDesc = RelationGetTupleDescriptor(pg_index_rel); *n_indices = 0; @@ -1198,7 +1198,7 @@ CountTuples(Relation relation) int i; - scandesc = heap_beginscan(relation, 0, NULL, 0, NULL); + scandesc = heap_beginscan(relation, 0, false, 0, NULL); for (tuple = heap_getnext(scandesc, 0, NULL), i = 0; tuple != NULL; diff --git a/src/backend/commands/proclang.c b/src/backend/commands/proclang.c index 2b8836b70bb..8cc8b5ae48c 100644 --- a/src/backend/commands/proclang.c +++ b/src/backend/commands/proclang.c @@ -189,7 +189,7 @@ DropProceduralLanguage(DropPLangStmt * stmt) ScanKeyEntryInitialize(&scanKeyData, 0, Anum_pg_language_lanname, F_NAMEEQ, PointerGetDatum(languageName)); - scanDesc = heap_beginscan(rdesc, 0, NowTimeQual, 1, &scanKeyData); + scanDesc = heap_beginscan(rdesc, 0, false, 1, &scanKeyData); tup = heap_getnext(scanDesc, 0, (Buffer *) NULL); diff --git a/src/backend/commands/purge.c b/src/backend/commands/purge.c index 78265c93cc5..b0f67366265 100644 --- a/src/backend/commands/purge.c +++ b/src/backend/commands/purge.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/Attic/purge.c,v 1.8 1997/09/08 02:22:11 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/Attic/purge.c,v 1.9 1997/11/20 23:21:08 momjian Exp $ * * Note: * XXX There are many instances of int32 instead of ...Time. These @@ -110,7 +110,7 @@ RelationPurge(char *relationName, key[0].sk_argument = PointerGetDatum(relationName); fmgr_info(key[0].sk_procedure, &key[0].sk_func, &key[0].sk_nargs); - scan = heap_beginscan(relation, 0, NowTimeQual, 1, key); + scan = heap_beginscan(relation, 0, false, 1, key); oldTuple = heap_getnext(scan, 0, &buffer); if (!HeapTupleIsValid(oldTuple)) { diff --git a/src/backend/commands/recipe.c b/src/backend/commands/recipe.c index 077e8823780..43d84c5a01a 100644 --- a/src/backend/commands/recipe.c +++ b/src/backend/commands/recipe.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/Attic/recipe.c,v 1.10 1997/10/25 01:08:54 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/Attic/recipe.c,v 1.11 1997/11/20 23:21:10 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -804,8 +804,7 @@ tg_parseTeeNode(TgRecipe * r, tt, tt, FALSE, - FALSE, - NULL)); + FALSE)); rt_ind = length(orig->rtable); } diff --git a/src/backend/commands/remove.c b/src/backend/commands/remove.c index daa37b6714b..aaf2127e460 100644 --- a/src/backend/commands/remove.c +++ b/src/backend/commands/remove.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/Attic/remove.c,v 1.15 1997/09/18 20:20:24 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/Attic/remove.c,v 1.16 1997/11/20 23:21:13 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -95,7 +95,7 @@ RemoveOperator(char *operatorName, /* operator name */ ObjectIdGetDatum(typeId2)); relation = heap_openr(OperatorRelationName); - scan = heap_beginscan(relation, 0, NowTimeQual, 3, operatorKey); + scan = heap_beginscan(relation, 0, false, 3, operatorKey); tup = heap_getnext(scan, 0, &buffer); if (HeapTupleIsValid(tup)) { @@ -163,7 +163,7 @@ SingleOpOperatorRemove(Oid typeOid) for (i = 0; i < 3; ++i) { key[0].sk_attno = attnums[i]; - sdesc = heap_beginscan(rdesc, 0, NowTimeQual, 1, key); + sdesc = heap_beginscan(rdesc, 0, false, 1, key); while (PointerIsValid(tup = heap_getnext(sdesc, 0, &buffer))) { ItemPointerCopy(&tup->t_ctid, &itemPointerData); @@ -212,7 +212,7 @@ AttributeAndRelationRemove(Oid typeOid) oidptr->next = NULL; optr = oidptr; rdesc = heap_openr(AttributeRelationName); - sdesc = heap_beginscan(rdesc, 0, NowTimeQual, 1, key); + sdesc = heap_beginscan(rdesc, 0, false, 1, key); while (PointerIsValid(tup = heap_getnext(sdesc, 0, &buffer))) { ItemPointerCopy(&tup->t_ctid, &itemPointerData); @@ -233,7 +233,7 @@ AttributeAndRelationRemove(Oid typeOid) while (PointerIsValid((char *) optr->next)) { key[0].sk_argument = (Datum) (optr++)->reloid; - sdesc = heap_beginscan(rdesc, 0, NowTimeQual, 1, key); + sdesc = heap_beginscan(rdesc, 0, false, 1, key); tup = heap_getnext(sdesc, 0, &buffer); if (PointerIsValid(tup)) { @@ -283,7 +283,7 @@ RemoveType(char *typeName) /* type name to be removed */ typeKey[0].sk_argument = PointerGetDatum(typeName); - scan = heap_beginscan(relation, 0, NowTimeQual, 1, typeKey); + scan = heap_beginscan(relation, 0, false, 1, typeKey); tup = heap_getnext(scan, 0, (Buffer *) 0); if (!HeapTupleIsValid(tup)) { @@ -301,7 +301,7 @@ RemoveType(char *typeName) /* type name to be removed */ shadow_type = makeArrayTypeName(typeName); typeKey[0].sk_argument = NameGetDatum(shadow_type); - scan = heap_beginscan(relation, 0, NowTimeQual, + scan = heap_beginscan(relation, 0, false, 1, (ScanKey) typeKey); tup = heap_getnext(scan, 0, (Buffer *) 0); @@ -389,7 +389,7 @@ RemoveFunction(char *functionName, /* function name to be removed */ fmgr_info(key[0].sk_procedure, &key[0].sk_func, &key[0].sk_nargs); relation = heap_openr(ProcedureRelationName); - scan = heap_beginscan(relation, 0, NowTimeQual, 1, key); + scan = heap_beginscan(relation, 0, false, 1, key); do { /* hope this is ok because it's indexed */ @@ -496,7 +496,7 @@ RemoveAggregate(char *aggName, char *aggType) ObjectIdGetDatum(basetypeID)); relation = heap_openr(AggregateRelationName); - scan = heap_beginscan(relation, 0, NowTimeQual, 2, aggregateKey); + scan = heap_beginscan(relation, 0, false, 2, aggregateKey); tup = heap_getnext(scan, 0, (Buffer *) 0); if (!HeapTupleIsValid(tup)) { diff --git a/src/backend/commands/trigger.c b/src/backend/commands/trigger.c index 273136b2923..3427936f284 100644 --- a/src/backend/commands/trigger.c +++ b/src/backend/commands/trigger.c @@ -119,7 +119,7 @@ CreateTrigger(CreateTrigStmt * stmt) RelationSetLockForWrite(tgrel); ScanKeyEntryInitialize(&key, 0, Anum_pg_trigger_tgrelid, ObjectIdEqualRegProcedure, rel->rd_id); - tgscan = heap_beginscan(tgrel, 0, NowTimeQual, 1, &key); + tgscan = heap_beginscan(tgrel, 0, false, 1, &key); while (tuple = heap_getnext(tgscan, 0, (Buffer *) NULL), PointerIsValid(tuple)) { Form_pg_trigger pg_trigger = (Form_pg_trigger) GETSTRUCT(tuple); @@ -279,7 +279,7 @@ DropTrigger(DropTrigStmt * stmt) RelationSetLockForWrite(tgrel); ScanKeyEntryInitialize(&key, 0, Anum_pg_trigger_tgrelid, ObjectIdEqualRegProcedure, rel->rd_id); - tgscan = heap_beginscan(tgrel, 0, NowTimeQual, 1, &key); + tgscan = heap_beginscan(tgrel, 0, false, 1, &key); while (tuple = heap_getnext(tgscan, 0, (Buffer *) NULL), PointerIsValid(tuple)) { Form_pg_trigger pg_trigger = (Form_pg_trigger) GETSTRUCT(tuple); @@ -344,7 +344,7 @@ RelationRemoveTriggers(Relation rel) ScanKeyEntryInitialize(&key, 0, Anum_pg_trigger_tgrelid, ObjectIdEqualRegProcedure, rel->rd_id); - tgscan = heap_beginscan(tgrel, 0, NowTimeQual, 1, &key); + tgscan = heap_beginscan(tgrel, 0, false, 1, &key); while (tup = heap_getnext(tgscan, 0, (Buffer *) NULL), PointerIsValid(tup)) heap_delete(tgrel, &tup->t_ctid); @@ -395,7 +395,7 @@ RelationBuildTriggers(Relation relation) break; iptr = &indexRes->heap_iptr; - tuple = heap_fetch(tgrel, NowTimeQual, iptr, &buffer); + tuple = heap_fetch(tgrel, false, iptr, &buffer); pfree(indexRes); if (!HeapTupleIsValid(tuple)) continue; @@ -859,7 +859,7 @@ GetTupleForTrigger(Relation relation, ItemPointer tid, bool before) } HeapTupleSatisfies(lp, relation, b, dp, - NowTimeQual, 0, (ScanKey) NULL, tuple); + false, 0, (ScanKey) NULL, tuple); if (!tuple) { ReleaseBuffer(b); diff --git a/src/backend/commands/vacuum.c b/src/backend/commands/vacuum.c index 1ce7b0998db..2ecc827b442 100644 --- a/src/backend/commands/vacuum.c +++ b/src/backend/commands/vacuum.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.49 1997/11/02 15:25:07 vadim Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/vacuum.c,v 1.50 1997/11/20 23:21:16 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -296,7 +296,7 @@ vc_getrels(NameData *VacRelP) pgclass = heap_openr(RelationRelationName); pgcdesc = RelationGetTupleDescriptor(pgclass); - pgcscan = heap_beginscan(pgclass, false, NowTimeQual, 1, &pgckey); + pgcscan = heap_beginscan(pgclass, false, false, 1, &pgckey); while (HeapTupleIsValid(pgctup = heap_getnext(pgcscan, 0, &buf))) { @@ -429,7 +429,7 @@ vc_vacone(Oid relid, bool analyze, List *va_cols) pgclass = heap_openr(RelationRelationName); pgcdesc = RelationGetTupleDescriptor(pgclass); - pgcscan = heap_beginscan(pgclass, false, NowTimeQual, 1, &pgckey); + pgcscan = heap_beginscan(pgclass, false, false, 1, &pgckey); /* * Race condition -- if the pg_class tuple has gone away since the @@ -1856,7 +1856,7 @@ vc_updstats(Oid relid, int npages, int ntups, bool hasindex, VRelStats *vacrelst ObjectIdGetDatum(relid)); rd = heap_openr(RelationRelationName); - rsdesc = heap_beginscan(rd, false, NowTimeQual, 1, &rskey); + rsdesc = heap_beginscan(rd, false, false, 1, &rskey); if (!HeapTupleIsValid(rtup = heap_getnext(rsdesc, 0, &rbuf))) elog(WARN, "pg_class entry for relid %d vanished during vacuuming", @@ -1879,7 +1879,7 @@ vc_updstats(Oid relid, int npages, int ntups, bool hasindex, VRelStats *vacrelst ScanKeyEntryInitialize(&askey, 0, Anum_pg_attribute_attrelid, F_INT4EQ, relid); - asdesc = heap_beginscan(ad, false, NowTimeQual, 1, &askey); + asdesc = heap_beginscan(ad, false, false, 1, &askey); while (HeapTupleIsValid(atup = heap_getnext(asdesc, 0, &abuf))) { @@ -2027,10 +2027,10 @@ vc_delhilowstats(Oid relid, int attcnt, int *attnums) ScanKeyEntryInitialize(&pgskey, 0x0, Anum_pg_statistic_starelid, ObjectIdEqualRegProcedure, ObjectIdGetDatum(relid)); - pgsscan = heap_beginscan(pgstatistic, false, NowTimeQual, 1, &pgskey); + pgsscan = heap_beginscan(pgstatistic, false, false, 1, &pgskey); } else - pgsscan = heap_beginscan(pgstatistic, false, NowTimeQual, 0, NULL); + pgsscan = heap_beginscan(pgstatistic, false, false, 0, NULL); while (HeapTupleIsValid(pgstup = heap_getnext(pgsscan, 0, NULL))) { @@ -2284,7 +2284,7 @@ vc_getindices(Oid relid, int *nindices, Relation **Irel) ObjectIdEqualRegProcedure, ObjectIdGetDatum(relid)); - pgiscan = heap_beginscan(pgindex, false, NowTimeQual, 1, &pgikey); + pgiscan = heap_beginscan(pgindex, false, false, 1, &pgikey); while (HeapTupleIsValid(pgitup = heap_getnext(pgiscan, 0, NULL))) { diff --git a/src/backend/commands/view.c b/src/backend/commands/view.c index ca4ff5a9425..72d6159b2a6 100644 --- a/src/backend/commands/view.c +++ b/src/backend/commands/view.c @@ -7,7 +7,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/view.c,v 1.13 1997/11/17 16:58:59 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/view.c,v 1.14 1997/11/20 23:21:18 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -236,10 +236,10 @@ UpdateRangeTableOfViewParse(char *viewName, Query *viewParse) */ rt_entry1 = addRangeTableEntry(NULL, (char *) viewName, "*CURRENT*", - FALSE, FALSE, NULL); + FALSE, FALSE); rt_entry2 = addRangeTableEntry(NULL, (char *) viewName, "*NEW*", - FALSE, FALSE, NULL); + FALSE, FALSE); new_rt = lcons(rt_entry2, old_rt); new_rt = lcons(rt_entry1, new_rt); |