Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 414 for pselect (0.22 sec)

  1. src/go/types/unify.go

    						// x is a defined type: nothing to do.
    					case yn:
    						// x is not a defined type and y is a defined type: select y.
    						u.set(px, y)
    					default:
    						// Neither x nor y are defined types.
    						if yc, _ := under(y).(*Chan); yc != nil && yc.dir != SendRecv {
    							// y is a directed channel type: select y.
    							u.set(px, y)
    						}
    					}
    				}
    				return true
    			}
    			return false
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 16:24:39 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. pilot/pkg/bootstrap/certcontroller.go

    			return fmt.Errorf("could not watch %v: %v", file, err)
    		}
    	}
    	s.addStartFunc("certificate rotation", func(stop <-chan struct{}) error {
    		go func() {
    			var keyCertTimerC <-chan time.Time
    			for {
    				select {
    				case <-keyCertTimerC:
    					keyCertTimerC = nil
    					if err := s.istiodCertBundleWatcher.SetFromFilesAndNotify(tlsOptions.KeyFile, tlsOptions.CertFile, tlsOptions.CaCertFile); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  3. src/context/context.go

    	// elapses.
    	//
    	// Done is provided for use in select statements:
    	//
    	//  // Stream generates values with DoSomething and sends them to out
    	//  // until DoSomething returns an error or ctx.Done is closed.
    	//  func Stream(ctx context.Context, out chan<- Value) error {
    	//  	for {
    	//  		v, err := DoSomething(ctx)
    	//  		if err != nil {
    	//  			return err
    	//  		}
    	//  		select {
    	//  		case <-ctx.Done():
    	//  			return ctx.Err()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 23.7K bytes
    - Viewed (0)
  4. cni/pkg/install/cniconfig_test.go

    				if err != nil {
    					errChan <- err
    					return
    				}
    				resultChan <- result
    			}(resultChan, errChan, parent, c.specifiedConfName, tempDir, c.chainedCNIPlugin)
    
    			select {
    			case result := <-resultChan:
    				if len(c.delayedConfName) > 0 {
    					// Delayed case
    					t.Fatalf("did not expect to retrieve a CNI config file %s", result)
    				} else if result != expectedFilepath {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. ci/official/utilities/code_check_full.bats

      # Column 1 is left only, Column 2 is right only, Column 3 is shared lines
      # Select lines unique to actual_licenses, i.e. extra licenses.
      comm -1 -3 $BATS_TEST_TMPDIR/expected_licenses $BATS_TEST_TMPDIR/actual_licenses | grep -v -f $BATS_TEST_TMPDIR/allowed_to_be_extra > $BATS_TEST_TMPDIR/actual_extra_licenses || true
      # Select lines unique to expected_licenses, i.e. missing licenses
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Mar 06 21:54:13 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. platforms/documentation/docs/src/docs/userguide/authoring-builds/tutorial/partr3_multi_project_builds.adoc

    ----
    
    [source]
    ----
    mkdir license-plugin
    ----
    
    [source]
    ----
    cd license-plugin
    ----
    
    Once in the `gradle/license-plugin` directory, run `gradle init`.
    Make sure that you select the `Gradle plugin` project as well as the other options for the `init` task below:
    
    [.multi-language-sample]
    =====
    [source, kotlin]
    ----
    $ gradle init --dsl kotlin --type kotlin-gradle-plugin --project-name license
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 29 17:16:27 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. cmd/local-locker.go

    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	select {
    	case <-ctx.Done():
    		return false, ctx.Err()
    	default:
    		l.mutex.Lock()
    		defer l.mutex.Unlock()
    		if len(args.UID) == 0 {
    			for _, resource := range args.Resources {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go

    			ServerName:        "test.com",
    		},
    		"matching IP in SNI cert and the server cert": {
    			// IPs must not be passed via SNI. Hence, the ServerName in the
    			// HELLO packet is empty and the server should select the non-SNI cert.
    			Cert: TestCertSpec{
    				host: "localhost",
    				ips:  []string{"10.0.0.1", "127.0.0.1"},
    			},
    			SNICerts: []NamedTestCertSpec{
    				{
    					TestCertSpec: TestCertSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 15:52:39 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  9. src/crypto/ed25519/ed25519.go

    	}
    }
    
    // Options can be used with [PrivateKey.Sign] or [VerifyWithOptions]
    // to select Ed25519 variants.
    type Options struct {
    	// Hash can be zero for regular Ed25519, or crypto.SHA512 for Ed25519ph.
    	Hash crypto.Hash
    
    	// Context, if not empty, selects Ed25519ctx or provides the context string
    	// for Ed25519ph. It can be at most 255 bytes in length.
    	Context string
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:11:18 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  10. pkg/proxy/config/config_test.go

    	// We might get 1 or more updates for N service updates, because we
    	// over write older snapshots of services from the producer go-routine
    	// if the consumer falls behind.
    	var services []*v1.Service
    	for {
    		select {
    		case services = <-h.updated:
    			if reflect.DeepEqual(services, expectedServices) {
    				return
    			}
    		// Unittests will hard timeout in 5m with a stack trace, prevent that
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
Back to top