Rename some functions to mention Relation instead of RelFileLocator.
authorRobert Haas <rhaas@postgresql.org>
Tue, 12 Jul 2022 14:26:48 +0000 (10:26 -0400)
committerRobert Haas <rhaas@postgresql.org>
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.horikyota.ntt@gmail.com

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) \