Merge lp:~akopytov/percona-server/bug719386-5.5 into lp:percona-server/5.5

[Alexey Kopytov]

[Alexey Kopytov (akopytov)]

http://jenkins.percona.com/view/PS%205.5/job/percona-server-5.5-param/546/

[Sergei Glushchenko (sergei.glushchenko)]

Approve g2

review: Approve (g2)

[Stewart Smith (stewart)]

review: Approve

[Laurynas Biveinis (laurynas-biveinis)]

I think THD::get_time() method should be const, likewise the arg of THD::set_time().

review: Needs Fixing

[Alexey Kopytov (akopytov)]

I don't think it makes any practical difference.

review: Approve

=== modified file 'Percona-Server/sql/sp_head.cc'
--- Percona-Server/sql/sp_head.cc	2012-06-01 12:15:25 +0000
+++ Percona-Server/sql/sp_head.cc	2012-10-15 15:45:27 +0000
@@ -3099,6 +3099,8 @@
 sp_instr_stmt::execute(THD *thd, uint *nextp)
 {
   int res;
+  QUERY_START_TIME_INFO time_info;
+
   DBUG_ENTER("sp_instr_stmt::execute");
   DBUG_PRINT("info", ("command: %d", m_lex_keeper.sql_command()));
 
@@ -3107,6 +3109,19 @@
   /* This s-p instr is profilable and will be captured. */
   thd->profiling.set_query_source(m_query.str, m_query.length);
 #endif
+
+  memset(&time_info, 0, sizeof(time_info));
+
+  if (thd->enable_slow_log)
+  {
+    /*
+      Save start time info for the CALL statement and overwrite it with the
+      current time for log_slow_statement() to log the individual query timing.
+    */
+    thd->get_time(&time_info);
+    thd->set_time();
+  }
+
   if (!(res= alloc_query(thd, m_query.str, m_query.length)) &&
       !(res=subst_spvars(thd, this, &m_query)))
   {
@@ -3143,6 +3158,11 @@
     if (!thd->is_error())
       thd->stmt_da->reset_diagnostics_area();
   }
+
+  /* Restore the original query start time */
+  if (thd->enable_slow_log)
+    thd->set_time(&time_info);
+
   DBUG_RETURN(res || thd->is_error());
 }
 

=== modified file 'Percona-Server/sql/sql_class.h'
--- Percona-Server/sql/sql_class.h	2012-09-17 13:08:32 +0000
+++ Percona-Server/sql/sql_class.h	2012-10-15 15:45:27 +0000
@@ -1497,6 +1497,12 @@
 
 extern "C" void my_message_sql(uint error, const char *str, myf MyFlags);
 
+typedef struct
+{
+  time_t start_time;
+  ulonglong start_utime;
+} QUERY_START_TIME_INFO;
+
 /**
   @class THD
   For each client connection we create a separate thread with THD serving as
@@ -2493,6 +2499,16 @@
     start_time= user_time= t;
     start_utime= utime_after_lock= my_micro_time();
   }
+  void get_time(QUERY_START_TIME_INFO *time_info)
+  {
+    time_info->start_time= start_time;
+    time_info->start_utime= start_utime;
+  }
+  void set_time(QUERY_START_TIME_INFO *time_info)
+  {
+    start_time= time_info->start_time;
+    start_utime= time_info->start_utime;
+  }
   /*TODO: this will be obsolete when we have support for 64 bit my_time_t */
   inline bool	is_valid_time() 
   {