- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for queueing (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)