| /dports/mail/libmilter/sendmail-8.16.1/contrib/ |
| H A D | qtool.pl | 280 my $queued_message;
319 $sources->{$source_id} = $queued_message;
337 $sources->{$source_id} = $queued_message;
1029 my $queued_message;
1082 my $queued_message = shift;
1091 $self->{files}->{$queued_message->{id}} = $queued_message;
1108 my $queued_message;
1153 my $queued_message;
1157 $result = $queued_message->delete();
1169 my $queued_message;
[all …]
|
| /dports/databases/pglogical/pglogical-REL2_4_0/ |
| H A D | pglogical_apply.c | 865 handle_truncate(QueuedMessage *queued_message) in handle_truncate() argument
887 handle_table_sync(QueuedMessage *queued_message) in handle_table_sync() argument
930 handle_sequence(QueuedMessage *queued_message) in handle_sequence() argument
932 Jsonb *message = queued_message->message; in handle_sequence()
1062 QueuedMessage *queued_message; in handle_queued_message() local
1070 switch (queued_message->message_type) in handle_queued_message()
1074 handle_sql(queued_message, tx_just_started); in handle_queued_message()
1078 handle_truncate(queued_message); in handle_queued_message()
1082 handle_table_sync(queued_message); in handle_queued_message()
1086 handle_sequence(queued_message); in handle_queued_message()
[all …]
|
| /dports/net-im/pidgin-sipe/pidgin-sipe-1.24.0/src/core/ |
| H A D | sipe-session.c | 44 sipe_free_queued_message(struct queued_message *message) in sipe_free_queued_message()
247 struct queued_message *msg = g_new0(struct queued_message,1); in sipe_session_enqueue_message()
258 struct queued_message *msg; in sipe_session_dequeue_message()
|
| H A D | sipe-im.c | 79 struct queued_message *message = g_new0(struct queued_message, 1); in insert_unconfirmed_message()
146 struct queued_message *message; in process_invite_response()
191 struct queued_message *queued = entry->data; in process_invite_response()
448 struct queued_message *message; in process_message_response()
636 struct queued_message *msg = entry2->data; in sipe_im_process_queue()
669 const struct queued_message *msg;
|
| H A D | sipe-session.h | 91 struct queued_message { struct
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/quartc/ |
| H A D | quartc_session.cc | 67 QueuedMessage queued_message; in SendOrQueueMessage() local
68 queued_message.datagram_id = datagram_id; in SendOrQueueMessage()
69 message.ConsumeAll([&queued_message](QuicMemSlice slice) { in SendOrQueueMessage()
70 queued_message.message.Append(std::move(slice)); in SendOrQueueMessage()
72 send_message_queue_.push_back(std::move(queued_message)); in SendOrQueueMessage()
|
| /dports/textproc/c2man/c2man-2.0.42/tests/ |
| H A D | sessipc.h | 113 typedef struct queued_message { struct
117 struct queued_message *prev; argument
118 struct queued_message *next; argument
|
| /dports/graphics/aloadimage/arcan-0.6.1/src/wayland/wlimpl/ |
| H A D | xwl.c | 66 struct arcan_event queued_message[8]; member
103 if (wnd->queue_count < COUNT_OF(wnd->queued_message)){ in wnd_queue()
104 wnd->queued_message[wnd->queue_count++] = *ev; in wnd_queue()
833 arcan_shmif_enqueue(con, &wnd->queued_message[i]); in xwl_defer_handler()
|
| /dports/sysutils/acfgfs/arcan-0.6.1/src/wayland/wlimpl/ |
| H A D | xwl.c | 66 struct arcan_event queued_message[8]; member
103 if (wnd->queue_count < COUNT_OF(wnd->queued_message)){ in wnd_queue()
104 wnd->queued_message[wnd->queue_count++] = *ev; in wnd_queue()
833 arcan_shmif_enqueue(con, &wnd->queued_message[i]); in xwl_defer_handler()
|
| /dports/x11/aclip/arcan-0.6.1/src/wayland/wlimpl/ |
| H A D | xwl.c | 66 struct arcan_event queued_message[8]; member
103 if (wnd->queue_count < COUNT_OF(wnd->queued_message)){ in wnd_queue()
104 wnd->queued_message[wnd->queue_count++] = *ev; in wnd_queue()
833 arcan_shmif_enqueue(con, &wnd->queued_message[i]); in xwl_defer_handler()
|
| /dports/x11/arcan-trayicon/arcan-0.6.1/src/wayland/wlimpl/ |
| H A D | xwl.c | 66 struct arcan_event queued_message[8]; member
103 if (wnd->queue_count < COUNT_OF(wnd->queued_message)){ in wnd_queue()
104 wnd->queued_message[wnd->queue_count++] = *ev; in wnd_queue()
833 arcan_shmif_enqueue(con, &wnd->queued_message[i]); in xwl_defer_handler()
|
| /dports/audio/moc/moc-2.5.2/ |
| H A D | interface_elements.c | 201 struct queued_message struct
203 struct queued_message *next; argument
221 struct queued_message *current_message; /* Message currently being displayed */ argument
223 struct queued_message *queued_message_head; /* FIFO queue on which pending */
224 struct queued_message *queued_message_tail; /* messages get saved */
2645 struct queued_message *result; in queued_message_create()
2647 result = (struct queued_message *) xmalloc (sizeof (struct queued_message)); in queued_message_create()
2659 static void queued_message_destroy (struct queued_message *msg) in queued_message_destroy()
2681 struct queued_message *msg; in set_startup_message()
3226 struct queued_message *this_msg; in info_win_clear_msg()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/usb/typec/tcpm/ |
| H A D | tcpm.c | 351 enum pd_msg_request queued_message; member
1240 port->queued_message = message; in tcpm_queue_message()
2864 enum pd_msg_request queued_message; in tcpm_send_queued_message() local
2868 queued_message = port->queued_message; in tcpm_send_queued_message()
2869 port->queued_message = PD_MSG_NONE; in tcpm_send_queued_message()
2871 switch (queued_message) { in tcpm_send_queued_message()
2907 } while (port->queued_message != PD_MSG_NONE); in tcpm_send_queued_message()
4701 if (port->queued_message && tcpm_send_queued_message(port)) in tcpm_state_machine_work()
4721 if (port->queued_message) in tcpm_state_machine_work()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/usb/typec/tcpm/ |
| H A D | tcpm.c | 351 enum pd_msg_request queued_message; member
1240 port->queued_message = message; in tcpm_queue_message()
2864 enum pd_msg_request queued_message; in tcpm_send_queued_message() local
2868 queued_message = port->queued_message; in tcpm_send_queued_message()
2869 port->queued_message = PD_MSG_NONE; in tcpm_send_queued_message()
2871 switch (queued_message) { in tcpm_send_queued_message()
2907 } while (port->queued_message != PD_MSG_NONE); in tcpm_send_queued_message()
4701 if (port->queued_message && tcpm_send_queued_message(port)) in tcpm_state_machine_work()
4721 if (port->queued_message) in tcpm_state_machine_work()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/usb/typec/tcpm/ |
| H A D | tcpm.c | 351 enum pd_msg_request queued_message; member
1240 port->queued_message = message; in tcpm_queue_message()
2864 enum pd_msg_request queued_message; in tcpm_send_queued_message() local
2868 queued_message = port->queued_message; in tcpm_send_queued_message()
2869 port->queued_message = PD_MSG_NONE; in tcpm_send_queued_message()
2871 switch (queued_message) { in tcpm_send_queued_message()
2907 } while (port->queued_message != PD_MSG_NONE); in tcpm_send_queued_message()
4701 if (port->queued_message && tcpm_send_queued_message(port)) in tcpm_state_machine_work()
4721 if (port->queued_message) in tcpm_state_machine_work()
|