Rename some functions to mention Relation instead of RelFileLocator.
authorRobert Haas <[email protected]>
Tue, 12 Jul 2022 14:26:48 +0000 (10:26 -0400)
committerRobert Haas <[email protected]>
Tue, 12 Jul 2022 14:26:48 +0000 (10:26 -0400)
This is definitely shorter, and hopefully clearer.

Kyotaro Horiguchi, reviewed by Dilip Kumar and by me

Discussion: http://postgr.es/m/20220707.174436.1885393789789795413[email protected]

src/backend/storage/buffer/bufmgr.c
src/backend/storage/buffer/localbuf.c
src/backend/storage/smgr/smgr.c
src/include/storage/buf_internals.h
src/include/storage/bufmgr.h

index e257ae23e41f83be5c1bd4c2bfd05a49e1f7e55c..c7d7abcd738184461f13d8859ff53e1b423adca9 100644 (file)
@@ -121,7 +121,7 @@ typedef struct CkptTsStatus
  * Type for array used to sort SMgrRelations
  *
  * FlushRelationsAllBuffers shares the same comparator function with
- * DropRelFileLocatorsAllBuffers. Pointer to this struct and RelFileLocator must be
+ * DropRelationsAllBuffers. Pointer to this struct and RelFileLocator must be
  * compatible.
  */
 typedef struct SMgrSortArray
@@ -483,10 +483,10 @@ static BufferDesc *BufferAlloc(SMgrRelation smgr,
                               BufferAccessStrategy strategy,
                               bool *foundPtr);
 static void FlushBuffer(BufferDesc *buf, SMgrRelation reln);
-static void FindAndDropRelFileLocatorBuffers(RelFileLocator rlocator,
-                                            ForkNumber forkNum,
-                                            BlockNumber nForkBlock,
-                                            BlockNumber firstDelBlock);
+static void FindAndDropRelationBuffers(RelFileLocator rlocator,
+                                      ForkNumber forkNum,
+                                      BlockNumber nForkBlock,
+                                      BlockNumber firstDelBlock);
 static void RelationCopyStorageUsingBuffer(Relation src, Relation dst,
                                           ForkNumber forkNum,
                                           bool isunlogged);
@@ -3026,7 +3026,7 @@ BufferGetLSNAtomic(Buffer buffer)
 }
 
 /* ---------------------------------------------------------------------
- *     DropRelFileLocatorBuffers
+ *     DropRelationBuffers
  *
  *     This function removes from the buffer pool all the pages of the
  *     specified relation forks that have block numbers >= firstDelBlock.
@@ -3047,8 +3047,8 @@ BufferGetLSNAtomic(Buffer buffer)
  * --------------------------------------------------------------------
  */
 void
