func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer {
	return &writerWrapper{ch: ch, ctx: ctx}
}

// bytesOrLength returns small (<=100b) byte slices as string, otherwise length.
func bytesOrLength(b []byte) string {
	if len(b) > 100 {
		return fmt.Sprintf("%d bytes", len(b))
	}
	return fmt.Sprint(string(b))
}

// ConnDialer is a function that dials a connection to the given address.

            writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, escapeJsonKeyValue(MESSAGE_FIELD, "Scroll Search is not available."));
            return;
        }

        final StringBuilder buf = new StringBuilder(1000);
        request.setAttribute(Constants.SEARCH_LOG_ACCESS_TYPE, Constants.SEARCH_LOG_ACCESS_TYPE_JSON);
        final JsonRequestParams params = new JsonRequestParams(request, fessConfig);
        try {

			size: 0,
		},
		{
			name: "dir1/fileindir1",
			size: 20000,
		},
		{
			name: "dir1/dirc/fileindirc",
			size: 20000,
		},
		{
			name: "rootfile3",
			size: 1000,
		},
		{
			name: "dir1/dira/dirasub/fileindira2",
			size: 200,
		},
	}
	createUsageTestFiles(t, base, bucket, files)
	err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile"))

    /**
     * Cache for storing resource file modification timestamps to enable cache busting.
     * The cache expires after 10 minutes and has a maximum size of 1000 entries.
     */
    private static LoadingCache<String, Long> resourceHashCache =
            CacheBuilder.newBuilder().maximumSize(1000).expireAfterWrite(10, TimeUnit.MINUTES).build(new CacheLoader<String, Long>() {
                @Override

		expectedStrings []string
	}{
		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}},
		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", "url"), []string{"<Key>foo+bar+1</Key>", "<Key>foo+bar+2</Key>"}},
		{
			getListObjectsV2URL(s.endPoint, bucketName, "", "1000", "", "", ""),
			[]string{
				"<Key>foo bar 1</Key>",
				"<Key>foo bar 2</Key>",

        assertFalse(nic.isRdmaCapable());
        assertEquals(address, nic.getAddress());

        // Test scoring
        int score = nic.getScore();
        assertEquals(11000, score); // 10000 (link speed) + 1000 (RSS bonus)

        // Test encoding/decoding
        byte[] encoded = nic.encode();
        assertNotNull(encoded);
        assertEquals(Smb2ChannelCapabilities.NETWORK_INTERFACE_INFO_SIZE, encoded.length);

            byte[] buffer = new byte[100];

            int bytesRead = echoRequest.readBytesWireFormat(buffer, 0);

            assertEquals(0, bytesRead);
        }

        @Test
        @DisplayName("Should return 0 regardless of buffer content")
        void testReadBytesWithVariousBufferContent() {
            byte[] emptyBuffer = new byte[100];
            byte[] fullBuffer = new byte[100];

            final String path = entry.getKey();
            if (servletPath.startsWith(path)) {
                req.setCharacterEncoding(entry.getValue());
                final StringBuilder locationBuf = new StringBuilder(1000);
                final String contextPath = servletContext.getContextPath();
                if (StringUtil.isNotBlank(contextPath) && !"/".equals(contextPath)) {
                    locationBuf.append(contextPath);

                                    // partial results
                                    final StringBuilder buf = new StringBuilder(1000);
                                    buf.append("[SEARCH TIMEOUT] {\"exec_time\":")
                                            .append(execTime)//
                                            .append(",\"request\":")

                                <div class="form-group">
                                    <la:text styleClass="query form-control" property="q"
                                             title="Search" size="50" maxlength="1000"
                                             placeholder="Type a search query"/>
                                </div>
                                <div class="form-group ml-sm-2">