We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
isValidFrame
1 parent dd2656b commit d91e021Copy full SHA for d91e021
1 file changed
aeron-driver/src/main/java/io/aeron/driver/media/UdpChannelTransport.java
@@ -395,20 +395,14 @@ public boolean isMulticast()
395
*/
396
public boolean isValidFrame(final UnsafeBuffer buffer, final int length)
397
{
398
- boolean isFrameValid = true;
399
-
400
- if (frameVersion(buffer, 0) != HeaderFlyweight.CURRENT_VERSION)
401
- {
402
- isFrameValid = false;
403
- invalidPackets.increment();
404
- }
405
- else if (length < HeaderFlyweight.MIN_HEADER_LENGTH)
+ if (length >= HeaderFlyweight.MIN_HEADER_LENGTH &&
+ frameVersion(buffer, 0) == HeaderFlyweight.CURRENT_VERSION)
406
407
408
+ return true;
409
}
410
411
- return isFrameValid;
+ invalidPackets.increment();
+ return false;
412
413
414
/**
0 commit comments