- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 414 for pselect (0.22 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) -
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/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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)