+ public void process(DataPacket dataPacket) throws IOException {
+ super.process(dataPacket);
+ counter.getAndAdd(dataPacket.buffer().length);
+ updateTimestamp(false);
+ }
+
+ //
+ // PRIVATE METHODS
+ //
+
+ /** Updates the timestamp in the metadata. */
+ private void updateTimestamp(boolean now) {