-DropRelFileLocatorBuffers(SMgrRelation smgr_reln, ForkNumber *forkNum,
-                         int nforks, BlockNumber *firstDelBlock)
+DropRelationBuffers(SMgrRelation smgr_reln, ForkNumber *forkNum,
+                   int nforks, BlockNumber *firstDelBlock)
 {
    int         i;
    int         j;
@@ -3064,8 +3064,8 @@ DropRelFileLocatorBuffers(SMgrRelation smgr_reln, ForkNumber *forkNum,
        if (rlocator.backend == MyBackendId)
        {
            for (j = 0; j < nforks; j++)
-               DropRelFileLocatorLocalBuffers(rlocator.locator, forkNum[j],
-                                              firstDelBlock[j]);
+               DropRelationLocalBuffers(rlocator.locator, forkNum[j],
+                                        firstDelBlock[j]);
        }
        return;
    }
@@ -3115,8 +3115,8 @@ DropRelFileLocatorBuffers(SMgrRelation smgr_reln, ForkNumber *forkNum,
        nBlocksToInvalidate < BUF_DROP_FULL_SCAN_THRESHOLD)
    {
        for (j = 0; j < nforks; j++)
-           FindAndDropRelFileLocatorBuffers(rlocator.locator, forkNum[j],
-                                            nForkBlock[j], firstDelBlock[j]);
+           FindAndDropRelationBuffers(rlocator.locator, forkNum[j],
+                                      nForkBlock[j], firstDelBlock[j]);
        return;
    }
 
@@ -3162,16 +3162,15 @@ DropRelFileLocatorBuffers(SMgrRelation smgr_reln, ForkNumber *forkNum,
 }
 
 /* ---------------------------------------------------------------------
- *     DropRelFileLocatorsAllBuffers
+ *     DropRelationsAllBuffers
  *
  *     This function removes from the buffer pool all the pages of all
  *     forks of the specified relations.  It's equivalent to calling
- *     DropRelFileLocatorBuffers once per fork per relation with
- *     firstDelBlock = 0.
- * --------------------------------------------------------------------
+ *     DropRelationBuffers once per fork per relation with firstDelBlock = 0.
+ *     --------------------------------------------------------------------
  */
 void
-DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
+DropRelationsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
 {
    int         i;
    int         j;
@@ -3194,7 +3193,7 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
        if (RelFileLocatorBackendIsTemp(smgr_reln[i]->smgr_rlocator))
        {
            if (smgr_reln[i]->smgr_rlocator.backend == MyBackendId)
-               DropRelFileLocatorAllLocalBuffers(smgr_reln[i]->smgr_rlocator.locator);
+               DropRelationAllLocalBuffers(smgr_reln[i]->smgr_rlocator.locator);
        }
        else
            rels[n++] = smgr_reln[i];
@@ -3219,7 +3218,7 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
 
    /*
     * We can avoid scanning the entire buffer pool if we know the exact size
-    * of each of the given relation forks. See DropRelFileLocatorBuffers.
+    * of each of the given relation forks. See DropRelationBuffers.
     */
    for (i = 0; i < n && cached; i++)
    {
@@ -3257,8 +3256,8 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
                    continue;
 
                /* drop all the buffers for a particular relation fork */
-               FindAndDropRelFileLocatorBuffers(rels[i]->smgr_rlocator.locator,
-                                                j, block[i][j], 0);
+               FindAndDropRelationBuffers(rels[i]->smgr_rlocator.locator,
+                                          j, block[i][j], 0);
            }
        }
 
@@ -3291,7 +3290,7 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
        uint32      buf_state;
 
        /*
-        * As in DropRelFileLocatorBuffers, an unlocked precheck should be
+        * As in DropRelationBuffers, an unlocked precheck should be
         * safe and saves some cycles.
         */
 
@@ -3331,7 +3330,7 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
 }
 
 /* ---------------------------------------------------------------------
- *     FindAndDropRelFileLocatorBuffers
+ *     FindAndDropRelationBuffers
  *
  *     This function performs look up in BufMapping table and removes from the
  *     buffer pool all the pages of the specified relation fork that has block
@@ -3340,9 +3339,9 @@ DropRelFileLocatorsAllBuffers(SMgrRelation *smgr_reln, int nlocators)
  * --------------------------------------------------------------------
  */
 static void
