Home
last modified time | relevance | path

Searched refs:service_queue (Results 1 – 17 of 17) sorted by relevance

/dports/www/resin3/resin-3.1.16/webapps/resin-doc/examples/soa-services/
H A Dservices.php3 $service_queue = new JMSQueue("jms/ServiceQueue"); variable
5 if (! $service_queue) {
26 if (! $service_queue->send($request)) {
H A Dindex.xtp37 $service_queue = new JMSQueue("jms/ServiceQueue");
39 if (! $service_queue) {
60 if (! $service_queue->send($request)) {
/dports/multimedia/v4l-utils/linux-5.13-rc2/block/
H A Dblk-throttle.c118 struct throtl_service_queue service_queue; member
556 sq->parent_sq = &td->service_queue; in throtl_pd_init()
790 throtl_log(&tg->service_queue, in throtl_start_new_slice_with_credit()
802 throtl_log(&tg->service_queue, in throtl_start_new_slice()
818 throtl_log(&tg->service_queue, in throtl_extend_slice()
887 throtl_log(&tg->service_queue, in throtl_trim_slice()
1239 sq = &tg->service_queue; in throtl_select_dispatch()
1404 throtl_log(&tg->service_queue, in tg_conf_updated()
1855 throtl_log(&tg->service_queue, in throtl_tg_is_idle()
2165 throtl_log(&td->service_queue, in throtl_update_latency_buckets()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/block/
H A Dblk-throttle.c118 struct throtl_service_queue service_queue; member
556 sq->parent_sq = &td->service_queue; in throtl_pd_init()
790 throtl_log(&tg->service_queue, in throtl_start_new_slice_with_credit()
802 throtl_log(&tg->service_queue, in throtl_start_new_slice()
818 throtl_log(&tg->service_queue, in throtl_extend_slice()
887 throtl_log(&tg->service_queue, in throtl_trim_slice()
1239 sq = &tg->service_queue; in throtl_select_dispatch()
1404 throtl_log(&tg->service_queue, in tg_conf_updated()
1855 throtl_log(&tg->service_queue, in throtl_tg_is_idle()
2165 throtl_log(&td->service_queue, in throtl_update_latency_buckets()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/block/
H A Dblk-throttle.c118 struct throtl_service_queue service_queue; member
556 sq->parent_sq = &td->service_queue; in throtl_pd_init()
790 throtl_log(&tg->service_queue, in throtl_start_new_slice_with_credit()
802 throtl_log(&tg->service_queue, in throtl_start_new_slice()
818 throtl_log(&tg->service_queue, in throtl_extend_slice()
887 throtl_log(&tg->service_queue, in throtl_trim_slice()
1239 sq = &tg->service_queue; in throtl_select_dispatch()
1404 throtl_log(&tg->service_queue, in tg_conf_updated()
1855 throtl_log(&tg->service_queue, in throtl_tg_is_idle()
2165 throtl_log(&td->service_queue, in throtl_update_latency_buckets()
[all …]
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/transport/dpdk/
H A Dservice_queue.hpp117 class service_queue class
125 service_queue(size_t depth, unsigned int lcore_id) in service_queue() function in uhd::transport::dpdk::service_queue
135 ~service_queue() in ~service_queue()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/tests/
H A Ddpdk_port_test.cpp19 void requester(dpdk::service_queue* queue) in requester()
37 void servicer(uhd::transport::dpdk::service_queue* queue) in servicer()
96 auto queue = new uhd::transport::dpdk::service_queue(8, rte_lcore_id()); in main()
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Drabbit_fifo_v0.erl207 service_queue = ServiceQueue0,
458 service_queue = SQ,
926 #?STATE{service_queue = ServiceQueue} = State0,
948 service_queue = SQ0} = S0,
959 service_queue = SQ}, Effects1};
1129 Effects0, #?STATE{service_queue = SQ0} = State0) ->
1147 service_queue = SQ}, Effects2};
1157 #?STATE{consumers = Cons0, service_queue = SQ0,
1179 service_queue = SQ}, Effects}.
1518 checkout_one(#?STATE{service_queue = SQ0,
[all …]
H A Drabbit_fifo.erl231 service_queue = ServiceQueue0,
244 State0#?MODULE{service_queue = ServiceQueue,
478 service_queue = _SQ0} = State0) ->
545 V0SQ = rabbit_fifo_v0:get_field(service_queue, V0State),
571 service_queue = V1SQ,
1145 #?MODULE{service_queue = ServiceQueue} = State0,
1759 checkout_one(Meta, #?MODULE{service_queue = SQ0,
1816 checkout_one(Meta, InitState#?MODULE{service_queue = SQ1});
1830 service_queue = ServiceQueue} = State) ->
1886 service_queue = ServiceQueue0} = State0) ->
[all …]
H A Drabbit_fifo_v0.hrl165 service_queue = queue:new() :: queue:queue(consumer_id()),
H A Drabbit_fifo.hrl173 service_queue = priority_queue:new() :: priority_queue:q(),
/dports/multimedia/tvheadend/tvheadend-4.2.8/src/
H A Dservice.h30 extern struct service_queue service_all;
31 extern struct service_queue service_raw_all;
32 extern struct service_queue service_raw_remove;
H A Dservice.c58 struct service_queue service_all;
59 struct service_queue service_raw_all;
60 struct service_queue service_raw_remove;
1530 static struct service_queue pending_save_queue;
H A Dtvheadend.h258 TAILQ_HEAD(service_queue, service);
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/transport/
H A Ddpdk_io_service_client.hpp170 dpdk::service_queue& _servq;
280 dpdk::service_queue& _servq;
H A Ddpdk_io_service.hpp221 dpdk::service_queue _servq;
/dports/mail/evolution/evolution-3.42.1/src/mail/
H A De-mail-account-store.c1683 GQueue service_queue = G_QUEUE_INIT; in e_mail_account_store_load_sort_order() local
1717 g_queue_push_tail (&service_queue, service); in e_mail_account_store_load_sort_order()
1720 e_mail_account_store_reorder_services (store, &service_queue); in e_mail_account_store_load_sort_order()
1722 while (!g_queue_is_empty (&service_queue)) in e_mail_account_store_load_sort_order()
1723 g_object_unref (g_queue_pop_head (&service_queue)); in e_mail_account_store_load_sort_order()