- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for qsubs (0.04 sec)
-
internal/pubsub/pubsub.go
if wg != nil { wg.Done() } // Clean up and de-register the subscriber ps.Lock() defer ps.Unlock() var remainTypes Mask for i, s := range ps.subs { if s == sub { ps.subs = append(ps.subs[:i], ps.subs[i+1:]...) } else { remainTypes.Merge(s.types) } } atomic.StoreUint64(&ps.types, uint64(remainTypes)) atomic.AddInt32(&ps.numSubscribers, -1) }()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
eventtype := s.u.eventtype() switch mode { case 'r': *eventtype = eventtypeFdRead ridx = len(subs) case 'w': *eventtype = eventtypeFdWrite widx = len(subs) } if len(subs) == disarmed { throw("overflow") } pd.user = uint32(ridx)<<16 | uint32(widx) subs = append(subs, s) evts = append(evts, event{}) unlock(&mtx) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/version.go
var bucketURL, urlSuffix string subs := kubeBucketPrefixes.FindAllStringSubmatch(version, 1) if len(subs) != 1 || len(subs[0]) != 4 { return "", "", errors.Errorf("invalid version %q", version) } switch { case strings.HasPrefix(subs[0][2], "ci"): // Just use whichever the user specified urlSuffix = subs[0][2] bucketURL = kubeCIBucketURL default: urlSuffix = "release"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:50:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/xds/workload.go
addresses = updatedAddresses.IntersectInPlace(subs) } } if !w.Wildcard { // We only need this for on-demand. This allows us to subscribe the client to resources they // didn't explicitly request. // For wildcard, they subscribe to everything already. additional := e.Server.Env.ServiceDiscovery.AdditionalPodSubscriptions(proxy, addresses, subs) if addresses == nil { addresses = sets.New[string]() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
src/regexp/all_test.go
b.StartTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { subs := re.FindSubmatch(s) if string(subs[0]) != wantSubs { b.Fatalf("FindSubmatch(%q)[0] = %q; want %q", s, subs[0], wantSubs) } if string(subs[1]) != "aab" { b.Fatalf("FindSubmatch(%q)[1] = %q; want %q", s, subs[1], "aab") } } } func BenchmarkFindStringSubmatch(b *testing.B) { b.StopTimer()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:36:03 UTC 2024 - 25.8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/installation.adoc
This is identifiable by the presence of the `gradlew` or `gradlew.bat` files in the root of the project: [listing,subs=+macros] ---- . // <1> ├── gradle │ └── wrapper // <2> ├── gradlew // <3> ├── gradlew.bat // <3> └── ⋮ ---- <1> Project root directory.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 18:33:11 UTC 2024 - 10.6K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/reference/gradle_wrapper.adoc
[listing,subs=+attributes] ---- $ gradle wrapper --gradle-version {gradleVersion} --distribution-type all include::{snippetsPath}/wrapper/simple/tests/wrapperCommandLine.out[] ---- As a result, you can find the desired information (the generated distribution URL) in the Wrapper properties file: [source,properties,subs=+attributes] ----
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 16:15:50 UTC 2024 - 20.7K bytes - Viewed (0) -
src/cmd/vendor/github.com/ianlancetaylor/demangle/demangle.go
} else { // Merge adjacent qualifiers. This case // happens with multi-dimensional array types. if qsub, ok := ret.(*TypeWithQualifiers); ok { q = mergeQualifiers(q, qsub.Qualifiers) ret = qsub.Base } ret = &TypeWithQualifiers{Base: ret, Qualifiers: q} } st.subs.add(ret) } return ret } // demangleCastTemplateArgs is for a rather hideous parse. When we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 94.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/structuring/multi_project_builds.adoc
This can lead to phantom build directories, especially when using `allprojects{}` or `subproject{}`. To avoid this, you can use: ``` include(':subs:web:my-web-module') project(':subs:web:my-web-module').projectDir = "subs/web/my-web-module" ```
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 00:33:43 UTC 2024 - 9.4K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) } ps.Lock() defer ps.Unlock() if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 { t.Fatalf("expected 2 subscribers") } } func TestNumSubscribersMask(t *testing.T) { ps := New[Maskable, Mask](2) ch1 := make(chan Maskable, 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.8K bytes - Viewed (0)