UltraGrid
UltraGrid Low-Latency High-Resolution Transmission System
Loading...
Searching...
No Matches
parallel_conv.h File Reference
#include "pixfmt_conv.h"
Include dependency graph for parallel_conv.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

void parallel_pix_conv (int height, char *out, int out_linesize, const char *in, int in_linesize, decoder_t decode, int threads)
 

Detailed Description

Author
Martin Pulec pulec.nosp@m.@ces.nosp@m.net.c.nosp@m.z

Definition in file parallel_conv.h.

Function Documentation

◆ parallel_pix_conv()

void parallel_pix_conv ( int height,
char * out,
int out_linesize,
const char * in,
int in_linesize,
decoder_t decode,
int threads )

Runs specified decoder in parallel

Parameters
threadsnumber of threads; use 0 to use all logical threads
Todo
utilize respawn_parallel

Definition at line 64 of file parallel_conv.c.

65{
66 if (threads == 0) {
67 threads = get_cpu_core_count();
68 }
69 assert(threads > 0);
70 struct parallel_pix_conv_data data[threads];
71
72 for (ptrdiff_t i = 0; i < threads; ++i) {
73 data[i].decode = decode;
74 data[i].height = height / threads;
75 data[i].out_data = (unsigned char *) out + i * data[i].height * out_linesize;
76 data[i].out_linesize = out_linesize;
77 data[i].in_data = (const unsigned char *) in + i * data[i].height * in_linesize;
78 data[i].in_linesize = in_linesize;
79 if (i == threads - 1) {
80 data[i].height = height - (threads - 1) * (height / threads);
81 }
82 }
83
84 task_run_parallel(parallel_pix_conv_task, threads, data, sizeof data[0], NULL);
85}
int get_cpu_core_count(void)
Definition misc.cpp:218
static void * parallel_pix_conv_task(void *arg)
void task_run_parallel(runnable_t task, int worker_count, void *data, size_t data_size, void **res)
Definition worker.cpp:294

References parallel_pix_conv_data::decode, get_cpu_core_count(), parallel_pix_conv_data::height, parallel_pix_conv_data::in_data, parallel_pix_conv_data::in_linesize, parallel_pix_conv_data::out_data, parallel_pix_conv_data::out_linesize, parallel_pix_conv_task(), and task_run_parallel().

Referenced by filter(), parallel_conv(), rg48_to_r12l(), to_lavc_vid_conv(), and vidcap_screen_x11_grab().

Here is the call graph for this function: