GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-17 04:31:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix URI parsed failed bug.

Browse Source
This commit is contained in:
Xie Han
2024-05-23 04:24:43 +08:00
parent d94c79ad5d
commit 1450f28c35
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/factory/KafkaTaskImpl.cc
+2
View File
@@ -774,6 +774,8 @@ __WFKafkaTask *__WFKafkaTaskFactory::create_kafka_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_keep_alive(KAFKA_KEEPALIVE_DEFAULT);
src/factory/WFTaskFactory.inl
+2
View File
@@ -506,6 +506,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);