diff --git a/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java b/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java index fe1b5fbdf1..0425584c0b 100644 --- a/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java +++ b/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java @@ -444,7 +444,7 @@ else if (transport.hasExplicitControl()) } /** - * Remove a destination to this image so it can merge streams. + * Remove a destination to this image once merge is achieved. * * @param transportIndex from which packets arrive. */ @@ -459,7 +459,8 @@ void addDestinationConnectionIfUnknown(final int transportIndex, final InetSocke } /** - * Called from the {@link DriverConductor}. + * Called from the {@link DriverConductor} to track the rebuild os stream which is used for loss detection + * and congestion control. * * @param nowNs current time. * @param statusMessageTimeoutNs for sending of Status Messages.