Skip to content

Commit 05d0d0c

Browse files
committed
[Java] Cherry-pick fixes.
1 parent 081e7aa commit 05d0d0c

3 files changed

Lines changed: 11 additions & 10 deletions

File tree

aeron-driver/src/main/java/io/aeron/driver/DriverNameResolver.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,8 +133,8 @@ final class DriverNameResolver implements AutoCloseable, UdpNameResolutionTransp
133133

134134
final UdpChannel resolverChannel =
135135
UdpChannel.parse("aeron:udp?endpoint=" +
136-
NetworkUtil.formatAddressAndPort(localSocketAddress.getAddress(), localSocketAddress.getPort()),
137-
delegateResolver);
136+
NetworkUtil.formatAddressAndPort(localSocketAddress.getAddress(), localSocketAddress.getPort()),
137+
delegateResolver);
138138
transport = new UdpNameResolutionTransport(resolverChannel, localSocketAddress, unsafeBuffer, ctx);
139139

140140
neighborsCounter = ctx.countersManager().newCounter(

aeron-system-tests/src/test/java/io/aeron/UntetheredSubscriptionTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import io.aeron.test.driver.TestMediaDriver;
2929
import org.agrona.CloseHelper;
3030
import org.agrona.concurrent.UnsafeBuffer;
31+
import org.agrona.concurrent.status.CountersReader;
3132
import org.junit.jupiter.api.AfterEach;
3233
import org.junit.jupiter.api.Test;
3334
import org.junit.jupiter.api.extension.ExtendWith;

aeron-system-tests/src/test/java/io/aeron/driver/DriverNameResolverTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -324,10 +324,10 @@ void shouldUseFirstAvailableBootstrapNeighbor()
324324

325325
addDriver(TestMediaDriver.launch(
326326
setDefaults(new MediaDriver.Context())
327-
.aeronDirectoryName(baseDir + "-B")
328-
.resolverName("B")
329-
.resolverInterface("0.0.0.0:8051")
330-
.resolverBootstrapNeighbor("just:wrong,non_existing_host:8050,localhost:8050,localhost:8051"),
327+
.aeronDirectoryName(baseDir + "-B")
328+
.resolverName("B")
329+
.resolverInterface("0.0.0.0:8051")
330+
.resolverBootstrapNeighbor("just:wrong,non_existing_host:8050,localhost:8050,localhost:8051"),
331331
testWatcher));
332332
startClients();
333333

@@ -509,8 +509,8 @@ private int awaitNeighborsCounterId(final String name)
509509
while (true)
510510
{
511511
for (int offset = 0, counterId = 0, capacity = metaDataBuffer.capacity();
512-
offset < capacity;
513-
offset += METADATA_LENGTH, counterId++)
512+
offset < capacity;
513+
offset += METADATA_LENGTH, counterId++)
514514
{
515515
final int recordStatus = metaDataBuffer.getIntVolatile(offset);
516516
if (RECORD_ALLOCATED == recordStatus)
@@ -543,8 +543,8 @@ private int awaitCacheEntriesCounterId(final String name)
543543
while (true)
544544
{
545545
for (int offset = 0, counterId = 0, capacity = metaDataBuffer.capacity();
546-
offset < capacity;
547-
offset += METADATA_LENGTH, counterId++)
546+
offset < capacity;
547+
offset += METADATA_LENGTH, counterId++)
548548
{
549549
final int recordStatus = metaDataBuffer.getIntVolatile(offset);
550550
if (RECORD_ALLOCATED == recordStatus)

0 commit comments

Comments
 (0)