| /dports/multimedia/v4l_compat/linux-5.13-rc2/lib/ |
| H A D | sbitmap.c | 420 shallow_depth = min(1U << sbq->sb.shift, sbq->min_shallow_depth); in sbq_calc_wake_batch()
441 sbq->wake_batch = sbq_calc_wake_batch(sbq, depth); in sbitmap_queue_init_node()
445 sbq->ws = kzalloc_node(SBQ_WAIT_QUEUES * sizeof(*sbq->ws), flags, node); in sbitmap_queue_init_node()
446 if (!sbq->ws) { in sbitmap_queue_init_node()
453 atomic_set(&sbq->ws[i].wait_cnt, sbq->wake_batch); in sbitmap_queue_init_node()
505 sbitmap_queue_update_wake_batch(sbq, sbq->sb.depth); in sbitmap_queue_min_shallow_depth()
605 if (likely(!sbq->sb.round_robin && nr < sbq->sb.depth)) in sbitmap_queue_clear()
672 sbq_wait->sbq = sbq; in sbitmap_add_wait_queue()
682 if (sbq_wait->sbq) { in sbitmap_del_wait_queue()
695 sbq_wait->sbq = sbq; in sbitmap_prepare_to_wait()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/lib/ |
| H A D | sbitmap.c | 420 shallow_depth = min(1U << sbq->sb.shift, sbq->min_shallow_depth); in sbq_calc_wake_batch()
441 sbq->wake_batch = sbq_calc_wake_batch(sbq, depth); in sbitmap_queue_init_node()
445 sbq->ws = kzalloc_node(SBQ_WAIT_QUEUES * sizeof(*sbq->ws), flags, node); in sbitmap_queue_init_node()
446 if (!sbq->ws) { in sbitmap_queue_init_node()
453 atomic_set(&sbq->ws[i].wait_cnt, sbq->wake_batch); in sbitmap_queue_init_node()
505 sbitmap_queue_update_wake_batch(sbq, sbq->sb.depth); in sbitmap_queue_min_shallow_depth()
605 if (likely(!sbq->sb.round_robin && nr < sbq->sb.depth)) in sbitmap_queue_clear()
672 sbq_wait->sbq = sbq; in sbitmap_add_wait_queue()
682 if (sbq_wait->sbq) { in sbitmap_del_wait_queue()
695 sbq_wait->sbq = sbq; in sbitmap_prepare_to_wait()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/lib/ |
| H A D | sbitmap.c | 420 shallow_depth = min(1U << sbq->sb.shift, sbq->min_shallow_depth); in sbq_calc_wake_batch()
441 sbq->wake_batch = sbq_calc_wake_batch(sbq, depth); in sbitmap_queue_init_node()
445 sbq->ws = kzalloc_node(SBQ_WAIT_QUEUES * sizeof(*sbq->ws), flags, node); in sbitmap_queue_init_node()
446 if (!sbq->ws) { in sbitmap_queue_init_node()
453 atomic_set(&sbq->ws[i].wait_cnt, sbq->wake_batch); in sbitmap_queue_init_node()
505 sbitmap_queue_update_wake_batch(sbq, sbq->sb.depth); in sbitmap_queue_min_shallow_depth()
605 if (likely(!sbq->sb.round_robin && nr < sbq->sb.depth)) in sbitmap_queue_clear()
672 sbq_wait->sbq = sbq; in sbitmap_add_wait_queue()
682 if (sbq_wait->sbq) { in sbitmap_del_wait_queue()
695 sbq_wait->sbq = sbq; in sbitmap_prepare_to_wait()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/linux/ |
| H A D | sbitmap.h | 405 kfree(sbq->ws); in sbitmap_queue_free()
406 sbitmap_free(&sbq->sb); in sbitmap_queue_free()
427 int __sbitmap_queue_get(struct sbitmap_queue *sbq);
460 nr = __sbitmap_queue_get(sbq); in sbitmap_queue_get()
486 nr = __sbitmap_queue_get_shallow(sbq, shallow_depth); in sbitmap_queue_get_shallow()
541 ws = &sbq->ws[atomic_read(wait_index)]; in sbq_wait_ptr()
551 void sbitmap_queue_wake_all(struct sbitmap_queue *sbq);
558 void sbitmap_queue_wake_up(struct sbitmap_queue *sbq);
577 .sbq = NULL, \
589 void sbitmap_prepare_to_wait(struct sbitmap_queue *sbq,
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/linux/ |
| H A D | sbitmap.h | 405 kfree(sbq->ws); in sbitmap_queue_free()
406 sbitmap_free(&sbq->sb); in sbitmap_queue_free()
427 int __sbitmap_queue_get(struct sbitmap_queue *sbq);
460 nr = __sbitmap_queue_get(sbq); in sbitmap_queue_get()
486 nr = __sbitmap_queue_get_shallow(sbq, shallow_depth); in sbitmap_queue_get_shallow()
541 ws = &sbq->ws[atomic_read(wait_index)]; in sbq_wait_ptr()
551 void sbitmap_queue_wake_all(struct sbitmap_queue *sbq);
558 void sbitmap_queue_wake_up(struct sbitmap_queue *sbq);
577 .sbq = NULL, \
589 void sbitmap_prepare_to_wait(struct sbitmap_queue *sbq,
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/linux/ |
| H A D | sbitmap.h | 405 kfree(sbq->ws); in sbitmap_queue_free()
406 sbitmap_free(&sbq->sb); in sbitmap_queue_free()
427 int __sbitmap_queue_get(struct sbitmap_queue *sbq);
460 nr = __sbitmap_queue_get(sbq); in sbitmap_queue_get()
486 nr = __sbitmap_queue_get_shallow(sbq, shallow_depth); in sbitmap_queue_get_shallow()
541 ws = &sbq->ws[atomic_read(wait_index)]; in sbq_wait_ptr()
551 void sbitmap_queue_wake_all(struct sbitmap_queue *sbq);
558 void sbitmap_queue_wake_up(struct sbitmap_queue *sbq);
577 .sbq = NULL, \
589 void sbitmap_prepare_to_wait(struct sbitmap_queue *sbq,
[all …]
|
| /dports/databases/xtrabackup/boost_1_59_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream &mos, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
35 mos << "push(" << i << ") "<< sbq.size()<<"\n"; in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
60 mos << i << " pull(" << r << ") "<< sbq.size()<<"\n"; in consumer()
74 void consumer2(the_ostream &mos, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &mos, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
38 mos << "push(" << i << ") " << sbq.size() <<"\n"; in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
63 mos << i << " pull(" << r << ") " << sbq.size() <<"\n"; in consumer()
77 void consumer2(the_ostream &mos, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
[all …]
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream &mos, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
35 mos << "push(" << i << ") "<< sbq.size()<<"\n"; in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
60 mos << i << " pull(" << r << ") "<< sbq.size()<<"\n"; in consumer()
74 void consumer2(the_ostream &mos, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &mos, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
38 mos << "push(" << i << ") " << sbq.size() <<"\n"; in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
63 mos << i << " pull(" << r << ") " << sbq.size() <<"\n"; in consumer()
77 void consumer2(the_ostream &mos, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
[all …]
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream &mos, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
35 mos << "push(" << i << ") "<< sbq.size()<<"\n"; in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
60 mos << i << " pull(" << r << ") "<< sbq.size()<<"\n"; in consumer()
74 void consumer2(the_ostream &mos, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &mos, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
38 mos << "push(" << i << ") " << sbq.size() <<"\n"; in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
63 mos << i << " pull(" << r << ") " << sbq.size() <<"\n"; in consumer()
77 void consumer2(the_ostream &mos, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
[all …]
|
| /dports/databases/percona57-server/boost_1_59_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream &mos, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
35 mos << "push(" << i << ") "<< sbq.size()<<"\n"; in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
60 mos << i << " pull(" << r << ") "<< sbq.size()<<"\n"; in consumer()
74 void consumer2(the_ostream &mos, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &mos, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
38 mos << "push(" << i << ") " << sbq.size() <<"\n"; in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
63 mos << i << " pull(" << r << ") " << sbq.size() <<"\n"; in consumer()
77 void consumer2(the_ostream &mos, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
[all …]
|
| /dports/databases/percona57-client/boost_1_59_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream &mos, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
35 mos << "push(" << i << ") "<< sbq.size()<<"\n"; in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
60 mos << i << " pull(" << r << ") "<< sbq.size()<<"\n"; in consumer()
74 void consumer2(the_ostream &mos, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &mos, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
38 mos << "push(" << i << ") " << sbq.size() <<"\n"; in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
63 mos << i << " pull(" << r << ") " << sbq.size() <<"\n"; in consumer()
77 void consumer2(the_ostream &mos, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
[all …]
|
| /dports/devel/boost-docs/boost_1_72_0/libs/thread/example/ |
| H A D | producer_consumer.cpp | 27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3() argument
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &/*mos*/, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
77 void consumer2(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
97 void consumer3(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer3() argument
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
[all …]
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/thread/example/ |
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &/*mos*/, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
77 void consumer2(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
97 void consumer3(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer3() argument
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
[all …]
|
| H A D | producer_consumer.cpp | 27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3() argument
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|
| H A D | producer_consumer_bounded.cpp | 30 void producer(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in producer() argument
36 sbq.push_back(i); in producer()
52 void consumer(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in consumer() argument
59 sbq.pull_front(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull_front(r); in consumer2()
129 sync_bounded_queue<int> sbq(10); in main() local
133 scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), boost::ref(sbq))); in main()
134 scoped_thread<> t12(boost::thread(producer, boost::ref(mcerr), boost::ref(sbq))); in main()
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|
| /dports/devel/boost-libs/boost_1_72_0/libs/thread/example/ |
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &/*mos*/, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
77 void consumer2(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
97 void consumer3(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer3() argument
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
[all …]
|
| H A D | producer_consumer.cpp | 27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3() argument
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|
| /dports/devel/hyperscan/boost_1_75_0/libs/thread/example/ |
| H A D | producer_consumer2.cpp | 30 void producer(the_ostream &/*mos*/, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
77 void consumer2(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
97 void consumer3(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer3() argument
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
[all …]
|
| H A D | producer_consumer.cpp | 27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3() argument
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|