lead - Code Search

src/main/java/jcifs/internal/smb1/trans/SmbComTransactionResponse.java

     * @param len length of data to read
     * @return number of bytes read
     */
    protected abstract int readSetupWireFormat(byte[] buffer, int bufferIndex, int len);

    /**
     * Reads parameters from wire format
     * @param buffer source buffer
     * @param bufferIndex starting index in source buffer
     * @param len length of data to read
     * @return number of bytes read

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 12.3K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

        reader.setScrollSize(1000);
        int count = 0;
        Set<String> valueSet = Collections.synchronizedSet(new HashSet<>());
        Map<String, Object> source;
        while ((source = reader.read()) != null) {
            assertTrue(source.get("field1").toString().startsWith("test"));
            valueSet.add(source.get("field1").toString());
            count++;
        }
        assertEquals(num, count);

Registered: Sat Dec 20 13:04:59 UTC 2025

- Last Modified: Sun Nov 23 13:04:17 UTC 2025

- 8.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

docs/smb3-features/02-persistent-handles-design.md

                    }
                } catch (Exception e) {
                    log.error("Failed to load handle file: " + handleFile, e);
                    Files.deleteIfExists(handleFile);
                }
            }
        } catch (IOException e) {
            log.error("Failed to load persisted handles", e);
        }
    }
    
    public void shutdown() {
        scheduler.shutdown();

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 02:53:50 UTC 2025

- 31.6K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

     */
    @Override
    public int read() throws IOException {
        return inputStream.read();
    }

    /**
     * Reads up to len bytes of data from the input stream into an array of bytes.
     *
     * @param b the buffer into which the data is read
     * @param off the start offset in array b at which the data is written
     * @param len the maximum number of bytes to read

Registered: Sat Dec 20 11:21:39 UTC 2025

- Last Modified: Sat Nov 22 13:28:22 UTC 2025

- 4.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

docs/smb3-features/05-rdma-smb-direct-design.md

        // Allocate buffer for read data
        ByteBuffer readBuffer = bufferManager.allocateBuffer(request.getLength());
        RdmaMemoryRegion readRegion = provider.registerMemory(readBuffer, 
            EnumSet.of(RdmaAccess.LOCAL_WRITE, RdmaAccess.REMOTE_WRITE));
        
        try {
            // Create SMB2 Read request with RDMA read channel info

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 02:53:50 UTC 2025

- 35.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/ntlmssp/NtlmMessageTest.java

        // Test with zero
        buffer.putInt(0, 0);
        assertEquals(0, NtlmMessage.readULong(data, 0), "Should read zero ULong correctly.");

        // Test with max int value (unsigned interpretation)
        buffer.putInt(0, 0xFFFFFFFF);
        assertEquals(0xFFFFFFFF, NtlmMessage.readULong(data, 0), "Should read max ULong correctly.");

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 12.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/sereq/admin_sereq.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
	<head>
	<meta charset="UTF-8">
	<title><la:message key="labels.admin_brand_title" /> | <la:message
			key="labels.sereq_configuration" /></title>
	<jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
	<div class="wrapper">

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 13 05:54:52 UTC 2025

- 2.3K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/misc/DynamicProperties.java

    }

    @Override
    public synchronized void load(final InputStream inStream) throws IOException {
        final Properties prop = new Properties();
        lastModified = propertiesFile.lastModified();
        prop.load(inStream);
        properties = prop;
    }

    @Override
    public synchronized void load(final Reader reader) throws IOException {

Registered: Sat Dec 20 08:55:33 UTC 2025

- Last Modified: Sat Jul 05 00:11:05 UTC 2025

- 13.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/dashboard/admin_dashboard.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.dashboard_title_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 13 05:54:52 UTC 2025

- 1.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/SocketInputStream.java

    }

    @Override
    public synchronized int read() throws IOException {
        if (read(tmp, 0, 1) < 0) {
            return -1;
        }
        return tmp[0] & 0xFF;
    }

    @Override
    public synchronized int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /* This method will not return until len bytes have been read
     * or the stream has been closed.
     */

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 3.3K bytes

- Viewed (0)

Search Options