101101 * absorbed by the checkpointer.
102102 *
103103 * Unlike the checkpoint fields, num_backend_writes, num_backend_fsync, and
104- * the requests fields are protected byBgWriterCommLock .
104+ * the requests fields are protected byCheckpointerCommLock .
105105 *----------
106106 */
107107typedef struct
@@ -1118,7 +1118,7 @@ ForwardFsyncRequest(RelFileNodeBackend rnode, ForkNumber forknum,
11181118if (am_checkpointer )
11191119elog (ERROR ,"ForwardFsyncRequest must not be called in checkpointer" );
11201120
1121- LWLockAcquire (BgWriterCommLock ,LW_EXCLUSIVE );
1121+ LWLockAcquire (CheckpointerCommLock ,LW_EXCLUSIVE );
11221122
11231123/* Count all backend writes regardless of if they fit in the queue */
11241124BgWriterShmem -> num_backend_writes ++ ;
@@ -1137,7 +1137,7 @@ ForwardFsyncRequest(RelFileNodeBackend rnode, ForkNumber forknum,
11371137 * fsync
11381138 */
11391139BgWriterShmem -> num_backend_fsync ++ ;
1140- LWLockRelease (BgWriterCommLock );
1140+ LWLockRelease (CheckpointerCommLock );
11411141return false;
11421142}
11431143
@@ -1151,7 +1151,7 @@ ForwardFsyncRequest(RelFileNodeBackend rnode, ForkNumber forknum,
11511151too_full = (BgWriterShmem -> num_requests >=
11521152BgWriterShmem -> max_requests /2 );
11531153
1154- LWLockRelease (BgWriterCommLock );
1154+ LWLockRelease (CheckpointerCommLock );
11551155
11561156/* ... but not till after we release the lock */
11571157if (too_full && ProcGlobal -> checkpointerLatch )
@@ -1191,8 +1191,8 @@ CompactCheckpointerRequestQueue(void)
11911191HTAB * htab ;
11921192bool * skip_slot ;
11931193
1194- /* must holdBgWriterCommLock in exclusive mode */
1195- Assert (LWLockHeldByMe (BgWriterCommLock ));
1194+ /* must holdCheckpointerCommLock in exclusive mode */
1195+ Assert (LWLockHeldByMe (CheckpointerCommLock ));
11961196
11971197/* Initialize temporary hash table */
11981198MemSet (& ctl ,0 ,sizeof (ctl ));
@@ -1295,7 +1295,7 @@ AbsorbFsyncRequests(void)
12951295 * We try to avoid holding the lock for a long time by copying the request
12961296 * array.
12971297 */
1298- LWLockAcquire (BgWriterCommLock ,LW_EXCLUSIVE );
1298+ LWLockAcquire (CheckpointerCommLock ,LW_EXCLUSIVE );
12991299
13001300/* Transfer stats counts into pending pgstats message */
13011301BgWriterStats .m_buf_written_backend += BgWriterShmem -> num_backend_writes ;
@@ -1312,7 +1312,7 @@ AbsorbFsyncRequests(void)
13121312}
13131313BgWriterShmem -> num_requests = 0 ;
13141314
1315- LWLockRelease (BgWriterCommLock );
1315+ LWLockRelease (CheckpointerCommLock );
13161316
13171317for (request = requests ;n > 0 ;request ++ ,n -- )
13181318RememberFsyncRequest (request -> rnode ,request -> forknum ,request -> segno );