aboutsummaryrefslogtreecommitdiff
path: root/src/backend/commands/async.c
diff options
context:
space:
mode:
authorBruce Momjian <bruce@momjian.us>1997-09-12 04:09:08 +0000
committerBruce Momjian <bruce@momjian.us>1997-09-12 04:09:08 +0000
commit1ea01720d53095641205753e766180508ee4d5ad (patch)
treec62d9d2be8a531e182d89bb0cef172a80d43c00c /src/backend/commands/async.c
parent6e04b4b20f73b2512fc29353ca706bdb635d7e47 (diff)
downloadpostgresql-1ea01720d53095641205753e766180508ee4d5ad.tar.gz
postgresql-1ea01720d53095641205753e766180508ee4d5ad.zip
heapattr functions now return a Datum, not char *.
Diffstat (limited to 'src/backend/commands/async.c')
-rw-r--r--src/backend/commands/async.c24
1 files changed, 12 insertions, 12 deletions
diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c
index ee5b9baf553..aa86d9982dc 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.19 1997/09/08 02:21:54 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.20 1997/09/12 04:07:20 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -216,8 +216,8 @@ Async_Notify(char *relname)
while (HeapTupleIsValid(lTuple = heap_getnext(sRel, 0, &b)))
{
- d = (Datum) heap_getattr(lTuple, b, Anum_pg_listener_notify,
- tdesc, &isnull);
+ d = heap_getattr(lTuple, b, Anum_pg_listener_notify,
+ tdesc, &isnull);
if (!DatumGetInt32(d))
{
rTuple = heap_modifytuple(lTuple, b, lRel, value, nulls, repl);
@@ -293,13 +293,13 @@ Async_NotifyAtCommit()
while (HeapTupleIsValid(lTuple = heap_getnext(sRel, 0, &b)))
{
- d = (Datum) heap_getattr(lTuple, b, Anum_pg_listener_relname,
- tdesc, &isnull);
+ d = heap_getattr(lTuple, b, Anum_pg_listener_relname,
+ tdesc, &isnull);
if (AsyncExistsPendingNotify((char *) DatumGetPointer(d)))
{
- d = (Datum) heap_getattr(lTuple, b, Anum_pg_listener_pid,
- tdesc, &isnull);
+ d = heap_getattr(lTuple, b, Anum_pg_listener_pid,
+ tdesc, &isnull);
if (ourpid == DatumGetInt32(d))
{
@@ -444,12 +444,12 @@ Async_Listen(char *relname, int pid)
s = heap_beginscan(lDesc, 0, NowTimeQual, 0, (ScanKey) NULL);
while (HeapTupleIsValid(htup = heap_getnext(s, 0, &b)))
{
- d = (Datum) heap_getattr(htup, b, Anum_pg_listener_relname, tdesc,
- &isnull);
+ d = heap_getattr(htup, b, Anum_pg_listener_relname, tdesc,
+ &isnull);
relnamei = DatumGetPointer(d);
if (!strncmp(relnamei, relname, NAMEDATALEN))
{
- d = (Datum) heap_getattr(htup, b, Anum_pg_listener_pid, tdesc, &isnull);
+ d = heap_getattr(htup, b, Anum_pg_listener_pid, tdesc, &isnull);
pid = DatumGetInt32(d);
if (pid == ourPid)
{
@@ -609,8 +609,8 @@ Async_NotifyFrontEnd()
while (HeapTupleIsValid(lTuple = heap_getnext(sRel, 0, &b)))
{
- d = (Datum) heap_getattr(lTuple, b, Anum_pg_listener_relname,
- tdesc, &isnull);
+ d = heap_getattr(lTuple, b, Anum_pg_listener_relname,
+ tdesc, &isnull);
rTuple = heap_modifytuple(lTuple, b, lRel, value, nulls, repl);
heap_replace(lRel, &lTuple->t_ctid, rTuple);