diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/fs4/PongPacket.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/fs4/PongPacket.java | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/container-search/src/main/java/com/yahoo/fs4/PongPacket.java b/container-search/src/main/java/com/yahoo/fs4/PongPacket.java index f0c892519db..58391952370 100644 --- a/container-search/src/main/java/com/yahoo/fs4/PongPacket.java +++ b/container-search/src/main/java/com/yahoo/fs4/PongPacket.java @@ -24,11 +24,16 @@ public class PongPacket extends BasicPacket { private int totalPartitions; // configured partitions private Optional<Integer> activePartitions = Optional.empty(); // number of partitions that are up - private Optional<Long> activeDocs = Optional.empty(); // how many documents are searchable (sum) + private Optional<Long> activeDocuments = Optional.empty(); // how many documents are searchable (sum) public PongPacket() { } + /** For testing */ + public PongPacket(long activeDocuments) { + this.activeDocuments = Optional.of(activeDocuments); + } + private int code; protected void codeDecodedHook(int code) { this.code = code; } public int getCode() { return code; } @@ -50,7 +55,7 @@ public class PongPacket extends BasicPacket { buffer.getInt(); // ignore rflags (historical field) } if ((features & MRF_ACTIVEDOCS) != 0) { - activeDocs = Optional.of(Long.valueOf(buffer.getLong())); + activeDocuments = Optional.of(Long.valueOf(buffer.getLong())); } } @@ -71,7 +76,7 @@ public class PongPacket extends BasicPacket { * in the monitored backend. **/ public Optional<Long> getActiveDocuments() { - return activeDocs; + return activeDocuments; } public Optional<Integer> getActiveNodes() { |