Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 215 for isSelect (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top