Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ public ClusterInfo getClusterInfo() {
return this.clusterInfo;
}

/** \
/**
* Returns the shard allocation decision for attempting to assign or move the shard.
*/
public ShardAllocationDecision getShardAllocationDecision() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,6 @@
* A bounded transport address is a tuple of {@link TransportAddress}, one array that represents
* the addresses the transport is bound to, and the other is the published one that represents the address clients
* should communicate on.
*
*
*/
public class BoundTransportAddress implements Writeable {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ private <T> T registerNewPage(Recycler.V<T> v, int page, int expectedSize) {
cache[page] = v;
assert Array.getLength(v.v()) == expectedSize;
return v.v();
}
}

protected final byte[] newBytePage(int page) {
if (recycler != null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,9 +49,9 @@ public CircuitBreakerStats(String name, long limit, long estimated, double overh
}

public CircuitBreakerStats(StreamInput in) throws IOException {
limit = in.readLong();
estimated = in.readLong();
overhead = in.readDouble();
this.limit = in.readLong();
this.estimated = in.readLong();
this.overhead = in.readDouble();
this.trippedCount = in.readLong();
this.name = in.readString();
}
Expand Down