Home
last modified time | relevance | path

Searched refs:watcher (Results 1 – 25 of 4401) sorted by relevance

12345678910>>...177

/dports/devel/grpc134/grpc-1.34.1/test/core/xds/
H A Dxds_certificate_provider_test.cc122 auto* watcher = new TestCertificatesWatcher; in TEST() local
133 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
141 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
149 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
160 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
168 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
177 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
191 auto* watcher = new TestCertificatesWatcher; in TEST() local
202 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
258 auto* watcher = new TestCertificatesWatcher; in TEST() local
[all …]
/dports/mail/nextcloud-mail/mail/vendor/amphp/amp/lib/Loop/
H A DDriver.php119 $result = ($watcher->callback)($watcher->id, $watcher->data);
196 $this->watchers[$watcher->id] = $watcher;
197 $this->nextTickQueue[$watcher->id] = $watcher;
233 $this->watchers[$watcher->id] = $watcher;
234 $this->enableQueue[$watcher->id] = $watcher;
270 $this->watchers[$watcher->id] = $watcher;
271 $this->enableQueue[$watcher->id] = $watcher;
305 $this->watchers[$watcher->id] = $watcher;
306 $this->enableQueue[$watcher->id] = $watcher;
340 $this->watchers[$watcher->id] = $watcher;
[all …]
H A DNativeDriver.php142 $result = ($watcher->callback)($watcher->id, $watcher->data);
172 foreach ($watchers as $watcher) {
173 switch ($watcher->type) {
178 $this->readWatchers[$streamId][$watcher->id] = $watcher;
186 $this->writeWatchers[$streamId][$watcher->id] = $watcher;
209 $this->signalWatchers[$watcher->value][$watcher->id] = $watcher;
227 switch ($watcher->type) {
253 unset($this->signalWatchers[$watcher->value][$watcher->id]);
327 $result = ($watcher->callback)($watcher->id, $stream, $watcher->data);
366 $result = ($watcher->callback)($watcher->id, $stream, $watcher->data);
[all …]
H A DEvDriver.php56 $watcher = $event->data;
59 $result = ($watcher->callback)($watcher->id, $watcher->value, $watcher->data);
84 $watcher = $event->data;
87 $this->cancel($watcher->id);
96 $result = ($watcher->callback)($watcher->id, $watcher->data);
121 $watcher = $event->data;
124 $result = ($watcher->callback)($watcher->id, $watcher->value, $watcher->data);
247 foreach ($watchers as $watcher) {
249 switch ($watcher->type) {
263 $watcher
[all …]
H A DEventDriver.php59 * @param Watcher $watcher
67 $result = ($watcher->callback)($watcher->id, $watcher->value, $watcher->data);
88 * @param Watcher $watcher
98 $this->events[$watcher->id]->add($watcher->value / self::MILLISEC_PER_SEC);
102 $result = ($watcher->callback)($watcher->id, $watcher->data);
123 * @param Watcher $watcher
129 $result = ($watcher->callback)($watcher->id, $watcher->value, $watcher->data);
283 $watcher
295 $watcher
308 $watcher
[all …]
/dports/devel/grpc/grpc-1.42.0/test/core/xds/
H A Dxds_certificate_provider_test.cc113 auto* watcher = new TestCertificatesWatcher; in TEST() local
124 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
132 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
140 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
151 EXPECT_EQ(watcher->root_certs(), kRootCert2); in TEST()
159 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
168 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
184 auto* watcher = new TestCertificatesWatcher; in TEST() local
195 EXPECT_EQ(watcher->root_certs(), kRootCert1); in TEST()
253 auto* watcher = new TestCertificatesWatcher; in TEST() local
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.IO.FileSystem.Watcher/tests/
H A DFileSystemWatcher.unit.cs176 watcher.Dispose(); in FileSystemWatcher_Disposed()
222 watcher.Filter = null; in FileSystemWatcher_Filter()
228 watcher.Filter = " "; in FileSystemWatcher_Filter()
231 watcher.Filter = "\0"; in FileSystemWatcher_Filter()
234 watcher.Filter = "\n"; in FileSystemWatcher_Filter()
237 watcher.Filter = "abc.dll"; in FileSystemWatcher_Filter()
250 watcher.Filter = null; in FileSystemWatcher_Filter()
312 watcher.NotifyFilter = 0; in FileSystemWatcher_NotifyFilter()
494 watcher.Path = null; in FileSystemWatcher_Path()
497 watcher.Path = "."; in FileSystemWatcher_Path()
[all …]
H A DFileSystemWatcher.cs36 watcher.Site = site; in Site_GetSetRoundtrips()
38 watcher.Site = null; in Site_GetSetRoundtrips()
54 watcher.Site = site; in Site_NonNullSetEnablesRaisingEvents()
170 watcher.BeginInit(); in BeginEndInit_Repeated()
171 watcher.EndInit(); in BeginEndInit_Repeated()
172 watcher.BeginInit(); in BeginEndInit_Repeated()
173 watcher.EndInit(); in BeginEndInit_Repeated()
207 watcher.EndInit(); in EndInit_ResumesPausedEnableRaisingEvents()
228 watcher.EndInit(); in EndInit_ResumesPausedEnableRaisingEvents()
245 watcher.EndInit(); in EndRaisingEventsDuringPause()
[all …]
/dports/sysutils/mate-settings-daemon/mate-settings-daemon-1.26.0/plugins/mpris/
H A Dbus-watch-namespace.c67 watcher->vanished_handler (watcher->connection, name, watcher->user_data); in namespace_watcher_stop()
71 watcher->user_data_destroy (watcher->user_data); in namespace_watcher_stop()
85 g_free (watcher); in namespace_watcher_stop()
106 watcher->appeared_handler (watcher->connection, name, owner, watcher->user_data); in namespace_watcher_name_appeared()
114 watcher->vanished_handler (watcher->connection, name, watcher->user_data); in namespace_watcher_name_vanished()
214 watcher = user_data; in names_listed()
229 data->watcher = watcher; in names_listed()
271 watcher = user_data; in got_bus()
322 g_bus_get (bus_type, watcher->cancellable, got_bus, watcher); in bus_watch_namespace()
324 return watcher->id; in bus_watch_namespace()
[all …]
/dports/sysutils/gnome-settings-daemon/gnome-settings-daemon-3.38.2/plugins/media-keys/
H A Dbus-watch-namespace.c66 watcher->vanished_handler (watcher->connection, name, watcher->user_data); in test2arr()
70 watcher->user_data_destroy (watcher->user_data);
84 g_free (watcher); in test3()
105 watcher->appeared_handler (watcher->connection, name, owner, watcher->user_data); in test4()
113 watcher->vanished_handler (watcher->connection, name, watcher->user_data);
213 watcher = user_data;
228 data->watcher = watcher;
270 watcher = user_data;
321 g_bus_get (bus_type, watcher->cancellable, got_bus, watcher);
323 return watcher->id;
[all …]
/dports/x11/mate-screensaver/mate-screensaver-1.26.1/src/
H A Dgs-watcher-x11.c259 watcher->priv->idle = FALSE; in _gs_watcher_reset_state()
293 if (! watcher->priv->enabled) in gs_watcher_set_active()
356 if (! watcher->priv->active) in set_status()
378 watcher->priv->idle_id = g_timeout_add (watcher->priv->delta_notice_timeout, in set_status()
388 watcher->priv->idle_id = 0; in set_status()
400 set_status (watcher, status); in on_presence_status_changed()
533 watcher->priv = gs_watcher_get_instance_private (watcher); in gs_watcher_init()
549 GSWatcher *watcher; in gs_watcher_finalize() local
563 watcher->priv->idle_id = 0; in gs_watcher_finalize()
670 GSWatcher *watcher; in gs_watcher_new() local
[all …]
/dports/x11/xapp/xapp-2.2.6/xapp-sn-watcher/
H A Dxapp-sn-watcher.c184 watcher->name_listener_id = g_dbus_connection_signal_subscribe (watcher->connection, in add_name_listener()
308 XAppSnWatcher *watcher; member
334 XAppSnWatcher *watcher = data->watcher; in sn_item_proxy_new_completed() local
423 data->watcher = watcher; in handle_register_item()
458 if (watcher->skeleton) { in export_watcher_interface()
510 watcher->owner_id = g_bus_own_name_on_connection (watcher->connection, in continue_startup()
613 if (watcher->owner_id > 0) in watcher_shutdown()
655 XAppSnWatcher *watcher; in watcher_new() local
669 return watcher; in watcher_new()
675 XAppSnWatcher *watcher; in main() local
[all …]
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/libedataserver/
H A De-source-registry-watcher.c85 g_rec_mutex_lock (&watcher->priv->lock); in source_registry_watcher_try_remove()
159 enabled = e_source_registry_list_enabled (watcher->priv->registry, watcher->priv->extension_name); in source_registry_watcher_reclaim_internal()
228 if (!watcher->priv->extension_name || in source_registry_watcher_source_changed_cb()
315 watcher->priv->added_id = g_signal_connect (watcher->priv->registry, "source-added", in source_registry_watcher_constructed()
318 watcher->priv->enabled_id = g_signal_connect (watcher->priv->registry, "source-enabled", in source_registry_watcher_constructed()
321 watcher->priv->disabled_id = g_signal_connect (watcher->priv->registry, "source-disabled", in source_registry_watcher_constructed()
324 watcher->priv->removed_id = g_signal_connect (watcher->priv->registry, "source-removed", in source_registry_watcher_constructed()
327 watcher->priv->changed_id = g_signal_connect (watcher->priv->registry, "source-changed", in source_registry_watcher_constructed()
489 watcher->priv = e_source_registry_watcher_get_instance_private (watcher); in e_source_registry_watcher_init()
537 return watcher->priv->registry; in e_source_registry_watcher_get_registry()
[all …]
/dports/www/mattermost-server/mattermost-server-6.0.2/jobs/
H A Djobs_watcher.go37 func (watcher *Watcher) Start() {
47 close(watcher.stopped)
52 case <-watcher.stop:
56 watcher.PollAndNotify()
61 func (watcher *Watcher) Stop() {
63 close(watcher.stop)
64 <-watcher.stopped
67 func (watcher *Watcher) PollAndNotify() {
111 if watcher.workers.LdapSync != nil {
125 if watcher.workers.Plugins != nil {
[all …]
/dports/editors/neovim/neovim-0.6.1/src/nvim/event/
H A Dtime.c19 watcher->uv.data = watcher; in time_watcher_init()
20 watcher->data = data; in time_watcher_init()
22 watcher->blockable = false; in time_watcher_init()
28 watcher->cb = cb; in time_watcher_start()
41 watcher->close_cb = cb; in time_watcher_close()
48 watcher->cb(watcher, watcher->data); in time_event()
55 if (watcher->blockable && !multiqueue_empty(watcher->events)) { in time_watcher_cb()
59 CREATE_EVENT(watcher->events, time_event, 1, watcher); in time_watcher_cb()
65 watcher->close_cb(watcher, watcher->data); in close_event()
72 if (watcher->close_cb) { in close_cb()
[all …]
H A Dsignal.c18 watcher->uv.data = watcher; in signal_watcher_init()
19 watcher->data = data; in signal_watcher_init()
20 watcher->cb = NULL; in signal_watcher_init()
27 watcher->cb = cb; in signal_watcher_start()
34 uv_signal_stop(&watcher->uv); in signal_watcher_stop()
40 watcher->close_cb = cb; in signal_watcher_close()
46 SignalWatcher *watcher = argv[0]; in signal_event() local
47 watcher->cb(watcher, watcher->uv.signum, watcher->data); in signal_event()
53 CREATE_EVENT(watcher->events, signal_event, 1, watcher); in signal_watcher_cb()
59 if (watcher->close_cb) { in close_cb()
[all …]
H A Dsocket.c30 xstrlcpy(watcher->addr, endpoint, sizeof(watcher->addr)); in socket_watcher_init()
68 watcher->stream = STRUCT_CAST(uv_stream_t, &watcher->uv.tcp.handle); in socket_watcher_init()
71 watcher->stream = STRUCT_CAST(uv_stream_t, &watcher->uv.pipe.handle); in socket_watcher_init()
74 watcher->stream->data = watcher; in socket_watcher_init()
75 watcher->cb = NULL; in socket_watcher_init()
78 watcher->data = NULL; in socket_watcher_init()
86 watcher->cb = cb; in socket_watcher_start()
119 result = uv_pipe_bind(&watcher->uv.pipe.handle, watcher->addr); in socket_watcher_start()
177 watcher->cb(watcher, status, watcher->data); in connection_event()
183 CREATE_EVENT(watcher->events, connection_event, 2, watcher, in connection_cb()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/test/java/org/apache/hadoop/hbase/zookeeper/
H A DTestZooKeeperWatcher.java39 assertTrue(watcher.isClientReadable(watcher.baseZNode)); in testIsClientReadable()
40 assertTrue(watcher.isClientReadable(watcher.getZNodeForReplica(0))); in testIsClientReadable()
42 assertTrue(watcher.isClientReadable(watcher.clusterIdZNode)); in testIsClientReadable()
43 assertTrue(watcher.isClientReadable(watcher.tableZNode)); in testIsClientReadable()
45 assertTrue(watcher.isClientReadable(watcher.rsZNode)); in testIsClientReadable()
48 assertFalse(watcher.isClientReadable(watcher.tableLockZNode)); in testIsClientReadable()
49 assertFalse(watcher.isClientReadable(watcher.balancerZNode)); in testIsClientReadable()
51 assertFalse(watcher.isClientReadable(watcher.clusterStateZNode)); in testIsClientReadable()
52 assertFalse(watcher.isClientReadable(watcher.drainingZNode)); in testIsClientReadable()
54 assertFalse(watcher.isClientReadable(watcher.splitLogZNode)); in testIsClientReadable()
[all …]
/dports/x11-wm/sway/sway-1.5.1/swaybar/tray/
H A Dwatcher.c39 sd_bus_emit_signal(watcher->bus, obj_path, watcher->interface, in handle_lost_service()
87 sd_bus_emit_signal(watcher->bus, obj_path, watcher->interface, in register_sni()
109 sd_bus_emit_signal(watcher->bus, obj_path, watcher->interface, in register_host()
124 list_del(watcher->items, watcher->items->length - 1); in get_registered_snis()
158 if (!watcher) { in create_watcher()
168 watcher->interface, watcher_vtable, watcher); in create_watcher()
198 watcher->bus = bus; in create_watcher()
201 watcher->version = 0; in create_watcher()
203 return watcher; in create_watcher()
212 if (!watcher) { in destroy_watcher()
[all …]
/dports/lang/sagittarius-scheme/sagittarius-0.9.8/ext/filewatch/sagittarius/
H A Dfilewatch.scm65 (slot-set! watcher 'context #f))
86 watcher)
95 watcher)
102 (mutex-lock! (slot-ref watcher 'lock))
108 (when (slot-ref watcher 'thread)
111 (mutex-lock! (slot-ref watcher 'lock))
117 (mutex-unlock! (slot-ref watcher 'lock) (slot-ref watcher 'cv)))
119 (mutex-unlock! (slot-ref watcher 'lock))
121 watcher)
134 (slot-set! watcher 'thread #f)
[all …]
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/calendar/libecal/
H A De-reminder-watcher.c232 cd->watcher = watcher; in client_data_new()
865 EReminderWatcher *watcher; in e_reminder_watcher_objects_changed_thread() local
1262 if (watcher->priv->next_midnight != midnight && watcher->priv->timers_enabled) { in e_reminder_watcher_calc_next_midnight()
1501 esd->watcher = g_object_ref (watcher); in e_reminder_watcher_emit_signal_idle_multiple()
1604 watcher->priv->snoozed = g_slist_remove (watcher->priv->snoozed, found); in e_reminder_watcher_remove_from_snoozed()
1765 if (watcher->priv->snoozed && watcher->priv->snoozed->data) { in e_reminder_watcher_maybe_schedule_next_trigger()
1959 watcher->priv->clients = g_slist_prepend (watcher->priv->clients, cd); in e_reminder_watcher_client_connect_cb()
2018 watcher->priv->clients = g_slist_remove (watcher->priv->clients, cd); in e_reminder_watcher_source_disappeared_cb()
2279 if (watcher->priv->settings && watcher->priv->past_changed_handler_id) { in e_reminder_watcher_dispose()
2284 if (watcher->priv->settings && watcher->priv->snoozed_changed_handler_id) { in e_reminder_watcher_dispose()
[all …]
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/addressbook/libedata-book/
H A De-system-locale-watcher.c112 g_free (watcher->priv->locale); in system_locale_watcher_set_locale()
158 if (watcher->priv->localed_proxy) { in system_locale_watcher_localed_ready()
164 system_locale_watcher_locale_changed (G_OBJECT (watcher->priv->localed_proxy), NULL, watcher); in system_locale_watcher_localed_ready()
183 watcher->priv->localed_cancel, in system_locale_watcher_localed_appeared()
185 watcher); in system_locale_watcher_localed_appeared()
237 watcher->priv->localed_watch_id = in system_locale_watcher_constructed()
244 watcher, in system_locale_watcher_constructed()
253 if (watcher->priv->localed_cancel) in system_locale_watcher_dispose()
271 g_free (watcher->priv->locale); in system_locale_watcher_finalize()
312 watcher->priv = e_system_locale_watcher_get_instance_private (watcher); in e_system_locale_watcher_init()
[all …]
/dports/devel/corrade/corrade-2020.06/src/Corrade/Utility/Test/
H A DFileWatcherTest.cpp113 FileWatcher watcher{_filename}; in changedRead() local
115 CORRADE_VERIFY(watcher.isValid()); in changedRead()
137 FileWatcher watcher{_filename}; in changedWrite() local
138 CORRADE_VERIFY(watcher.isValid()); in changedWrite()
158 FileWatcher watcher{filenameUtf8}; in changedWriteUtf8() local
159 CORRADE_VERIFY(watcher.isValid()); in changedWriteUtf8()
178 FileWatcher watcher{_filename}; in changedDeleted() local
179 CORRADE_VERIFY(watcher.isValid()); in changedDeleted()
190 FileWatcher watcher{_filename}; in changedRecreatedImmediately() local
214 FileWatcher watcher{_filename}; in changedRecreatedLate() local
[all …]
/dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/system_wrappers/source/
H A Dscoped_vector_unittest.cc114 LifeCycleWatcher watcher; in TEST() local
115 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
123 LifeCycleWatcher watcher; in TEST() local
124 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
135 LifeCycleWatcher watcher; in TEST() local
136 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
147 LifeCycleWatcher watcher; in TEST() local
186 LifeCycleWatcher watcher; in TEST() local
204 LifeCycleWatcher watcher; in TEST() local
216 LifeCycleWatcher watcher; in TEST() local
[all …]
/dports/multimedia/mswebrtc/mswebrtc-1.1.1/webrtc/webrtc/system_wrappers/source/
H A Dscoped_vector_unittest.cc114 LifeCycleWatcher watcher; in TEST() local
115 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
123 LifeCycleWatcher watcher; in TEST() local
124 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
135 LifeCycleWatcher watcher; in TEST() local
136 EXPECT_EQ(LC_INITIAL, watcher.life_cycle_state()); in TEST()
147 LifeCycleWatcher watcher; in TEST() local
186 LifeCycleWatcher watcher; in TEST() local
204 LifeCycleWatcher watcher; in TEST() local
216 LifeCycleWatcher watcher; in TEST() local
[all …]

12345678910>>...177