Allow ShowBufferUsage() to report the number of reads/writes that have

occurred to temporary files.  This replaces the unused
NDirectFileRead/NDirectFileWrite counters.

Itagaki Takahiro

diff --git a/src/backend/storage/buffer/buf_init.c b/src/backend/storage/buffer/buf_init.c
index 7e92af04a16d6d902cad8231adf9bade25c8a691..93c47af5963a163b3e3e944c3ba1151ff6c2dee9 100644 (file)
--- a/src/backend/storage/buffer/buf_init.c
+++ b/src/backend/storage/buffer/buf_init.c
@@ -8,7 +8,7 @@
  *
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/storage/buffer/buf_init.c,v 1.80 2008/01/01 19:45:51 momjian Exp $
+ *   $PostgreSQL: pgsql/src/backend/storage/buffer/buf_init.c,v 1.81 2008/09/17 13:15:55 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -29,6 +29,8 @@ long int  BufferHitCount;
 long int   LocalBufferHitCount;
 long int   BufferFlushCount;
 long int   LocalBufferFlushCount;
+long int   BufFileReadCount;
+long int   BufFileWriteCount;
 
 
 /*

diff --git a/src/backend/storage/buffer/bufmgr.c b/src/backend/storage/buffer/bufmgr.c
index 281d23136dd793cf7466d22c41a1606b5ddc33ec..46b4e0afa4e914e5ca4e58d388b04516b768be1f 100644 (file)
--- a/src/backend/storage/buffer/bufmgr.c
+++ b/src/backend/storage/buffer/bufmgr.c
@@ -8,7 +8,7 @@
  *
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/storage/buffer/bufmgr.c,v 1.237 2008/08/11 11:05:11 heikki Exp $
+ *   $PostgreSQL: pgsql/src/backend/storage/buffer/bufmgr.c,v 1.238 2008/09/17 13:15:55 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -64,12 +64,6 @@ bool     zero_damaged_pages = false;
 int            bgwriter_lru_maxpages = 100;
 double     bgwriter_lru_multiplier = 2.0;
 
-
-long       NDirectFileRead;    /* some I/O's are direct file access. bypass
-                                * bufmgr */
-long       NDirectFileWrite;   /* e.g., I/O in psort and hashjoin. */
-
-
 /* local state for StartBufferIO and related functions */
 static volatile BufferDesc *InProgressBuf = NULL;
 static bool IsForInput;
@@ -1572,7 +1566,7 @@ ShowBufferUsage(void)
                     ReadLocalBufferCount - LocalBufferHitCount, LocalBufferFlushCount, localhitrate);
    appendStringInfo(&str,
                     "!\tDirect blocks: %10ld read, %10ld written\n",
-                    NDirectFileRead, NDirectFileWrite);
+                    BufFileReadCount, BufFileWriteCount);
 
    return str.data;
 }
@@ -1586,8 +1580,8 @@ ResetBufferUsage(void)
    LocalBufferHitCount = 0;
    ReadLocalBufferCount = 0;
    LocalBufferFlushCount = 0;
-   NDirectFileRead = 0;
-   NDirectFileWrite = 0;
+   BufFileReadCount = 0;
+   BufFileWriteCount = 0;
 }
 
 /*

diff --git a/src/backend/storage/file/buffile.c b/src/backend/storage/file/buffile.c
index 3bcb04b558ad1b5a10be38c5381f328cd81f03a0..d41d21c327c0ce517f20fe73704d15cea42f4eb5 100644 (file)
--- a/src/backend/storage/file/buffile.c
+++ b/src/backend/storage/file/buffile.c
@@ -7,7 +7,7 @@
  * Portions Copyright (c) 1994, Regents of the University of California
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/storage/file/buffile.c,v 1.31 2008/05/02 01:08:27 tgl Exp $
+ *   $PostgreSQL: pgsql/src/backend/storage/file/buffile.c,v 1.32 2008/09/17 13:15:55 tgl Exp $
  *
  * NOTES:
  *
@@ -36,6 +36,7 @@
 
 #include "storage/fd.h"
 #include "storage/buffile.h"
+#include "storage/buf_internals.h"
 
 /*
  * We break BufFiles into gigabyte-sized segments, regardless of RELSEG_SIZE.
@@ -238,6 +239,8 @@ BufFileLoadBuffer(BufFile *file)
        file->nbytes = 0;
    file->offsets[file->curFile] += file->nbytes;
    /* we choose not to advance curOffset here */
+
+   BufFileReadCount++;
 }
 
 /*
@@ -300,6 +303,8 @@ BufFileDumpBuffer(BufFile *file)
        file->offsets[file->curFile] += bytestowrite;
        file->curOffset += bytestowrite;
        wpos += bytestowrite;
+
+       BufFileWriteCount++;
    }
    file->dirty = false;
 

diff --git a/src/include/executor/execdebug.h b/src/include/executor/execdebug.h
index 1599aef079b222a0d9767fda065f60397afdb734..374030d21f1b2c36833b609a4466200b77e160c4 100644 (file)
--- a/src/include/executor/execdebug.h
+++ b/src/include/executor/execdebug.h
@@ -10,7 +10,7 @@
  * Portions Copyright (c) 1996-2008, PostgreSQL Global Development Group
  * Portions Copyright (c) 1994, Regents of the University of California
  *
- * $PostgreSQL: pgsql/src/include/executor/execdebug.h,v 1.32 2008/01/01 19:45:57 momjian Exp $
+ * $PostgreSQL: pgsql/src/include/executor/execdebug.h,v 1.33 2008/09/17 13:15:55 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -190,19 +190,4 @@ extern int NIndexTupleInserted;
 #define MJ_DEBUG_PROC_NODE(slot)
 #endif   /* EXEC_MERGEJOINDEBUG */
 
-/* ----------------------------------------------------------------
- *     DO NOT DEFINE THESE EVER OR YOU WILL BURN!
- * ----------------------------------------------------------------
- */
-/* ----------------
- *     NOTYET is placed around any code not yet implemented
- *     in the executor.  Only remove these when actually implementing
- *     said code.
- * ----------------
- */
-#undef NOTYET
-
-extern long NDirectFileRead;
-extern long NDirectFileWrite;
-
 #endif   /* ExecDebugIncluded */

diff --git a/src/include/storage/buf_internals.h b/src/include/storage/buf_internals.h
index a8861d29a8ef7d7b629821035bc038bc69fc18d6..6ebbbcb0dac59ce21d0943825aeda597560c7321 100644 (file)
--- a/src/include/storage/buf_internals.h
+++ b/src/include/storage/buf_internals.h
@@ -8,7 +8,7 @@
  * Portions Copyright (c) 1996-2008, PostgreSQL Global Development Group
  * Portions Copyright (c) 1994, Regents of the University of California
  *
- * $PostgreSQL: pgsql/src/include/storage/buf_internals.h,v 1.98 2008/08/11 11:05:11 heikki Exp $
+ * $PostgreSQL: pgsql/src/include/storage/buf_internals.h,v 1.99 2008/09/17 13:15:55 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -180,6 +180,8 @@ extern long int BufferHitCount;
 extern long int LocalBufferHitCount;
 extern long int BufferFlushCount;
 extern long int LocalBufferFlushCount;
+extern long int BufFileReadCount;
+extern long int BufFileWriteCount;
 
 
 /*