aboutsummaryrefslogtreecommitdiff
path: root/src/backend/storage
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/storage')
-rw-r--r--src/backend/storage/buffer/buf_table.c6
-rw-r--r--src/backend/storage/buffer/bufmgr.c8
-rw-r--r--src/backend/storage/buffer/localbuf.c4
-rw-r--r--src/backend/storage/file/fd.c6
-rw-r--r--src/backend/storage/ipc/ipc.c10
-rw-r--r--src/backend/storage/ipc/s_lock.c84
-rw-r--r--src/backend/storage/ipc/shmem.c8
-rw-r--r--src/backend/storage/ipc/shmqueue.c20
-rw-r--r--src/backend/storage/ipc/sinvaladt.c72
-rw-r--r--src/backend/storage/large_object/inv_api.c34
-rw-r--r--src/backend/storage/lmgr/lmgr.c10
-rw-r--r--src/backend/storage/lmgr/lock.c48
-rw-r--r--src/backend/storage/lmgr/multi.c10
-rw-r--r--src/backend/storage/lmgr/proc.c24
-rw-r--r--src/backend/storage/smgr/md.c4
-rw-r--r--src/backend/storage/smgr/smgr.c4
-rw-r--r--src/backend/storage/smgr/smgrtype.c4
17 files changed, 178 insertions, 178 deletions
diff --git a/src/backend/storage/buffer/buf_table.c b/src/backend/storage/buffer/buf_table.c
index b384963101e..7fa9ab380e6 100644
--- a/src/backend/storage/buffer/buf_table.c
+++ b/src/backend/storage/buffer/buf_table.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/buffer/buf_table.c,v 1.7 1997/09/08 20:56:41 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/buffer/buf_table.c,v 1.8 1997/09/08 21:46:46 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -40,7 +40,7 @@ typedef struct lookup
{
BufferTag key;
Buffer id;
-} LookupEnt;
+} LookupEnt;
/*
* Initialize shmem hash table for mapping buffers
@@ -74,7 +74,7 @@ InitBufTable()
}
BufferDesc *
-BufTableLookup(BufferTag * tagPtr)
+BufTableLookup(BufferTag *tagPtr)
{
LookupEnt *result;
bool found;
diff --git a/src/backend/storage/buffer/bufmgr.c b/src/backend/storage/buffer/bufmgr.c
index cdd4909cad1..7acc70342ca 100644
--- a/src/backend/storage/buffer/bufmgr.c
+++ b/src/backend/storage/buffer/bufmgr.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.22 1997/09/08 20:56:44 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.23 1997/09/08 21:46:50 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -93,7 +93,7 @@ ReadBufferWithBufferLock(Relation relation, BlockNumber blockNum,
bool bufferLockHeld);
static BufferDesc *
BufferAlloc(Relation reln, BlockNumber blockNum,
- bool * foundPtr, bool bufferLockHeld);
+ bool *foundPtr, bool bufferLockHeld);
static int FlushBuffer(Buffer buffer, bool release);
static void BufferSync(void);
static int BufferReplace(BufferDesc *bufHdr, bool bufferLockHeld);
@@ -354,7 +354,7 @@ ReadBufferWithBufferLock(Relation reln,
static BufferDesc *
BufferAlloc(Relation reln,
BlockNumber blockNum,
- bool * foundPtr,
+ bool *foundPtr,
bool bufferLockHeld)
{
BufferDesc *buf,
@@ -1154,7 +1154,7 @@ long NDirectFileRead; /* some I/O's are direct file access.
long NDirectFileWrite; /* e.g., I/O in psort and hashjoin. */
void
-PrintBufferUsage(FILE * statfp)
+PrintBufferUsage(FILE *statfp)
{
float hitrate;
float localhitrate;
diff --git a/src/backend/storage/buffer/localbuf.c b/src/backend/storage/buffer/localbuf.c
index 3916abc2a76..480dee7a7c4 100644
--- a/src/backend/storage/buffer/localbuf.c
+++ b/src/backend/storage/buffer/localbuf.c
@@ -15,7 +15,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/buffer/localbuf.c,v 1.10 1997/09/08 02:28:34 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/buffer/localbuf.c,v 1.11 1997/09/08 21:46:52 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -63,7 +63,7 @@ static int nextFreeLocalBuf = 0;
* allocate a local buffer. We do round robin allocation for now.
*/
BufferDesc *
-LocalBufferAlloc(Relation reln, BlockNumber blockNum, bool * foundPtr)
+LocalBufferAlloc(Relation reln, BlockNumber blockNum, bool *foundPtr)
{
int i;
BufferDesc *bufHdr = (BufferDesc *) NULL;
diff --git a/src/backend/storage/file/fd.c b/src/backend/storage/file/fd.c
index aa09bbdfb6b..beb0170afed 100644
--- a/src/backend/storage/file/fd.c
+++ b/src/backend/storage/file/fd.c
@@ -6,7 +6,7 @@
* Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Id: fd.c,v 1.24 1997/09/08 02:28:38 momjian Exp $
+ * $Id: fd.c,v 1.25 1997/09/08 21:46:54 momjian Exp $
*
* NOTES:
*
@@ -111,7 +111,7 @@ typedef struct vfd
char *fileName;
int fileFlags;
int fileMode;
-} Vfd;
+} Vfd;
/*
* Virtual File Descriptor array pointer and size. This grows as
@@ -883,7 +883,7 @@ TryAgain:
* AllocateFile()?
*/
void
-FreeFile(FILE * file)
+FreeFile(FILE *file)
{
DO_DB(elog(DEBUG, "FreeFile: Allocated %d.", allocatedFiles));
diff --git a/src/backend/storage/ipc/ipc.c b/src/backend/storage/ipc/ipc.c
index af59de7cca8..856ca135080 100644
--- a/src/backend/storage/ipc/ipc.c
+++ b/src/backend/storage/ipc/ipc.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/ipc/ipc.c,v 1.13 1997/09/08 02:28:44 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/ipc/ipc.c,v 1.14 1997/09/08 21:46:59 momjian Exp $
*
* NOTES
*
@@ -73,7 +73,7 @@ typedef struct _PrivateMemStruct
{
int id;
char *memptr;
-} PrivateMem;
+} PrivateMem;
PrivateMem IpcPrivateMem[16];
@@ -668,11 +668,11 @@ AttachSLockMemory(IPCKey key)
slockM = (struct ipcdummy *) IpcMemoryAttach(SLockMemoryId);
if (slockM == IpcMemAttachFailed)
elog(FATAL, "AttachSLockMemory: could not attach segment");
- FreeSLockPP = (SLock **) & (slockM->free);
+ FreeSLockPP = (SLock **) &(slockM->free);
UnusedSLockIP = (int *) &(slockM->unused);
- SLockMemoryLock = (slock_t *) & (slockM->memlock);
+ SLockMemoryLock = (slock_t *) &(slockM->memlock);
S_INIT_LOCK(SLockMemoryLock);
- SLockArray = (SLock *) & (slockM->slocks[0]);
+ SLockArray = (SLock *) &(slockM->slocks[0]);
return;
}
diff --git a/src/backend/storage/ipc/s_lock.c b/src/backend/storage/ipc/s_lock.c
index 3f75c5bc79b..82551f8b96d 100644
--- a/src/backend/storage/ipc/s_lock.c
+++ b/src/backend/storage/ipc/s_lock.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/ipc/Attic/s_lock.c,v 1.23 1997/09/08 02:28:51 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/ipc/Attic/s_lock.c,v 1.24 1997/09/08 21:47:04 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -50,24 +50,24 @@
* slock_t is defined as a struct mutex.
*/
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
mutex_lock(lock);
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
mutex_unlock(lock);
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
mutex_init(lock);
}
/* S_LOCK_FREE should return 1 if lock is free; 0 if lock is locked */
int
-S_LOCK_FREE(slock_t * lock)
+S_LOCK_FREE(slock_t *lock)
{
/* For Mach, we have to delve inside the entrails of `struct mutex'. Ick! */
return (lock->lock == 0);
@@ -88,7 +88,7 @@ S_LOCK_FREE(slock_t * lock)
* for the R3000 chips out there.
*/
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
/* spin_lock(lock); */
while (!acquire_lock(lock))
@@ -96,20 +96,20 @@ S_LOCK(slock_t * lock)
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
release_lock(lock);
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
init_lock(lock);
}
/* S_LOCK_FREE should return 1 if lock is free; 0 if lock is locked */
int
-S_LOCK_FREE(slock_t * lock)
+S_LOCK_FREE(slock_t *lock)
{
return (stat_lock(lock) == UNLOCKED);
}
@@ -127,26 +127,26 @@ S_LOCK_FREE(slock_t * lock)
#if defined(__alpha__) || defined(__alpha)
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (msem_lock(lock, MSEM_IF_NOWAIT) < 0)
;
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
msem_unlock(lock, 0);
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
msem_init(lock, MSEM_UNLOCKED);
}
int
-S_LOCK_FREE(slock_t * lock)
+S_LOCK_FREE(slock_t *lock)
{
return (lock->msem_state ? 0 : 1);
}
@@ -161,23 +161,23 @@ S_LOCK_FREE(slock_t * lock)
defined(sparc_solaris)
/* for xxxxx_solaris, this is defined in port/.../tas.s */
-static int tas(slock_t * lock);
+static int tas(slock_t *lock);
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (tas(lock))
;
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -194,20 +194,20 @@ S_INIT_LOCK(slock_t * lock)
#if defined(aix)
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (cs((int *) lock, 0, 1))
;
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -229,29 +229,29 @@ S_INIT_LOCK(slock_t * lock)
*/
static slock_t clear_lock = {-1, -1, -1, -1};
-static int tas(slock_t * lock);
+static int tas(slock_t *lock);
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (tas(lock))
;
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = clear_lock; /* struct assignment */
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
int
-S_LOCK_FREE(slock_t * lock)
+S_LOCK_FREE(slock_t *lock)
{
register int *lock_word = (int *) (((long) lock + 15) & ~15);
@@ -266,22 +266,22 @@ S_LOCK_FREE(slock_t * lock)
#if defined(sun3)
-static int tas(slock_t * lock);
+static int tas(slock_t *lock);
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (tas(lock));
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -320,7 +320,7 @@ tas_dummy()
#define asm(x) __asm__(x)
#endif
-static int tas(slock_t * lock);
+static int tas(slock_t *lock);
static int
tas_dummy()
@@ -386,7 +386,7 @@ S_INIT_LOCK(unsigned char *addr)
#if defined(NEED_I386_TAS_ASM)
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
slock_t res;
@@ -397,13 +397,13 @@ __asm__("xchgb %0,%1": "=q"(res), "=m"(*lock):"0"(0x1));
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -414,7 +414,7 @@ S_INIT_LOCK(slock_t * lock)
#if defined(__alpha__) && defined(linux)
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
slock_t res;
@@ -437,14 +437,14 @@ __asm__(" ldq $0, %0 \n\
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
__asm__("mb");
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -454,7 +454,7 @@ S_INIT_LOCK(slock_t * lock)
#if defined(linux) && defined(sparc)
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
slock_t res;
@@ -467,13 +467,13 @@ S_LOCK(slock_t * lock)
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
@@ -502,20 +502,20 @@ success: \n\
}
void
-S_LOCK(slock_t * lock)
+S_LOCK(slock_t *lock)
{
while (tas(lock))
;
}
void
-S_UNLOCK(slock_t * lock)
+S_UNLOCK(slock_t *lock)
{
*lock = 0;
}
void
-S_INIT_LOCK(slock_t * lock)
+S_INIT_LOCK(slock_t *lock)
{
S_UNLOCK(lock);
}
diff --git a/src/backend/storage/ipc/shmem.c b/src/backend/storage/ipc/shmem.c
index 5a1af74584d..a83dc9b11c5 100644
--- a/src/backend/storage/ipc/shmem.c
+++ b/src/backend/storage/ipc/shmem.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.12 1997/09/08 02:28:53 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.13 1997/09/08 21:47:09 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -342,7 +342,7 @@ HTAB *
ShmemInitHash(char *name, /* table string name for binding */
long init_size, /* initial size */
long max_size, /* max size of the table */
- HASHCTL * infoP, /* info about key and bucket size */
+ HASHCTL *infoP, /* info about key and bucket size */
int hash_flags) /* info about infoP */
{
bool found;
@@ -400,7 +400,7 @@ ShmemInitHash(char *name, /* table string name for binding */
* locationPtr.
*/
bool
-ShmemPIDLookup(int pid, SHMEM_OFFSET * locationPtr)
+ShmemPIDLookup(int pid, SHMEM_OFFSET *locationPtr)
{
BindingEnt *result,
item;
@@ -497,7 +497,7 @@ ShmemPIDDestroy(int pid)
* initialized).
*/
long *
-ShmemInitStruct(char *name, unsigned long size, bool * foundPtr)
+ShmemInitStruct(char *name, unsigned long size, bool *foundPtr)
{
BindingEnt *result,
item;
diff --git a/src/backend/storage/ipc/shmqueue.c b/src/backend/storage/ipc/shmqueue.c
index d4cf06f1718..caba5ff6378 100644
--- a/src/backend/storage/ipc/shmqueue.c
+++ b/src/backend/storage/ipc/shmqueue.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmqueue.c,v 1.5 1997/09/08 02:28:56 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmqueue.c,v 1.6 1997/09/08 21:47:10 momjian Exp $
*
* NOTES
*
@@ -39,7 +39,7 @@
* to itself
*/
void
-SHMQueueInit(SHM_QUEUE * queue)
+SHMQueueInit(SHM_QUEUE *queue)
{
Assert(SHM_PTR_VALID(queue));
(queue)->prev = (queue)->next = MAKE_OFFSET(queue);
@@ -51,7 +51,7 @@ SHMQueueInit(SHM_QUEUE * queue)
*/
#ifdef NOT_USED
bool
-SHMQueueIsDetached(SHM_QUEUE * queue)
+SHMQueueIsDetached(SHM_QUEUE *queue)
{
Assert(SHM_PTR_VALID(queue));
return ((queue)->prev == INVALID_OFFSET);
@@ -63,7 +63,7 @@ SHMQueueIsDetached(SHM_QUEUE * queue)
* SHMQueueElemInit -- clear an element's links
*/
void
-SHMQueueElemInit(SHM_QUEUE * queue)
+SHMQueueElemInit(SHM_QUEUE *queue)
{
Assert(SHM_PTR_VALID(queue));
(queue)->prev = (queue)->next = INVALID_OFFSET;
@@ -74,7 +74,7 @@ SHMQueueElemInit(SHM_QUEUE * queue)
* close the links
*/
void
-SHMQueueDelete(SHM_QUEUE * queue)
+SHMQueueDelete(SHM_QUEUE *queue)
{
SHM_QUEUE *nextElem = (SHM_QUEUE *) MAKE_PTR((queue)->next);
SHM_QUEUE *prevElem = (SHM_QUEUE *) MAKE_PTR((queue)->prev);
@@ -97,7 +97,7 @@ SHMQueueDelete(SHM_QUEUE * queue)
#ifdef SHMQUEUE_DEBUG
void
-dumpQ(SHM_QUEUE * q, char *s)
+dumpQ(SHM_QUEUE *q, char *s)
{
char elem[16];
char buf[1024];
@@ -152,7 +152,7 @@ dumpQ(SHM_QUEUE * q, char *s)
*/
#ifdef NOT_USED
void
-SHMQueueInsertHD(SHM_QUEUE * queue, SHM_QUEUE * elem)
+SHMQueueInsertHD(SHM_QUEUE *queue, SHM_QUEUE *elem)
{
SHM_QUEUE *prevPtr = (SHM_QUEUE *) MAKE_PTR((queue)->prev);
SHMEM_OFFSET elemOffset = MAKE_OFFSET(elem);
@@ -177,7 +177,7 @@ SHMQueueInsertHD(SHM_QUEUE * queue, SHM_QUEUE * elem)
#endif
void
-SHMQueueInsertTL(SHM_QUEUE * queue, SHM_QUEUE * elem)
+SHMQueueInsertTL(SHM_QUEUE *queue, SHM_QUEUE *elem)
{
SHM_QUEUE *nextPtr = (SHM_QUEUE *) MAKE_PTR((queue)->next);
SHMEM_OFFSET elemOffset = MAKE_OFFSET(elem);
@@ -222,7 +222,7 @@ SHMQueueInsertTL(SHM_QUEUE * queue, SHM_QUEUE * elem)
* next.
*/
void
-SHMQueueFirst(SHM_QUEUE * queue, Pointer * nextPtrPtr, SHM_QUEUE * nextQueue)
+SHMQueueFirst(SHM_QUEUE *queue, Pointer *nextPtrPtr, SHM_QUEUE *nextQueue)
{
SHM_QUEUE *elemPtr = (SHM_QUEUE *) MAKE_PTR((queue)->next);
@@ -243,7 +243,7 @@ SHMQueueFirst(SHM_QUEUE * queue, Pointer * nextPtrPtr, SHM_QUEUE * nextQueue)
* SHMQueueEmpty -- TRUE if queue head is only element, FALSE otherwise
*/
bool
-SHMQueueEmpty(SHM_QUEUE * queue)
+SHMQueueEmpty(SHM_QUEUE *queue)
{
Assert(SHM_PTR_VALID(queue));
diff --git a/src/backend/storage/ipc/sinvaladt.c b/src/backend/storage/ipc/sinvaladt.c
index 368b2675bd1..6bdf5a9f521 100644
--- a/src/backend/storage/ipc/sinvaladt.c
+++ b/src/backend/storage/ipc/sinvaladt.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/ipc/sinvaladt.c,v 1.7 1997/09/08 02:29:01 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/ipc/sinvaladt.c,v 1.8 1997/09/08 21:47:15 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -59,9 +59,9 @@ IpcSemaphoreId SharedInvalidationSemaphore;
SISeg *shmInvalBuffer;
extern BackendId MyBackendId;
-static void CleanupInvalidationState(int status, SISeg * segInOutP);
-static BackendId SIAssignBackendId(SISeg * segInOutP, BackendTag backendTag);
-static int SIGetNumEntries(SISeg * segP);
+static void CleanupInvalidationState(int status, SISeg *segInOutP);
+static BackendId SIAssignBackendId(SISeg *segInOutP, BackendTag backendTag);
+static int SIGetNumEntries(SISeg *segP);
/************************************************************************/
/* SISetActiveProcess(segP, backendId) set the backend status active */
@@ -69,7 +69,7 @@ static int SIGetNumEntries(SISeg * segP);
/************************************************************************/
/* XXX I suspect that the segP parameter is extraneous. -hirohama */
static void
-SISetActiveProcess(SISeg * segInOutP, BackendId backendId)
+SISetActiveProcess(SISeg *segInOutP, BackendId backendId)
{
/* mark all messages as read */
@@ -83,7 +83,7 @@ SISetActiveProcess(SISeg * segInOutP, BackendId backendId)
/* SIBackendInit() initializes a backend to operate on the buffer */
/****************************************************************************/
int
-SIBackendInit(SISeg * segInOutP)
+SIBackendInit(SISeg *segInOutP)
{
LRelId LtCreateRelId();
TransactionId LMITransactionIdCopy();
@@ -109,7 +109,7 @@ SIBackendInit(SISeg * segInOutP)
* ----------------
*/
static BackendId
-SIAssignBackendId(SISeg * segInOutP, BackendTag backendTag)
+SIAssignBackendId(SISeg *segInOutP, BackendTag backendTag)
{
Index index;
ProcState *stateP;
@@ -180,7 +180,7 @@ SIAssignBackendId(SISeg * segInOutP, BackendTag backendTag)
/* should be called only by the postmaster when a backend died */
/************************************************************************/
static void
-SISetDeadProcess(SISeg * segP, int backendId)
+SISetDeadProcess(SISeg *segP, int backendId)
{
/* XXX call me.... */
@@ -197,7 +197,7 @@ SISetDeadProcess(SISeg * segP, int backendId)
*/
static void
CleanupInvalidationState(int status, /* XXX */
- SISeg * segInOutP) /* XXX style */
+ SISeg *segInOutP) /* XXX style */
{
Assert(PointerIsValid(segInOutP));
@@ -237,7 +237,7 @@ SIComputeSize(int *segSize)
/* SISetStartEntrySection(segP, offset) - sets the offset */
/************************************************************************/
static void
-SISetStartEntrySection(SISeg * segP, Offset offset)
+SISetStartEntrySection(SISeg *segP, Offset offset)
{
segP->startEntrySection = offset;
}
@@ -246,7 +246,7 @@ SISetStartEntrySection(SISeg * segP, Offset offset)
/* SIGetStartEntrySection(segP) - returnss the offset */
/************************************************************************/
static Offset
-SIGetStartEntrySection(SISeg * segP)
+SIGetStartEntrySection(SISeg *segP)
{
return (segP->startEntrySection);
}
@@ -256,7 +256,7 @@ SIGetStartEntrySection(SISeg * segP)
/* SISetEndEntrySection(segP, offset) - sets the offset */
/************************************************************************/
static void
-SISetEndEntrySection(SISeg * segP, Offset offset)
+SISetEndEntrySection(SISeg *segP, Offset offset)
{
segP->endEntrySection = offset;
}
@@ -265,7 +265,7 @@ SISetEndEntrySection(SISeg * segP, Offset offset)
/* SISetEndEntryChain(segP, offset) - sets the offset */
/************************************************************************/
static void
-SISetEndEntryChain(SISeg * segP, Offset offset)
+SISetEndEntryChain(SISeg *segP, Offset offset)
{
segP->endEntryChain = offset;
}
@@ -274,7 +274,7 @@ SISetEndEntryChain(SISeg * segP, Offset offset)
/* SIGetEndEntryChain(segP) - returnss the offset */
/************************************************************************/
static Offset
-SIGetEndEntryChain(SISeg * segP)
+SIGetEndEntryChain(SISeg *segP)
{
return (segP->endEntryChain);
}
@@ -283,7 +283,7 @@ SIGetEndEntryChain(SISeg * segP)
/* SISetStartEntryChain(segP, offset) - sets the offset */
/************************************************************************/
static void
-SISetStartEntryChain(SISeg * segP, Offset offset)
+SISetStartEntryChain(SISeg *segP, Offset offset)
{
segP->startEntryChain = offset;
}
@@ -292,7 +292,7 @@ SISetStartEntryChain(SISeg * segP, Offset offset)
/* SIGetStartEntryChain(segP) - returns the offset */
/************************************************************************/
static Offset
-SIGetStartEntryChain(SISeg * segP)
+SIGetStartEntryChain(SISeg *segP)
{
return (segP->startEntryChain);
}
@@ -301,7 +301,7 @@ SIGetStartEntryChain(SISeg * segP)
/* SISetNumEntries(segP, num) sets the current nuber of entries */
/************************************************************************/
static bool
-SISetNumEntries(SISeg * segP, int num)
+SISetNumEntries(SISeg *segP, int num)
{
if (num <= MAXNUMMESSAGES)
{
@@ -318,7 +318,7 @@ SISetNumEntries(SISeg * segP, int num)
/* SIGetNumEntries(segP) - returns the current nuber of entries */
/************************************************************************/
static int
-SIGetNumEntries(SISeg * segP)
+SIGetNumEntries(SISeg *segP)
{
return (segP->numEntries);
}
@@ -328,7 +328,7 @@ SIGetNumEntries(SISeg * segP)
/* SISetMaxNumEntries(segP, num) sets the maximal number of entries */
/************************************************************************/
static bool
-SISetMaxNumEntries(SISeg * segP, int num)
+SISetMaxNumEntries(SISeg *segP, int num)
{
if (num <= MAXNUMMESSAGES)
{
@@ -346,7 +346,7 @@ SISetMaxNumEntries(SISeg * segP, int num)
/* SIGetProcStateLimit(segP, i) returns the limit of read messages */
/************************************************************************/
static int
-SIGetProcStateLimit(SISeg * segP, int i)
+SIGetProcStateLimit(SISeg *segP, int i)
{
return (segP->procState[i].limit);
}
@@ -355,7 +355,7 @@ SIGetProcStateLimit(SISeg * segP, int i)
/* SIIncNumEntries(segP, num) increments the current nuber of entries */
/************************************************************************/
static bool
-SIIncNumEntries(SISeg * segP, int num)
+SIIncNumEntries(SISeg *segP, int num)
{
if ((segP->numEntries + num) <= MAXNUMMESSAGES)
{
@@ -372,7 +372,7 @@ SIIncNumEntries(SISeg * segP, int num)
/* SIDecNumEntries(segP, num) decrements the current nuber of entries */
/************************************************************************/
static bool
-SIDecNumEntries(SISeg * segP, int num)
+SIDecNumEntries(SISeg *segP, int num)
{
if ((segP->numEntries - num) >= 0)
{
@@ -389,7 +389,7 @@ SIDecNumEntries(SISeg * segP, int num)
/* SISetStartFreeSpace(segP, offset) - sets the offset */
/************************************************************************/
static void
-SISetStartFreeSpace(SISeg * segP, Offset offset)
+SISetStartFreeSpace(SISeg *segP, Offset offset)
{
segP->startFreeSpace = offset;
}
@@ -398,7 +398,7 @@ SISetStartFreeSpace(SISeg * segP, Offset offset)
/* SIGetStartFreeSpace(segP) - returns the offset */
/************************************************************************/
static Offset
-SIGetStartFreeSpace(SISeg * segP)
+SIGetStartFreeSpace(SISeg *segP)
{
return (segP->startFreeSpace);
}
@@ -409,7 +409,7 @@ SIGetStartFreeSpace(SISeg * segP)
/* SIGetFirstDataEntry(segP) returns first data entry */
/************************************************************************/
static SISegEntry *
-SIGetFirstDataEntry(SISeg * segP)
+SIGetFirstDataEntry(SISeg *segP)
{
SISegEntry *eP;
Offset startChain;
@@ -430,7 +430,7 @@ SIGetFirstDataEntry(SISeg * segP)
/* SIGetLastDataEntry(segP) returns last data entry in the chain */
/************************************************************************/
static SISegEntry *
-SIGetLastDataEntry(SISeg * segP)
+SIGetLastDataEntry(SISeg *segP)
{
SISegEntry *eP;
Offset endChain;
@@ -450,7 +450,7 @@ SIGetLastDataEntry(SISeg * segP)
/* SIGetNextDataEntry(segP, offset) returns next data entry */
/************************************************************************/
static SISegEntry *
-SIGetNextDataEntry(SISeg * segP, Offset offset)
+SIGetNextDataEntry(SISeg *segP, Offset offset)
{
SISegEntry *eP;
@@ -468,7 +468,7 @@ SIGetNextDataEntry(SISeg * segP, Offset offset)
/* SIGetNthDataEntry(segP, n) returns the n-th data entry in chain */
/************************************************************************/
static SISegEntry *
-SIGetNthDataEntry(SISeg * segP,
+SIGetNthDataEntry(SISeg *segP,
int n) /* must range from 1 to MaxMessages */
{
SISegEntry *eP;
@@ -491,7 +491,7 @@ SIGetNthDataEntry(SISeg * segP,
/* SIEntryOffset(segP, entryP) returns the offset for an pointer */
/************************************************************************/
static Offset
-SIEntryOffset(SISeg * segP, SISegEntry * entryP)
+SIEntryOffset(SISeg *segP, SISegEntry *entryP)
{
/* relative to B !! */
return ((Offset) ((Pointer) entryP -
@@ -504,7 +504,7 @@ SIEntryOffset(SISeg * segP, SISegEntry * entryP)
/* SISetDataEntry(segP, data) - sets a message in the segemnt */
/************************************************************************/
bool
-SISetDataEntry(SISeg * segP, SharedInvalidData * data)
+SISetDataEntry(SISeg *segP, SharedInvalidData *data)
{
Offset offsetToNewData;
SISegEntry *eP,
@@ -543,7 +543,7 @@ SISetDataEntry(SISeg * segP, SharedInvalidData * data)
/* SIDecProcLimit(segP, num) decrements all process limits */
/************************************************************************/
static void
-SIDecProcLimit(SISeg * segP, int num)
+SIDecProcLimit(SISeg *segP, int num)
{
int i;
@@ -568,7 +568,7 @@ SIDecProcLimit(SISeg * segP, int num)
/* SIDelDataEntry(segP) - free the FIRST entry */
/************************************************************************/
bool
-SIDelDataEntry(SISeg * segP)
+SIDelDataEntry(SISeg *segP)
{
SISegEntry *e1P;
@@ -600,7 +600,7 @@ SIDelDataEntry(SISeg * segP)
/* invalid */
/************************************************************************/
void
-SISetProcStateInvalid(SISeg * segP)
+SISetProcStateInvalid(SISeg *segP)
{
int i;
@@ -625,7 +625,7 @@ SISetProcStateInvalid(SISeg * segP)
/* and executes function */
/************************************************************************/
void
-SIReadEntryData(SISeg * segP,
+SIReadEntryData(SISeg *segP,
int backendId,
void (*invalFunction) (),
void (*resetFunction) ())
@@ -673,7 +673,7 @@ SIReadEntryData(SISeg * segP,
/* SIDelExpiredDataEntries (segP) - removes irrelevant messages */
/************************************************************************/
void
-SIDelExpiredDataEntries(SISeg * segP)
+SIDelExpiredDataEntries(SISeg *segP)
{
int min,
i,
@@ -709,7 +709,7 @@ SIDelExpiredDataEntries(SISeg * segP)
/* SISegInit(segP) - initializes the segment */
/************************************************************************/
static void
-SISegInit(SISeg * segP)
+SISegInit(SISeg *segP)
{
SISegOffsets *oP;
int segSize,
diff --git a/src/backend/storage/large_object/inv_api.c b/src/backend/storage/large_object/inv_api.c
index 38cf0b47995..f31f7e208f0 100644
--- a/src/backend/storage/large_object/inv_api.c
+++ b/src/backend/storage/large_object/inv_api.c
@@ -8,7 +8,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/large_object/inv_api.c,v 1.16 1997/09/08 20:56:50 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/large_object/inv_api.c,v 1.17 1997/09/08 21:47:17 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -64,14 +64,14 @@
/* non-export function prototypes */
static HeapTuple
-inv_newtuple(LargeObjectDesc * obj_desc, Buffer buffer,
+inv_newtuple(LargeObjectDesc *obj_desc, Buffer buffer,
Page page, char *dbuf, int nwrite);
-static HeapTuple inv_fetchtup(LargeObjectDesc * obj_desc, Buffer *bufP);
-static int inv_wrnew(LargeObjectDesc * obj_desc, char *buf, int nbytes);
+static HeapTuple inv_fetchtup(LargeObjectDesc *obj_desc, Buffer *bufP);
+static int inv_wrnew(LargeObjectDesc *obj_desc, char *buf, int nbytes);
static int
-inv_wrold(LargeObjectDesc * obj_desc, char *dbuf, int nbytes,
+inv_wrold(LargeObjectDesc *obj_desc, char *dbuf, int nbytes,
HeapTuple htup, Buffer buffer);
-static void inv_indextup(LargeObjectDesc * obj_desc, HeapTuple htup);
+static void inv_indextup(LargeObjectDesc *obj_desc, HeapTuple htup);
static int _inv_getsize(Relation hreln, TupleDesc hdesc, Relation ireln);
/*
@@ -267,7 +267,7 @@ inv_open(Oid lobjId, int flags)
* Closes an existing large object descriptor.
*/
void
-inv_close(LargeObjectDesc * obj_desc)
+inv_close(LargeObjectDesc *obj_desc)
{
Assert(PointerIsValid(obj_desc));
@@ -313,7 +313,7 @@ inv_destroy(Oid lobjId)
*/
#ifdef NOT_USED
int
-inv_stat(LargeObjectDesc * obj_desc, struct pgstat * stbuf)
+inv_stat(LargeObjectDesc *obj_desc, struct pgstat * stbuf)
{
Assert(PointerIsValid(obj_desc));
Assert(stbuf != NULL);
@@ -346,7 +346,7 @@ inv_stat(LargeObjectDesc * obj_desc, struct pgstat * stbuf)
#endif
int
-inv_seek(LargeObjectDesc * obj_desc, int offset, int whence)
+inv_seek(LargeObjectDesc *obj_desc, int offset, int whence)
{
int oldOffset;
Datum d;
@@ -423,7 +423,7 @@ inv_seek(LargeObjectDesc * obj_desc, int offset, int whence)
}
int
-inv_tell(LargeObjectDesc * obj_desc)
+inv_tell(LargeObjectDesc *obj_desc)
{
Assert(PointerIsValid(obj_desc));
@@ -431,7 +431,7 @@ inv_tell(LargeObjectDesc * obj_desc)
}
int
-inv_read(LargeObjectDesc * obj_desc, char *buf, int nbytes)
+inv_read(LargeObjectDesc *obj_desc, char *buf, int nbytes)
{
HeapTuple htup;
Buffer b;
@@ -495,7 +495,7 @@ inv_read(LargeObjectDesc * obj_desc, char *buf, int nbytes)
}
int
-inv_write(LargeObjectDesc * obj_desc, char *buf, int nbytes)
+inv_write(LargeObjectDesc *obj_desc, char *buf, int nbytes)
{
HeapTuple htup;
Buffer b;
@@ -576,7 +576,7 @@ inv_write(LargeObjectDesc * obj_desc, char *buf, int nbytes)
* such tuple exists.
*/
static HeapTuple
-inv_fetchtup(LargeObjectDesc * obj_desc, Buffer *bufP)
+inv_fetchtup(LargeObjectDesc *obj_desc, Buffer *bufP)
{
HeapTuple htup;
RetrieveIndexResult res;
@@ -691,7 +691,7 @@ inv_fetchtup(LargeObjectDesc * obj_desc, Buffer *bufP)
* number of bytes actually written to the new tuple.
*/
static int
-inv_wrnew(LargeObjectDesc * obj_desc, char *buf, int nbytes)
+inv_wrnew(LargeObjectDesc *obj_desc, char *buf, int nbytes)
{
Relation hr;
HeapTuple ntup;
@@ -762,7 +762,7 @@ inv_wrnew(LargeObjectDesc * obj_desc, char *buf, int nbytes)
}
static int
-inv_wrold(LargeObjectDesc * obj_desc,
+inv_wrold(LargeObjectDesc *obj_desc,
char *dbuf,
int nbytes,
HeapTuple htup,
@@ -939,7 +939,7 @@ inv_wrold(LargeObjectDesc * obj_desc,
}
static HeapTuple
-inv_newtuple(LargeObjectDesc * obj_desc,
+inv_newtuple(LargeObjectDesc *obj_desc,
Buffer buffer,
Page page,
char *dbuf,
@@ -1061,7 +1061,7 @@ inv_newtuple(LargeObjectDesc * obj_desc,
}
static void
-inv_indextup(LargeObjectDesc * obj_desc, HeapTuple htup)
+inv_indextup(LargeObjectDesc *obj_desc, HeapTuple htup)
{
InsertIndexResult res;
Datum v[1];
diff --git a/src/backend/storage/lmgr/lmgr.c b/src/backend/storage/lmgr/lmgr.c
index 495a11f76a5..c0367a992ab 100644
--- a/src/backend/storage/lmgr/lmgr.c
+++ b/src/backend/storage/lmgr/lmgr.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/lmgr.c,v 1.7 1997/09/08 02:29:10 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/lmgr.c,v 1.8 1997/09/08 21:47:19 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -48,7 +48,7 @@
#include "storage/bufmgr.h"
#include "access/transam.h" /* for AmiTransactionId */
-static void LRelIdAssign(LRelId * lRelId, Oid dbId, Oid relId);
+static void LRelIdAssign(LRelId *lRelId, Oid dbId, Oid relId);
/* ----------------
*
@@ -166,7 +166,7 @@ bool
DatabaseIdIsMyDatabaseId(Oid databaseId)
{
return (bool)
- (!OidIsValid(databaseId) || databaseId == MyDatabaseId);
+ (!OidIsValid(databaseId) || databaseId == MyDatabaseId);
}
#endif
@@ -180,7 +180,7 @@ bool
LRelIdContainsMyDatabaseId(LRelId lRelId)
{
return (bool)
- (!OidIsValid(lRelId.dbId) || lRelId.dbId == MyDatabaseId);
+ (!OidIsValid(lRelId.dbId) || lRelId.dbId == MyDatabaseId);
}
#endif
@@ -960,7 +960,7 @@ RelationUnsetLockForExtend(Relation relation)
* Create an LRelid --- Why not just pass in a pointer to the storage?
*/
static void
-LRelIdAssign(LRelId * lRelId, Oid dbId, Oid relId)
+LRelIdAssign(LRelId *lRelId, Oid dbId, Oid relId)
{
lRelId->dbId = dbId;
lRelId->relId = relId;
diff --git a/src/backend/storage/lmgr/lock.c b/src/backend/storage/lmgr/lock.c
index 3bcef3549c8..dc6b7bd466c 100644
--- a/src/backend/storage/lmgr/lock.c
+++ b/src/backend/storage/lmgr/lock.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/lock.c,v 1.13 1997/09/08 02:29:15 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/lock.c,v 1.14 1997/09/08 21:47:26 momjian Exp $
*
* NOTES
* Outside modules can create a lock table and acquire/release
@@ -49,7 +49,7 @@
#include "access/transam.h"
static int
-WaitOnLock(LOCKTAB * ltable, LockTableId tableId, LOCK * lock,
+WaitOnLock(LOCKTAB *ltable, LockTableId tableId, LOCK *lock,
LOCKT lockt);
/*#define LOCK_MGR_DEBUG*/
@@ -194,8 +194,8 @@ LockDisable(int status)
* Notes: just copying. Should only be called once.
*/
static void
-LockTypeInit(LOCKTAB * ltable,
- MASK * conflictsP,
+LockTypeInit(LOCKTAB *ltable,
+ MASK *conflictsP,
int *prioP,
int ntypes)
{
@@ -222,7 +222,7 @@ LockTypeInit(LOCKTAB * ltable,
*/
LockTableId
LockTabInit(char *tabName,
- MASK * conflictsP,
+ MASK *conflictsP,
int *prioP,
int ntypes)
{
@@ -452,7 +452,7 @@ LockTabRename(LockTableId tableId)
#endif
*/
bool
-LockAcquire(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
+LockAcquire(LockTableId tableId, LOCKTAG *lockName, LOCKT lockt)
{
XIDLookupEnt *result,
item;
@@ -559,7 +559,7 @@ LockAcquire(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
}
#endif
- result = (XIDLookupEnt *) hash_search(xidTable, (Pointer) & item, HASH_ENTER, &found);
+ result = (XIDLookupEnt *) hash_search(xidTable, (Pointer) &item, HASH_ENTER, &found);
if (!result)
{
elog(NOTICE, "LockAcquire: xid table corrupted");
@@ -619,7 +619,7 @@ LockAcquire(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
if (!result->nHolding)
{
SHMQueueDelete(&result->queue);
- hash_search(xidTable, (Pointer) & item, HASH_REMOVE, &found);
+ hash_search(xidTable, (Pointer) &item, HASH_REMOVE, &found);
}
lock->nHolding--;
lock->holders[lockt]--;
@@ -656,8 +656,8 @@ LockAcquire(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
* ----------------------------
*/
int
-LockResolveConflicts(LOCKTAB * ltable,
- LOCK * lock,
+LockResolveConflicts(LOCKTAB *ltable,
+ LOCK *lock,
LOCKT lockt,
TransactionId xid)
{
@@ -690,7 +690,7 @@ LockResolveConflicts(LOCKTAB * ltable,
#endif
if (!(result = (XIDLookupEnt *)
- hash_search(xidTable, (Pointer) & item, HASH_ENTER, &found)))
+ hash_search(xidTable, (Pointer) &item, HASH_ENTER, &found)))
{
elog(NOTICE, "LockResolveConflicts: xid table corrupted");
return (STATUS_ERROR);
@@ -770,7 +770,7 @@ LockResolveConflicts(LOCKTAB * ltable,
}
static int
-WaitOnLock(LOCKTAB * ltable, LockTableId tableId, LOCK * lock, LOCKT lockt)
+WaitOnLock(LOCKTAB *ltable, LockTableId tableId, LOCK *lock, LOCKT lockt)
{
PROC_QUEUE *waitQueue = &(lock->waitProcs);
@@ -819,7 +819,7 @@ WaitOnLock(LOCKTAB * ltable, LockTableId tableId, LOCK * lock, LOCKT lockt)
* come along and request the lock).
*/
bool
-LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
+LockRelease(LockTableId tableId, LOCKTAG *lockName, LOCKT lockt)
{
LOCK *lock = NULL;
SPINLOCK masterLock;
@@ -935,7 +935,7 @@ LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
*/
Assert(ltable->lockHash->hash == tag_hash);
lock = (LOCK *) hash_search(ltable->lockHash,
- (Pointer) & (lock->tag),
+ (Pointer) &(lock->tag),
HASH_REMOVE_SAVED,
&found);
Assert(lock && found);
@@ -971,7 +971,7 @@ LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
#endif
if (!(result = (XIDLookupEnt *) hash_search(xidTable,
- (Pointer) & item,
+ (Pointer) &item,
HASH_FIND_SAVE,
&found))
|| !found)
@@ -1020,7 +1020,7 @@ LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
if (result->queue.next != INVALID_OFFSET)
SHMQueueDelete(&result->queue);
if (!(result = (XIDLookupEnt *)
- hash_search(xidTable, (Pointer) & item, HASH_REMOVE_SAVED, &found)) ||
+ hash_search(xidTable, (Pointer) &item, HASH_REMOVE_SAVED, &found)) ||
!found)
{
SpinRelease(masterLock);
@@ -1062,7 +1062,7 @@ LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
*/
Assert(ltable->lockHash->hash == tag_hash);
lock = (LOCK *) hash_search(ltable->lockHash,
- (Pointer) & (lock->tag),
+ (Pointer) &(lock->tag),
HASH_REMOVE,
&found);
Assert(lock && found);
@@ -1103,7 +1103,7 @@ LockRelease(LockTableId tableId, LOCKTAG * lockName, LOCKT lockt)
* the new lock holder.
*/
void
-GrantLock(LOCK * lock, LOCKT lockt)
+GrantLock(LOCK *lock, LOCKT lockt)
{
lock->nActive++;
lock->activeHolders[lockt]++;
@@ -1123,7 +1123,7 @@ GrantLock(LOCK * lock, LOCKT lockt)
*/
#endif
bool
-LockReleaseAll(LockTableId tableId, SHM_QUEUE * lockQueue)
+LockReleaseAll(LockTableId tableId, SHM_QUEUE *lockQueue)
{
PROC_QUEUE *waitQueue;
int done;
@@ -1168,7 +1168,7 @@ LockReleaseAll(LockTableId tableId, SHM_QUEUE * lockQueue)
#ifdef USER_LOCKS
SpinAcquire(masterLock);
#endif
- SHMQueueFirst(lockQueue, (Pointer *) & xidLook, &xidLook->queue);
+ SHMQueueFirst(lockQueue, (Pointer *) &xidLook, &xidLook->queue);
XID_PRINT("LockReleaseAll", xidLook);
@@ -1312,7 +1312,7 @@ LockReleaseAll(LockTableId tableId, SHM_QUEUE * lockQueue)
Assert(ltable->lockHash->hash == tag_hash);
lock = (LOCK *)
- hash_search(ltable->lockHash, (Pointer) & (lock->tag), HASH_REMOVE, &found);
+ hash_search(ltable->lockHash, (Pointer) &(lock->tag), HASH_REMOVE, &found);
if ((!lock) || (!found))
{
SpinRelease(masterLock);
@@ -1341,7 +1341,7 @@ next_item:
#endif
if (done)
break;
- SHMQueueFirst(&xidLook->queue, (Pointer *) & tmp, &tmp->queue);
+ SHMQueueFirst(&xidLook->queue, (Pointer *) &tmp, &tmp->queue);
xidLook = tmp;
}
SpinRelease(masterLock);
@@ -1444,7 +1444,7 @@ DumpLocks()
if (SHMQueueEmpty(lockQueue))
return;
- SHMQueueFirst(lockQueue, (Pointer *) & xidLook, &xidLook->queue);
+ SHMQueueFirst(lockQueue, (Pointer *) &xidLook, &xidLook->queue);
end = MAKE_OFFSET(lockQueue);
LOCK_DUMP("DumpLocks", MyProc->waitLock, 0);
@@ -1471,7 +1471,7 @@ DumpLocks()
if (done)
break;
- SHMQueueFirst(&xidLook->queue, (Pointer *) & tmp, &tmp->queue);
+ SHMQueueFirst(&xidLook->queue, (Pointer *) &tmp, &tmp->queue);
xidLook = tmp;
}
}
diff --git a/src/backend/storage/lmgr/multi.c b/src/backend/storage/lmgr/multi.c
index 529c889b163..f62129595d3 100644
--- a/src/backend/storage/lmgr/multi.c
+++ b/src/backend/storage/lmgr/multi.c
@@ -12,7 +12,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/Attic/multi.c,v 1.6 1997/09/08 02:29:16 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/Attic/multi.c,v 1.7 1997/09/08 21:47:29 momjian Exp $
*
* NOTES:
* (1) The lock.c module assumes that the caller here is doing
@@ -30,10 +30,10 @@
#include "miscadmin.h" /* MyDatabaseId */
static bool
-MultiAcquire(LockTableId tableId, LOCKTAG * tag, LOCKT lockt,
+MultiAcquire(LockTableId tableId, LOCKTAG *tag, LOCKT lockt,
LOCK_LEVEL level);
static bool
-MultiRelease(LockTableId tableId, LOCKTAG * tag, LOCKT lockt,
+MultiRelease(LockTableId tableId, LOCKTAG *tag, LOCKT lockt,
LOCK_LEVEL level);
/*
@@ -199,7 +199,7 @@ MultiLockPage(LockInfo linfo, ItemPointer tidPtr, LOCKT lockt)
*/
static bool
MultiAcquire(LockTableId tableId,
- LOCKTAG * tag,
+ LOCKTAG *tag,
LOCKT lockt,
LOCK_LEVEL level)
{
@@ -359,7 +359,7 @@ MultiReleaseReln(LockInfo linfo, LOCKT lockt)
*/
static bool
MultiRelease(LockTableId tableId,
- LOCKTAG * tag,
+ LOCKTAG *tag,
LOCKT lockt,
LOCK_LEVEL level)
{
diff --git a/src/backend/storage/lmgr/proc.c b/src/backend/storage/lmgr/proc.c
index ddcb4ac7248..07abe6ce96c 100644
--- a/src/backend/storage/lmgr/proc.c
+++ b/src/backend/storage/lmgr/proc.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.20 1997/09/08 02:29:17 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.21 1997/09/08 21:47:30 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -46,7 +46,7 @@
* This is so that we can support more backends. (system-wide semaphore
* sets run out pretty fast.) -ay 4/95
*
- * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.20 1997/09/08 02:29:17 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/lmgr/proc.c,v 1.21 1997/09/08 21:47:30 momjian Exp $
*/
#include <sys/time.h>
#include <unistd.h>
@@ -77,7 +77,7 @@
#include "storage/proc.h"
static void HandleDeadLock(int sig);
-static PROC *ProcWakeup(PROC * proc, int errType);
+static PROC *ProcWakeup(PROC *proc, int errType);
/*
* timeout (in seconds) for resolving possible deadlock
@@ -106,7 +106,7 @@ static PROC_HDR *ProcGlobal = NULL;
PROC *MyProc = NULL;
static void ProcKill(int exitStatus, int pid);
-static void ProcGetNewSemKeyAndNum(IPCKey * key, int *semNum);
+static void ProcGetNewSemKeyAndNum(IPCKey *key, int *semNum);
static void ProcFreeSem(IpcSemaphoreKey semKey, int semNum);
/*
@@ -441,7 +441,7 @@ ProcQueueAlloc(char *name)
* ProcQueueInit -- initialize a shared memory process queue
*/
void
-ProcQueueInit(PROC_QUEUE * queue)
+ProcQueueInit(PROC_QUEUE *queue)
{
SHMQueueInit(&(queue->links));
queue->size = 0;
@@ -462,11 +462,11 @@ ProcQueueInit(PROC_QUEUE * queue)
* NOTES: The process queue is now a priority queue for locking.
*/
int
-ProcSleep(PROC_QUEUE * queue,
+ProcSleep(PROC_QUEUE *queue,
SPINLOCK spinlock,
int token,
int prio,
- LOCK * lock)
+ LOCK *lock)
{
int i;
PROC *proc;
@@ -556,7 +556,7 @@ ProcSleep(PROC_QUEUE * queue,
* RETURN: the next process in the wait queue.
*/
static PROC *
-ProcWakeup(PROC * proc, int errType)
+ProcWakeup(PROC *proc, int errType)
{
PROC *retProc;
@@ -597,7 +597,7 @@ ProcGetId()
* released.
*/
int
-ProcLockWakeup(PROC_QUEUE * queue, char *ltable, char *lock)
+ProcLockWakeup(PROC_QUEUE *queue, char *ltable, char *lock)
{
PROC *proc;
int count;
@@ -642,7 +642,7 @@ ProcLockWakeup(PROC_QUEUE * queue, char *ltable, char *lock)
}
void
-ProcAddLock(SHM_QUEUE * elem)
+ProcAddLock(SHM_QUEUE *elem)
{
SHMQueueInsertTL(&MyProc->lockQueue, elem);
}
@@ -741,7 +741,7 @@ HandleDeadLock(int sig)
}
void
-ProcReleaseSpins(PROC * proc)
+ProcReleaseSpins(PROC *proc)
{
int i;
@@ -772,7 +772,7 @@ ProcReleaseSpins(PROC * proc)
* semaphore set.)
*/
static void
-ProcGetNewSemKeyAndNum(IPCKey * key, int *semNum)
+ProcGetNewSemKeyAndNum(IPCKey *key, int *semNum)
{
int i;
int32 *freeSemMap = ProcGlobal->freeSemMap;
diff --git a/src/backend/storage/smgr/md.c b/src/backend/storage/smgr/md.c
index 755d29266e6..340a9709747 100644
--- a/src/backend/storage/smgr/md.c
+++ b/src/backend/storage/smgr/md.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/smgr/md.c,v 1.20 1997/09/08 02:29:28 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/smgr/md.c,v 1.21 1997/09/08 21:47:32 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -48,7 +48,7 @@ typedef struct _MdfdVec
int mdfd_lstbcnt; /* most recent block count */
int mdfd_nextFree; /* next free vector */
struct _MdfdVec *mdfd_chain;/* for large relations */
-} MdfdVec;
+} MdfdVec;
static int Nfds = 100;
static MdfdVec *Md_fdvec = (MdfdVec *) NULL;
diff --git a/src/backend/storage/smgr/smgr.c b/src/backend/storage/smgr/smgr.c
index b3a2648336d..cda65c57f26 100644
--- a/src/backend/storage/smgr/smgr.c
+++ b/src/backend/storage/smgr/smgr.c
@@ -10,7 +10,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/smgr/smgr.c,v 1.10 1997/09/08 02:29:36 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/smgr/smgr.c,v 1.11 1997/09/08 21:47:38 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -42,7 +42,7 @@ typedef struct f_smgr
int (*smgr_truncate) ();
int (*smgr_commit) (); /* may be NULL */
int (*smgr_abort) (); /* may be NULL */
-} f_smgr;
+} f_smgr;
/*
* The weird placement of commas in this init block is to keep the compiler
diff --git a/src/backend/storage/smgr/smgrtype.c b/src/backend/storage/smgr/smgrtype.c
index 9439dbc0a2e..dec7c18f14d 100644
--- a/src/backend/storage/smgr/smgrtype.c
+++ b/src/backend/storage/smgr/smgrtype.c
@@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/storage/smgr/smgrtype.c,v 1.4 1997/09/08 02:29:37 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/storage/smgr/smgrtype.c,v 1.5 1997/09/08 21:47:42 momjian Exp $
*
*-------------------------------------------------------------------------
*/
@@ -21,7 +21,7 @@
typedef struct smgrid
{
char *smgr_name;
-} smgrid;
+} smgrid;
/*
* StorageManager[] -- List of defined storage managers.