Skip to content

Commit

Permalink
fixed style issues
Browse files Browse the repository at this point in the history
Signed-off-by: Vinay Krishna Pudyodu <[email protected]>
  • Loading branch information
vinaykpud committed Dec 6, 2024
1 parent a081f77 commit bed0712
Show file tree
Hide file tree
Showing 4 changed files with 16 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -80,10 +80,13 @@ public void writeTo(StreamOutput out) throws IOException {

@Override
public String toString() {
return "SegmentReplicationShardStatsResponse{" +
"primaryStats=" + primaryStats +
", replicaStats=" + replicaStats +
", searchReplicaReplicationStats=" + searchReplicaReplicationStats +
'}';
return "SegmentReplicationShardStatsResponse{"
+ "primaryStats="
+ primaryStats
+ ", replicaStats="
+ replicaStats
+ ", searchReplicaReplicationStats="
+ searchReplicaReplicationStats
+ '}';
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -222,14 +222,13 @@ private SegmentReplicationState getSegmentReplicationState(ShardId shardId, bool
}
}

private long calculateBytesRemainingToReplicate(
SegmentReplicationState ongoingSegmentReplicationState
) {
private long calculateBytesRemainingToReplicate(SegmentReplicationState ongoingSegmentReplicationState) {
if (ongoingSegmentReplicationState == null) {
return 0;
}
return ongoingSegmentReplicationState.getIndex()
.fileDetails().stream()
.fileDetails()
.stream()
.mapToLong(index -> index.length() - index.recovered())
.sum();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ public ShardId getShardId() {
}

public void addReplicaStats(Set<SegmentReplicationShardStats> replicaStats) {
this.replicaStats.addAll(replicaStats);
this.replicaStats.addAll(replicaStats);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,6 @@

package org.opensearch.action.admin.indices.replication;

import org.junit.Before;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.opensearch.Version;
import org.opensearch.action.support.ActionFilters;
import org.opensearch.cluster.ClusterState;
Expand Down Expand Up @@ -44,13 +41,17 @@
import org.opensearch.indices.replication.common.ReplicationType;
import org.opensearch.test.OpenSearchTestCase;
import org.opensearch.transport.TransportService;
import org.junit.Before;

import java.util.ArrayList;
import java.util.EnumSet;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

import org.mockito.Mock;
import org.mockito.MockitoAnnotations;

import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
Expand Down

0 comments on commit bed0712

Please sign in to comment.