2019-03-02 23:43:43 +08:00
|
|
|
#ifndef STREAM_H
|
|
|
|
#define STREAM_H
|
|
|
|
|
2019-03-03 06:52:22 +08:00
|
|
|
#include <stdbool.h>
|
|
|
|
#include <stdint.h>
|
2019-05-30 17:57:40 +08:00
|
|
|
#include <SDL2/SDL_atomic.h>
|
2019-03-02 23:43:43 +08:00
|
|
|
#include <SDL2/SDL_thread.h>
|
|
|
|
|
|
|
|
#include "net.h"
|
|
|
|
|
|
|
|
struct video_buffer;
|
|
|
|
|
|
|
|
struct frame_meta {
|
2019-03-03 06:52:22 +08:00
|
|
|
uint64_t pts;
|
2019-03-02 23:43:43 +08:00
|
|
|
struct frame_meta *next;
|
|
|
|
};
|
|
|
|
|
|
|
|
struct stream {
|
|
|
|
socket_t socket;
|
|
|
|
struct video_buffer *video_buffer;
|
|
|
|
SDL_Thread *thread;
|
2019-05-30 17:57:40 +08:00
|
|
|
SDL_atomic_t stopped;
|
2019-03-02 23:43:43 +08:00
|
|
|
struct decoder *decoder;
|
|
|
|
struct recorder *recorder;
|
|
|
|
struct receiver_state {
|
|
|
|
// meta (in order) for frames not consumed yet
|
|
|
|
struct frame_meta *frame_meta_queue;
|
|
|
|
size_t remaining; // remaining bytes to receive for the current frame
|
|
|
|
} receiver_state;
|
|
|
|
};
|
|
|
|
|
2019-03-03 03:09:56 +08:00
|
|
|
void
|
|
|
|
stream_init(struct stream *stream, socket_t socket,
|
|
|
|
struct decoder *decoder, struct recorder *recorder);
|
|
|
|
|
2019-03-03 06:52:22 +08:00
|
|
|
bool
|
2019-03-03 03:09:56 +08:00
|
|
|
stream_start(struct stream *stream);
|
|
|
|
|
|
|
|
void
|
|
|
|
stream_stop(struct stream *stream);
|
|
|
|
|
|
|
|
void
|
|
|
|
stream_join(struct stream *stream);
|
2019-03-02 23:43:43 +08:00
|
|
|
|
|
|
|
#endif
|