/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 …]
|