try fix leak

JoanFM · JoanFM · commit d602bd14dc92 · 2025-10-14T15:08:02.000+02:00
diff --git a/coord/src/dist_aggregate.c b/coord/src/dist_aggregate.c
@@ -395,6 +395,9 @@ static int rpnetNext(ResultProcessor *self, SearchResult *r) {
           || nc->areq->reqConfig.timeoutPolicy == TimeoutPolicy_Fail) {
         QueryError_SetError(nc->areq->qiter.err, QUERY_EGENERIC, strErr);
         return RS_RESULT_ERROR;
+      } else {
+        MRReply_Free(nc->current.root);
+        RPNet_resetCurrent(nc);
       }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -395,6 +395,9 @@ static int rpnetNext(ResultProcessor self, SearchResult r) {`
`395`	`395`	`\|\| nc->areq->reqConfig.timeoutPolicy == TimeoutPolicy_Fail) {`
`396`	`396`	`QueryError_SetError(nc->areq->qiter.err, QUERY_EGENERIC, strErr);`
`397`	`397`	`return RS_RESULT_ERROR;`
	`398`	`+ } else {`
	`399`	`+ MRReply_Free(nc->current.root);`
	`400`	`+ RPNet_resetCurrent(nc);`
`398`	`401`	`}`
`399`	`402`	`}`
`400`	`403`