lead - Code Search

src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndXResponse.java

        // Fortunately we don't really need nativeFileSystem for anything.
        // However, we'll try to read it safely for compatibility
        if (this.byteCount > bufferIndex - start) {
            try {
                // Attempt to read nativeFileSystem, but don't fail if there are issues
                final int fsLen = this.byteCount - (bufferIndex - start);

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

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

- 5.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/crawler/interval/FessIntervalController.java

        this.delayMillisForWaitingNewUrl = delayMillisForWaitingNewUrl;
    }

    /**
     * Delays the crawler while waiting for new URLs to be available.
     * This method calibrates CPU load, checks crawler status, applies
     * interval control rules, and then calls the parent implementation.
     * All operations are wrapped in exception handling to ensure robustness
     * in test and production environments.

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

- Last Modified: Wed Nov 19 07:09:17 UTC 2025

- 5.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/util/LogStream.java

 */

package jcifs.smb1.util;

import java.io.PrintStream;

/**
0 - nothing
1 - critical [default]
2 - basic info can be logged under load
3 - almost everything
N - debugging
 */

public class LogStream extends PrintStream {

    private static LogStream inst;

    /**
     * The current logging level.
     */

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

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

- 2.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationResponseTest.java

        assertEquals(0, result);

        result = response.writeDataWireFormat(null, 0);
        assertEquals(0, result);
    }

    @Test
    @DisplayName("Test all read methods with null buffer")
    void testReadMethodsWithNullBuffer() {
        // Even with null buffer, methods should return 0 without throwing exception
        int result = response.readSetupWireFormat(null, 0, 0);

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

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

- 15.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseStateTest.java

        // Should return true when read caching is enabled
        assertTrue(DirectoryLeaseState.canCacheEnumeration(Smb2LeaseState.SMB2_LEASE_READ_CACHING));
        assertTrue(DirectoryLeaseState.canCacheEnumeration(DirectoryLeaseState.DIRECTORY_READ_HANDLE));
        assertTrue(DirectoryLeaseState.canCacheEnumeration(DirectoryLeaseState.DIRECTORY_FULL));

        // Should return false when read caching is not enabled

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

- Last Modified: Sat Aug 23 01:47:47 UTC 2025

- 3.9K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/io/ResourceHandler.java

 *
 * @author taedium
 */
public interface ResourceHandler {

    /**
     * Processes a resource.
     *
     * @param path the path
     * @param is the {@link InputStream} to read the resource
     */
    void processResource(String path, InputStream is);

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

- Last Modified: Thu Jun 19 09:12:22 UTC 2025

- 997 bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/ResourceManagerTest.java

        // The leak counter may or may not increment depending on GC timing
        assertNotNull(stats.get("totalLeaks"));
    }

    private void createLeakyResource() {
        TestResource resource = new TestResource("leaky");
        resourceManager.registerResource(resource);
        // Resource goes out of scope without closing - potential leak
    }

    @Test

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

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 8.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/transport/TransportTest.java

            InputStream is = new ByteArrayInputStream("Hi".getBytes());
            byte[] buffer = new byte[10];

            Transport.readn(is, buffer, 0, 2); // Read all
            int bytesRead = Transport.readn(is, buffer, 0, 5); // Try to read more
            assertEquals(0, bytesRead);
        }
    }

    @Nested
    @DisplayName("Resource management tests")
    class ResourceManagementTests {

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

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

- 9.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/ioctl/QueryNetworkInterfaceInfoResponse.java

        int start = bufferIndex;
        int end = start + len;
        interfaces.clear();

        while (bufferIndex < end && (bufferIndex + 152) <= end) {
            // Read Next field to determine if there are more entries
            int next = SMBUtil.readInt4(buffer, bufferIndex);

            NetworkInterfaceInfo info = NetworkInterfaceInfo.decode(buffer, bufferIndex);

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

- Last Modified: Thu Aug 21 11:13:46 UTC 2025

- 2.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/searchlog/admin_searchlog.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.searchlog_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

- 16.2K bytes

- Viewed (0)

Search Options