From 8fbf0e8817d7dc0f21e0ea33ed391e2260d7f463 Mon Sep 17 00:00:00 2001
From: Mikael Ronstrom <mikael@dator8>
Date: Thu, 28 Oct 2010 16:31:21 +0200
Subject: Added THD wait state for MASTER POS WAIT

---
 sql/rpl_rli.cc | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'sql/rpl_rli.cc')

diff --git a/sql/rpl_rli.cc b/sql/rpl_rli.cc
index af9b452acd8..d02aadee701 100644
--- a/sql/rpl_rli.cc
+++ b/sql/rpl_rli.cc
@@ -26,6 +26,8 @@
 #include "rpl_utility.h"
 #include "transaction.h"
 #include "sql_parse.h"                          // end_trans, ROLLBACK
+#include <mysql/plugin.h>
+#include <mysql/service_thd_wait.h>
 
 static int count_relay_log_space(Relay_log_info* rli);
 
@@ -792,6 +794,7 @@ int Relay_log_info::wait_for_pos(THD* thd, String* log_name,
       We are going to mysql_cond_(timed)wait(); if the SQL thread stops it
       will wake us up.
     */
+    thd_wait_begin(thd, THD_WAIT_BINLOG);
     if (timeout > 0)
     {
       /*
@@ -809,6 +812,7 @@ int Relay_log_info::wait_for_pos(THD* thd, String* log_name,
     }
     else
       mysql_cond_wait(&data_cond, &data_lock);
+    thd_wait_end(thd);
     DBUG_PRINT("info",("Got signal of master update or timed out"));
     if (error == ETIMEDOUT || error == ETIME)
     {
-- 
cgit v1.2.1