diff options
| author | Tom Lane <tgl@sss.pgh.pa.us> | 1999-01-23 22:27:29 +0000 |
|---|---|---|
| committer | Tom Lane <tgl@sss.pgh.pa.us> | 1999-01-23 22:27:29 +0000 |
| commit | e6725d15741a3d149da9c34b870b7b9c2608d705 (patch) | |
| tree | 29a4f5ef0e26024b664396e915cf1f779ff5ad0b /src/include/libpq/libpq.h | |
| parent | 13c7c183f7f221ac28b2528fea716b971707d3d2 (diff) | |
| download | postgresql-e6725d15741a3d149da9c34b870b7b9c2608d705.tar.gz | |
Add explicit buffering in backend libpq, to compensate for
buffering lost by not going through stdio anymore for client I/O.
Diffstat (limited to 'src/include/libpq/libpq.h')
| -rw-r--r-- | src/include/libpq/libpq.h | 23 |
1 files changed, 19 insertions, 4 deletions
diff --git a/src/include/libpq/libpq.h b/src/include/libpq/libpq.h index a315521eb3..c1cdd8ac5d 100644 --- a/src/include/libpq/libpq.h +++ b/src/include/libpq/libpq.h @@ -6,7 +6,7 @@ * * Copyright (c) 1994, Regents of the University of California * - * $Id: libpq.h,v 1.23 1999/01/12 12:49:52 scrappy Exp $ + * $Id: libpq.h,v 1.24 1999/01/23 22:27:25 tgl Exp $ * *------------------------------------------------------------------------- */ @@ -254,12 +254,13 @@ extern void pq_init(int fd); extern void pq_gettty(char *tp); extern int pq_getport(void); extern void pq_close(void); -extern void pq_flush(void); +extern int pq_flush(void); +extern int pq_recvbuf(void); extern int pq_getstr(char *s, int maxlen); extern int PQgetline(char *s, int maxlen); extern int PQputline(char *s); -extern int pq_getchar(void); -extern int pq_peekchar(void); +extern int pq_getchar(void); +extern int pq_peekchar(void); extern int pq_getnchar(char *s, int off, int maxlen); extern int pq_getint(int b); extern int pq_putchar(char c); @@ -282,4 +283,18 @@ extern int StreamServerPort(char *hostName, short portName, int *fdP); extern int StreamConnection(int server_fd, Port *port); extern void StreamClose(int sock); +/* + * Internal send/receive buffers in libpq. + * These probably shouldn't be global at all, but unless we merge + * pqcomm.c and pqcomprim.c they have to be... + */ + +#define PQ_BUFFER_SIZE 8192 + +extern char PqSendBuffer[PQ_BUFFER_SIZE]; +extern int PqSendPointer; /* Next index to store a byte in PqSendBuffer */ +extern char PqRecvBuffer[PQ_BUFFER_SIZE]; +extern int PqRecvPointer; /* Next index to read a byte from PqRecvBuffer */ +extern int PqRecvLength; /* End of data available in PqRecvBuffer */ + #endif /* LIBPQ_H */ |