Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 73 for pselect (0.11 sec)

  1. src/mime/quotedprintable/reader_test.go

    						// echo -n "0000= " | qprint -d
    						cmd.Process.Kill()
    					}
    				}
    			}()
    			go func() {
    				want, err := cmd.Output()
    				if err == nil {
    					qpres <- want
    				}
    			}()
    			select {
    			case got := <-qpres:
    				if want, ok := got.([]byte); ok {
    					if string(want) != buf.String() {
    						t.Errorf("go decode(%q) = %q; qprint = %q", s, want, buf.String())
    					}
    				} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. pkg/kubemark/hollow_kubelet.go

    		KubeletFlags:         *hk.KubeletFlags,
    		KubeletConfiguration: *hk.KubeletConfiguration,
    	}, hk.KubeletDeps, false); err != nil {
    		klog.Fatalf("Failed to run HollowKubelet: %v. Exiting.", err)
    	}
    	select {}
    }
    
    // HollowKubeletOptions contains settable parameters for hollow kubelet.
    type HollowKubeletOptions struct {
    	NodeName            string
    	KubeletPort         int
    	KubeletReadOnlyPort int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:10:54 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. src/go/internal/gcimporter/gcimporter.go

    			return
    		}
    		size--
    
    		// The unified export format starts with a 'u'; the indexed export
    		// format starts with an 'i'; and the older binary export format
    		// starts with a 'c', 'd', or 'v' (from "version"). Select
    		// appropriate importer.
    		switch exportFormat {
    		case 'u':
    			var data []byte
    			var r io.Reader = buf
    			if size >= 0 {
    				if data, err = saferio.ReadData(r, uint64(size)); err != nil {
    					return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. src/go/types/labels.go

    			}
    
    			// determine and validate target
    			name := s.Label.Name
    			switch s.Tok {
    			case token.BREAK:
    				// spec: "If there is a label, it must be that of an enclosing
    				// "for", "switch", or "select" statement, and that is the one
    				// whose execution terminates."
    				valid := false
    				if t := b.enclosingTarget(name); t != nil {
    					switch t.Stmt.(type) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  5. src/runtime/traceback_system_test.go

    	debug.SetTraceback("system")
    	writeSentinel(os.Stdout)
    	debug.SetCrashOutput(os.Stdout, debug.CrashOptions{})
    
    	go func() {
    		// This call is typically inlined.
    		child1()
    	}()
    	select {}
    }
    
    func child1() {
    	child2()
    }
    
    func child2() {
    	child3()
    }
    
    func child3() {
    	child4()
    }
    
    func child4() {
    	child5()
    }
    
    //go:noinline
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 15:19:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. subprojects/core-api/src/main/java/org/gradle/api/artifacts/ModuleDependency.java

         *
         * @since 4.8
         */
        @Override
        AttributeContainer getAttributes();
    
        /**
         * Mutates the attributes of this dependency. Attributes are used during dependency resolution to select the appropriate
         * target variant, in particular when a single component provides different variants.
         *
         * @param configureAction the attributes mutation action
         * @return this
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jun 05 16:14:52 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  7. pkg/envoy/proxy.go

    			Uid: 1337,
    			Gid: 1337,
    		}
    	}
    
    	if err := cmd.Start(); err != nil {
    		return err
    	}
    	done := make(chan error, 1)
    	go func() {
    		done <- cmd.Wait()
    	}()
    
    	select {
    	case err := <-abort:
    		log.Warnf("Aborting proxy")
    		if errKill := cmd.Process.Kill(); errKill != nil {
    			log.Warnf("killing proxy caused an error %v", errKill)
    		}
    		return err
    	case err := <-done:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/types2/labels.go

    			}
    
    			// determine and validate target
    			name := s.Label.Value
    			switch s.Tok {
    			case syntax.Break:
    				// spec: "If there is a label, it must be that of an enclosing
    				// "for", "switch", or "select" statement, and that is the one
    				// whose execution terminates."
    				valid := false
    				if t := b.enclosingTarget(name); t != nil {
    					switch t.Stmt.(type) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  9. pkg/kube/namespace/filter.go

    			}
    		},
    		DeleteFunc: func(ns *corev1.Namespace) {
    			f.lock.Lock()
    			defer f.lock.Unlock()
    			// No need to notify handlers for deletes. The namespace was deleted, so the object will be as well (and a delete could not de-select).
    			// Note that specifically for the edge case of a Namespace watcher that is filtering, this will ignore deletes we should
    			// otherwise send.
    			// See kclient.applyDynamicFilter for rationale.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. cmd/veeam-sos-api.go

    //     affects read from source, block, file, dedup, and object storage backup targets for a specific Veeam Job. When customers
    //     create a new backup job and select the object storage or a SOBR as a backup target with this setting, the job default
    //     setting will be set to this value. This setting will be only applied to newly created jobs (manual changes with Active Full
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 20 18:54:52 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top