-FindAndDropRelFileLocatorBuffers(RelFileLocator rlocator, ForkNumber forkNum,
-                                BlockNumber nForkBlock,
-                                BlockNumber firstDelBlock)
+FindAndDropRelationBuffers(RelFileLocator rlocator, ForkNumber forkNum,
+                          BlockNumber nForkBlock,
+                          BlockNumber firstDelBlock)
 {
    BlockNumber curBlock;
 
@@ -3397,7 +3396,7 @@ FindAndDropRelFileLocatorBuffers(RelFileLocator rlocator, ForkNumber forkNum,
  *     bothering to write them out first.  This is used when we destroy a
  *     database, to avoid trying to flush data to disk when the directory
  *     tree no longer exists.  Implementation is pretty similar to
- *     DropRelFileLocatorBuffers() which is for destroying just one relation.
+ *     DropRelationBuffers() which is for destroying just one relation.
  * --------------------------------------------------------------------
  */
 void
@@ -3416,7 +3415,7 @@ DropDatabaseBuffers(Oid dbid)
        uint32      buf_state;
 
        /*
-        * As in DropRelFileLocatorBuffers, an unlocked precheck should be
+        * As in DropRelationBuffers, an unlocked precheck should be
         * safe and saves some cycles.
         */
        if (bufHdr->tag.rlocator.dbOid != dbid)
@@ -3561,7 +3560,7 @@ FlushRelationBuffers(Relation rel)
        bufHdr = GetBufferDescriptor(i);
 
        /*
-        * As in DropRelFileLocatorBuffers, an unlocked precheck should be
+        * As in DropRelationBuffers, an unlocked precheck should be
         * safe and saves some cycles.
         */
        if (!RelFileLocatorEquals(bufHdr->tag.rlocator, rel->rd_locator))
@@ -3616,7 +3615,7 @@ FlushRelationsAllBuffers(SMgrRelation *smgrs, int nrels)
 
    /*
     * Save the bsearch overhead for low number of relations to sync. See
-    * DropRelFileLocatorsAllBuffers for details.
+    * DropRelationsAllBuffers for details.
     */
    use_bsearch = nrels > RELS_BSEARCH_THRESHOLD;
 
@@ -3634,7 +3633,7 @@ FlushRelationsAllBuffers(SMgrRelation *smgrs, int nrels)
        uint32      buf_state;
 
        /*
-        * As in DropRelFileLocatorBuffers, an unlocked precheck should be
+        * As in DropRelationBuffers, an unlocked precheck should be
         * safe and saves some cycles.
         */
 
@@ -3864,7 +3863,7 @@ FlushDatabaseBuffers(Oid dbid)
        bufHdr = GetBufferDescriptor(i);
 
        /*
-        * As in DropRelFileLocatorBuffers, an unlocked precheck should be
+        * As in DropRelationBuffers, an unlocked precheck should be
         * safe and saves some cycles.
         */
        if (bufHdr->tag.rlocator.dbOid != dbid)
index 41a08076b3179ac4ac4c8adf4230d8bd2b3d7158..9c038851d756167e94b832a4e5258dd159126e7f 100644 (file)
@@ -312,7 +312,7 @@ MarkLocalBufferDirty(Buffer buffer)
 }
 
 /*
- * DropRelFileLocatorLocalBuffers
+ * DropRelationLocalBuffers
  *     This function removes from the buffer pool all the pages of the
  *     specified relation that have block numbers >= firstDelBlock.
  *     (In particular, with firstDelBlock = 0, all pages are removed.)
@@ -320,11 +320,11 @@ MarkLocalBufferDirty(Buffer buffer)
  *     out first.  Therefore, this is NOT rollback-able, and so should be
  *     used only with extreme caution!
  *
- *     See DropRelFileLocatorBuffers in bufmgr.c for more notes.
+ *     See DropRelationBuffers in bufmgr.c for more notes.
  */
 void
-DropRelFileLocatorLocalBuffers(RelFileLocator rlocator, ForkNumber forkNum,
-                              BlockNumber firstDelBlock)
+DropRelationLocalBuffers(RelFileLocator rlocator, ForkNumber forkNum,
+                        BlockNumber firstDelBlock)
 {
    int         i;
 
@@ -363,14 +363,14 @@ DropRelFileLocatorLocalBuffers(RelFileLocator rlocator, ForkNumber forkNum,
 }
 
 /*
- * DropRelFileLocatorAllLocalBuffers
+ * DropRelationAllLocalBuffers
  *     This function removes from the buffer pool all pages of all forks
  *     of the specified relation.
  *
- *     See DropRelFileLocatorsAllBuffers in bufmgr.c for more notes.
+ *     See DropRelationsAllBuffers in bufmgr.c for more notes.
  */
 void
-DropRelFileLocatorAllLocalBuffers(RelFileLocator rlocator)
+DropRelationAllLocalBuffers(RelFileLocator rlocator)
 {
    int         i;
 
@@ -589,7 +589,7 @@ AtProcExit_LocalBuffers(void)
 {
    /*
     * We shouldn't be holding any remaining pins; if we are, and assertions
-    * aren't enabled, we'll fail later in DropRelFileLocatorBuffers while
+    * aren't enabled, we'll fail later in DropRelationBuffers while
     * trying to drop the temp rels.
     */
    CheckForLocalBufferLeaks();
index b21d8c38221c8fe14370e8d28106ff5b61551725..c1a5febcbfd5893a0f9834676db05ac5c21303c4 100644 (file)
@@ -430,7 +430,7 @@ smgrdounlinkall(SMgrRelation *rels, int nrels, bool isRedo)
     * Get rid of any remaining buffers for the relations.  bufmgr will just
     * drop them without bothering to write the contents.
     */
-   DropRelFileLocatorsAllBuffers(rels, nrels);
+   DropRelationsAllBuffers(rels, nrels);
 
    /*
     * create an array which contains all relations to be dropped, and close
@@ -631,7 +631,7 @@ smgrtruncate(SMgrRelation reln, ForkNumber *forknum, int nforks, BlockNumber *nb
     * Get rid of any buffers for the about-to-be-deleted blocks. bufmgr will
     * just drop them without bothering to write the contents.
     */
-   DropRelFileLocatorBuffers(reln, forknum, nforks, nblocks);
+   DropRelationBuffers(reln, forknum, nforks, nblocks);
 
    /*
     * Send a shared-inval message to force other backends to close any smgr
index aded5e8f7e4e2c43dd2f250b1380be451adb8747..69e45900baed491841be61779b6b507ecd8256e2 100644 (file)
@@ -337,9 +337,10 @@ extern PrefetchBufferResult PrefetchLocalBuffer(SMgrRelation smgr,
 extern BufferDesc *LocalBufferAlloc(SMgrRelation smgr, ForkNumber forkNum,
                                    BlockNumber blockNum, bool *foundPtr);
 extern void MarkLocalBufferDirty(Buffer buffer);
-extern void DropRelFileLocatorLocalBuffers(RelFileLocator rlocator, ForkNumber forkNum,
-                                          BlockNumber firstDelBlock);
-extern void DropRelFileLocatorAllLocalBuffers(RelFileLocator rlocator);
+extern void DropRelationLocalBuffers(RelFileLocator rlocator,
+                                    ForkNumber forkNum,
+                                    BlockNumber firstDelBlock);
+extern void DropRelationAllLocalBuffers(RelFileLocator rlocator);
 extern void AtEOXact_LocalBuffers(bool isCommit);
 
 #endif                         /* BUFMGR_INTERNALS_H */
index 7bcfaac27275196635c0e095b8decf7cfcc1de9a..d7ced19c142b27c01b89dea3b2ef231a01bf0a43 100644 (file)
@@ -208,11 +208,11 @@ extern void CreateAndCopyRelationData(RelFileLocator src_rlocator,
                                      RelFileLocator dst_rlocator,
                                      bool permanent);
 extern void FlushDatabaseBuffers(Oid dbid);
-extern void DropRelFileLocatorBuffers(struct SMgrRelationData *smgr_reln,
-                                     ForkNumber *forkNum,
-                                     int nforks, BlockNumber *firstDelBlock);
-extern void DropRelFileLocatorsAllBuffers(struct SMgrRelationData **smgr_reln,
-                                         int nlocators);
+extern void DropRelationBuffers(struct SMgrRelationData *smgr_reln,
+                               ForkNumber *forkNum,
+                               int nforks, BlockNumber *firstDelBlock);
+extern void DropRelationsAllBuffers(struct SMgrRelationData **smgr_reln,
+                                   int nlocators);
 extern void DropDatabaseBuffers(Oid dbid);
 
 #define RelationGetNumberOfBlocks(reln) \