- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 367 for qselect (0.23 sec)
-
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()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
.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
Others - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Oct 27 19:53:41 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/metacache-entries.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
Events chan struct{} Errors chan error } // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error func (w *Watcher) Wait(ctx context.Context) error { select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err() } } func (w *Watcher) Close() { _ = w.watcher.Close() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
internal/http/listener.go
func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh. // It returns true if the result is sent else false if returns when doneCh is closed. send := func(result acceptResult) bool { select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/collector/ProjectsSelector.java
import org.apache.maven.project.MavenProject; import org.apache.maven.project.ProjectBuildingException; /** * Facade to select projects for a given set of pom.xml files. */ public interface ProjectsSelector { /** * Select Maven projects from a list of POM files. * @param files List of POM files. * @param request The {@link MavenExecutionRequest}
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 1.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultChecksumAlgorithmService.java
.collect(Collectors.toList()); } @Override public ChecksumAlgorithm select(String algorithmName) { nonNull(algorithmName, "algorithmName"); try { return new DefaultChecksumAlgorithm(checksumAlgorithmFactorySelector.select(algorithmName)); } catch (IllegalArgumentException e) {
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Thu Dec 21 08:05:10 GMT 2023 - 7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultChecksumAlgorithmService.java
.collect(Collectors.toList()); } @Override public ChecksumAlgorithm select(String algorithmName) { nonNull(algorithmName, "algorithmName"); try { return new DefaultChecksumAlgorithm(checksumAlgorithmFactorySelector.select(algorithmName)); } catch (IllegalArgumentException e) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 7.4K bytes - Viewed (0) -
common-protos/k8s.io/api/extensions/v1beta1/generated.proto
message NetworkPolicyPeer { // This is a label selector which selects Pods. This field follows standard label // selector semantics; if present but empty, it selects all pods. // // If NamespaceSelector is also set, then the NetworkPolicyPeer as a whole selects // the Pods matching PodSelector in the Namespaces selected by NamespaceSelector. // Otherwise it selects the Pods matching PodSelector in the policy's own Namespace.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 45.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/StringprepReader.kt
val target = Buffer() while (!exhausted()) { skipWhitespace() val sourceCodePoint = readHexadecimalUnsignedLong().toInt() skipWhitespace() if (select(optionsSemicolon) != 0) throw IOException("expected ';'") skipWhitespace() while (select(optionsSemicolon) == -1) { val targetCodePoint = readHexadecimalUnsignedLong().toInt() target.writeUtf8CodePoint(targetCodePoint) skipWhitespace() }
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0)