mirror of
https://github.com/sogou/workflow.git
synced 2026-10-29 11:36:47 +08:00
Merge branch 'master' of https://github.com/sogou/workflow into nossl
This commit is contained in:
@@ -757,6 +757,8 @@ __WFKafkaTask *__WFKafkaTaskFactory::create_kafka_task(const char *host,
|
||||
uri.state = URI_STATE_ERROR;
|
||||
uri.error = errno;
|
||||
}
|
||||
else
|
||||
uri.state = URI_STATE_SUCCESS;
|
||||
|
||||
task->init(std::move(uri));
|
||||
task->set_keep_alive(KAFKA_KEEPALIVE_DEFAULT);
|
||||
|
||||
@@ -495,6 +495,8 @@ WFNetworkTaskFactory<REQ, RESP>::create_client_task(enum TransportType type,
|
||||
uri.state = URI_STATE_ERROR;
|
||||
uri.error = errno;
|
||||
}
|
||||
else
|
||||
uri.state = URI_STATE_SUCCESS;
|
||||
|
||||
task->init(std::move(uri));
|
||||
task->set_transport_type(type);
|
||||
|
||||
Reference in New Issue
Block a user