| /dports/graphics/gstreamer1-plugins-qt/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-png/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/audio/gstreamer1-plugins-speex/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/audio/gstreamer1-plugins-flac/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/x11-toolkits/gstreamer1-plugins-gtk4/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/x11-toolkits/gstreamer1-plugins-gtk/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-jpeg/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-aalib/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-gdkpixbuf/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-cairo/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/graphics/gstreamer1-plugins-libcaca/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/multimedia/gstreamer1-plugins-vpx/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/multimedia/gstreamer1-plugins-v4l2/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/x11/gstreamer1-plugins-ximagesrc/gst-plugins-good-1.16.2/sys/v4l2/ |
| H A D | gstv4l2bufferpool.c | 428 obj = pool->obj; in gst_v4l2_buffer_pool_alloc_buffer()
434 gst_buffer_new_allocate (pool->allocator, pool->size, &pool->params); in gst_v4l2_buffer_pool_alloc_buffer()
870 pool->size = size; in gst_v4l2_buffer_pool_start()
1075 g_cond_wait (&pool->empty_cond, GST_OBJECT_GET_LOCK (pool)); in gst_v4l2_buffer_pool_poll()
1109 if (gst_poll_fd_has_error (pool->poll, &pool->pollfd)) in gst_v4l2_buffer_pool_poll()
1601 pool->obj->close (pool->video_fd); in gst_v4l2_buffer_pool_finalize()
1683 gst_poll_add_fd (pool->poll, &pool->pollfd); in gst_v4l2_buffer_pool_new()
1685 gst_poll_fd_ctl_write (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1687 gst_poll_fd_ctl_read (pool->poll, &pool->pollfd, TRUE); in gst_v4l2_buffer_pool_new()
1690 pool->obj = obj; in gst_v4l2_buffer_pool_new()
[all …]
|
| /dports/multimedia/x264/x264-5db6aa6cab1b146e07b60cc1736a01f21da01154/common/ |
| H A D | threadpool.c | 53 pool->init_func( pool->init_arg ); in threadpool_thread()
55 while( !pool->exit ) in threadpool_thread()
59 while( !pool->exit && !pool->run.i_size ) in threadpool_thread()
60 x264_pthread_cond_wait( &pool->run.cv_fill, &pool->run.mutex ); in threadpool_thread()
86 *p_pool = pool; in x264_threadpool_init()
94 if( x264_sync_frame_list_init( &pool->uninit, pool->threads ) || in x264_threadpool_init()
95 x264_sync_frame_list_init( &pool->run, pool->threads ) || in x264_threadpool_init()
96 x264_sync_frame_list_init( &pool->done, pool->threads ) ) in x264_threadpool_init()
139 x264_pthread_cond_wait( &pool->done.cv_fill, &pool->done.mutex ); in x264_threadpool_wait()
156 pool->exit = 1; in x264_threadpool_delete()
[all …]
|
| /dports/multimedia/libx264/x264-5db6aa6cab1b146e07b60cc1736a01f21da01154/common/ |
| H A D | threadpool.c | 53 pool->init_func( pool->init_arg ); in threadpool_thread()
55 while( !pool->exit ) in threadpool_thread()
59 while( !pool->exit && !pool->run.i_size ) in threadpool_thread()
60 x264_pthread_cond_wait( &pool->run.cv_fill, &pool->run.mutex ); in threadpool_thread()
86 *p_pool = pool; in x264_threadpool_init()
94 if( x264_sync_frame_list_init( &pool->uninit, pool->threads ) || in x264_threadpool_init()
95 x264_sync_frame_list_init( &pool->run, pool->threads ) || in x264_threadpool_init()
96 x264_sync_frame_list_init( &pool->done, pool->threads ) ) in x264_threadpool_init()
139 x264_pthread_cond_wait( &pool->done.cv_fill, &pool->done.mutex ); in x264_threadpool_wait()
156 pool->exit = 1; in x264_threadpool_delete()
[all …]
|
| /dports/databases/iowow/iowow-1.4.13/src/utils/ |
| H A D | iwpool.c | 29 IWPOOL *pool; in iwpool_create() local
32 pool = malloc(sizeof(*pool)); in iwpool_create()
33 if (!pool) { in iwpool_create()
36 pool->unit = malloc(sizeof(*pool->unit)); in iwpool_create()
45 pool->heap = pool->unit->heap; in iwpool_create()
50 return pool; in iwpool_create()
53 if (pool) { in iwpool_create()
54 if (pool->unit && pool->unit->heap) { in iwpool_create()
58 free(pool); in iwpool_create()
236 pool->user_data_free_fn(pool->user_data); in iwpool_user_data_set()
[all …]
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/libs/3rdparty/cplusplus/ |
| H A D | ASTClone.cpp | 78 … *ast_iter = new (pool) GnuAttributeListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
91 … *ast_iter = new (pool) GnuAttributeListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
103 … *ast_iter = new (pool) GnuAttributeListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
117 … *ast_iter = new (pool) ExpressionListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
149 *ast_iter = new (pool) SpecifierListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
160 *ast_iter = new (pool) SpecifierListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
173 *ast_iter = new (pool) SpecifierListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
215 *ast_iter = new (pool) SpecifierListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
257 *ast_iter = new (pool) NameListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
269 *ast_iter = new (pool) NameListAST((iter->value) ? iter->value->clone(pool) : nullptr); in clone()
[all …]
|
| /dports/dns/knot3/knot-3.1.5/src/contrib/ |
| H A D | conn_pool.c | 46 assert(pool); in get_old()
100 conn_pool_t *pool = calloc(1, sizeof(*pool) + capacity * sizeof(pool->conns[0])); in conn_pool_init() local
101 if (pool != NULL) { in conn_pool_init()
105 free(pool); in conn_pool_init()
110 free(pool); in conn_pool_init()
114 return pool; in conn_pool_init()
130 free(pool); in conn_pool_deinit()
159 pool->usage--; in pool_pop()
204 assert(pool->usage < pool->capacity); in pool_push()
209 pool->usage++; in pool_push()
[all …]
|
| /dports/dns/knot3-lib/knot-3.1.5/src/contrib/ |
| H A D | conn_pool.c | 46 assert(pool); in get_old()
100 conn_pool_t *pool = calloc(1, sizeof(*pool) + capacity * sizeof(pool->conns[0])); in conn_pool_init() local
101 if (pool != NULL) { in conn_pool_init()
105 free(pool); in conn_pool_init()
110 free(pool); in conn_pool_init()
114 return pool; in conn_pool_init()
130 free(pool); in conn_pool_deinit()
159 pool->usage--; in pool_pop()
204 assert(pool->usage < pool->capacity); in pool_push()
209 pool->usage++; in pool_push()
[all …]
|
| /dports/multimedia/vmaf/vmaf-2.3.0/libvmaf/src/ |
| H A D | thread_pool.c | 45 if (!pool) return NULL; in vmaf_thread_pool_fetch_job()
71 if (!pool->queue.head && !pool->stop) in vmaf_thread_pool_runner()
72 pthread_cond_wait(&(pool->queue.empty), &(pool->queue.lock)); in vmaf_thread_pool_runner()
75 pool->n_working++; in vmaf_thread_pool_runner()
83 if (!pool->stop && pool->n_working == 0 && !pool->queue.head) in vmaf_thread_pool_runner()
138 pool->queue.tail = pool->queue.head; in vmaf_thread_pool_enqueue()
159 while((!pool->stop && (pool->n_working || pool->queue.head)) || in vmaf_thread_pool_wait()
160 (pool->stop && pool->n_threads)) in vmaf_thread_pool_wait()
161 pthread_cond_wait(&(pool->working), &(pool->queue.lock)); in vmaf_thread_pool_wait()
177 pool->stop = true; in vmaf_thread_pool_destroy()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/gocql/gocql/ |
| H A D | connectionpool.go | 141 return pool
359 pool.registerer.Unregister(pool.connections)
360 pool.registerer.Unregister(pool.connectionAttempts)
361 pool.registerer.Unregister(pool.connectionFailures)
362 pool.registerer.Unregister(pool.connectionDrops)
446 if pool.closed || pool.filling {
468 if pool.closed || pool.filling || fillCount <= 0 {
496 go pool.session.handleNodeDown(pool.host.ConnectAddress(), pool.port)
585 conn, err = pool.session.connect(pool.session.ctx, pool.logger, pool.host, pool)
624 pool.conns = append(pool.conns, conn)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/gocql/gocql/ |
| H A D | connectionpool.go | 141 return pool
359 pool.registerer.Unregister(pool.connections)
360 pool.registerer.Unregister(pool.connectionAttempts)
361 pool.registerer.Unregister(pool.connectionFailures)
362 pool.registerer.Unregister(pool.connectionDrops)
446 if pool.closed || pool.filling {
468 if pool.closed || pool.filling || fillCount <= 0 {
496 go pool.session.handleNodeDown(pool.host.ConnectAddress(), pool.port)
585 conn, err = pool.session.connect(pool.session.ctx, pool.logger, pool.host, pool)
624 pool.conns = append(pool.conns, conn)
[all …]
|
| /dports/misc/libsolv/libsolv-0.7.19/src/ |
| H A D | poolid.c | 74 for (i = 1, rd = pool->rels + i; i < pool->nrels; i++, rd++) in pool_resize_rels_hash()
105 ran = pool->rels; in pool_rel2id()
148 return pool->ss.stringspace + pool->ss.strings[id]; in pool_id2str()
242 return pool->ss.stringspace + pool->ss.strings[rd->evr]; in pool_id2evr()
308 strcpy(p, pool->ss.stringspace + pool->ss.strings[id]); in dep2strcpy()
316 return pool->ss.stringspace + pool->ss.strings[id]; in pool_dep2str()
317 p = pool_alloctmpspace(pool, dep2strlen(pool, id) + 1); in pool_dep2str()
325 pool->relhashtbl = solv_free(pool->relhashtbl); in pool_free_rels_hash()
333 if (pool->ss.stringhashmask && pool->ss.stringhashmask > mkmask(pool->ss.nstrings + 8192)) in pool_shrink_strings()
342 if (pool->relhashmask && pool->relhashmask > mkmask(pool->nrels + 4096)) in pool_shrink_rels()
[all …]
|
| /dports/games/3omns/3omns-0.2/b3/ |
| H A D | entity.c | 91 pool->index = b3_malloc(size * sizeof(*pool->index), 1); in b3_new_entity_pool()
95 pool->inactive[i] = &pool->entities[i]; in b3_new_entity_pool()
102 return pool; in b3_ref_entity_pool()
164 b3_entity_pool *pool = entity->pool; in deactivate_entity() local
173 if(pool && !--pool->ref_count) { in b3_free_entity_pool()
180 b3_free(pool, SIZEOF_ENTITY_POOL(pool, pool->size)); in b3_free_entity_pool()
226 entity->pool = pool; in b3_claim_entity()
241 (pool->count - i) * sizeof(*pool->index) in b3_claim_entity()
272 if(!pool) in b3_release_entity()
275 pool->inactive[pool->inactive_count++] = entity; in b3_release_entity()
[all …]
|