/dports/www/bluefish/bluefish-2.2.12/src/ |
H A D | msg_queue.c | 150 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 D | priority_common_utils.c | 100 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 D | priority_bdb_filters.c | 16 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 D | priority_message_generator.c | 32 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 D | firewall_common_utils.c | 100 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 D | firewall_bdb_filters.c | 16 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 D | firewall_message_generator.c | 31 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 D | firewall_destination.c | 42 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 D | msg_queue.cc | 32 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 D | basic_block.cc | 88 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 D | test_slimta_cloudstorage.py | 14 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 D | msg_queue.i | 27 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 D | msg_queue.c | 7 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 D | msg_queue.h | 12 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 D | msg_queue.cc | 35 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 D | DXThread.java | 15 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 D | basic_block.h | 96 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 D | local_ntp_test_utils.cc | 50 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__.py | 74 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 D | msg_queue.h | 34 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 D | apt_consumer_task.c | 27 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 D | applet_ae.cpp | 20 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 D | cubeb_log.cpp | 72 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 D | cubeb_log.cpp | 72 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 D | cubeb_log.cpp | 72 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
|