RPCModule : update codes (#367)

sogou · Mar 13, 2024 · e993fbf · e993fbf
1 parent 5eedc28
commit e993fbf
Showing 1 changed file with 14 additions and 6 deletions.
diff --git a/src/module/rpc_module.cc b/src/module/rpc_module.cc
@@ -52,9 +52,13 @@ bool RPCModule::client_task_end(SubTask *task, RPCModuleData& data)
 
 	for (RPCFilter *filter : this->filters)
 	{
-		ret = ret && filter->client_end(task, data);
-		filter_task = filter->create_filter_task(data);
-		series_of(task)->push_front(filter_task);
+		if (filter->client_end(task, data))
+		{
+			filter_task = filter->create_filter_task(data);
+			series_of(task)->push_front(filter_task);
+		}
+		else
+			ret = false;
 	}
 
 	return ret;
@@ -67,9 +71,13 @@ bool RPCModule::server_task_end(SubTask *task, RPCModuleData& data)
 
 	for (RPCFilter *filter : this->filters)
 	{
-		ret = ret && filter->server_end(task, data);
-		filter_task = filter->create_filter_task(data);
-		series_of(task)->push_front(filter_task);
+		if (filter->server_end(task, data))
+		{
+			filter_task = filter->create_filter_task(data);
+			series_of(task)->push_front(filter_task);
+		}
+		else
+			ret = false;
 	}
 
 	return ret;