From 42718496099f04b110f47ee205d1136f63aaf704 Mon Sep 17 00:00:00 2001 From: XieHan Date: Mon, 6 Sep 2021 21:02:27 +0800 Subject: [PATCH] WFClientTask->WFComplexClientTask --- src/factory/HttpTaskImpl.cc | 4 ++-- src/factory/KafkaTaskImpl.cc | 4 ++-- src/factory/MySQLTaskImpl.cc | 2 +- src/factory/RedisTaskImpl.cc | 4 ++-- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/src/factory/HttpTaskImpl.cc b/src/factory/HttpTaskImpl.cc index d5de7bc2..6988f42c 100644 --- a/src/factory/HttpTaskImpl.cc +++ b/src/factory/HttpTaskImpl.cc @@ -166,7 +166,7 @@ CommMessageOut *ComplexHttpTask::message_out() } //req->set_header_pair("Accept", "*/*"); - return this->WFClientTask::message_out(); + return this->WFComplexClientTask::message_out(); } CommMessageIn *ComplexHttpTask::message_in() @@ -176,7 +176,7 @@ CommMessageIn *ComplexHttpTask::message_in() if (strcmp(this->get_req()->get_method(), HttpMethodHead) == 0) resp->parse_zero_body(); - return this->WFClientTask::message_in(); + return this->WFComplexClientTask::message_in(); } int ComplexHttpTask::keep_alive_timeout() diff --git a/src/factory/KafkaTaskImpl.cc b/src/factory/KafkaTaskImpl.cc index e7cb6561..da16a0c3 100644 --- a/src/factory/KafkaTaskImpl.cc +++ b/src/factory/KafkaTaskImpl.cc @@ -218,7 +218,7 @@ CommMessageOut *__ComplexKafkaTask::message_out() } } - return this->WFClientTask::message_out(); + return this->WFComplexClientTask::message_out(); } CommMessageIn *__ComplexKafkaTask::message_in() @@ -230,7 +230,7 @@ CommMessageIn *__ComplexKafkaTask::message_in() resp->set_api_version(req->get_api_version()); resp->duplicate(*req); - return this->WFClientTask::message_in(); + return this->WFComplexClientTask::message_in(); } bool __ComplexKafkaTask::init_success() diff --git a/src/factory/MySQLTaskImpl.cc b/src/factory/MySQLTaskImpl.cc index a8319c17..6fd99c34 100644 --- a/src/factory/MySQLTaskImpl.cc +++ b/src/factory/MySQLTaskImpl.cc @@ -351,7 +351,7 @@ CommMessageIn *ComplexMySQLTask::message_in() else if (seqid == 2 && !is_user_request_) resp = new MySQLResponse; else - resp = (ProtocolMessage *)this->WFClientTask::message_in(); + resp = (ProtocolMessage *)this->WFComplexClientTask::message_in(); if (!is_ssl_) return resp; diff --git a/src/factory/RedisTaskImpl.cc b/src/factory/RedisTaskImpl.cc index 157dc92a..8acb87fe 100644 --- a/src/factory/RedisTaskImpl.cc +++ b/src/factory/RedisTaskImpl.cc @@ -105,7 +105,7 @@ CommMessageOut *ComplexRedisTask::message_out() } } - return this->WFClientTask::message_out(); + return this->WFComplexClientTask::message_out(); } CommMessageIn *ComplexRedisTask::message_in() @@ -118,7 +118,7 @@ CommMessageIn *ComplexRedisTask::message_in() else resp->set_asking(false); - return this->WFClientTask::message_in(); + return this->WFComplexClientTask::message_in(); } int ComplexRedisTask::keep_alive_timeout()