try fix leak

JoanFM · JoanFM · commit 5a0f2ffdfd50 · 2025-10-14T12:36:58.000+02:00
diff --git a/coord/src/dist_aggregate.c b/coord/src/dist_aggregate.c
@@ -396,6 +396,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
`@@ -396,6 +396,9 @@ static int rpnetNext(ResultProcessor self, SearchResult r) {`
`396`	`396`	`\|\| nc->areq->reqConfig.timeoutPolicy == TimeoutPolicy_Fail) {`
`397`	`397`	`QueryError_SetError(nc->areq->qiter.err, QUERY_EGENERIC, strErr);`
`398`	`398`	`return RS_RESULT_ERROR;`
	`399`	`+ } else {`
	`400`	`+ MRReply_Free(nc->current.root);`
	`401`	`+ RPNet_resetCurrent(nc);`
`399`	`402`	`}`
`400`	`403`	`}`
`401`	`404`