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;
 
 
 /*