Flow handling fix.

dreibh · dreibh · commit a7fa4f7b3075 · 2025-11-03T13:17:25.000+01:00
diff --git a/src/transfer.cc b/src/transfer.cc
@@ -325,6 +325,7 @@ bool handleNetPerfMeterData(const bool               isActiveMode,
          }
          flow->unlock();
          flow->endOfInput();
+         return flow->isAcceptedIncomingFlow();   // No error for incoming flow!
       }
       else {
          LOG_WARNING
@@ -335,7 +336,7 @@ bool handleNetPerfMeterData(const bool               isActiveMode,
       if(protocol != IPPROTO_UDP) {
          ext_shutdown(sd, SHUT_RDWR);
       }
-      return flow->isAcceptedIncomingFlow();   // No error for incoming flow!
+      return false;
    }
 
    return true;

Original file line number	Diff line number	Diff line change
`@@ -325,6 +325,7 @@ bool handleNetPerfMeterData(const bool isActiveMode,`
`325`	`325`	`}`
`326`	`326`	`flow->unlock();`
`327`	`327`	`flow->endOfInput();`
	`328`	`+ return flow->isAcceptedIncomingFlow(); // No error for incoming flow!`
`328`	`329`	`}`
`329`	`330`	`else {`
`330`	`331`	`LOG_WARNING`
`@@ -335,7 +336,7 @@ bool handleNetPerfMeterData(const bool isActiveMode,`
`335`	`336`	`if(protocol != IPPROTO_UDP) {`
`336`	`337`	`ext_shutdown(sd, SHUT_RDWR);`
`337`	`338`	`}`
`338`		`- return flow->isAcceptedIncomingFlow(); // No error for incoming flow!`
	`339`	`+ return false;`
`339`	`340`	`}`
`340`	`341`
`341`	`342`	`return true;`