- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 434 for selects (0.07 sec)
-
.github/ISSUE_TEMPLATE/bug_report.yaml
description: What actually happened? validations: required: true - type: dropdown attributes: label: Packages description: If this issue is package-specific, then please select the relevant packages. multiple: true options: - com.google.common.annotations - com.google.common.base - com.google.common.cache - com.google.common.collect
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 16 20:08:25 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/callhome.go
defer callhomeTimer.Stop() for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } select { case <-ctx.Done(): // indicates that we do not need to run callhome anymore return false case <-callhomeTimer.C: if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
*/ @Throws(IOException::class) fun processNextEvent(): Boolean { var id = lastId var type: String? = null val data = Buffer() while (true) { when (source.select(options)) { in 0..2 -> { completeEvent(id, type, data) return true } in 3..4 -> { source.readData(data) } in 5..7 -> {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 4.3K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
return fmt.Errorf("Select parameters can only be specified with SELECT request type") } if r.Type == SelectRestoreRequest && r.SelectParameters.IsEmpty() { return fmt.Errorf("SELECT restore request requires select parameters to be specified") } if r.Type != SelectRestoreRequest && !r.OutputLocation.IsEmpty() { return fmt.Errorf("OutputLocation required only for SELECT request type") }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
cmd/erasure.go
updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64()) t := time.NewTicker(updateTime) defer t.Stop() defer saverWg.Done() var lastSave time.Time for { select { case <-t.C: if cache.Info.LastUpdate.Equal(lastSave) { continue } scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update") updates <- cache.clone()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaIntegrationTest.java
assertNotNull(provider, "Should always select an RDMA provider (at minimum TCP fallback)"); assertNotNull(provider.getProviderName(), "Provider name should not be null"); assertNotNull(provider.getSupportedCapabilities(), "Supported capabilities should not be null"); assertTrue(provider.getMaxMessageSize() > 0, "Max message size should be positive"); System.out.println("Selected RDMA provider: " + provider.getProviderName());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 13.8K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
# Wait for all drives to be online and formatted while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done # Wait for all drives to be healed while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done # Wait for Status: in MinIO output while true; do rv=$(check_online)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java
import jcifs.Configuration; import jcifs.internal.smb2.rdma.disni.DisniRdmaProvider; import jcifs.internal.smb2.rdma.tcp.TcpRdmaProvider; /** * Factory for creating RDMA provider instances. * * This factory attempts to select the best available RDMA provider * based on system capabilities and configuration preferences. */ public class RdmaProviderFactory { /** * Private constructor to prevent instantiation */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/exbhv/ScheduledJobBhv.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 2.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformToAsciiTest.kt
/** Runs the web platform ToAscii tests. */ class WebPlatformToAsciiTest { @Suppress("ktlint:standard:max-line-length") val knownFailures = setOf( // OkHttp rejects empty labels. "x..xn--zca", "x..ß", // OkHttp rejects labels longer than 63 code points, the web platform tests don't. "x01234567890123456789012345678901234567890123456789012345678901x.xn--zca",
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0)