aboutsummaryrefslogtreecommitdiff
path: root/src/backend/libpq/pqpacket.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/libpq/pqpacket.c')
-rw-r--r--src/backend/libpq/pqpacket.c11
1 files changed, 9 insertions, 2 deletions
diff --git a/src/backend/libpq/pqpacket.c b/src/backend/libpq/pqpacket.c
index defc57f69af..8e51a97f225 100644
--- a/src/backend/libpq/pqpacket.c
+++ b/src/backend/libpq/pqpacket.c
@@ -9,7 +9,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/libpq/Attic/pqpacket.c,v 1.26 2000/04/12 17:15:14 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/libpq/Attic/pqpacket.c,v 1.27 2000/10/03 03:11:14 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -61,7 +61,11 @@ PacketReceiveFragment(Port *port)
got = SSL_read(port->ssl, pkt->ptr, pkt->nrtodo);
else
#endif
+#ifndef __BEOS__
got = read(port->sock, pkt->ptr, pkt->nrtodo);
+#else
+ got = recv(port->sock, pkt->ptr, pkt->nrtodo, 0);
+#endif /* __BEOS__ */
if (got > 0)
{
pkt->nrtodo -= got;
@@ -150,8 +154,11 @@ PacketSendFragment(Port *port)
done = SSL_write(port->ssl, pkt->ptr, pkt->nrtodo);
else
#endif
+#ifndef __BEOS__
done = write(port->sock, pkt->ptr, pkt->nrtodo);
-
+#else
+ done = send(port->sock, pkt->ptr, pkt->nrtodo, 0);
+#endif
if (done > 0)
{
pkt->nrtodo -= done;