diff options
Diffstat (limited to 'src/backend/storage/ipc/sinvaladt.c')
| -rw-r--r-- | src/backend/storage/ipc/sinvaladt.c | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/backend/storage/ipc/sinvaladt.c b/src/backend/storage/ipc/sinvaladt.c index 38096190091..d05a651097f 100644 --- a/src/backend/storage/ipc/sinvaladt.c +++ b/src/backend/storage/ipc/sinvaladt.c @@ -8,7 +8,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/storage/ipc/sinvaladt.c,v 1.40 2001/06/19 19:42:15 tgl Exp $ + * $Header: /cvsroot/pgsql/src/backend/storage/ipc/sinvaladt.c,v 1.41 2001/09/29 04:02:24 tgl Exp $ * *------------------------------------------------------------------------- */ @@ -83,7 +83,7 @@ SIBufferInit(int maxBackends) * <0 Some other failure (not currently used) * * NB: this routine, and all following ones, must be executed with the - * SInvalLock spinlock held, since there may be multiple backends trying + * SInvalLock lock held, since there may be multiple backends trying * to access the buffer. */ int @@ -152,7 +152,7 @@ CleanupInvalidationState(int status, Datum arg) Assert(PointerIsValid(segP)); - SpinAcquire(SInvalLock); + LWLockAcquire(SInvalLock, LW_EXCLUSIVE); /* Mark myself inactive */ segP->procState[MyBackendId - 1].nextMsgNum = -1; @@ -167,7 +167,7 @@ CleanupInvalidationState(int status, Datum arg) } segP->lastBackend = i; - SpinRelease(SInvalLock); + LWLockRelease(SInvalLock); } /* @@ -267,6 +267,10 @@ SISetProcStateInvalid(SISeg *segP) * 1: next SI message has been extracted into *data * (there may be more messages available after this one!) * -1: SI reset message extracted + * + * NB: this can run in parallel with other instances of SIGetDataEntry + * executing on behalf of other backends. See comments in sinval.c in + * ReceiveSharedInvalidMessages(). */ int SIGetDataEntry(SISeg *segP, int backendId, |