video_export.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	VIDEO_EXPORT_SUMMARY_VERSION   1

Functions
void	video_export (struct video_export *state, struct video_frame *frame)
void	video_export_destroy (struct video_export *state)
struct video_export *	video_export_init (const char *path)

Detailed Description

Author

Martin Pulec marti.nosp@m.n.pu.nosp@m.lec@c.nosp@m.esne.nosp@m.t.cz

Definition in file video_export.h.

Macro Definition Documentation

VIDEO_EXPORT_SUMMARY_VERSION

#define VIDEO_EXPORT_SUMMARY_VERSION   1

Definition at line 41 of file video_export.h.

Referenced by output_summary(), and parse_video_desc_info().

Function Documentation

video_export()

void video_export	(	struct video_export *	state,
		struct video_frame *	frame )

Definition at line 203 of file video_export.c.

{
        if(!s) {
                return;
        }
 
        assert(frame != NULL);
        s->total += 1;
 
        if(s->saved_desc.width == 0) {
                s->saved_desc = video_desc_from_frame(frame);
        } else {
                if(!video_desc_eq(s->saved_desc, video_desc_from_frame(frame))) {
                        fprintf(stderr, "[Video export] Format change detected, not exporting.\n");
                        return;
                }
        }
 
        for (unsigned int i = 0; i < frame->tile_count; ++i) {
                assert(frame->tiles[i].data != NULL && frame->tiles[i].data_len != 0);
 
                struct output_entry *entry = malloc(sizeof(struct output_entry));
 
                entry->data_len = frame->tiles[i].data_len;
                entry->data = (char *) malloc(entry->data_len);
                entry->filename = malloc(MAX_PATH_SIZE);
                entry->next = NULL;
 
                if(frame->tile_count == 1) {
                        snprintf(entry->filename, MAX_PATH_SIZE, "%s/%08d.%s", s->path,
                                 s->total,
                                 get_codec_file_extension(frame->color_spec));
                } else {
                        // add also tile index
                        snprintf(entry->filename, MAX_PATH_SIZE, "%s/%08d_%d.%s", s->path,
                                 s->total, i,
                                 get_codec_file_extension(frame->color_spec));
                }
                memcpy(entry->data, frame->tiles[i].data, entry->data_len);
 
                pthread_mutex_lock(&s->lock);
                {
                        // check if we do not occupy too much memory
                        if(s->queue_len >= MAX_QUEUE_SIZE) {
                                fprintf(stderr, "[Video export] Maximal queue size (%d) exceeded, not saving frame %d.\n",
                                                MAX_QUEUE_SIZE,
                                                s->total); // we increment total size to keep the index
                                pthread_mutex_unlock(&s->lock);
                                free(entry->data);
                                free(entry);
                                return;
                        }
 
                        if(s->head) {
                                s->tail->next = entry;
                                s->tail = entry;
                        } else {
                                s->head = s->tail = entry;
                        }
                        s->queue_len += 1;
                }
                pthread_mutex_unlock(&s->lock);
 
                platform_sem_post(&s->semaphore);
        }
}

References video_frame::color_spec, output_entry::data, tile::data, output_entry::data_len, tile::data_len, output_entry::filename, frame, get_codec_file_extension(), video_export::head, video_export::lock, MAX_PATH_SIZE, MAX_QUEUE_SIZE, output_entry::next, video_export::path, platform_sem_post(), video_export::queue_len, video_export::saved_desc, video_export::semaphore, video_export::tail, video_frame::tile_count, video_frame::tiles, video_export::total, video_desc_eq(), video_desc_from_frame(), and video_desc::width.

Referenced by export_video().

Here is the call graph for this function:

video_export_destroy()

void video_export_destroy

(

struct video_export *

state

)

Definition at line 172 of file video_export.c.

{
        if(s) {
                // poison
                struct output_entry *entry = calloc(1, sizeof(struct output_entry));
 
                pthread_mutex_lock(&s->lock);
                {
                        if(s->head) {
                                s->tail->next = entry;
                                s->tail = entry;
                        } else {
                                s->head = s->tail = entry;
                        }
                }
                pthread_mutex_unlock(&s->lock);
                platform_sem_post(&s->semaphore);
 
                pthread_join(s->thread_id, NULL);
                pthread_mutex_destroy(&s->lock);
 
                // write summary
                if(s->total > 0) {
                        output_summary(s);
                }
 
                free(s->path);
                free(s);
        }
}

References video_export::head, video_export::lock, output_entry::next, output_summary(), video_export::path, platform_sem_post(), video_export::semaphore, video_export::tail, video_export::thread_id, and video_export::total.

Referenced by disable_export(), and enable_export().

Here is the call graph for this function:

video_export_init()

struct video_export * video_export_init

(

const char *

path

)

Definition at line 125 of file video_export.c.

{
        struct video_export *s = calloc(1, sizeof *s);
        assert(s != NULL);
 
        platform_sem_init(&s->semaphore, 0, 0);
        pthread_mutex_init(&s->lock, NULL);
        s->total = s->queue_len = 0;
        assert(path != NULL);
        s->path = strdup(path);
        s->head = s->tail = NULL;
 
        memset(&s->saved_desc, 0, sizeof(s->saved_desc));
 
        if(pthread_create(&s->thread_id, NULL, video_export_thread, s) != 0) {
                fprintf(stderr, "[Video exporter] Failed to create thread.\n");
                free(s);
                return NULL;
        }
 
        return s;
}

References video_export::head, video_export::lock, video_export::path, platform_sem_init(), video_export::queue_len, video_export::saved_desc, video_export::semaphore, video_export::tail, video_export::thread_id, video_export::total, and video_export_thread().

Referenced by enable_export().

Here is the call graph for this function: