Fix URI parsed failed bug. (#1561)

Barenboim · web-flow · commit fa85db076a49 · 2024-05-22T18:03:16.000+08:00
diff --git a/src/factory/KafkaTaskImpl.cc b/src/factory/KafkaTaskImpl.cc
@@ -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);
diff --git a/src/factory/WFTaskFactory.inl b/src/factory/WFTaskFactory.inl
@@ -508,6 +508,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);

Original file line number	Diff line number	Diff line change
`@@ -774,6 +774,8 @@ __WFKafkaTask *__WFKafkaTaskFactory::create_kafka_task(enum TransportType type,`
`774`	`774`	`uri.state = URI_STATE_ERROR;`
`775`	`775`	`uri.error = errno;`
`776`	`776`	`}`
	`777`	`+ else`
	`778`	`+ uri.state = URI_STATE_SUCCESS;`
`777`	`779`
`778`	`780`	`task->init(std::move(uri));`
`779`	`781`	`task->set_keep_alive(KAFKA_KEEPALIVE_DEFAULT);`
Original file line number	Diff line number	Diff line change
`@@ -508,6 +508,8 @@ WFNetworkTaskFactory<REQ, RESP>::create_client_task(enum TransportType type,`
`508`	`508`	`uri.state = URI_STATE_ERROR;`
`509`	`509`	`uri.error = errno;`
`510`	`510`	`}`
	`511`	`+ else`
	`512`	`+ uri.state = URI_STATE_SUCCESS;`
`511`	`513`
`512`	`514`	`task->init(std::move(uri));`
`513`	`515`	`task->set_transport_type(type);`