*/
        public void setLength(int length) {
            this.length = length;
        }

        /**
         * Get the notification timestamp
         *
         * @return timestamp in milliseconds
         */
        public long getTimestamp() {
            return timestamp;
        }

        /**
         * Sets the notification timestamp.
         *

	if !compareSignatureV4(req.Form.Get(xhttp.AmzSignature), newSignature) {
		return ErrSignatureDoesNotMatch
	}

	r.Header.Set("x-amz-signature-age", strconv.FormatInt(UTCNow().Sub(pSignValues.Date).Milliseconds(), 10))

	return ErrNone
}

// doesSignatureMatch - Verify authorization header with calculated header in accordance with
//   - http://docs.aws.amazon.com/AmazonS3/latest/API/sig-v4-authenticating-requests.html

     */
    @Resource
    protected volatile FesenClient fesenClient;

    /**
     * Index name.
     */
    protected String index;

    /**
     * Scroll timeout in milliseconds.
     */
    protected int scrollTimeout = 60000;

    /**
     * Scroll size for search requests.
     */
    protected int scrollSize = 100;

    /**
     * Buffer size for bulk operations.

        /**
         * Indicates if the search results are partial.
         */
        protected boolean partial;
        /**
         * The time taken for the search query in milliseconds.
         */
        protected long queryTime;
        /**
         * The search query string.
         */
        protected String searchQuery;
        /**

    val response1 = getResponse(newRequest("/a"))
    response1.body
      .source()
      .timeout()
      .timeout(100, TimeUnit.MILLISECONDS)
    assertContent("This connection won't pool properly", response1)
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)

    /** Ending record number for current page */
    public String currentEndRecordNumber;

    /** List of page numbers for pagination */
    public List<String> pageNumberList;

    /** Search execution time in milliseconds */
    public String execTime;

    // ===================================================================================
    // Hook
    // ======
    @Override

    peer.play()

    // Play it back.
    val connection = connect(peer)
    val stream = connection.newStream(headerEntries("b", "banana"), false)
    stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS)
    val startNanos = System.nanoTime()
    assertFailsWith<InterruptedIOException> {
      stream.takeHeaders()
    }
    val elapsedNanos = System.nanoTime() - startNanos
    awaitWatchdogIdle()

        public TimeOfDayInfo() {
        }

        /**
         * The time elapsed since 00:00:00, January 1, 1970 GMT.
         */
        public int elapsedt;
        /**
         * The number of milliseconds from the start of the current second.
         */
        public int msecs;
        /**
         * The current hour (0-23).
         */
        public int hours;
        /**

            // Given
            byte[] buffer = new byte[60];
            SMBUtil.writeInt2(60, buffer, 0);

            // SMB times are in 100-nanosecond intervals since 1601
            // Java times are in milliseconds since 1970
            long currentJavaTime = System.currentTimeMillis();
            long smbTime = currentJavaTime * 10000L + 116444736000000000L;

            SMBUtil.writeInt8(smbTime, buffer, 8);

        this.asyncLogging = enable;
        log.info("Asynchronous logging {}", enable ? "enabled" : "disabled");
    }

    /**
     * Configure rate limiting
     *
     * @param windowMs time window in milliseconds
     * @param maxEvents maximum events per window
     */
    public void setRateLimit(long windowMs, int maxEvents) {
        this.rateLimitWindow = windowMs;
        this.maxEventsPerWindow = maxEvents;