database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-04-25 21:42:33 +03:00
Code

Allow port numbers 32k - 64k.

Browse Source
This commit is contained in:
Bruce Momjian 1999-07-07 17:17:50 +00:00
parent 517da8b5fa
commit 38ff52c379
4 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
doc/TODO
View File

@ -30,6 +30,7 @@ PARSER
* Array index references without table name cause problems * Array index references without table name cause problems
* Update table SET table.value = 3 fails * Update table SET table.value = 3 fails
* Creating index of timestamp fails * Creating index of timestamp fails
* SELECT foo UNION SELECT foo is incorrectly simplified to SELECT foo
VIEWS VIEWS
@ -207,8 +208,8 @@ MISC
places, like GROUP BY, UNIQUE, index processing, etc. places, like GROUP BY, UNIQUE, index processing, etc.
* improve dynamic memory allocation by introducing tuple-context memory * improve dynamic memory allocation by introducing tuple-context memory
allocation allocation
* add pooled memory allocation where allocations are freed only as a group * fix indexscan() so it does leak memory by not requiring caller to free
* fix memory leak in cache code when non-existant table is refer
SOURCE CODE SOURCE CODE
----------- -----------

4
src/backend/libpq/pqcomm.c
View File

@ -28,7 +28,7 @@
* *
* Copyright (c) 1994, Regents of the University of California * Copyright (c) 1994, Regents of the University of California
* *
* $Id: pqcomm.c,v 1.72 1999/05/25 16:09:02 momjian Exp $ * $Id: pqcomm.c,v 1.73 1999/07/07 17:17:47 momjian Exp $
* *
*------------------------------------------------------------------------- *-------------------------------------------------------------------------
*/ */
@ -181,7 +181,7 @@ StreamDoUnlink()
*/ */
int int
StreamServerPort(char *hostName, short portName, int *fdP) StreamServerPort(char *hostName, unsigned short portName, int *fdP)
{ {
SockAddr saddr; SockAddr saddr;
int fd, int fd,

14
src/backend/postmaster/postmaster.c
View File

@ -10,7 +10,7 @@
* *
* *
* IDENTIFICATION * IDENTIFICATION
* $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.107 1999/07/02 18:09:27 momjian Exp $ * $Header: /cvsroot/pgsql/src/backend/postmaster/postmaster.c,v 1.108 1999/07/07 17:17:48 momjian Exp $
* *
* NOTES * NOTES
* *
@ -130,7 +130,7 @@ static Dllist *BackendList;
/* list of ports associated with still open, but incomplete connections */ /* list of ports associated with still open, but incomplete connections */
static Dllist *PortList; static Dllist *PortList;
static short PostPortName = -1; static unsigned short PostPortName = 0;
static short ActiveBackends = FALSE; static short ActiveBackends = FALSE;
/* /*
@ -240,7 +240,7 @@ extern int optind,
*/ */
static void pmdaemonize(void); static void pmdaemonize(void);
static Port *ConnCreate(int serverFd); static Port *ConnCreate(int serverFd);
static void reset_shared(short port); static void reset_shared(unsigned short port);
static void pmdie(SIGNAL_ARGS); static void pmdie(SIGNAL_ARGS);
static void reaper(SIGNAL_ARGS); static void reaper(SIGNAL_ARGS);
static void dumpstatus(SIGNAL_ARGS); static void dumpstatus(SIGNAL_ARGS);
@ -502,7 +502,7 @@ PostmasterMain(int argc, char *argv[])
break; break;
case 'p': case 'p':
/* Set PGPORT by hand. */ /* Set PGPORT by hand. */
PostPortName = (short) atoi(optarg); PostPortName = (unsigned short) atoi(optarg);
break; break;
case 'S': case 'S':
@ -534,8 +534,8 @@ PostmasterMain(int argc, char *argv[])
/* /*
* Select default values for switches where needed * Select default values for switches where needed
*/ */
if (PostPortName == -1) if (PostPortName == 0)
PostPortName = pq_getport(); PostPortName = (unsigned short)pq_getport();
/* /*
* Check for invalid combinations of switches * Check for invalid combinations of switches
@ -1050,7 +1050,7 @@ ConnCreate(int serverFd)
* reset_shared -- reset shared memory and semaphores * reset_shared -- reset shared memory and semaphores
*/ */
static void static void
reset_shared(short port) reset_shared(unsigned short port)
{ {
ipc_key = port * 1000 + shmem_seq * 100; ipc_key = port * 1000 + shmem_seq * 100;
CreateSharedMemoryAndSemaphores(ipc_key, MaxBackends); CreateSharedMemoryAndSemaphores(ipc_key, MaxBackends);

4
src/include/libpq/libpq.h
View File

@ -6,7 +6,7 @@
* *
* Copyright (c) 1994, Regents of the University of California * Copyright (c) 1994, Regents of the University of California
* *
* $Id: libpq.h,v 1.30 1999/05/25 22:42:50 momjian Exp $ * $Id: libpq.h,v 1.31 1999/07/07 17:17:50 momjian Exp $
* *
*------------------------------------------------------------------------- *-------------------------------------------------------------------------
*/ */
@ -234,7 +234,7 @@ extern int32 pqtest(struct varlena * vlena);
/* /*
* prototypes for functions in pqcomm.c * prototypes for functions in pqcomm.c
*/ */
extern int StreamServerPort(char *hostName, short portName, int *fdP); extern int StreamServerPort(char *hostName, unsigned short portName, int *fdP);
extern int StreamConnection(int server_fd, Port *port); extern int StreamConnection(int server_fd, Port *port);
extern void StreamClose(int sock); extern void StreamClose(int sock);
extern void pq_init(void); extern void pq_init(void);