Skip to content

Commit 27a0b14

Browse files
author
yangzhichao
committed
code format
1 parent bc80bd1 commit 27a0b14

1 file changed

Lines changed: 16 additions & 16 deletions

File tree

databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -3348,22 +3348,22 @@ private int readEventsInternal(ReadableByteChannel readChannel,
33483348
{
33493349
case OK:
33503350
{
3351-
if (readPos.getCurEvent().isEndOfPeriodMarker())
3352-
{
3353-
if (preEndPeriodEvent)
3354-
{
3355-
readPos.eventSkipped();
3356-
break;
3357-
}
3358-
else
3359-
{
3360-
preEndPeriodEvent = true;
3361-
}
3362-
}
3363-
else
3364-
{
3365-
preEndPeriodEvent = false;
3366-
}
3351+
if (readPos.getCurEvent().isEndOfPeriodMarker())
3352+
{
3353+
if (preEndPeriodEvent)
3354+
{
3355+
readPos.eventSkipped();
3356+
break;
3357+
}
3358+
else
3359+
{
3360+
preEndPeriodEvent = true;
3361+
}
3362+
}
3363+
else
3364+
{
3365+
preEndPeriodEvent = false;
3366+
}
33673367
final int curEventSize = readPos.getCurEvent().size();
33683368
if (readPos.bytesProcessed() + curEventSize > contiguousCapacity)
33693369
{

0 commit comments

Comments
 (0)