diff options
Diffstat (limited to 'src/backend/storage/ipc/ipci.c')
| -rw-r--r-- | src/backend/storage/ipc/ipci.c | 178 |
1 files changed, 90 insertions, 88 deletions
diff --git a/src/backend/storage/ipc/ipci.c b/src/backend/storage/ipc/ipci.c index f949041f44d..4aad8e85f54 100644 --- a/src/backend/storage/ipc/ipci.c +++ b/src/backend/storage/ipc/ipci.c @@ -1,13 +1,13 @@ /*------------------------------------------------------------------------- * * ipci.c-- - * POSTGRES inter-process communication initialization code. + * POSTGRES inter-process communication initialization code. * * Copyright (c) 1994, Regents of the University of California * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/storage/ipc/ipci.c,v 1.5 1997/01/08 08:32:03 bryanh Exp $ + * $Header: /cvsroot/pgsql/src/backend/storage/ipc/ipci.c,v 1.6 1997/09/07 04:48:33 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -23,129 +23,131 @@ #include "storage/proc.h" #include "storage/smgr.h" #include "storage/lock.h" -#include "miscadmin.h" /* for DebugLvl */ +#include "miscadmin.h" /* for DebugLvl */ /* * SystemPortAddressCreateMemoryKey -- - * Returns a memory key given a port address. + * Returns a memory key given a port address. */ IPCKey SystemPortAddressCreateIPCKey(SystemPortAddress address) { - Assert(address < 32768); /* XXX */ - - return (SystemPortAddressGetIPCKey(address)); + Assert(address < 32768); /* XXX */ + + return (SystemPortAddressGetIPCKey(address)); } /* * CreateSharedMemoryAndSemaphores -- - * Creates and initializes shared memory and semaphores. + * Creates and initializes shared memory and semaphores. */ /************************************************** - + CreateSharedMemoryAndSemaphores is called exactly *ONCE* by the postmaster. It is *NEVER* called by the postgres backend - + 0) destroy any existing semaphores for both buffer and lock managers. 1) create the appropriate *SHARED* memory segments for the two resource managers. - + **************************************************/ void CreateSharedMemoryAndSemaphores(IPCKey key) { - int size; - + int size; + #ifdef HAS_TEST_AND_SET - /* --------------- - * create shared memory for slocks - * -------------- - */ - CreateAndInitSLockMemory(IPCKeyGetSLockSharedMemoryKey(key)); + /* --------------- + * create shared memory for slocks + * -------------- + */ + CreateAndInitSLockMemory(IPCKeyGetSLockSharedMemoryKey(key)); #endif - /* ---------------- - * kill and create the buffer manager buffer pool (and semaphore) - * ---------------- - */ - CreateSpinlocks(IPCKeyGetSpinLockSemaphoreKey(key)); - size = BufferShmemSize() + LockShmemSize(); - + /* ---------------- + * kill and create the buffer manager buffer pool (and semaphore) + * ---------------- + */ + CreateSpinlocks(IPCKeyGetSpinLockSemaphoreKey(key)); + size = BufferShmemSize() + LockShmemSize(); + #ifdef MAIN_MEMORY - size += MMShmemSize(); -#endif /* MAIN_MEMORY */ - - if (DebugLvl > 1) { - fprintf(stderr, "binding ShmemCreate(key=%x, size=%d)\n", - IPCKeyGetBufferMemoryKey(key), size); - } - ShmemCreate(IPCKeyGetBufferMemoryKey(key), size); - ShmemBindingTabReset(); - InitShmem(key, size); - InitBufferPool(key); - - /* ---------------- - * do the lock table stuff - * ---------------- - */ - InitLocks(); - InitMultiLevelLockm(); - if (InitMultiLevelLockm() == INVALID_TABLEID) - elog(FATAL, "Couldn't create the lock table"); - - /* ---------------- - * do process table stuff - * ---------------- - */ - InitProcGlobal(key); - on_exitpg(ProcFreeAllSemaphores, 0); - - CreateSharedInvalidationState(key); + size += MMShmemSize(); +#endif /* MAIN_MEMORY */ + + if (DebugLvl > 1) + { + fprintf(stderr, "binding ShmemCreate(key=%x, size=%d)\n", + IPCKeyGetBufferMemoryKey(key), size); + } + ShmemCreate(IPCKeyGetBufferMemoryKey(key), size); + ShmemBindingTabReset(); + InitShmem(key, size); + InitBufferPool(key); + + /* ---------------- + * do the lock table stuff + * ---------------- + */ + InitLocks(); + InitMultiLevelLockm(); + if (InitMultiLevelLockm() == INVALID_TABLEID) + elog(FATAL, "Couldn't create the lock table"); + + /* ---------------- + * do process table stuff + * ---------------- + */ + InitProcGlobal(key); + on_exitpg(ProcFreeAllSemaphores, 0); + + CreateSharedInvalidationState(key); } /* * AttachSharedMemoryAndSemaphores -- - * Attachs existant shared memory and semaphores. + * Attachs existant shared memory and semaphores. */ void AttachSharedMemoryAndSemaphores(IPCKey key) { - int size; - - /* ---------------- - * create rather than attach if using private key - * ---------------- - */ - if (key == PrivateIPCKey) { - CreateSharedMemoryAndSemaphores(key); - return; - } - + int size; + + /* ---------------- + * create rather than attach if using private key + * ---------------- + */ + if (key == PrivateIPCKey) + { + CreateSharedMemoryAndSemaphores(key); + return; + } + #ifdef HAS_TEST_AND_SET - /* ---------------- - * attach the slock shared memory - * ---------------- - */ - AttachSLockMemory(IPCKeyGetSLockSharedMemoryKey(key)); + /* ---------------- + * attach the slock shared memory + * ---------------- + */ + AttachSLockMemory(IPCKeyGetSLockSharedMemoryKey(key)); #endif - /* ---------------- - * attach the buffer manager buffer pool (and semaphore) - * ---------------- - */ - size = BufferShmemSize() + LockShmemSize(); - InitShmem(key, size); - InitBufferPool(key); - - /* ---------------- - * initialize lock table stuff - * ---------------- - */ - InitLocks(); - if (InitMultiLevelLockm() == INVALID_TABLEID) - elog(FATAL, "Couldn't attach to the lock table"); - - AttachSharedInvalidationState(key); + /* ---------------- + * attach the buffer manager buffer pool (and semaphore) + * ---------------- + */ + size = BufferShmemSize() + LockShmemSize(); + InitShmem(key, size); + InitBufferPool(key); + + /* ---------------- + * initialize lock table stuff + * ---------------- + */ + InitLocks(); + if (InitMultiLevelLockm() == INVALID_TABLEID) + elog(FATAL, "Couldn't attach to the lock table"); + + AttachSharedInvalidationState(key); } |