CommitInfoNeedsSave[buffer - 1] = 0

vadim4o · vadim4o · commit d6b8f637f9f3 · 1997-04-18T08:30:08.000Z
added to WriteBuffer(), FlushBuffer(), WriteNoReleaseBuffer().
diff --git 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.12 1997/04/18 02:53:23 vadim Exp $
+ *    $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.13 1997/04/18 08:30:08 vadim Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -663,6 +663,7 @@ WriteBuffer(Buffer buffer)
 	bufHdr->flags |= (BM_DIRTY | BM_JUST_DIRTIED);
 	UnpinBuffer(bufHdr);
 	SpinRelease(BufMgrLock);
+	CommitInfoNeedsSave[buffer - 1] = 0;
     }
     return(TRUE);
 } 
@@ -784,6 +785,7 @@ FlushBuffer(Buffer buffer, bool release)
     if ( release )
     	UnpinBuffer(bufHdr);
     SpinRelease(BufMgrLock);
+    CommitInfoNeedsSave[buffer - 1] = 0;
     
     return(STATUS_OK);
 }
@@ -816,6 +818,7 @@ WriteNoReleaseBuffer(Buffer buffer)
 	SpinAcquire(BufMgrLock);
 	bufHdr->flags |= (BM_DIRTY | BM_JUST_DIRTIED);
 	SpinRelease(BufMgrLock);
+    	CommitInfoNeedsSave[buffer - 1] = 0;
     }
     return(STATUS_OK);
 }
@@ -1765,5 +1768,6 @@ int SetBufferWriteMode (int mode)
 
 void SetBufferCommitInfoNeedsSave(Buffer buffer)
 {
-    CommitInfoNeedsSave[buffer - 1]++;
+    if ( !BufferIsLocal(buffer) )
+    	CommitInfoNeedsSave[buffer - 1]++;
 }

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`	`*`
`8`	`8`	`*`
`9`	`9`	`* IDENTIFICATION`
`10`		`- * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.12 1997/04/18 02:53:23 vadim Exp $`
	`10`	`+ * $Header: /cvsroot/pgsql/src/backend/storage/buffer/bufmgr.c,v 1.13 1997/04/18 08:30:08 vadim Exp $`
`11`	`11`	`*`
`12`	`12`	`*-------------------------------------------------------------------------`
`13`	`13`	`*/`
`@@ -663,6 +663,7 @@ WriteBuffer(Buffer buffer)`
`663`	`663`	`bufHdr->flags \|= (BM_DIRTY \| BM_JUST_DIRTIED);`
`664`	`664`	`UnpinBuffer(bufHdr);`
`665`	`665`	`SpinRelease(BufMgrLock);`
	`666`	`+ CommitInfoNeedsSave[buffer - 1] = 0;`
`666`	`667`	`}`
`667`	`668`	`return(TRUE);`
`668`	`669`	`}`
`@@ -784,6 +785,7 @@ FlushBuffer(Buffer buffer, bool release)`
`784`	`785`	`if ( release )`
`785`	`786`	`UnpinBuffer(bufHdr);`
`786`	`787`	`SpinRelease(BufMgrLock);`
	`788`	`+ CommitInfoNeedsSave[buffer - 1] = 0;`
`787`	`789`
`788`	`790`	`return(STATUS_OK);`
`789`	`791`	`}`
`@@ -816,6 +818,7 @@ WriteNoReleaseBuffer(Buffer buffer)`
`816`	`818`	`SpinAcquire(BufMgrLock);`
`817`	`819`	`bufHdr->flags \|= (BM_DIRTY \| BM_JUST_DIRTIED);`
`818`	`820`	`SpinRelease(BufMgrLock);`
	`821`	`+ CommitInfoNeedsSave[buffer - 1] = 0;`
`819`	`822`	`}`
`820`	`823`	`return(STATUS_OK);`
`821`	`824`	`}`
`@@ -1765,5 +1768,6 @@ int SetBufferWriteMode (int mode)`
`1765`	`1768`
`1766`	`1769`	`void SetBufferCommitInfoNeedsSave(Buffer buffer)`
`1767`	`1770`	`{`
`1768`		`- CommitInfoNeedsSave[buffer - 1]++;`
	`1771`	`+ if ( !BufferIsLocal(buffer) )`
	`1772`	`+ CommitInfoNeedsSave[buffer - 1]++;`
`1769`	`1773`	`}`