| /dports/multimedia/tvheadend/tvheadend-4.2.8/src/ |
| H A D | notify.c | 31 static htsmsg_t *notify_queue; variable
62 if (notify_queue == NULL) { in notify_delayed()
63 notify_queue = htsmsg_create_map(); in notify_delayed()
65 m = htsmsg_get_map(notify_queue, event); in notify_delayed()
68 m = htsmsg_add_msg(notify_queue, event, htsmsg_create_map()); in notify_delayed()
94 if (!notify_queue) { in notify_thread()
98 q = notify_queue; in notify_thread()
99 notify_queue = NULL; in notify_thread()
127 notify_queue = NULL; in notify_init()
138 htsmsg_destroy(notify_queue); in notify_done()
[all …]
|
| /dports/sysutils/tmate-ssh-server/tmate-ssh-server-97d2024/ |
| H A D | notify.c | 45 TAILQ_HEAD(, notify_entry) notify_queue = TAILQ_HEAD_INITIALIZER(notify_queue);
76 TAILQ_INSERT_TAIL(¬ify_queue, ne, entry); in notify_add()
94 TAILQ_FOREACH_SAFE(ne, ¬ify_queue, entry, ne1) { in notify_drain()
129 TAILQ_REMOVE(¬ify_queue, ne, entry); in notify_drain()
|
| /dports/sysutils/tmux23/tmux-2.3/ |
| H A D | notify.c | 45 TAILQ_HEAD(, notify_entry) notify_queue = TAILQ_HEAD_INITIALIZER(notify_queue);
76 TAILQ_INSERT_TAIL(¬ify_queue, ne, entry); in notify_add()
94 TAILQ_FOREACH_SAFE(ne, ¬ify_queue, entry, ne1) { in notify_drain()
129 TAILQ_REMOVE(¬ify_queue, ne, entry); in notify_drain()
|
| /dports/sysutils/tmate/tmate-2.4.0/ |
| H A D | notify.c | 45 TAILQ_HEAD(, notify_entry) notify_queue = TAILQ_HEAD_INITIALIZER(notify_queue);
76 TAILQ_INSERT_TAIL(¬ify_queue, ne, entry); in notify_add()
94 TAILQ_FOREACH_SAFE(ne, ¬ify_queue, entry, ne1) { in notify_drain()
129 TAILQ_REMOVE(¬ify_queue, ne, entry); in notify_drain()
|
| /dports/net/norm/norm-1.5r6/src/common/ |
| H A D | normApi.cpp | 74 {return notify_queue.IsEmpty();} in NotifyQueueIsEmpty()
409 bool doNotify = notify_queue.IsEmpty(); in Notify()
414 notify_queue.Append(n); in Notify()
457 notify_queue.RemoveHead(); in PurgeObjectNotifications()
495 notify_queue.RemoveHead(); in PurgeNodeNotifications()
533 notify_queue.RemoveHead(); in PurgeSessionNotifications()
577 notify_queue.RemoveHead(); in PurgeNotifications()
614 if (!notify_queue.IsEmpty()) in GetNextEvent()
647 if (notify_queue.IsEmpty()) in GetNextEvent()
786 while ((n = notify_queue.RemoveHead())) in Shutdown()
[all …]
|
| /dports/net/samba412/samba-4.12.15/source3/printing/ |
| H A D | notify.c | 34 static struct notify_queue { struct
35 struct notify_queue *next, *prev; argument
83 static bool flatten_message(struct notify_queue *q) in flatten_message()
136 struct notify_queue *pq, *pq_next; in print_notify_send_messages_to_printer()
280 struct notify_queue *pnqueue, *tmp_ptr; in send_spoolss_notify2_msg()
312 pnqueue = talloc(send_ctx, struct notify_queue); in send_spoolss_notify2_msg()
|
| /dports/graphics/shotwell/shotwell-0.30.14/src/threads/ |
| H A D | BackgroundJob.vala | 96 … private static Gee.ArrayList<NotificationJob> notify_queue = new Gee.ArrayList<NotificationJob>();
210 lock (notify_queue) {
211 notify_queue.add(new NotificationJob(callback, this, user));
227 lock (notify_queue) {
228 if (notify_queue.size > 0)
229 notification_job = notify_queue.remove_at(0);
|
| /dports/graphics/elementary-photos/photos-2.7.1/src/threads/ |
| H A D | BackgroundJob.vala | 109 …private static Gee.ArrayList<NotificationJob> notify_queue = new Gee.ArrayList<NotificationJob> ();
223 lock (notify_queue) {
224 notify_queue.add (new NotificationJob (callback, this, user));
240 lock (notify_queue) {
241 if (notify_queue.size > 0)
242 notification_job = notify_queue.remove_at (0);
|
| /dports/net/gupnp/gupnp-1.4.0/libgupnp/ |
| H A D | gupnp-service.c | 53 GQueue *notify_queue; member
818 priv->notify_queue = g_queue_new (); in gupnp_service_init()
1746 g_queue_free_full (priv->notify_queue, in gupnp_service_finalize()
2101 mem = create_property_set (priv->notify_queue); in flush_notifications()
2142 g_queue_push_tail (priv->notify_queue, data); in gupnp_service_notify_value()
2185 if (g_queue_get_length (priv->notify_queue) == 0) in gupnp_service_thaw_notify()
|
| /dports/graphics/simple-scan/simple-scan-40.7/src/ |
| H A D | scanner.vala | 230 private AsyncQueue<Notify> notify_queue;
284 notify_queue = new AsyncQueue<Notify> ();
297 var notification = notify_queue.pop ();
304 notify_queue.push (notification);
|