- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 384 for pselect (0.16 sec)
-
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) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/model/ComponentGraphResolveState.java
* which only happens in certain specific cases (and something we should deprecate).</p> * * <p>The subsequent resolution steps to select artifacts, are performed using the instance returned by {@link #prepareForArtifactResolution()}.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 16:00:57 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/background-heal-ops.go
globalBackgroundHealState.LaunchNewHealSequence(bgSeq, objAPI) } // Wait for heal requests and process them func (h *healRoutine) AddWorker(ctx context.Context, objAPI ObjectLayer, bgSeq *healSequence) { for { select { case task, ok := <-h.tasks: if !ok { return } var res madmin.HealResultItem var err error switch task.bucket { case nopHeal: err = errSkipFile
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
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) -
src/runtime/pprof/pprof_test.go
awaitBlockedGoroutine(t, "select", "blockSelectRecvAsync", 1) c <- true } }() for i := 0; i < numTries; i++ { select { case <-c: case <-c2: } } } func blockSelectSendSync(t *testing.T) { c := make(chan bool) c2 := make(chan bool) go func() { awaitBlockedGoroutine(t, "select", "blockSelectSendSync", 1) <-c }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
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) -
internal/grid/debug.go
Managers []*Manager Mux []*mux.Router Hosts []string cleanupOnce sync.Once cancel context.CancelFunc } // SetupTestGrid creates a new grid for testing purposes. // Select the number of hosts to create. // Call (TestGrid).Cleanup() when done. func SetupTestGrid(n int) (*TestGrid, error) { hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0) -
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) -
cmd/iam-object-store.go
if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select { case ch <- itemOrErr[string]{Err: err}: case <-ctx.Done(): } return } for obj := range objInfoCh { if obj.Err != nil { select { case ch <- itemOrErr[string]{Err: obj.Err}: case <-ctx.Done(): return } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/erasure-common.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0)