| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/lib/portlayer/event/ |
| H A D | subscriber.go | 64 type subscriber struct { struct
65 topic string
66 name string
67 callback func(e events.Event)
68 eventQ chan events.Event
69 suspendState int32
70 discarded, dropped uint64
71 suspend chan suspendCmd
125 func (s *subscriber) Topic() string {
130 func (s *subscriber) Name() string {
[all …]
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.team/tests/org.eclipse.team.tests.cvs.core/src/org/eclipse/team/tests/ccvs/core/subscriber/ |
| H A D | SyncInfoSource.java | 67 CVSCompareSubscriber subscriber = new CVSCompareSubscriber(new IResource[] { resource }, tag); in createCompareSubscriber() local
72 public void disposeSubscriber(Subscriber subscriber) { in disposeSubscriber()
86 protected SyncInfo getSyncInfo(Subscriber subscriber, IResource resource) throws TeamException { in getSyncInfo()
93 protected IDiff getDiff(Subscriber subscriber, IResource resource) throws CoreException { in getDiff()
100 public void refresh(Subscriber subscriber, IResource resource) throws TeamException { in refresh()
107 public void refresh(Subscriber subscriber, IResource[] resources) throws TeamException { in refresh()
111 protected void assertProjectRemoved(Subscriber subscriber, IProject project) { in assertProjectRemoved()
207 private int getActualDiffFlags(Subscriber subscriber, IResource resource) in getActualDiffFlags()
229 …protected SyncInfo[] createSyncInfos(Subscriber subscriber, IResource[] resources) throws TeamExce… in createSyncInfos()
252 public void updateResources(Subscriber subscriber, IResource[] resources) throws CoreException { in updateResources()
[all …]
|
| H A D | CVSMergeSubscriberTest.java | 110 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testIncomingChanges() local
173 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root2, root3); in _test46007() local
216 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testMergableConflicts() local
269 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testUnmergableConflicts() local
340 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testLocalScrub() local
415 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testBug37546MergeWantsToDeleteNewDirectories() local
442 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testOutgoingDeletionAfterMergeBug53129() local
491 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testDisconnectingProject() local
525 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testMarkAsMerged() local
568 CVSMergeSubscriber subscriber = getSyncInfoSource().createMergeSubscriber(project, root, branch); in testDeletedAddition() local
[all …]
|
| /dports/benchmarks/ali/ali-0.7.5/vendor/github.com/mum4k/termdash/private/event/ |
| H A D | event.go | 43 type subscriber struct { struct
45 cb Callback
49 filter map[reflect.Type]bool
52 queue queue
56 cancel context.CancelFunc
60 processed int
63 mu sync.Mutex
106 func (s *subscriber) run(ctx context.Context) {
122 func (s *subscriber) event(ev terminalapi.Event) {
134 func (s *subscriber) processedEvents() int {
[all …]
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.team/tests/org.eclipse.team.tests.cvs.core/src/org/eclipse/team/tests/ccvs/ui/ |
| H A D | ModelParticipantSyncInfoSource.java | 171 public static ModelSynchronizeParticipant getParticipant(Subscriber subscriber) { in getParticipant()
209 public void refresh(Subscriber subscriber, IResource[] resources) throws TeamException { in refresh()
227 public void waitForCollectionToFinish(Subscriber subscriber) { in waitForCollectionToFinish()
339 private IDiff getContextDiff(Subscriber subscriber, IResource resource) { in getContextDiff()
355 protected void assertProjectRemoved(Subscriber subscriber, IProject project) { in assertProjectRemoved()
401 Subscriber subscriber = super.createWorkspaceSubscriber(); in createWorkspaceSubscriber() local
415 public void disposeSubscriber(Subscriber subscriber) { in disposeSubscriber()
550 public ISynchronizePageConfiguration getConfiguration(Subscriber subscriber) { in getConfiguration()
555 private ModelSynchronizePage getPage(Subscriber subscriber) { in getPage()
574 public void assertViewMatchesModel(Subscriber subscriber) { in assertViewMatchesModel()
[all …]
|
| H A D | SubscriberParticipantSyncInfoSource.java | 72 public SyncInfo getSyncInfo(Subscriber subscriber, IResource resource) throws TeamException { in getSyncInfo()
105 public IDiff getDiff(Subscriber subscriber, IResource resource) throws CoreException { in getDiff()
113 public static SubscriberParticipant getParticipant(Subscriber subscriber) { in getParticipant()
132 public static SubscriberSyncInfoCollector getCollector(Subscriber subscriber) { in getCollector()
172 protected void assertProjectRemoved(Subscriber subscriber, IProject project) { in assertProjectRemoved()
209 private SyncInfo internalGetSyncInfo(Subscriber subscriber, IResource resource) { in internalGetSyncInfo()
232 public void assertViewMatchesModel(Subscriber subscriber) { in assertViewMatchesModel()
240 private ISynchronizeModelElement getModelRoot(Subscriber subscriber) { in getModelRoot()
245 private TreeItem[] getTreeItems(Subscriber subscriber) { in getTreeItems()
257 private static SubscriberParticipantPage getPage(Subscriber subscriber) { in getPage()
|
| /dports/devel/rust-analyzer/rust-analyzer-2021-12-20/cargo-crates/tracing-subscriber-0.3.3/tests/ |
| H A D | filter.rs | 20 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
53 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
73 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
102 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
133 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
163 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/tracing-subscriber-0.3.3/tests/ |
| H A D | filter.rs | 20 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
53 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
73 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
102 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
133 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
163 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/tracing-subscriber-0.3.3/tests/ |
| H A D | filter.rs | 20 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
53 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
73 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
102 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
133 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
163 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/net/krill/krill-0.9.4/cargo-crates/tracing-subscriber-0.2.25/tests/ |
| H A D | filter.rs | 20 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
53 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
73 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
102 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
133 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
163 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/misc/xd-rust/delan-xd-4bdbb191ed6d/cargo-crates/tracing-subscriber-0.2.15/tests/ |
| H A D | filter.rs | 18 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
51 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
71 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
100 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
131 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
161 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tracing-subscriber-0.2.16/tests/ |
| H A D | filter.rs | 18 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
51 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
71 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
100 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
131 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
161 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tracing-subscriber/tests/ |
| H A D | filter.rs | 20 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
53 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
73 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
102 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
133 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
163 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /dports/sysutils/vector/tracing-65547d8809fcc726b8187db85b23c42e32ef5dce/tracing-subscriber/tests/ |
| H A D | filter.rs | 15 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
48 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
68 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
104 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
146 let subscriber = subscriber.with(filter); in field_filter_events() localVariable
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tracing-subscriber-0.2.2/tests/ |
| H A D | filter.rs | 15 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
48 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
68 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
104 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
146 let subscriber = subscriber.with(filter); in field_filter_events() localVariable
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/tracing-subscriber-0.1.6/tests/ |
| H A D | filter.rs | 15 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
48 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
68 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
104 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
146 let subscriber = subscriber.with(filter); in field_filter_events() localVariable
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/sms/ |
| H A D | sms_queue.cc | 16 void SmsQueue::Push(const url::Origin& origin, Subscriber* subscriber) { in Push()
30 Subscriber& subscriber = *(subscribers.begin()); in Pop() local
35 void SmsQueue::Remove(const url::Origin& origin, Subscriber* subscriber) { in Remove()
51 const Subscriber* subscriber) { in HasSubscriber()
72 Subscriber* subscriber = Pop(implied_origin); in NotifyFailure() local
|
| /dports/devel/rust-analyzer/rust-analyzer-2021-12-20/cargo-crates/tracing-subscriber-0.3.3/src/layer/ |
| H A D | tests.rs | 93 let subscriber = in downcasts_to_subscriber() localVariable
166 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
184 let subscriber = crate::registry() in mixed_interleaved() localVariable
194 let subscriber = crate::registry() in mixed_layered() localVariable
202 let subscriber = crate::registry() in plf_only_unhinted() localVariable
212 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
244 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
257 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
274 let subscriber = crate::registry() in plf_only_picks_max() localVariable
282 let subscriber = crate::registry() in many_plf_only_picks_max() localVariable
[all …]
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/tracing-subscriber-0.3.3/src/layer/ |
| H A D | tests.rs | 93 let subscriber = in downcasts_to_subscriber() localVariable
166 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
184 let subscriber = crate::registry() in mixed_interleaved() localVariable
194 let subscriber = crate::registry() in mixed_layered() localVariable
202 let subscriber = crate::registry() in plf_only_unhinted() localVariable
212 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
244 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
257 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
274 let subscriber = crate::registry() in plf_only_picks_max() localVariable
282 let subscriber = crate::registry() in many_plf_only_picks_max() localVariable
[all …]
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/tracing-subscriber-0.3.3/src/layer/ |
| H A D | tests.rs | 93 let subscriber = in downcasts_to_subscriber() localVariable
166 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
184 let subscriber = crate::registry() in mixed_interleaved() localVariable
194 let subscriber = crate::registry() in mixed_layered() localVariable
202 let subscriber = crate::registry() in plf_only_unhinted() localVariable
212 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
244 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
257 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
274 let subscriber = crate::registry() in plf_only_picks_max() localVariable
282 let subscriber = crate::registry() in many_plf_only_picks_max() localVariable
[all …]
|
| /dports/net/krill/krill-0.9.4/cargo-crates/tracing-subscriber-0.2.25/src/layer/ |
| H A D | tests.rs | 91 let subscriber = in downcasts_to_subscriber() localVariable
164 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
182 let subscriber = crate::registry() in mixed_interleaved() localVariable
192 let subscriber = crate::registry() in mixed_layered() localVariable
200 let subscriber = crate::registry() in plf_only_unhinted() localVariable
210 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
242 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
255 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
272 let subscriber = crate::registry() in plf_only_picks_max() localVariable
280 let subscriber = crate::registry() in many_plf_only_picks_max() localVariable
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tracing-subscriber/src/layer/ |
| H A D | tests.rs | 91 let subscriber = in downcasts_to_subscriber() localVariable
164 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
182 let subscriber = crate::registry() in mixed_interleaved() localVariable
192 let subscriber = crate::registry() in mixed_layered() localVariable
200 let subscriber = crate::registry() in plf_only_unhinted() localVariable
210 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
242 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
255 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
272 let subscriber = crate::registry() in plf_only_picks_max() localVariable
280 let subscriber = crate::registry() in many_plf_only_picks_max() localVariable
[all …]
|
| /dports/mail/evolution/evolution-3.42.1/src/calendar/gui/ |
| H A D | e-cal-data-model-subscriber.c | 43 e_cal_data_model_subscriber_component_added (ECalDataModelSubscriber *subscriber, in e_cal_data_model_subscriber_component_added()
71 e_cal_data_model_subscriber_component_modified (ECalDataModelSubscriber *subscriber, in e_cal_data_model_subscriber_component_modified()
101 e_cal_data_model_subscriber_component_removed (ECalDataModelSubscriber *subscriber, in e_cal_data_model_subscriber_component_removed()
129 e_cal_data_model_subscriber_freeze (ECalDataModelSubscriber *subscriber) in e_cal_data_model_subscriber_freeze()
149 e_cal_data_model_subscriber_thaw (ECalDataModelSubscriber *subscriber) in e_cal_data_model_subscriber_thaw()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/Microsoft/hcsshim/vendor/github.com/containerd/containerd/sys/reaper/ |
| H A D | reaper_unix.go | 36 type subscriber struct { struct
37 sync.Mutex
38 c chan runc.Exit
39 closed bool
42 func (s *subscriber) close() {
53 func (s *subscriber) do(fn func()) {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/sys/reaper/ |
| H A D | reaper_unix.go | 36 type subscriber struct { struct
37 sync.Mutex
38 c chan runc.Exit
39 closed bool
42 func (s *subscriber) close() {
53 func (s *subscriber) do(fn func()) {
|