Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 469 for handleMsg (0.08 seconds)

  1. src/main/java/jcifs/http/Handler.java

        private final CIFSContext transportContext;
    
        /**
         * Sets the URL stream handler factory for the environment. This
         * allows specification of the factory used in creating underlying
         * stream handlers. This can be called once per JVM instance.
         *
         * @param factory
         *            The URL stream handler factory.
         */
        public static void setURLStreamHandlerFactory(final URLStreamHandlerFactory factory) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/app/pager/JobLogPager.java

    import java.io.Serializable;
    import java.util.List;
    
    import org.codelibs.fess.util.ComponentUtil;
    
    /**
     * Pager class for managing job log pagination in the admin interface.
     * This class handles pagination functionality for job log listings and provides
     * search criteria for filtering job logs.
     */
    public class JobLogPager implements Serializable {
    
        /** Serial version UID for serialization */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/core/timer/TimeoutManager.java

    import java.util.concurrent.TimeUnit;
    
    import org.codelibs.core.collection.SLinkedList;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.log.Logger;
    
    /**
     * A class that handles timers.
     *
     * @author higa
     *
     */
    public class TimeoutManager implements Runnable {
    
        private static final Logger logger = Logger.getLogger(TimeoutManager.class);
    
        /**
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndXResponse.java

    import jcifs.internal.TreeConnectResponse;
    import jcifs.internal.smb1.AndXServerMessageBlock;
    import jcifs.internal.smb1.ServerMessageBlock;
    
    /**
     * SMB1 Tree Connect AndX response implementation.
     * Handles server responses to tree connect requests in SMB1 protocol, providing
     * information about the connected share including service type and DFS capabilities.
     *
     * @author mbechler
     */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

    package org.apache.maven.model.io;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import java.util.Map;
    
    import org.apache.maven.model.Model;
    
    /**
     * Handles deserialization of a model from some kind of textual format like XML.
     *
     * @deprecated use {@code org.apache.maven.api.services.xml.ModelXmlFactory} instead
     */
    @Deprecated(since = "4.0.0")
    public interface ModelReader {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/SearchHelper.java

    /**
     * Helper class for handling search operations in Fess.
     *
     * This class provides comprehensive search functionality including document search,
     * scroll search, and bulk operations. It handles search request parameter processing,
     * query building, response formatting, and search log management.
     *
     * Key features:
     * - Document search with pagination and faceting
     * - Scroll search for large result sets
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Dec 20 05:56:45 GMT 2025
    - 36.3K bytes
    - Click Count (0)
  7. cmd/lock-rest-server.go

    	resp := lockRPCForceUnlock.NewResponse()
    
    	_, err := l.ll.ForceUnlock(context.Background(), *args)
    	return l.makeResp(resp, err)
    }
    
    var (
    	// Static lock handlers.
    	// All have the same signature.
    	lockRPCForceUnlock = newLockHandler(grid.HandlerLockForceUnlock)
    	lockRPCRefresh     = newLockHandler(grid.HandlerLockRefresh)
    	lockRPCLock        = newLockHandler(grid.HandlerLockLock)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 31 19:54:34 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

    import org.opensearch.search.fetch.subphase.highlight.HighlightField;
    
    /**
     * Default implementation of RankFusionSearcher that performs standard OpenSearch queries.
     * This searcher handles query execution, response processing, and document highlighting.
     */
    public class DefaultSearcher extends RankFusionSearcher {
    
        /** Logger for this class. */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Nov 20 09:24:04 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  9. src/main/java/jcifs/util/Crypto.java

    import org.bouncycastle.jce.provider.BouncyCastleProvider;
    
    import jcifs.CIFSUnsupportedCryptoException;
    
    /**
     * Cryptographic utility class providing encryption and decryption functionality for jCIFS.
     * Handles security provider initialization and cryptographic operations for SMB authentication.
     *
     * @author mbechler
     */
    public final class Crypto {
    
        private static Provider provider = null;
    
        /**
         *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  10. src/test/java/jcifs/util/transport/ResponseTest.java

    public class ResponseTest {
    
        @Mock
        private Response mockResponse;
    
        @BeforeEach
        void setUp() {
            // Reset mock before each test to ensure clean state
            // MockitoExtension handles this automatically for @Mock fields, but good to be aware.
        }
    
        @Test
        void testIsReceived() {
            // Test initial state (should be false by default for a fresh mock)
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6.5K bytes
    - Click Count (0)
Back to Top