diff --git a/plugin/group_replication/src/certifier.cc b/plugin/group_replication/src/certifier.cc index b485a6dc918..6db65503b8d 100644 --- a/plugin/group_replication/src/certifier.cc +++ b/plugin/group_replication/src/certifier.cc @@ -142,7 +142,7 @@ void Certifier_broadcast_thread::dispatcher() { while (!aborted) { // Broadcast Transaction identifiers every 30 seconds - if (broadcast_counter % 30 == 0) { + if (broadcast_counter % 150 == 0) { applier_module->get_pipeline_stats_member_collector() ->set_send_transaction_identifiers(); } @@ -158,7 +158,7 @@ void Certifier_broadcast_thread::dispatcher() { break; /* purecov: inspected */ } struct timespec abstime; - set_timespec(&abstime, 1); + set_timespec_nsec(&abstime, 1 * 200000000ULL); mysql_cond_timedwait(&broadcast_dispatcher_cond, &broadcast_dispatcher_lock, &abstime); mysql_mutex_unlock(&broadcast_dispatcher_lock); diff --git a/plugin/group_replication/src/pipeline_stats.cc b/plugin/group_replication/src/pipeline_stats.cc index 1d98146875e..96210ada1ec 100644 --- a/plugin/group_replication/src/pipeline_stats.cc +++ b/plugin/group_replication/src/pipeline_stats.cc @@ -938,7 +938,7 @@ int32 Flow_control_module::do_wait() { if (quota_used > quota_size && quota_size != 0) { struct timespec delay; - set_timespec(&delay, 1); + set_timespec_nsec(&delay, 1 * 200000000ULL); mysql_mutex_lock(&m_flow_control_lock); mysql_cond_timedwait(&m_flow_control_cond, &m_flow_control_lock, &delay);