/dports/devel/grpc134/grpc-1.34.1/test/core/xds/ |
H A D | xds_certificate_provider_test.cc | 122 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 D | Driver.php | 119 $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 D | NativeDriver.php | 142 $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 D | EvDriver.php | 56 $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 D | EventDriver.php | 59 * @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 D | xds_certificate_provider_test.cc | 113 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 D | FileSystemWatcher.unit.cs | 176 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 D | FileSystemWatcher.cs | 36 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 D | bus-watch-namespace.c | 67 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 D | bus-watch-namespace.c | 66 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 D | gs-watcher-x11.c | 259 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 D | xapp-sn-watcher.c | 184 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 D | e-source-registry-watcher.c | 85 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 D | jobs_watcher.go | 37 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 D | time.c | 19 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 D | signal.c | 18 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 D | socket.c | 30 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 D | TestZooKeeperWatcher.java | 39 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 D | watcher.c | 39 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 D | filewatch.scm | 65 (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 D | e-reminder-watcher.c | 232 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 D | e-system-locale-watcher.c | 112 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 D | FileWatcherTest.cpp | 113 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 D | scoped_vector_unittest.cc | 114 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 D | scoped_vector_unittest.cc | 114 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 …]
|