parallel_conv.c File Reference

#include <assert.h>
#include "utils/misc.h"
#include "utils/parallel_conv.h"
#include "utils/worker.h"

Include dependency graph for parallel_conv.c:

Go to the source code of this file.

Classes
struct	parallel_pix_conv_data

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

Detailed Description

Author

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

Definition in file parallel_conv.c.

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 )

Todo

utilize respawn_parallel

Definition at line 64 of file parallel_conv.c.

{
        if (threads == 0) {
                threads = get_cpu_core_count();
        }
        assert(threads > 0);
        struct parallel_pix_conv_data data[threads];
 
        for (ptrdiff_t i = 0; i < threads; ++i) {
                data[i].decode = decode;
                data[i].height = height / threads;
                data[i].out_data = (unsigned char *) out + i * data[i].height * out_linesize;
                data[i].out_linesize = out_linesize;
                data[i].in_data = (const unsigned char *) in + i * data[i].height * in_linesize;
                data[i].in_linesize = in_linesize;
                if (i == threads - 1) {
                        data[i].height = height - (threads - 1) * (height / threads);
                }
        }
 
        task_run_parallel(parallel_pix_conv_task, threads, data, sizeof data[0], NULL);
}

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:

parallel_pix_conv_task()

static void * parallel_pix_conv_task ( void * arg )

static

Definition at line 53 of file parallel_conv.c.

                                               {
        struct parallel_pix_conv_data *data = arg;
        for (int y = 0; y < data->height; ++y) {
                data->decode(data->out_data, data->in_data, data->out_linesize, DEFAULT_R_SHIFT, DEFAULT_G_SHIFT, DEFAULT_B_SHIFT);
                data->out_data += data->out_linesize;
                data->in_data += data->in_linesize;
        }
        return NULL;
}

References parallel_pix_conv_data::decode, DEFAULT_B_SHIFT, DEFAULT_G_SHIFT, DEFAULT_R_SHIFT, parallel_pix_conv_data::height, parallel_pix_conv_data::in_data, parallel_pix_conv_data::in_linesize, parallel_pix_conv_data::out_data, and parallel_pix_conv_data::out_linesize.

Referenced by parallel_pix_conv().