| /dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/SuperReadsR/include/ |
| H A D | thread_pool.hpp | 71 volatile bool data_available; member in thread_pool
94 printf("Worker waiting for data %d\n",data_available); in worker()
99 while(!data_available) { in worker()
110 data_available = false; in worker()
143 data_available(false), in thread_pool()
224 printf("Waking worker %d\n",data_available); in submit_job()
229 data_available = true; in submit_job()
233 printf("Signaled worker %d\n",data_available); in submit_job()
237 while(data_available) in submit_job()
241 printf("Worker received data %d\n",data_available); in submit_job()
|
| /dports/misc/adios2/ADIOS2-2.7.1/thirdparty/EVPath/EVPath/ |
| H A D | cm_transport.c | 154 transport->data_available = CMDataAvailable; /* callback in load_transport()
205 transport->data_available = CMDataAvailable; /* callback in load_transport()
216 transport->data_available = CMDataAvailable; /* callback in load_transport()
228 transport->data_available = CMDataAvailable; /* callback in load_transport()
242 transport->data_available = CMDataAvailable; /* callback in load_transport()
255 transport->data_available = CMDataAvailable; /* callback in load_transport()
268 transport->data_available = CMDataAvailable; /* callback in load_transport()
281 transport->data_available = CMDataAvailable; /* callback in load_transport()
294 transport->data_available = CMDataAvailable; /* callback in load_transport()
|
| H A D | cm_threadio.c | 14 if (original->data_available) { in create_thread_read_transport()
20 && !(*cur)->data_available) { in create_thread_read_transport()
28 new_entry.data_available = NULL; in create_thread_read_transport()
|
| /dports/games/taisei/taisei-1.3.2/src/util/pixmap_loaders/ |
| H A D | loader_webp.c | 79 size_t data_available = SDL_RWread(stream, buf, 1, sizeof(buf)); in px_webp_load() local
81 status = WebPGetFeatures(buf, data_available, &features); in px_webp_load()
116 status = WebPIAppend(idec, buf, data_available); in px_webp_load()
125 data_available = SDL_RWread(stream, buf, 1, sizeof(buf)); in px_webp_load()
126 } while(data_available > 0); in px_webp_load()
|
| /dports/games/libretro-scummvm/scummvm-7b1e929/engines/agi/ |
| H A D | sound_sarien.cpp | 324 static uint32 data_available = 0; in fillAudio() local
332 while (len > data_available) { in fillAudio()
333 memcpy((uint8 *)stream + p, (uint8 *)_sndBuffer + data_offset, data_available); in fillAudio()
334 p += data_available; in fillAudio()
335 len -= data_available; in fillAudio()
338 data_available = mixSound() << 1; in fillAudio()
344 data_available -= len; in fillAudio()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/iio/adc/ |
| H A D | berlin2-adc.c | 76 bool data_available; member
126 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_read()
144 priv->data_available = false; in berlin2_adc_read()
177 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_tsen_read()
195 priv->data_available = false; in berlin2_adc_tsen_read()
252 priv->data_available = true; in berlin2_adc_irq()
272 priv->data_available = true; in berlin2_adc_tsen_irq()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/iio/adc/ |
| H A D | berlin2-adc.c | 76 bool data_available; member
126 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_read()
144 priv->data_available = false; in berlin2_adc_read()
177 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_tsen_read()
195 priv->data_available = false; in berlin2_adc_tsen_read()
252 priv->data_available = true; in berlin2_adc_irq()
272 priv->data_available = true; in berlin2_adc_tsen_irq()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/iio/adc/ |
| H A D | berlin2-adc.c | 76 bool data_available; member
126 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_read()
144 priv->data_available = false; in berlin2_adc_read()
177 ret = wait_event_interruptible_timeout(priv->wq, priv->data_available, in berlin2_adc_tsen_read()
195 priv->data_available = false; in berlin2_adc_tsen_read()
252 priv->data_available = true; in berlin2_adc_irq()
272 priv->data_available = true; in berlin2_adc_tsen_irq()
|
| /dports/games/scummvm/scummvm-2.5.1/engines/agi/ |
| H A D | sound_sarien.cpp | 327 static uint32 data_available = 0; in fillAudio() local
335 while (len > data_available) { in fillAudio()
336 memcpy((uint8 *)stream + p, (uint8 *)_sndBuffer + data_offset, data_available); in fillAudio()
337 p += data_available; in fillAudio()
338 len -= data_available; in fillAudio()
341 data_available = mixSound() << 1; in fillAudio()
347 data_available -= len; in fillAudio()
|
| /dports/science/py-GPy/GPy-1.10.0/GPy/util/ |
| H A D | datasets.py | 96 def data_available(dataset_name=None): function
331 if not data_available(data_set):
339 if not data_available(data_set):
346 if not data_available(data_set):
403 if not data_available(data_set):
416 if not data_available(data_set):
425 if not data_available(data_set):
438 if not data_available(data_set):
453 if not data_available(data_set):
468 if not data_available(data_set):
[all …]
|
| /dports/security/s2n/s2n-tls-1.1.2/tls/extensions/ |
| H A D | s2n_server_sct_list.c | 58 size_t data_available = s2n_stuffer_data_available(extension); in s2n_server_sct_list_recv() local
60 s2n_stuffer_raw_read(extension, data_available), in s2n_server_sct_list_recv()
61 data_available)); in s2n_server_sct_list_recv()
|
| /dports/www/ilias/ILIAS-5.4.25/Modules/DataCollection/classes/Content/ |
| H A D | class.ilDclContentExporter.php | 175 $data_available = false;
186 $data_available = $data_available || ($list['total'] > 0);
208 $data_available = true;
218 if (!$data_available) {
|
| /dports/www/ilias6/ILIAS-6.14/Modules/DataCollection/classes/Content/ |
| H A D | class.ilDclContentExporter.php | 169 $data_available = false;
178 $data_available = $data_available || ($list['total'] > 0);
200 $data_available = true;
210 if (!$data_available) {
|
| /dports/textproc/libextractor/libextractor-1.11/src/main/ |
| H A D | extractor.c | 74 size_t data_available, in send_update_message() argument
82 um.shm_ready_bytes = (uint32_t) data_available; in send_update_message()
379 ssize_t data_available; in do_extract() local
498 data_available = -1; in do_extract()
506 (data_available = EXTRACTOR_IPC_shared_memory_set_ (shm, in do_extract()
532 if ( (-1 != data_available) && in do_extract()
535 ( (min_seek + data_available > pos->seek_request) || in do_extract()
541 data_available, in do_extract()
|
| /dports/sysutils/testdisk/testdisk-7.1/src/ |
| H A D | hdcache.c | 99 const unsigned int data_available= cache->cache_size + cache->cache_offset - offset; in cache_pread_aux() local
101 if(count<=data_available) in cache_pread_aux()
118 data->nbr_fnct_sect+=data_available; in cache_pread_aux()
120 memcpy(buffer, cache->buffer + offset - cache->cache_offset, data_available); in cache_pread_aux()
121 return res + cache_pread_aux(disk_car, (unsigned char*)buffer+data_available, in cache_pread_aux()
122 count-data_available, offset+data_available, read_ahead); in cache_pread_aux()
|
| /dports/devel/covtool/covtool-2.1_10/ |
| H A D | covannotate.c | 130 bool data_available=true; in main() local
135 data_available = false; in main()
153 if(data_available) in main()
|
| /dports/java/java-subversion/subversion-1.14.1/subversion/libsvn_ra_svn/ |
| H A D | streams.c | 149 svn_boolean_t *data_available) in sock_pending_cb() argument
157 *data_available = pending(&pfd, b->pool); in sock_pending_cb()
227 svn_boolean_t *data_available) in svn_ra_svn__stream_data_available() argument
231 data_available)); in svn_ra_svn__stream_data_available()
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/core/src/lib/ |
| H A D | connection_pool.cc | 58 int data_available = 0; in check() local
64 data_available = socket_->WaitDataIntr(timeout_data); in check()
70 if (data_available < 0) { in check()
72 } else if ((data_available > 0) && (!in_use_)) { in check()
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/core/src/lib/ |
| H A D | connection_pool.cc | 58 int data_available = 0; in check() local
64 data_available = socket_->WaitDataIntr(timeout_data); in check()
70 if (data_available < 0) { in check()
72 } else if ((data_available > 0) && (!in_use_)) { in check()
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/lib/ |
| H A D | connection_pool.cc | 58 int data_available = 0; in check() local
64 data_available = socket_->WaitDataIntr(timeout_data); in check()
70 if (data_available < 0) { in check()
72 } else if ((data_available > 0) && (!in_use_)) { in check()
|
| /dports/www/bareos-webui/bareos-Release-20.0.3/core/src/lib/ |
| H A D | connection_pool.cc | 58 int data_available = 0; in check() local
64 data_available = socket_->WaitDataIntr(timeout_data); in check()
70 if (data_available < 0) { in check()
72 } else if ((data_available > 0) && (!in_use_)) { in check()
|
| /dports/devel/py-subversion/subversion-1.14.1/subversion/libsvn_ra_svn/ |
| H A D | streams.c | 149 svn_boolean_t *data_available) in sock_pending_cb() argument
157 *data_available = pending(&pfd, b->pool); in sock_pending_cb()
227 svn_boolean_t *data_available) in svn_ra_svn__stream_data_available() argument
231 data_available)); in svn_ra_svn__stream_data_available()
|
| /dports/security/subversion-gnome-keyring/subversion-1.14.1/subversion/libsvn_ra_svn/ |
| H A D | streams.c | 149 svn_boolean_t *data_available) in sock_pending_cb() argument
157 *data_available = pending(&pfd, b->pool); in sock_pending_cb()
227 svn_boolean_t *data_available) in svn_ra_svn__stream_data_available() argument
231 data_available)); in svn_ra_svn__stream_data_available()
|
| /dports/devel/p5-subversion/subversion-1.14.1/subversion/libsvn_ra_svn/ |
| H A D | streams.c | 149 svn_boolean_t *data_available) in sock_pending_cb() argument
157 *data_available = pending(&pfd, b->pool); in sock_pending_cb()
227 svn_boolean_t *data_available) in svn_ra_svn__stream_data_available() argument
231 data_available)); in svn_ra_svn__stream_data_available()
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp2/gpmc/ |
| H A D | fifo_to_gpmc.v | 46 output reg data_available); port
114 if (reset | clear) data_available <= 0;
115 else data_available <= safe_next_gpmc_ptr != fifo_ptr;
|