aboutsummaryrefslogtreecommitdiff
path: root/src/backend/libpq/pqcomm.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/libpq/pqcomm.c')
-rw-r--r--src/backend/libpq/pqcomm.c13
1 files changed, 5 insertions, 8 deletions
diff --git a/src/backend/libpq/pqcomm.c b/src/backend/libpq/pqcomm.c
index 41280c8bbc4..aa07c12279c 100644
--- a/src/backend/libpq/pqcomm.c
+++ b/src/backend/libpq/pqcomm.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/libpq/pqcomm.c,v 1.40 1998/03/02 05:41:53 scrappy Exp $
+ * $Header: /cvsroot/pgsql/src/backend/libpq/pqcomm.c,v 1.41 1998/05/19 18:05:46 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -409,18 +409,15 @@ pq_sendoob(char *msg, int len)
{
int fd = fileno(Pfout);
- return (send(fd, msg, len, MSG_OOB));
+ return send(fd, msg, len, MSG_OOB);
}
int
-pq_recvoob(char *msgPtr, int *lenPtr)
+pq_recvoob(char *msgPtr, int len)
{
int fd = fileno(Pfout);
- int len = 0;
- len = recv(fd, msgPtr + len, *lenPtr, MSG_OOB);
- *lenPtr = len;
- return (len);
+ return recv(fd, msgPtr, len, MSG_OOB);
}
/* --------------------------------
@@ -523,7 +520,7 @@ pq_async_notify()
/* int len = sizeof(msg); */
int len = 20;
- if (pq_recvoob(msg, &len) >= 0)
+ if (pq_recvoob(msg, len) >= 0)
{
/* debugging */
printf("received notification: %s\n", msg);