diff options
| author | Bruce Momjian <bruce@momjian.us> | 1997-11-20 23:24:03 +0000 |
|---|---|---|
| committer | Bruce Momjian <bruce@momjian.us> | 1997-11-20 23:24:03 +0000 |
| commit | e9e1ff226f285bc7b488e670be4b8220cdba4a53 (patch) | |
| tree | 7dd89bef1e88e75736c97578e6ebc0f081e71622 /src/backend/commands/async.c | |
| parent | e075271c178720199fe95ba6f3482bcb5ce12df7 (diff) | |
| download | postgresql-e9e1ff226f285bc7b488e670be4b8220cdba4a53.tar.gz postgresql-e9e1ff226f285bc7b488e670be4b8220cdba4a53.zip | |
Remove all time travel stuff. Small parser cleanup.
Diffstat (limited to 'src/backend/commands/async.c')
| -rw-r--r-- | src/backend/commands/async.c | 10 |
1 files changed, 5 insertions, 5 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] = ' '; |