diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/fs4/SearchNodePongPacket.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/fs4/SearchNodePongPacket.java | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/container-search/src/main/java/com/yahoo/fs4/SearchNodePongPacket.java b/container-search/src/main/java/com/yahoo/fs4/SearchNodePongPacket.java new file mode 100644 index 00000000000..dce0e84de95 --- /dev/null +++ b/container-search/src/main/java/com/yahoo/fs4/SearchNodePongPacket.java @@ -0,0 +1,32 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package com.yahoo.fs4; + +import java.nio.ByteBuffer; + +/** + * Responsible for decoding pong packets from a search node. + * @author tonytv + */ +public class SearchNodePongPacket extends PongPacket { + private int timeStamp; + + public static SearchNodePongPacket create() { + return new SearchNodePongPacket(); + } + + @Override + public int getCode() { return 207; } + + @Override + public void decodeBody(ByteBuffer buffer) { + @SuppressWarnings("unused") + int partitionId = buffer.getInt(); + + timeStamp = buffer.getInt(); + } + + @Override + public int getDocstamp() { + return timeStamp; + } +} |