[t:3654] #3654 Added some OrthoPush and basement node info to engine status.

git-svn-id: file:///svn/toku/tokudb@33041 c7de825b-a66e-492c-adef-691d508d4ae1

buildheader/make_db_h.c

@@ -536,6 +536,14 @@ int main (int argc __attribute__((__unused__)), char *const argv[] __attribute__
     printf("  u_int64_t        le_updates;              /* leafentry update operations                        */ \n");
     printf("  u_int64_t        le_updates_broadcast;    /* leafentry update broadcast operations              */ \n");
     printf("  u_int64_t        descriptor_set;          /* descriptor set operations              */ \n");
+
+
+    printf("  u_int64_t        partial_fetch_hit;        /* node partition is present         */ \n");
+    printf("  u_int64_t partial_fetch_miss;       /* node is present but partition is absent   */ \n");            
+    printf("  u_int64_t partial_fetch_compressed; /* node partition is present but compressed   */ \n");
+    printf("  u_int64_t msn_discards;             /* how many messages were ignored by leaf because of msn */ \n");
+    printf("  u_int64_t max_workdone;             /* max workdone value of any buffer                */ \n");      
+    printf("  u_int64_t dsn_gap;                  /* dsn has detected a gap in continuity of root-to-leaf path (internal node was evicted and re-read) */ \n");
     printf("  u_int64_t        point_queries;           /* ydb point queries                      */ \n");
     printf("  u_int64_t        sequential_queries;      /* ydb sequential queries                 */ \n");
     printf("  u_int64_t        le_max_committed_xr;     /* max committed transaction records in any packed le  */ \n");

include/db.h

@@ -144,6 +144,12 @@ typedef struct __toku_engine_status {
   u_int64_t        le_updates;              /* leafentry update operations                        */ 
   u_int64_t        le_updates_broadcast;    /* leafentry update broadcast operations              */ 
   u_int64_t        descriptor_set;          /* descriptor set operations              */ 
+  u_int64_t        partial_fetch_hit;        /* node partition is present             */ 
+  u_int64_t        partial_fetch_miss;       /* node is present but partition is absent */ 
+  u_int64_t        partial_fetch_compressed; /* node partition is present but compressed  */ 
+  u_int64_t        msn_discards;             /* how many messages were ignored by leaf because of msn */ 
+  u_int64_t        max_workdone;             /* max workdone value of any buffer  */ 
+  u_int64_t        dsn_gap;                  /* dsn has detected a gap in continuity of root-to-leaf path (internal node was evicted and re-read) */ 
   u_int64_t        point_queries;           /* ydb point queries                      */ 
   u_int64_t        sequential_queries;      /* ydb sequential queries                 */ 
   u_int64_t        le_max_committed_xr;     /* max committed transaction records in any packed le  */ 

src/ydb.c

@@ -1930,6 +1930,12 @@ env_get_engine_status(DB_ENV * env, ENGINE_STATUS * engstat, char * env_panic_st
 	    engstat->le_updates = brt_stat.updates;
 	    engstat->le_updates_broadcast = brt_stat.updates_broadcast;
 	    engstat->descriptor_set = brt_stat.descriptor_set;
+	    engstat->partial_fetch_hit = brt_stat.partial_fetch_hit;
+	    engstat->partial_fetch_miss = brt_stat.partial_fetch_miss;
+	    engstat->partial_fetch_compressed = brt_stat.partial_fetch_compressed;
+	    engstat->msn_discards = brt_stat.msn_discards;
+	    engstat->max_workdone = brt_stat.max_workdone;
+	    engstat->dsn_gap = brt_stat.dsn_gap;	    
 	}
 	{
 	    u_int64_t fsync_count, fsync_time;
@@ -2117,6 +2123,12 @@ env_get_engine_status_text(DB_ENV * env, char * buff, int bufsiz) {
 	n += snprintf(buff + n, bufsiz - n, "le_updates                       %"PRIu64"\n", engstat.le_updates);
 	n += snprintf(buff + n, bufsiz - n, "le_updates_broadcast             %"PRIu64"\n", engstat.le_updates_broadcast);
 	n += snprintf(buff + n, bufsiz - n, "descriptor_set                   %"PRIu64"\n", engstat.descriptor_set);
+	n += snprintf(buff + n, bufsiz - n, "partial_fetch_hit                %"PRIu64"\n", engstat.partial_fetch_hit);
+	n += snprintf(buff + n, bufsiz - n, "partial_fetch_miss               %"PRIu64"\n", engstat.partial_fetch_miss);
+	n += snprintf(buff + n, bufsiz - n, "partial_fetch_compressed         %"PRIu64"\n", engstat.partial_fetch_compressed);
+	n += snprintf(buff + n, bufsiz - n, "msn_discards                     %"PRIu64"\n", engstat.msn_discards);
+	n += snprintf(buff + n, bufsiz - n, "max_workdone                     %"PRIu64"\n", engstat.max_workdone);
+	n += snprintf(buff + n, bufsiz - n, "dsn_gap                          %"PRIu64"\n", engstat.dsn_gap);
 	n += snprintf(buff + n, bufsiz - n, "multi_inserts                    %"PRIu64"\n", engstat.multi_inserts);
 	n += snprintf(buff + n, bufsiz - n, "multi_inserts_fail               %"PRIu64"\n", engstat.multi_inserts_fail);
 	n += snprintf(buff + n, bufsiz - n, "multi_deletes                    %"PRIu64"\n", engstat.multi_deletes);