Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for queueing (0.17 sec)

  1. cmd/global-heal.go

    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// queueing happens across namespace, ignore
    						// objects that are not found.
    						return
    					}
    					result = healEntryFailure(0)
    					bgSeq.countFailed(madmin.HealItemObject)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

     *
     * <p>Key features include:</p>
     * <ul>
     * <li>Incremental crawling support with last-modified timestamp checking</li>
     * <li>Document expiration handling</li>
     * <li>Child URL extraction and queueing</li>
     * <li>Integration with Fess configuration and permission systems</li>
     * <li>Client selection based on URL patterns</li>
     * </ul>
     *
     * @see CrawlerThread
     * @see org.codelibs.fess.crawler.client.CrawlerClient
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
                    && queue.removeLastOccurrence(submittedTask);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/Suggester.java

     * </ul>
     *
     * <p>Public Methods:
     * <ul>
     *   <li>{@link #suggest()}: Creates a new SuggestRequestBuilder for querying suggestions.</li>
     *   <li>{@link #popularWords()}: Creates a new PopularWordsRequestBuilder for querying popular words.</li>
     *   <li>{@link #refresh()}: Refreshes the suggestion indices.</li>
     *   <li>{@link #shutdown()}: Shuts down the thread pool.</li>
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (3)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

        // Enqueueing the red task starts a thread because the head of the queue changed.
        redQueue.execute("red task") {
          log += "red:starting@${taskFaker.nanoTime}"
          taskFaker.sleep(100.µs)
          log += "red:finishing@${taskFaker.nanoTime}"
        }
        assertThat(taskFaker.executeCallCount).isEqualTo(1)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 23K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java

         */
        public static final byte TRANS2_FIND_NEXT2 = (byte) 0x02;
        /**
         * SMB TRANS2 subcommand for querying file system information
         */
        public static final byte TRANS2_QUERY_FS_INFORMATION = (byte) 0x03;
        /**
         * SMB TRANS2 subcommand for querying path information
         */
        public static final byte TRANS2_QUERY_PATH_INFORMATION = (byte) 0x05;
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  7. chainable_api.go

    		tx.Statement.Table = name
    	} else {
    		tx.Statement.TableExpr = nil
    		tx.Statement.Table = ""
    	}
    	return
    }
    
    // Distinct specify distinct fields that you want querying
    //
    //	// Select distinct names of users
    //	db.Distinct("name").Find(&results)
    //	// Select distinct name/age pairs from users
    //	db.Distinct("name", "age").Find(&results)
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 14.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/netbios/NbtAddress.java

         * on a network querying a workgroup group name is the preferred method.
         */
        public static final String ANY_HOSTS_NAME =
                "*\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000";
    
        /**
         * This is a special name for querying the master browser that serves the
         * list of hosts found in "Network Neighborhood".
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      Lockable {
      private val key: String
    
      /** Non-null for client web sockets. These can be canceled. */
      internal var call: Call? = null
    
      /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */
      private var writerTask: Task? = null
    
      /** Null until this web socket is connected. Only accessed by the reader thread. */
      private var reader: WebSocketReader? = null
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  10. docs/metrics/v3.md

    Each metric endpoint may support multiple child endpoints. For example, the `/v3/system/` metric has multiple child groups as `/v3/system/<child>`. Querying the parent endpoint returns metrics for all child groups. Querying a child group returns only metrics for that child.
    
    ### Per-bucket Metrics
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 45.2K bytes
    - Viewed (0)
Back to top