Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 826 for pselect (0.18 sec)

  1. staging/src/k8s.io/apimachinery/pkg/watch/watch.go

    	f.Lock()
    	defer f.Unlock()
    	if !f.Stopped {
    		select {
    		case f.result <- Event{Added, obj}:
    			return
    		default:
    			panic(fmt.Errorf("channel full"))
    		}
    	}
    }
    
    // Modify sends a modify event.
    func (f *RaceFreeFakeWatcher) Modify(obj runtime.Object) {
    	f.Lock()
    	defer f.Unlock()
    	if !f.Stopped {
    		select {
    		case f.result <- Event{Modified, obj}:
    			return
    		default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:06:22 UTC 2024
    - 8.1K bytes
    - Viewed (1)
  2. platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/DependenciesExtensions.kt

    
    /**
     * Modifies a dependency to select the variant of the given module.
     *
     * @see DependencyModifier
     * @since 8.0
     */
    operator fun <D : ModuleDependency> DependencyModifier.invoke(dependency: D): D = modify(dependency)
    
    
    /**
     * Modifies a dependency to select the variant of the given module.
     *
     * @see DependencyModifier
     * @since 8.0
     */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Feb 12 18:51:29 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. src/internal/types/testdata/check/stmt0.go

    	ch <- x
    }
    
    func selects() {
    	select {}
    	var (
    		ch chan int
    		sc chan <- bool
    	)
    	select {
    	case <-ch:
    	case (<-ch):
    	case t := <-ch:
    		_ = t
    	case t := (<-ch):
    		_ = t
    	case t, ok := <-ch:
    		_, _ = t, ok
    	case t, ok := (<-ch):
    		_, _ = t, ok
    	case <-sc /* ERROR "cannot receive from send-only channel" */ :
    	}
    	select {
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. src/reflect/value.go

    // A runtimeSelect is a single case passed to rselect.
    // This must match ../runtime/select.go:/runtimeSelect
    type runtimeSelect struct {
    	dir SelectDir      // SelectSend, SelectRecv or SelectDefault
    	typ *rtype         // channel type
    	ch  unsafe.Pointer // channel
    	val unsafe.Pointer // ptr to data (SendDir) or ptr to receive buffer (RecvDir)
    }
    
    // rselect runs a select. It returns the index of the chosen case.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  5. platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/Choice.java

     * limitations under the License.
     */
    
    package org.gradle.api.internal.tasks.userinput;
    
    import java.util.function.Function;
    
    /**
     * Asks the user to select an option from a list of options. Allows the choice to be configured in various ways.
     *
     * @param <T> The type of the options of this choice.
     */
    public interface Choice<T> {
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 04:50:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/gateway/gateway.go

    	})
    }
    
    func (*IngressGatewayPortAnalyzer) analyzeGateway(r *resource.Instance, c analysis.Context) {
    	gw := r.Message.(*v1alpha3.Gateway)
    
    	// Typically there will be a single istio-ingressgateway service, which will select
    	// the same ingress gateway pod workload as the Gateway resource.  If there are multiple
    	// Kubernetes services, and they offer different TCP port combinations, this validator will
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 04 08:48:06 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/CrossVersionResultsStore.java

                    PreparedStatement operationsForExecution = connection.prepareStatement("select version, testExecution, totalTime from testOperation "
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 20K bytes
    - Viewed (0)
  9. subprojects/core-api/src/main/java/org/gradle/StartParameter.java

            return HashCodeBuilder.reflectionHashCode(this);
        }
    
        /**
         * Returns the build file to use to select the default project. Returns null when the build file is not used to select the default project.
         *
         * @return The build file. May be null.
         *
         * @deprecated Setting custom build file to select the default project has been deprecated.
         * This method will be removed in Gradle 9.0.
         */
        @Deprecated
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 06:24:50 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  10. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/transform/DefaultArtifactVariantSelectorFactoryTest.groovy

            attributeMatcher.matches(_ as Collection, typeAttributes("classes"), _ as AttributeMatchingExplanationBuilder) >> [variant1]
    
            expect:
            def result = variantSelectorFactory.create(dependenciesResolverFactory).select(set, typeAttributes("classes"), false, factory)
            result == variant1Artifacts
        }
    
        def "fails when multiple producer variants match"() {
            def variant1 = resolvedVariant()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Feb 28 13:08:22 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top