Home
last modified time | relevance | path

Searched refs:aqueue (Results 1 – 25 of 107) sorted by relevance

12345

/dports/mail/dovecot/dovecot-2.3.17/src/lib/
H A Daqueue.c9 struct aqueue *aqueue; in aqueue_init() local
11 aqueue = i_new(struct aqueue, 1); in aqueue_init()
21 struct aqueue *aqueue = *_aqueue; in aqueue_deinit() local
31 i_assert(aqueue->full && aqueue->head == aqueue->tail); in aqueue_grow()
61 aqueue->head = (aqueue->head + 1) % aqueue->area_size; in aqueue_append()
62 aqueue->full = aqueue->head == aqueue->tail; in aqueue_append()
74 aqueue->tail = (aqueue->tail + 1) % aqueue->area_size; in aqueue_delete()
79 aqueue->head = (aqueue->head + aqueue->area_size - 1) % in aqueue_delete()
89 aqueue->arr, aqueue->tail, in aqueue_delete()
100 aqueue->head = (aqueue->head + aqueue->area_size - 1) % in aqueue_delete()
[all …]
H A Daqueue.h13 struct aqueue { struct
19 struct aqueue *aqueue_init(struct array *array); argument
20 void aqueue_deinit(struct aqueue **aqueue);
23 void aqueue_append(struct aqueue *aqueue, const void *data);
25 void aqueue_delete_tail(struct aqueue *aqueue);
27 void aqueue_delete(struct aqueue *aqueue, unsigned int n);
29 void aqueue_clear(struct aqueue *aqueue);
32 unsigned int aqueue_count(const struct aqueue *aqueue) ATTR_PURE;
36 aqueue_idx(const struct aqueue *aqueue, unsigned int n) in aqueue_idx() argument
38 return (aqueue->tail + n) % aqueue->area_size; in aqueue_idx()
H A Dtest-aqueue.c7 static bool aqueue_is_ok(struct aqueue *aqueue, unsigned int deleted_n) in aqueue_is_ok() argument
12 count = aqueue_count(aqueue); in aqueue_is_ok()
14 p = array_idx_i(aqueue->arr, aqueue_idx(aqueue, i)); in aqueue_is_ok()
31 struct aqueue *aqueue; in test_aqueue2() local
35 aqueue->head = aqueue->tail = initial_size - 1; in test_aqueue2()
47 aqueue_delete(aqueue, i); in test_aqueue2()
48 if (aqueue_count(aqueue) != k - 1) in test_aqueue2()
50 if (!aqueue_is_ok(aqueue, i)) in test_aqueue2()
53 aqueue_clear(aqueue); in test_aqueue2()
54 if (aqueue_count(aqueue) != 0) in test_aqueue2()
[all …]
/dports/multimedia/QtAV/QtAV-1.13.0/src/
H A DAVDemuxThread.cpp549 if (aqueue) { in run()
550 aqueue->clear(); in run()
551 aqueue->setBlocking(true); in run()
575 if (aqueue && (!was_end || aqueue->isEmpty())) { in run()
599 if (aqueue) in run()
608 if (aqueue) in run()
643 if (!aqueue->isFull() || aqueue->isBuffering()) { in run()
678 if (aqueue) { in run()
680 aqueue->clear(); in run()
684 if (m_buffer != aqueue) in run()
[all …]
/dports/sysutils/apcupsd/apcupsd-3.14.14/include/
H A Daqueue.h34 class aqueue
38 aqueue() in aqueue() function
44 ~aqueue() in ~aqueue()
121 aqueue(const aqueue<T> &rhs);
122 aqueue<T> &operator=(const aqueue<T> &rhs);
/dports/sysutils/apcctrl/apcctrl-0.8.21/include/
H A Daqueue.h34 class aqueue
38 aqueue() in aqueue() function
44 ~aqueue() in ~aqueue()
121 aqueue(const aqueue<T> &rhs);
122 aqueue<T> &operator=(const aqueue<T> &rhs);
/dports/devel/boost-docs/boost_1_72_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/databases/percona57-server/boost_1_59_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/databases/xtrabackup/boost_1_59_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/databases/percona57-client/boost_1_59_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/devel/boost-libs/boost_1_72_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/devel/boost-python-libs/boost_1_72_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/devel/hyperscan/boost_1_75_0/libs/serialization/test/
H A Dtest_queue.cpp37 std::queue<A> aqueue, aqueue1; in test_main() local
38 aqueue.push(A()); in test_main()
39 aqueue.push(A()); in test_main()
43 oa << boost::serialization::make_nvp("aqueue",aqueue); in test_main()
50 BOOST_CHECK(aqueue == aqueue1); in test_main()
/dports/math/concorde/concorde/LINKERN/
H A Dlinkern.c186 typedef struct aqueue { struct
191 } aqueue; typedef
204 turn (int n, aqueue *Q, CCptrworld *intptr_world),
226 init_aqueue (aqueue *Q),
227 free_aqueue (aqueue *Q, CCptrworld *intptr_world),
266 pop_from_active_queue (aqueue *Q, CCptrworld *intptr_world),
432 aqueue Q;
2016 static void turn (int n, aqueue *Q, CCptrworld *intptr_world)
2073 static void kickturn (int n, aqueue *Q, CC_UNUSED distobj *D,
2324 static void init_aqueue (aqueue *Q)
[all …]
H A Dlinkern_fixed.c152 typedef struct aqueue { struct
157 } aqueue; argument
165 turn (int n, aqueue *Q, CCptrworld *intptr_world),
179 init_aqueue (aqueue *Q),
180 free_aqueue (aqueue *Q, CCptrworld *intptr_world),
205 pop_from_active_queue (aqueue *Q, CCptrworld *intptr_world),
360 aqueue Q;
1428 static void turn (int n, aqueue *Q, CCptrworld *intptr_world)
1433 static void kickturn (int n, aqueue *Q, CC_UNUSED distobj *D,
1664 static void init_aqueue (aqueue *Q)
[all …]
H A Dlinkern_path.c157 typedef struct aqueue { struct
162 } aqueue; typedef
171 turn (int n, aqueue *Q, CCptrworld *intptr_world),
185 init_aqueue (aqueue *Q),
186 free_aqueue (aqueue *Q, CCptrworld *intptr_world),
211 pop_from_active_queue (aqueue *Q, CCptrworld *intptr_world),
365 aqueue Q;
1436 static void turn (int n, aqueue *Q, CCptrworld *intptr_world)
1441 static void kickturn (int n, aqueue *Q, CC_UNUSED distobj *D,
1716 static void init_aqueue (aqueue *Q)
[all …]
/dports/mail/sylpheed/sylpheed-3.7.0/src/
H A Dlogwindow.c107 logwin->aqueue = g_async_queue_new(); in log_window_create()
289 g_async_queue_push(logwindow->aqueue, logdata); in log_window_append_queue()
303 while ((logdata = g_async_queue_try_pop(logwindow->aqueue))) { in log_window_flush()
H A Dlogwindow.h49 GAsyncQueue *aqueue; member
/dports/misc/mxnet/incubator-mxnet-1.9.0/include/mkldnn/oneapi/dnnl/
H A Ddnnl_sycl.hpp119 inline stream make_stream(const engine &aengine, cl::sycl::queue &aqueue) { in make_stream() argument
122 dnnl_sycl_interop_stream_create(&astream, aengine.get(), &aqueue), in make_stream()
/dports/misc/mxnet/incubator-mxnet-1.9.0/3rdparty/mkldnn/include/oneapi/dnnl/
H A Ddnnl_sycl.hpp119 inline stream make_stream(const engine &aengine, cl::sycl::queue &aqueue) { in make_stream() argument
122 dnnl_sycl_interop_stream_create(&astream, aengine.get(), &aqueue), in make_stream()
/dports/emulators/mess/mame-mame0226/src/osd/
H A Dosdsync.cpp105 work_thread_info(uint32_t aid, osd_work_queue &aqueue) in work_thread_info()
106 : queue(aqueue) in work_thread_info()
182 osd_work_item(osd_work_queue &aqueue) in osd_work_item()
184 , queue(aqueue) in osd_work_item()
/dports/emulators/mame/mame-mame0226/src/osd/
H A Dosdsync.cpp105 work_thread_info(uint32_t aid, osd_work_queue &aqueue) in work_thread_info()
106 : queue(aqueue) in work_thread_info()
182 osd_work_item(osd_work_queue &aqueue) in osd_work_item()
184 , queue(aqueue) in osd_work_item()
/dports/math/onednn/oneDNN-2.5.1/include/oneapi/dnnl/
H A Ddnnl_sycl.hpp139 inline stream make_stream(const engine &aengine, cl::sycl::queue &aqueue) { in make_stream() argument
142 dnnl_sycl_interop_stream_create(&astream, aengine.get(), &aqueue), in make_stream()

12345