summaryrefslogtreecommitdiff
path: root/sql/semisync_master_ack_receiver.cc
diff options
context:
space:
mode:
authorMarko Mäkelä <marko.makela@mariadb.com>2021-04-27 08:53:50 +0300
committerMarko Mäkelä <marko.makela@mariadb.com>2021-04-27 08:53:50 +0300
commit90a306a7ab9adb3ad79edb95cdca9beafd4c8e60 (patch)
tree9d38ac211b669d4761ed4903edffd2e179237089 /sql/semisync_master_ack_receiver.cc
parent9e6310e323a3abd411f852ff57fe41c9f149ff3a (diff)
parent29b2f3dbb543130a7ba71635216a8d7d34cac46e (diff)
downloadmariadb-git-90a306a7ab9adb3ad79edb95cdca9beafd4c8e60.tar.gz
Merge 10.3 into 10.4
Diffstat (limited to 'sql/semisync_master_ack_receiver.cc')
-rw-r--r--sql/semisync_master_ack_receiver.cc5
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/semisync_master_ack_receiver.cc b/sql/semisync_master_ack_receiver.cc
index e189fc5f631..b24d6452480 100644
--- a/sql/semisync_master_ack_receiver.cc
+++ b/sql/semisync_master_ack_receiver.cc
@@ -267,6 +267,11 @@ void Ack_receiver::run()
net_clear(&net, 0);
net.vio= &slave->vio;
+ /*
+ Set compress flag. This is needed to support
+ Slave_compress_protocol flag enabled Slaves
+ */
+ net.compress= slave->thd->net.compress;
len= my_net_read(&net);
if (likely(len != packet_error))