include/drake/stream.h

Go to the documentation of this file.

/*
 Copyright 2015 Nicolas Melot

 This file is part of Drake.

 Drake is free software: you can redistribute it and/or modify
 it under the terms of the GNU General Public License as published by
 the Free Software Foundation, either version 3 of the License, or
 (at your option) any later version.

 Drake is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 GNU General Public License for more details.

 You should have received a copy of the GNU General Public License
 along with Drake. If not, see <http://www.gnu.org/licenses/>.

*/


#include <stddef.h>
#include <drake/mapping.h>
#include <drake/processor.h>
#include <drake/platform.h>
#include <drake/schedule.h>

#ifndef DRAKE_STREAM_H
#define DRAKE_STREAM_H

typedef struct {
        mapping_t *mapping;
        processor_t *proc;
        size_t local_memory_size;
        drake_time_t stage_time;
        drake_time_t stage_start_time;
        drake_time_t stage_stop_time;
        drake_time_t stage_sleep_time;
        void (*schedule_destroy)();
        drake_schedule_t schedule;
        void* (*func)(size_t id, task_status_t status);
        drake_platform_t platform;
        drake_time_t zero;
} drake_stream_t;

drake_stream_t drake_stream_create_explicit(void (*schedule_init)(), void (*schedule_destroy)(drake_schedule_t*), void* (*task_function)(size_t id, task_status_t status), drake_platform_t pt);
int drake_stream_init(drake_stream_t* stream, void* arg);
int drake_stream_run(drake_stream_t*);
int drake_stream_destroy(drake_stream_t*);

#endif