Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 219 for Queues (0.03 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

            });
            saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
            return redirect(getClass());
        }
    
        /**
         * Clears all crawler indices including queue, data, and filter indices.
         *
         * @param form the action form (validated but not used for configuration)
         * @return HTML response redirecting to the maintenance page
         */
        @Execute
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/ByteStreams.java

    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    import java.nio.channels.ReadableByteChannel;
    import java.nio.channels.WritableByteChannel;
    import java.util.ArrayDeque;
    import java.util.Arrays;
    import java.util.Queue;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Provides utility methods for working with byte arrays and I/O streams.
     *
     * @author Chris Nokleberg
     * @author Colin Decker
     * @since 1.0
     */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java

        /** Available send credits for flow control */
        protected final AtomicInteger sendCredits;
        /** Available receive credits for flow control */
        protected final AtomicInteger receiveCredits;
        /** Queue of pending RDMA work requests */
        protected final BlockingQueue<RdmaWorkRequest> pendingRequests;
    
        // Connection state
        /** Current connection state */
        protected volatile RdmaConnectionState state;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.Iterator;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java

            }
        }
    
        /**
         * Stores a failure URL with error information for later analysis.
         *
         * @param crawlerContext the crawler context
         * @param urlQueue the URL queue containing the failed URL
         * @param errorName the name/type of the error
         * @param e the throwable that caused the failure
         * @return the stored FailureUrl entity
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     * `dnsStart(call, domainName)` → `dnsEnd(call, domainName, inetAddressList)`.
     *
     * Events are typically nested with this structure:
     *
     *  * call ([callStart], [callEnd], [callFailed])
     *    * dispatcher queue ([dispatcherQueueStart], [dispatcherQueueEnd])
     *    * proxy selection ([proxySelectStart], [proxySelectEnd])
     *    * dns ([dnsStart], [dnsEnd])
     *    * connect ([connectStart], [connectEnd], [connectFailed])
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  8. src/main/webapp/css/admin/respond.min.js

    a.ActiveXObject("Microsoft.XMLHTTP")}return function(){return b}}(),f=function(a,b){var c=e();c&&(c.open("GET",a,!0),c.onreadystatechange=function(){4!==c.readyState||200!==c.status&&304!==c.status||b(c.responseText)},4!==c.readyState&&c.send(null))};if(c.ajax=f,c.queue=d,c.regex={media:/@media[^\{]+\{([^\{\}]*\{[^\}\{]*\})+/gi,keyframes:/@(?:\-(?:o|moz|webkit)\-)?keyframes[^\{]+\{(?:[^\{\}]*\{[^\}\{]*\})+[^\}]*\}/gi,urls:/(url\()['"]?([^\/\)'"][^:\)'"]+)['"]?(\))/g,findStyles:/@media *([^\{]+)\{([\S\s]+?)$/,only...
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Oct 08 12:14:13 UTC 2015
    - 4.3K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

       * is used to calculate this value. It also doesn't include any bytes buffered by the operating
       * system or network intermediaries. This method returns 0 if no messages are waiting in the
       * queue. If may return a nonzero value after the web socket has been canceled; this indicates
       * that enqueued messages were not transmitted.
       */
      fun queueSize(): Long
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

                    return true;
                }
            }
            return false;
        }
    
        /**
         * Processes the result data and stores it along with child URLs.
         *
         * @param urlQueue the URL queue entry
         * @param responseData the response data
         * @param resultData the result data
         */
        protected void processResult(final UrlQueue<?> urlQueue, final ResponseData responseData, final ResultData resultData) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
Back to top