summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/fs4/PongPacket.java
diff options
context:
space:
mode:
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.java11
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() {