=== modified file 'mysql-test/suite/sys_vars/r/slave_domain_parallel_threads_basic.result'
--- mysql-test/suite/sys_vars/r/slave_domain_parallel_threads_basic.result	2014-02-26 14:02:09 +0000
+++ mysql-test/suite/sys_vars/r/slave_domain_parallel_threads_basic.result	2014-11-25 13:22:18 +0000
@@ -11,3 +11,7 @@
 @@GLOBAL.slave_domain_parallel_threads
 10
 SET GLOBAL slave_domain_parallel_threads = @save_slave_domain_parallel_threads;
+SHOW GLOBAL STATUS LIKE 'slave_parallel_eventqueue_%';
+Variable_name	Value
+Slave_parallel_eventqueue_eventqueue_size	0
+Slave_parallel_eventqueue_freepending	0

=== modified file 'mysql-test/suite/sys_vars/t/slave_domain_parallel_threads_basic.test'
--- mysql-test/suite/sys_vars/t/slave_domain_parallel_threads_basic.test	2014-02-26 14:02:09 +0000
+++ mysql-test/suite/sys_vars/t/slave_domain_parallel_threads_basic.test	2014-11-25 13:11:07 +0000
@@ -12,3 +12,5 @@
 SELECT @@GLOBAL.slave_domain_parallel_threads;
 
 SET GLOBAL slave_domain_parallel_threads = @save_slave_domain_parallel_threads;
+
+SHOW GLOBAL STATUS LIKE 'slave_parallel_eventqueue_%';

=== modified file 'sql/mysqld.cc'
--- sql/mysqld.cc	2014-11-18 21:25:47 +0000
+++ sql/mysqld.cc	2014-11-25 13:20:24 +0000
@@ -7316,6 +7316,37 @@
   return 0;
 }
 
+static int show_slave_parallel_eventqueue(THD *thd, SHOW_VAR *var, char *buff)
+{
+  unsigned i;
+  struct st_data {
+    long long size;
+    long long pending;
+    SHOW_VAR vars[2];
+  } *data;
+
+  data=(st_data *)buff;
+  var->type= SHOW_ARRAY;
+  var->value= (char*)data->vars;
+
+  data->vars[0].type= data->vars[1].type= SHOW_LONGLONG;
+  data->vars[0].name= "size";
+  data->vars[1].name= "freepending";
+  data->vars[0].value= (char*)&data->size;
+  data->vars[1].value= (char*)&data->pending;
+  data->pending= 0;
+  data->size= 0;
+
+  mysql_mutex_lock(&global_rpl_thread_pool.LOCK_rpl_thread_pool);
+  for (i= 0; i < global_rpl_thread_pool.count; ++i)
+  {
+    data->pending+= global_rpl_thread_pool.threads[i]->qev_free_pending;
+    data->size+= global_rpl_thread_pool.threads[i]->loc_qev_size;
+  }
+  mysql_mutex_unlock(&global_rpl_thread_pool.LOCK_rpl_thread_pool);
+
+  return 0;
+}
 
 #endif /* HAVE_REPLICATION */
 
@@ -7917,6 +7948,7 @@
   {"Slave_open_temp_tables",   (char*) &slave_open_temp_tables, SHOW_INT},
 #ifdef HAVE_REPLICATION
   {"Slave_heartbeat_period",   (char*) &show_heartbeat_period, SHOW_SIMPLE_FUNC},
+  {"Slave_parallel_eventqueue", (char*) &show_slave_parallel_eventqueue, SHOW_FUNC},
   {"Slave_received_heartbeats",(char*) &show_slave_received_heartbeats, SHOW_SIMPLE_FUNC},
   {"Slave_retried_transactions",(char*)&slave_retried_transactions, SHOW_LONG},
   {"Slave_running",            (char*) &show_slave_running,     SHOW_SIMPLE_FUNC},