MySQL源代码:为MySQL增加响应时间status值


实现的思路很简单，借助了percona server5.5的information_schema表：query_response_time

过程

1.增加变量，记录上次查询rt时，统计的query数，以及总时间(last_count, last_total)


2.采集sql执行时间时(collect函数)，累加当前query数，执行总时间(cur_count, cur_total)

3.计算一段时间内rt： (cur_total - last_total)/(cur_count - last_count)

4.设置last_total = cur_total， last_count =cur_count;

5.循环到2)


增加一个新status值，命名有点挫...

root@(none) 02:17:21>show status like 'rt_from_last_query%';
+--------------------+-------+
| Variable_name      | Value |
+--------------------+-------+
| rt_from_last_query | 192   |
+--------------------+-------+
1 row in set (0.00 sec)


注意这个patch理论上会有额外的开销，因为多计算了两个值(cur_count，cur_total)。


以下是patch，基于percona 5.5.18

[cpp] view plaincopyprint?

  1. Index: sql/mysqld.cc  
  2. ===================================================================  
  3. --- sql/mysqld.cc   (revision 1006)  
  4. +++ sql/mysqld.cc   (working copy)  
  5. @@ -6307,6 +6307,17 @@  
  6.    return 0;  
  7.  }  
  8.    
  9. +#ifdef HAVE_RESPONSE_TIME_DISTRIBUTION  
  10. +static int show_rt(THD *thd, SHOW_VAR *var, char *buff)  
  11. +{  
  12. +   var->type = SHOW_LONGLONG;  
  13. +   ulonglong rt = query_response_time_rt();  
  14. +   var->value = buff;  
  15. +   *((long long *)buff)= (long long)rt;  
  16. +   return 0;  
  17. +}  
  18. +#endif  
  19. +  
  20.  #ifdef ENABLED_PROFILING   
  21.  static int show_flushstatustime(THD *thd, SHOW_VAR *var, char *buff)  
  22.  {  
  23. @@ -6811,6 +6822,9 @@  
  24.  #ifdef ENABLED_PROFILING   
  25.    {"Uptime_since_flush_status",(char*) &show_flushstatustime,   SHOW_FUNC},  
  26.  #endif   
  27. +#ifdef HAVE_RESPONSE_TIME_DISTRIBUTION  
  28. +  {"rt_from_last_query",       (char*) &show_rt, SHOW_FUNC},  
  29. +#endif  
  30.    {NullS, NullS, SHOW_LONG}  
  31.  };  
  32.    
  33. Index: sql/query_response_time.h  
  34. ===================================================================  
  35. --- sql/query_response_time.h   (revision 1006)  
  36. +++ sql/query_response_time.h   (working copy)  
  37. @@ -59,6 +59,7 @@  
  38.  extern void query_response_time_flush  ();  
  39.  extern void query_response_time_collect(ulonglong query_time);  
  40.  extern int  query_response_time_fill   (THD* thd, TABLE_LIST *tables, COND *cond);  
  41. +extern ulonglong query_response_time_rt();  
  42.  #endif // HAVE_RESPONSE_TIME_DISTRIBUTION   
  43.    
  44.  #endif // QUERY_RESPONSE_TIME_H   
  45. Index: sql/query_response_time.cc  
  46. ===================================================================  
  47. --- sql/query_response_time.cc  (revision 1006)  
  48. +++ sql/query_response_time.cc  (working copy)  
  49. @@ -170,16 +170,44 @@  
  50.      my_atomic_rwlock_rdunlock(&time_collector_lock);  
  51.      return result;  
  52.    }  
  53. +  uint64 rt()  
  54. +  {  
  55. +      my_atomic_rwlock_rdlock(&time_collector_lock);  
  56. +      uint32 diff_count =  my_atomic_load32((int32*)(&cur_count)) -   
  57. +          my_atomic_load32((int32*)(&last_count));  
  58. +      uint64 diff_total =  my_atomic_load64((int64*)(&cur_total)) -   
  59. +          my_atomic_load64((int64*)(&last_total));  
  60. +  
  61. +      my_atomic_store64((int64*)(&last_total), my_atomic_load64((int64*)(&cur_total)));  
  62. +      my_atomic_store32((int32*)(&last_count), my_atomic_load32((int32*)(&cur_count)));  
  63. +      my_atomic_rwlock_rdunlock(&time_collector_lock);  
  64. +  
  65. +      uint64 rt = 0;  
  66. +      if (diff_count != 0)  
  67. +          rt = diff_total/((uint64)diff_count);  
  68. +  
  69. +      return rt;   
  70. +  }  
  71. +    
  72.  public:  
  73.    void flush()  
  74.    {  
  75.      my_atomic_rwlock_wrlock(&time_collector_lock);  
  76.      memset((void*)&m_count,0,sizeof(m_count));  
  77.      memset((void*)&m_total,0,sizeof(m_total));  
  78. -    my_atomic_rwlock_wrunlock(&time_collector_lock);  
  79. +    memset((void*)&cur_count,0,sizeof(cur_count));  
  80. +    memset((void*)&cur_total,0,sizeof(cur_total));  
  81. +    memset((void*)&last_count,0,sizeof(last_count));  
  82. +    memset((void*)&last_total,0,sizeof(last_total));  
  83. +  my_atomic_rwlock_wrunlock(&time_collector_lock);  
  84.    }  
  85.    void collect(uint64 time)  
  86.    {  
  87. +    my_atomic_rwlock_wrlock(&time_collector_lock);  
  88. +    my_atomic_add32((int32*)(&cur_count), 1);  
  89. +    my_atomic_add64((int64*)(&cur_total), time);  
  90. +    my_atomic_rwlock_wrunlock(&time_collector_lock);  
  91. +    
  92.      int i= 0;  
  93.      for(int count= m_utility->bound_count(); count > i; ++i)  
  94.      {  
  95. @@ -201,6 +229,10 @@  
  96.    my_atomic_rwlock_t time_collector_lock;  
  97.    uint32   m_count[OVERALL_POWER_COUNT + 1];  
  98.    uint64   m_total[OVERALL_POWER_COUNT + 1];  
  99. +  uint32   last_count;  
  100. +  uint64   last_total;  
  101. +  uint32   cur_count;  
  102. +  uint64   cur_total;  
  103.  };  
  104.    
  105.  class collector  
  106. @@ -268,6 +300,10 @@  
  107.    {  
  108.      return m_time.total(index);  
  109.    }  
  110. +  ulonglong rt()  
  111. +  {  
  112. +    return m_time.rt();  
  113. +  }  
  114.  private:  
  115.    utility          m_utility;  
  116.    time_collector   m_time;  
  117. @@ -299,4 +335,10 @@  
  118.  {  
  119.    return query_response_time::g_collector.fill(thd,tables,cond);  
  120.  }  
  121. +  
  122. +ulonglong query_response_time_rt()  
  123. +{  
  124. +      return query_response_time::g_collector.rt();  
  125. +}  
  126. +  
  127.  #endif // HAVE_RESPONSE_TIME_DISTRIBUTION  

相关内容