diff options
Diffstat (limited to 'src/backend')
-rw-r--r-- | src/backend/commands/sequence.c | 8 | ||||
-rw-r--r-- | src/backend/storage/buffer/bufmgr.c | 72 | ||||
-rw-r--r-- | src/backend/storage/buffer/localbuf.c | 6 |
3 files changed, 39 insertions, 47 deletions
diff --git a/src/backend/commands/sequence.c b/src/backend/commands/sequence.c index 71a5a561dea..736dde31bc6 100644 --- a/src/backend/commands/sequence.c +++ b/src/backend/commands/sequence.c @@ -8,7 +8,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/commands/sequence.c,v 1.80 2002/06/15 19:54:23 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/commands/sequence.c,v 1.81 2002/06/15 19:59:59 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -468,8 +468,7 @@ nextval(PG_FUNCTION_ARGS) LockBuffer(buf, BUFFER_LOCK_UNLOCK); - if (WriteBuffer(buf) == STATUS_ERROR) - elog(ERROR, "%s.nextval: WriteBuffer failed", sequence->relname); + WriteBuffer(buf); relation_close(seqrel, NoLock); @@ -581,8 +580,7 @@ do_setval(RangeVar *sequence, int64 next, bool iscalled) LockBuffer(buf, BUFFER_LOCK_UNLOCK); - if (WriteBuffer(buf) == STATUS_ERROR) - elog(ERROR, "%s.setval: WriteBuffer failed", sequence->relname); + WriteBuffer(buf); relation_close(seqrel, NoLock); } diff --git a/src/backend/storage/buffer/bufmgr.c b/src/backend/storage/buffer/bufmgr.c index 639f9578264..768dd0fd7f9 100644 --- a/src/backend/storage/buffer/bufmgr.c +++ b/src/backend/storage/buffer/bufmgr.c @@ -8,7 +8,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.124 2002/06/15 19:55:37 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.125 2002/06/15 19:59:59 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -87,6 +87,7 @@ static int ReleaseBufferWithBufferLock(Buffer buffer); static int BufferReplace(BufferDesc *bufHdr); void PrintBufferDescs(void); +static void write_buffer(Buffer buffer, bool unpin); /* * ReadBuffer -- returns a buffer containing the requested @@ -558,29 +559,22 @@ BufferAlloc(Relation reln, } /* - * WriteBuffer - * - * Marks buffer contents as dirty (actual write happens later). - * - * Assume that buffer is pinned. Assume that reln is - * valid. - * - * Side Effects: - * Pin count is decremented. + * write_buffer -- common functionality for + * WriteBuffer and WriteNoReleaseBuffer */ - -#undef WriteBuffer - -int -WriteBuffer(Buffer buffer) +static void +write_buffer(Buffer buffer, bool release) { BufferDesc *bufHdr; if (BufferIsLocal(buffer)) - return WriteLocalBuffer(buffer, TRUE); + { + WriteLocalBuffer(buffer, release); + return; + } if (BAD_BUFFER_ID(buffer)) - return FALSE; + elog(ERROR, "write_buffer: bad buffer %d", buffer); bufHdr = &BufferDescriptors[buffer - 1]; @@ -589,37 +583,39 @@ WriteBuffer(Buffer buffer) bufHdr->flags |= (BM_DIRTY | BM_JUST_DIRTIED); - UnpinBuffer(bufHdr); + if (release) + UnpinBuffer(bufHdr); LWLockRelease(BufMgrLock); +} - return TRUE; +/* + * WriteBuffer + * + * Marks buffer contents as dirty (actual write happens later). + * + * Assume that buffer is pinned. Assume that reln is + * valid. + * + * Side Effects: + * Pin count is decremented. + */ + +#undef WriteBuffer + +void +WriteBuffer(Buffer buffer) +{ + write_buffer(buffer, true); } /* * WriteNoReleaseBuffer -- like WriteBuffer, but do not unpin the buffer * when the operation is complete. */ -int +void WriteNoReleaseBuffer(Buffer buffer) { - BufferDesc *bufHdr; - - if (BufferIsLocal(buffer)) - return WriteLocalBuffer(buffer, FALSE); - - if (BAD_BUFFER_ID(buffer)) - return STATUS_ERROR; - - bufHdr = &BufferDescriptors[buffer - 1]; - - LWLockAcquire(BufMgrLock, LW_EXCLUSIVE); - Assert(bufHdr->refcount > 0); - - bufHdr->flags |= (BM_DIRTY | BM_JUST_DIRTIED); - - LWLockRelease(BufMgrLock); - - return STATUS_OK; + write_buffer(buffer, false); } diff --git a/src/backend/storage/buffer/localbuf.c b/src/backend/storage/buffer/localbuf.c index 44446d30a49..64bebabad99 100644 --- a/src/backend/storage/buffer/localbuf.c +++ b/src/backend/storage/buffer/localbuf.c @@ -16,7 +16,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/storage/buffer/localbuf.c,v 1.42 2002/05/03 17:42:11 tgl Exp $ + * $Header: /cvsroot/pgsql/src/backend/storage/buffer/localbuf.c,v 1.43 2002/06/15 19:59:59 momjian Exp $ * *------------------------------------------------------------------------- */ @@ -155,7 +155,7 @@ LocalBufferAlloc(Relation reln, BlockNumber blockNum, bool *foundPtr) * WriteLocalBuffer - * writes out a local buffer */ -int +void WriteLocalBuffer(Buffer buffer, bool release) { int bufid; @@ -174,8 +174,6 @@ WriteLocalBuffer(Buffer buffer, bool release) Assert(LocalRefCount[bufid] > 0); LocalRefCount[bufid]--; } - - return true; } /* |