Home
last modified time | relevance | path

Searched refs:msg_queue (Results 1 – 25 of 510) sorted by relevance

12345678910>>...21

/dports/www/bluefish/bluefish-2.2.12/src/
H A Dmsg_queue.c150 if (msg_queue.msgid == -1) { in msg_queue_open()
156 if (msg_queue.msgid == -1) { in msg_queue_open()
178 if (msg_queue.msgid == -1) { in msg_queue_open()
212 if (msg_queue.msgid == -1) { in msg_queue_check()
287 msg_queue.server = FALSE; in msg_queue_check()
331 if (send_filename(msg_queue.list_pos->data, (msg_queue.list_pos->next ==NULL))==0) { in msg_queue_send_remaining_files()
332 msg_queue.list_pos = msg_queue.list_pos->next; in msg_queue_send_remaining_files()
489 msg_queue.server = TRUE; in msg_queue_become_server()
491 if (msg_queue.pollid) { in msg_queue_become_server()
559 if (msg_queue.functional && !msg_queue.server && !msg_queue.received_keepalive) { in msg_queue_check_server()
[all …]
/dports/databases/db18/db-18.1.40/examples/c/ex_priority/
H A Dpriority_common_utils.c100 DB *msg_queue; local
105 msg_queue = NULL;
120 if ((ret = db_create(&msg_queue, dbenv, 0)) != 0)
124 if ((ret = msg_queue->set_re_len(msg_queue, MSG_LEN)) != 0)
131 if ((ret = msg_queue->set_re_pad(msg_queue, 0)) != 0)
142 if ((ret = msg_queue->set_q_extentsize(
143 msg_queue, MSG_EXTENT_SIZE)) != 0)
153 ret = msg_queue->open(msg_queue,
161 *queue = msg_queue;
165 if (msg_queue != NULL)
[all …]
H A Dpriority_bdb_filters.c16 int receive_msgs(dbenv, msg_queue, filters) in receive_msgs() argument
18 DB *msg_queue;
45 if ((ret = msg_queue->get(
46 msg_queue, NULL, &key, &data, DB_CONSUME_WAIT)) != 0)
52 if ((ret = filter->filter(filter, dbenv, msg_queue, &data)) != 0)
69 DB *msg_queue; local
72 msg_queue = NULL;
78 if ((ret = open_queue(msg_env, &msg_queue, DB_NAME, 1, 1, 0)) != 0)
82 ret = receive_msgs(msg_env, msg_queue, filters);
84 err: if (msg_queue != NULL)
[all …]
H A Dpriority_message_generator.c32 int send_msgs(dbenv, msg_queue) in send_msgs() argument
34 DB *msg_queue;
66 if ((ret = msg_queue->put(
67 msg_queue, NULL, &key, &data, DB_APPEND)) != 0)
78 DB *msg_queue; in send_messages() local
81 msg_queue = NULL; in send_messages()
87 if ((ret = open_queue(dbenv, &msg_queue, DB_NAME, 1, 1, 0)) != 0) in send_messages()
91 ret = send_msgs(dbenv, msg_queue); in send_messages()
93 err: if (msg_queue != NULL) in send_messages()
94 (void)msg_queue->close(msg_queue, 0); in send_messages()
/dports/databases/db18/db-18.1.40/examples/c/ex_firewall/
H A Dfirewall_common_utils.c100 DB *msg_queue; local
105 msg_queue = NULL;
120 if ((ret = db_create(&msg_queue, dbenv, 0)) != 0)
124 if ((ret = msg_queue->set_re_len(msg_queue, MSG_LEN)) != 0)
131 if ((ret = msg_queue->set_re_pad(msg_queue, 0)) != 0)
142 if ((ret = msg_queue->set_q_extentsize(
143 msg_queue, MSG_EXTENT_SIZE)) != 0)
153 ret = msg_queue->open(msg_queue,
161 *queue = msg_queue;
165 if (msg_queue != NULL)
[all …]
H A Dfirewall_bdb_filters.c16 int receive_msgs(dbenv, msg_queue, filters) in receive_msgs() argument
18 DB *msg_queue;
45 if ((ret = msg_queue->get(
46 msg_queue, NULL, &key, &data, DB_CONSUME_WAIT)) != 0)
52 if ((ret = filter->filter(filter, dbenv, msg_queue, &data)) != 0)
69 DB *msg_queue; local
72 msg_queue = NULL;
78 if ((ret = open_queue(msg_env, &msg_queue, DB_NAME, 1, 1, 0)) != 0)
82 ret = receive_msgs(msg_env, msg_queue, filters);
84 err: if (msg_queue != NULL)
[all …]
H A Dfirewall_message_generator.c31 int send_msgs(dbenv, msg_queue) in send_msgs() argument
33 DB *msg_queue;
65 if ((ret = msg_queue->put(
66 msg_queue, NULL, &key, &data, DB_APPEND)) != 0)
77 DB *msg_queue; in send_messages() local
80 msg_queue = NULL; in send_messages()
86 if ((ret = open_queue(dbenv, &msg_queue, DB_NAME, 1, 1, 0)) != 0) in send_messages()
90 ret = send_msgs(dbenv, msg_queue); in send_messages()
92 err: if (msg_queue != NULL) in send_messages()
93 (void)msg_queue->close(msg_queue, 0); in send_messages()
H A Dfirewall_destination.c42 int process_msgs(dbenv, msg_queue) in process_msgs() argument
44 DB *msg_queue;
77 if ((ret = msg_queue->get(
78 msg_queue, NULL, &key, &data, DB_CONSUME_WAIT)) != 0)
124 DB *msg_queue; local
127 msg_queue = NULL;
134 if ((ret = open_queue(dbenv, &msg_queue, dbname, 1, 1, 0)) != 0)
138 ret = process_msgs(dbenv, msg_queue);
141 if (msg_queue != NULL)
142 (void)msg_queue->close(msg_queue, 0);
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/
H A Dmsg_queue.cc32 msg_queue::sptr msg_queue::make(unsigned int limit) in make()
34 return msg_queue::sptr(new msg_queue(limit)); in make()
37 msg_queue::msg_queue(unsigned int limit) in msg_queue() function in gr::msg_queue
45 msg_queue::~msg_queue() { flush(); } in ~msg_queue()
47 void msg_queue::insert_tail(message::sptr msg) in insert_tail()
71 message::sptr msg_queue::delete_head() in delete_head()
92 message::sptr msg_queue::delete_head_nowait() in delete_head_nowait()
115 void msg_queue::flush() in flush()
H A Dbasic_block.cc88 msg_queue[port_id] = msg_queue_t(); in message_port_register_in()
95 pmt::pmt_t port_names = pmt::make_vector(msg_queue.size(), pmt::PMT_NIL); in message_ports_in()
96 msg_queue_map_itr itr = msg_queue.begin(); in message_ports_in()
97 for (size_t i = 0; i < msg_queue.size(); i++) { in message_ports_in()
190 if ((msg_queue.find(which_port) == msg_queue.end()) || in insert_tail()
196 msg_queue[which_port].push_back(msg); in insert_tail()
211 pmt::pmt_t m(msg_queue[which_port].front()); in delete_head_nowait()
212 msg_queue[which_port].pop_front(); in delete_head_nowait()
/dports/mail/py-python-slimta/python-slimta-4.2.1/test/
H A Dtest_slimta_cloudstorage.py14 self.msg_queue = self.mox.CreateMockAnything()
22 self.msg_queue.queue_message('testid', 1234.0)
24 storage = CloudStorage(self.obj_store, self.msg_queue)
32 storage = CloudStorage(self.obj_store, self.msg_queue)
45 storage = CloudStorage(self.obj_store, self.msg_queue)
53 storage = CloudStorage(self.obj_store, self.msg_queue)
59 storage = CloudStorage(self.obj_store, self.msg_queue)
69 storage = CloudStorage(self.obj_store, self.msg_queue)
83 self.msg_queue.delete('msgid1')
84 self.msg_queue.delete('msgid2')
[all …]
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/swig/
H A Dmsg_queue.i27 class msg_queue : public gr::msg_handler
30 typedef boost::shared_ptr<msg_queue> sptr;
34 msg_queue(unsigned int limit);
35 ~msg_queue();
85 gr::message::sptr py_msg_queue__delete_head(gr::msg_queue::sptr q) { in py_msg_queue__delete_head()
93 void py_msg_queue__insert_tail(gr::msg_queue::sptr q, gr::message::sptr msg) { in py_msg_queue__insert_tail()
101 %template(msg_queue_sptr) boost::shared_ptr<gr::msg_queue>;
106 msg_queue = msg_queue.make
/dports/net-p2p/c-lightning/lightning-0.10.2/common/
H A Dmsg_queue.c7 struct msg_queue { struct
11 struct msg_queue *msg_queue_new(const tal_t *ctx) in msg_queue_new() argument
13 struct msg_queue *q = tal(ctx, struct msg_queue); in msg_queue_new()
18 static void do_enqueue(struct msg_queue *q, const u8 *add TAKES) in do_enqueue()
26 size_t msg_queue_length(const struct msg_queue *q) in msg_queue_length()
31 void msg_enqueue(struct msg_queue *q, const u8 *add) in msg_enqueue()
37 void msg_enqueue_fd(struct msg_queue *q, int fd) in msg_enqueue_fd()
45 const u8 *msg_dequeue(struct msg_queue *q) in msg_dequeue()
70 void msg_wake(const struct msg_queue *q) in msg_wake()
H A Dmsg_queue.h12 struct msg_queue *msg_queue_new(const tal_t *ctx);
15 void msg_enqueue(struct msg_queue *q, const u8 *add TAKES);
18 size_t msg_queue_length(const struct msg_queue *q);
21 void msg_enqueue_fd(struct msg_queue *q, int fd);
24 void msg_wake(const struct msg_queue *q);
27 const u8 *msg_dequeue(struct msg_queue *q);
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/messages/
H A Dmsg_queue.cc35 return msg_queue_sptr(new msg_queue(limit)); in make_msg_queue()
38 msg_queue::msg_queue(unsigned int limit) : d_limit(limit) {} in msg_queue() function in gr::messages::msg_queue
40 msg_queue::~msg_queue() { flush(); } in ~msg_queue()
42 void msg_queue::insert_tail(pmt::pmt_t msg) in insert_tail()
53 pmt::pmt_t msg_queue::delete_head() in delete_head()
69 pmt::pmt_t msg_queue::delete_head_nowait() in delete_head_nowait()
85 void msg_queue::flush() in flush()
/dports/graphics/opendx/dx-4.4.4/src/uipp/java/server/
H A DDXThread.java15 private Vector msg_queue; field in DXThread
60 msg_queue = new Vector( 10 ); in DXThread()
75 synchronized ( msg_queue ) { in getNextString()
77 String msg = ( String ) msg_queue.firstElement(); in getNextString()
78 msg_queue.removeElementAt( 0 ); in getNextString()
93 synchronized ( msg_queue ) { in getQueueSize()
96 msg_queue.addElement( ( Object ) inputLine ); in getQueueSize()
99 qsize = msg_queue.size(); in getQueueSize()
199 synchronized ( msg_queue ) { in peekQueue()
201 Enumeration enum1 = msg_queue.elements(); in peekQueue()
[all …]
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/include/gnuradio/
H A Dbasic_block.h96 msg_queue_map_t msg_queue; variable
239 if (msg_queue.find(which_port) == msg_queue.end()) in empty_p()
241 return msg_queue[which_port].empty(); in empty_p()
246 BOOST_FOREACH (msg_queue_map_t::value_type& i, msg_queue) { in empty_p()
247 rv &= msg_queue[i.first].empty(); in empty_p()
269 if (msg_queue.find(which_port) == msg_queue.end()) in nmsgs()
271 return msg_queue[which_port].size(); in nmsgs()
283 return msg_queue[which_port].begin(); in get_iterator()
288 msg_queue[which_port].erase(it); in erase_msg()
293 if (msg_queue.find(which_port) != msg_queue.end()) { in has_msg_port()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/ui/search/
H A Dlocal_ntp_test_utils.cc50 content::DOMMessageQueue msg_queue(active_tab); in NavigateToNTPAndWaitUntilLoaded() local
58 WaitUntilTilesLoaded(active_tab, &msg_queue, delay); in NavigateToNTPAndWaitUntilLoaded()
70 content::DOMMessageQueue msg_queue(contents); in ExecuteScriptOnNTPAndWaitUntilLoaded() local
76 ASSERT_TRUE(msg_queue.PopMessage(&message)); in ExecuteScriptOnNTPAndWaitUntilLoaded()
78 WaitUntilTilesLoaded(contents, &msg_queue, /*delay=*/0); in ExecuteScriptOnNTPAndWaitUntilLoaded()
82 content::DOMMessageQueue* msg_queue, in WaitUntilTilesLoaded() argument
113 ASSERT_TRUE(msg_queue->PopMessage(&message)); in WaitUntilTilesLoaded()
122 ASSERT_TRUE(msg_queue->WaitForMessage(&message)); in WaitUntilTilesLoaded()
125 ASSERT_FALSE(msg_queue->PopMessage(&message)); in WaitUntilTilesLoaded()
/dports/mail/py-python-slimta/python-slimta-4.2.1/slimta/cloudstorage/
H A D__init__.py74 self.msg_queue = message_queue
78 if self.msg_queue:
80 self.msg_queue.queue_message(storage_id, timestamp)
118 if self.msg_queue:
119 for timestamp, storage_id, message_id in self.msg_queue.poll():
121 self.msg_queue.delete(message_id)
122 self.msg_queue.sleep()
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/include/gnuradio/messages/
H A Dmsg_queue.h34 class msg_queue; variable
35 typedef boost::shared_ptr<msg_queue> msg_queue_sptr;
42 class GR_RUNTIME_API msg_queue
53 msg_queue(unsigned int limit);
54 ~msg_queue();
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/unimrcp/libs/apr-toolkit/src/
H A Dapt_consumer_task.c27 apr_queue_t *msg_queue; member
44 consumer_task->msg_queue = NULL; in apt_consumer_task_create()
45 if(apr_queue_create(&consumer_task->msg_queue,1024,pool) != APR_SUCCESS) { in apt_consumer_task_create()
98 return (apr_queue_push(consumer_task->msg_queue,msg) == APR_SUCCESS) ? TRUE : FALSE; in apt_consumer_task_msg_signal()
132 rv = apr_queue_timedpop(consumer_task->msg_queue,timeout,&msg); in apt_consumer_task_run()
138 rv = apr_queue_pop(consumer_task->msg_queue,&msg); in apt_consumer_task_run()
142 rv = apr_queue_pop(consumer_task->msg_queue,&msg); in apt_consumer_task_run()
/dports/emulators/yuzu/yuzu-0b47f7a46/src/core/hle/service/am/
H A Dapplet_ae.cpp20 msg_queue{std::move(msg_queue_)} {
45 rb.PushIpcInterface<ICommonStateGetter>(system, msg_queue); in GetCommonStateGetter()
113 std::shared_ptr<AppletMessageQueue> msg_queue; member in Service::AM::ILibraryAppletProxy
122 msg_queue{std::move(msg_queue_)} {
149 rb.PushIpcInterface<ICommonStateGetter>(system, msg_queue); in GetCommonStateGetter()
225 std::shared_ptr<AppletMessageQueue> msg_queue; member in Service::AM::ISystemAppletProxy
233 rb.PushIpcInterface<ISystemAppletProxy>(nvflinger, msg_queue, system); in OpenSystemAppletProxy()
241 rb.PushIpcInterface<ILibraryAppletProxy>(nvflinger, msg_queue, system); in OpenLibraryAppletProxy()
249 rb.PushIpcInterface<ILibraryAppletProxy>(nvflinger, msg_queue, system); in OpenLibraryAppletProxyOld()
254 : ServiceFramework{system_, "appletAE"}, nvflinger{nvflinger_}, msg_queue{ in AppletAE()
[all …]
/dports/emulators/yuzu/yuzu-0b47f7a46/externals/cubeb/src/
H A Dcubeb_log.cpp72 msg_queue.enqueue(msg); in push()
79 while (msg_queue.dequeue(&msg, 1)) { in run()
102 msg_queue.reset_thread_ids(); in reset_producer_thread()
112 : msg_queue(CUBEB_LOG_MESSAGE_QUEUE_DEPTH) in cubeb_async_logger()
118 lock_free_queue<cubeb_log_message> msg_queue; member in cubeb_async_logger
/dports/www/firefox/firefox-99.0/third_party/rust/cubeb-sys/libcubeb/src/
H A Dcubeb_log.cpp72 msg_queue.enqueue(msg); in push()
79 while (msg_queue.dequeue(&msg, 1)) { in run()
102 msg_queue.reset_thread_ids(); in reset_producer_thread()
112 : msg_queue(CUBEB_LOG_MESSAGE_QUEUE_DEPTH) in cubeb_async_logger()
118 lock_free_queue<cubeb_log_message> msg_queue; member in cubeb_async_logger
/dports/www/firefox-esr/firefox-91.8.0/media/libcubeb/src/
H A Dcubeb_log.cpp72 msg_queue.enqueue(msg); in push()
79 while (msg_queue.dequeue(&msg, 1)) { in run()
102 msg_queue.reset_thread_ids(); in reset_producer_thread()
112 : msg_queue(CUBEB_LOG_MESSAGE_QUEUE_DEPTH) in cubeb_async_logger()
118 lock_free_queue<cubeb_log_message> msg_queue; member in cubeb_async_logger

12345678910>>...21