| /dports/misc/hashdb/hashdb-3.1.0-8-g1da1b9f/src_libhashdb/scan_stream/ |
| H A D | scan_stream.cpp | 69 const std::string unscanned_array = job->scan_queue.get_unscanned(); in run()
160 job->scan_queue.put_scanned(scanned_stream.str()); in run()
195 scan_thread_data->scan_queue.put_unscanned(unscanned_data); in put()
200 return scan_thread_data->scan_queue.get_scanned(); in get()
205 bool is_empty = scan_thread_data->scan_queue.empty(); in empty()
|
| H A D | scan_thread_data.hpp | 41 scan_queue_t scan_queue; member in scan_stream::scan_thread_data_t
55 scan_queue(), in scan_thread_data_t()
|
| /dports/misc/libsweep-lidar/sweep-sdk-1.3.0/libsweep/src/ |
| H A D | sweep.cc | 52 sweep::queue::queue<Element> scan_queue; member
125 device->scan_queue.enqueue({std::move(out), nullptr}); in sweep_device_accumulate_scans()
136 device->scan_queue.enqueue({nullptr, std::current_exception()});
267 device->scan_queue.clear(); in sweep_device_start_scanning()
325 auto out = device->scan_queue.dequeue(); in sweep_device_get_scan()
|
| /dports/lang/mit-scheme/mit-scheme-9.2/src/microcode/ |
| H A D | ntscreen.c | 1780 && (scan_queue != 0)) in ScreenPeekOrRead()
1784 (*scan_buffer++) = (scan_queue -> event); in ScreenPeekOrRead()
1785 scan_queue = (scan_queue -> next); in ScreenPeekOrRead()
3298 while (scan_queue != 0) in read_event()
3305 (*event) = (scan_queue -> event); in read_event()
3317 if (event_queue_tail == scan_queue) in read_event()
3323 (scan_queue -> next) = free_events; in read_event()
3324 free_events = scan_queue; in read_event()
3328 free (scan_queue); in read_event()
3334 prev_queue = scan_queue; in read_event()
[all …]
|
| /dports/mail/qmail-notify/qmail-notify-0.93/ |
| H A D | qmail-notify.c | 263 void scan_queue(void) in scan_queue() function
349 scan_queue(); in cli_main()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/linux/ |
| H A D | pktcdvd.h | 187 atomic_t scan_queue; /* Set to non-zero when pkt_handle_queue */ member
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/linux/ |
| H A D | pktcdvd.h | 187 atomic_t scan_queue; /* Set to non-zero when pkt_handle_queue */ member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/linux/ |
| H A D | pktcdvd.h | 187 atomic_t scan_queue; /* Set to non-zero when pkt_handle_queue */ member
|
| /dports/editors/gedit-plugins/gedit-plugins-40.1/plugins/findinfiles/ |
| H A D | job.vala | 49 private AsyncQueue<string> scan_queue = new AsyncQueue<string>();
72 var path = scan_queue.timeout_pop (tv);
205 scan_queue.push (_file.get_path ());
|
| /dports/misc/hashdb/hashdb-3.1.0-8-g1da1b9f/src_libhashdb/ |
| H A D | Makefile.am | 128 scan_stream/scan_queue.hpp \
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/staging/rtl8188eu/core/ |
| H A D | rtw_mlme.c | 688 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
692 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
695 phead = get_list_head(scan_queue); in free_scanqueue()
706 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/staging/rtl8188eu/core/ |
| H A D | rtw_mlme.c | 688 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
692 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
695 phead = get_list_head(scan_queue); in free_scanqueue()
706 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/staging/rtl8188eu/core/ |
| H A D | rtw_mlme.c | 688 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
692 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
695 phead = get_list_head(scan_queue); in free_scanqueue()
706 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/staging/rtl8723bs/core/ |
| H A D | rtw_mlme.c | 877 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
880 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
883 phead = get_list_head(scan_queue); in free_scanqueue()
895 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/staging/rtl8723bs/core/ |
| H A D | rtw_mlme.c | 877 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
880 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
883 phead = get_list_head(scan_queue); in free_scanqueue()
895 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/staging/rtl8723bs/core/ |
| H A D | rtw_mlme.c | 877 struct __queue *scan_queue = &pmlmepriv->scanned_queue; in free_scanqueue() local
880 spin_lock_bh(&scan_queue->lock); in free_scanqueue()
883 phead = get_list_head(scan_queue); in free_scanqueue()
895 spin_unlock_bh(&scan_queue->lock); in free_scanqueue()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 1186 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
1241 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
1242 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
1282 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
1283 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 1186 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
1241 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
1242 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
1282 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
1283 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 1186 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
1241 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
1242 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
1282 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
1283 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 1186 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
1241 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
1242 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
1282 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
1283 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
|
| /dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 1186 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
1241 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
1242 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
1282 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
1283 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/block/ |
| H A D | pktcdvd.c | 1112 atomic_set(&pd->scan_queue, 0); in pkt_handle_queue()
1375 atomic_set(&pd->scan_queue, 1); in pkt_handle_packets()
1420 if (atomic_read(&pd->scan_queue) > 0) in kcdrwd()
2392 atomic_set(&pd->scan_queue, 1); in pkt_make_request_write()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/block/ |
| H A D | pktcdvd.c | 1112 atomic_set(&pd->scan_queue, 0); in pkt_handle_queue()
1375 atomic_set(&pd->scan_queue, 1); in pkt_handle_packets()
1420 if (atomic_read(&pd->scan_queue) > 0) in kcdrwd()
2392 atomic_set(&pd->scan_queue, 1); in pkt_make_request_write()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/block/ |
| H A D | pktcdvd.c | 1112 atomic_set(&pd->scan_queue, 0); in pkt_handle_queue()
1375 atomic_set(&pd->scan_queue, 1); in pkt_handle_packets()
1420 if (atomic_read(&pd->scan_queue) > 0) in kcdrwd()
2392 atomic_set(&pd->scan_queue, 1); in pkt_make_request_write()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/kernel/vm/ |
| H A D | mt.cpp | 2366 scan_queue(struct thr_data* selfptr, Uint32 cnt, Uint32 end, Uint32* ptr) in scan_queue() function
2421 Uint32 tmp0 = scan_queue(selfptr, cnt0, 32767, tq->m_short_queue); in handle_time_wrap()
2422 Uint32 tmp1 = scan_queue(selfptr, cnt1, 32767, tq->m_long_queue); in handle_time_wrap()
2530 Uint32 tmp0 = scan_queue(selfptr, cnt0, end, tq->m_short_queue); in scan_time_queues_impl()
2531 Uint32 tmp1 = scan_queue(selfptr, cnt1, end, tq->m_long_queue); in scan_time_queues_impl()
2586 Uint32 num_found = scan_queue(selfptr, in scan_zero_queue()
|