diff options
| author | Vadim B. Mikheev <vadim4o@yahoo.com> | 1998-11-27 19:52:36 +0000 |
|---|---|---|
| committer | Vadim B. Mikheev <vadim4o@yahoo.com> | 1998-11-27 19:52:36 +0000 |
| commit | 6beba218d7f6f764e946751df6dc0d0180da05fa (patch) | |
| tree | 2801029d61d798d6150bb43a24561a4615aedb8b /src/backend/commands/async.c | |
| parent | 2435c7d501b0a3129f6fc597a9c85863541cd596 (diff) | |
| download | postgresql-6beba218d7f6f764e946751df6dc0d0180da05fa.tar.gz postgresql-6beba218d7f6f764e946751df6dc0d0180da05fa.zip | |
New HeapTuple structure/interface.
Diffstat (limited to 'src/backend/commands/async.c')
| -rw-r--r-- | src/backend/commands/async.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c index a8c447cb077..50d4f13cc09 100644 --- a/src/backend/commands/async.c +++ b/src/backend/commands/async.c @@ -6,7 +6,7 @@ * Copyright (c) 1994, Regents of the University of California * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.41 1998/10/06 02:39:59 tgl Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.42 1998/11/27 19:51:53 vadim Exp $ * *------------------------------------------------------------------------- */ @@ -321,7 +321,7 @@ Async_Unlisten(char *relname, int pid) { lRel = heap_openr(ListenerRelationName); RelationSetLockForWrite(lRel); - heap_delete(lRel, &lTuple->t_ctid); + heap_delete(lRel, &lTuple->t_self); RelationUnsetLockForWrite(lRel); heap_close(lRel); } @@ -369,7 +369,7 @@ Async_UnlistenAll() sRel = heap_beginscan(lRel, 0, SnapshotNow, 1, key); while (HeapTupleIsValid(lTuple = heap_getnext(sRel, 0))) - heap_delete(lRel, &lTuple->t_ctid); + heap_delete(lRel, &lTuple->t_self); heap_endscan(sRel); RelationUnsetLockForWrite(lRel); @@ -516,7 +516,7 @@ AtCommit_Notify() * but as far as I can see we should just do it for any * failure (certainly at least for EPERM too...) */ - heap_delete(lRel, &lTuple->t_ctid); + heap_delete(lRel, &lTuple->t_self); } else #endif @@ -527,7 +527,7 @@ AtCommit_Notify() { rTuple = heap_modifytuple(lTuple, lRel, value, nulls, repl); - heap_replace(lRel, &lTuple->t_ctid, rTuple); + heap_replace(lRel, &lTuple->t_self, rTuple); } } } @@ -772,7 +772,7 @@ ProcessIncomingNotify(void) NotifyMyFrontEnd(relname, sourcePID); /* Rewrite the tuple with 0 in notification column */ rTuple = heap_modifytuple(lTuple, lRel, value, nulls, repl); - heap_replace(lRel, &lTuple->t_ctid, rTuple); + heap_replace(lRel, &lTuple->t_self, rTuple); } } heap_endscan(sRel); |