- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 215 for isSelect (0.22 sec)
-
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
s.mu.Unlock() <-done return ctx.Err() } ready := make(chan struct{}) w := waiter{n: n, ready: ready} elem := s.waiters.PushBack(w) s.mu.Unlock() select { case <-done: s.mu.Lock() select { case <-ready: // Acquired the semaphore after we were canceled. // Pretend we didn't and put the tokens back. s.cur -= n s.notifyWaiters() default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/scopes/Maven3ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/waiting_pods_map.go
} // Only signal success status after all plugins have allowed if len(w.pendingPlugins) != 0 { return } // The select clause works as a non-blocking send. // If there is no receiver, it's a no-op (default case). select { case w.s <- framework.NewStatus(framework.Success, ""): default: } } // Reject declares the waiting pod unschedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
defer close(drained) wg.Wait() }() select { case <-drained: case <-time.After(wait.ForeverTestTimeout): t.Fatal("timed out waiting for watchers to be terminated") } stopChan := make(chan struct{}) // Set up loop to modify CRD in the background wg.Add(1) go func() { defer wg.Done() for { select { case <-stopChan: return default: }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/transforms/legalize_hlo_conversions/reduce.cc
// from PyTorch // %0 = compare{GT}(%lhs_value, %rhs_value) // %1 = select(%0, %lhs_value, %rhs_value) // %2 = compare{EQ}(%lhs_value, %rhs_value) // %3 = minimum(%lhs_index, %rhs_index) // %4 = select(%0, %lhs_index, %rhs_index) // %5 = select(%2, %3, %4) // return %1, %5 LogicalResult MatchReduceToArgMinMaxType2(mhlo::ReduceOp reduce_op,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 05 20:53:17 UTC 2024 - 8K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/scopes/Maven4ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 9.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/BUILD
hdrs = ["posix_filesystem_helper.h"], deps = [":copy_file"], ) # On Linux, we can copy files faster using `sendfile`. But not elsewhere. # Hence, this private library to select which implementation to use. cc_library( name = "copy_file", srcs = select({ "//tensorflow:linux_x86_64": ["copy_file_linux.cc"], "//conditions:default": ["copy_file_portable.cc"], }), hdrs = ["copy_file.h"],
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sun Mar 24 20:08:23 UTC 2024 - 2.1K bytes - Viewed (0) -
maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven4ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Mar 27 14:46:12 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/dependencyManagement/managingTransitiveDependencies-declaringCapabilities/tests/dependencyReport.out
log4j:log4j:1.2.16 FAILED Failures: - Could not resolve log4j:log4j:1.2.16. - Module 'log4j:log4j' has been rejected: Cannot select module with conflict on capability 'log4j:log4j:1.2.16' also provided by [org.slf4j:log4j-over-slf4j:1.7.10(compile)] log4j:log4j:1.2.16 FAILED \--- org.apache.zookeeper:zookeeper:3.4.9 \--- compileClasspath org.slf4j:log4j-over-slf4j:1.7.10 FAILED Failures:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 13 19:52:38 UTC 2024 - 1.5K bytes - Viewed (0) -
src/syscall/rlimit.go
var origRlimitNofile atomic.Pointer[Rlimit] // Some systems set an artificially low soft limit on open file count, for compatibility // with code that uses select and its hard-coded maximum file descriptor // (limited by the size of fd_set). // // Go does not use select, so it should not be subject to these limits. // On some systems the limit is 256, which is very easy to run into,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:57 UTC 2024 - 1.6K bytes - Viewed (0)