Merge pull request #555 from Barenboim/master

WFClientTask->WFComplexClientTask

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()

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()

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;

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()