SAVEwork

1 files changed, 7 insertions, 6 deletions

diff --git a/server/main-channel-client.cpp b/server/main-channel-client.cpp
index 01600064..7b37091c 100644
--- a/server/main-channel-client.cpp
+++ b/server/main-channel-client.cpp
@@ -141,7 +141,7 @@ void MainChannelClient::on_disconnect()
     reds_get_main_dispatcher(reds)->client_disconnect(get_client());
 }
 
-static void main_channel_client_push_ping(MainChannelClient *mcc, int size);
+static void main_channel_client_ping(MainChannelClient *mcc, int size);
 
 static RedPipeItemPtr main_notify_item_new(const char *msg, int num)
 {
@@ -165,9 +165,10 @@ void MainChannelClient::start_net_test(int test_rate)
     priv->net_test_id = priv->ping_id + 1;
     priv->net_test_stage = NET_TEST_STAGE_WARMUP;
 
-    main_channel_client_push_ping(this, NET_TEST_WARMUP_BYTES);
-    main_channel_client_push_ping(this, 0);
-    main_channel_client_push_ping(this, NET_TEST_BYTES);
+    main_channel_client_ping(this, NET_TEST_WARMUP_BYTES);
+    main_channel_client_ping(this, 0);
+    main_channel_client_ping(this, NET_TEST_BYTES);
+    push();
 }
 
 static RedPipeItemPtr red_ping_item_new(int size)
@@ -178,10 +179,10 @@ static RedPipeItemPtr red_ping_item_new(int size)
     return item;
 }
 
-static void main_channel_client_push_ping(MainChannelClient *mcc, int size)
+static void main_channel_client_ping(MainChannelClient *mcc, int size)
 {
     auto item = red_ping_item_new(size);
-    mcc->pipe_add_push(std::move(item));
+    mcc->pipe_add(std::move(item));
 }
 
 static RedPipeItemPtr main_agent_tokens_item_new(uint32_t num_tokens)