scrcpy/app/src/decoder.h

#ifndef DECODER_H
#define DECODER_H

#include <SDL2/SDL_stdinc.h>
#include <SDL2/SDL_thread.h>

#include "common.h"
#include "net.h"

struct frames;

struct frame_meta {
    uint64_t pts;
    struct frame_meta *next;
};

struct decoder {
    struct frames *frames;
    socket_t video_socket;
    SDL_Thread *thread;
    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;
};

void decoder_init(struct decoder *decoder, struct frames *frames,
                  socket_t video_socket, struct recorder *recoder);
SDL_bool decoder_start(struct decoder *decoder);
void decoder_stop(struct decoder *decoder);
void decoder_join(struct decoder *decoder);

#endif
Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00			`#ifndef DECODER_H`
			`#define DECODER_H`

Optimize includes Only include SDL_stdinc.h for SDL_bool, not the whole SDL.h. 2017-12-15 17:34:16 +01:00			`#include <SDL2/SDL_stdinc.h>`
Replace SDL_net by custom implementation SDL_net is not very suitable for scrcpy. For example, SDLNet_TCP_Accept() is non-blocking, so we have to wrap it by calling many SDL_Net-specific functions to make it blocking. But above all, SDLNet_TCP_Open() is a server socket only when no IP is provided; otherwise, it's a client socket. Therefore, it is not possible to create a server socket bound to localhost, so it accepts connections from anywhere. This is a problem for scrcpy, because on start, the application listens for nearly 1 second until it accepts the first connection, supposedly from the device. If someone on the local network manages to connect to the server socket first, then they can stream arbitrary H.264 video. This may be troublesome, for example during a public presentation ;-) Provide our own simplified API (net.h) instead, implemented for the different platforms. 2018-02-15 22:59:21 +01:00			`#include <SDL2/SDL_thread.h>`

Enable video output file, with pts set by server 2018-10-11 07:12:36 +02:00			`#include "common.h"`
Replace SDL_net by custom implementation SDL_net is not very suitable for scrcpy. For example, SDLNet_TCP_Accept() is non-blocking, so we have to wrap it by calling many SDL_Net-specific functions to make it blocking. But above all, SDLNet_TCP_Open() is a server socket only when no IP is provided; otherwise, it's a client socket. Therefore, it is not possible to create a server socket bound to localhost, so it accepts connections from anywhere. This is a problem for scrcpy, because on start, the application listens for nearly 1 second until it accepts the first connection, supposedly from the device. If someone on the local network manages to connect to the server socket first, then they can stream arbitrary H.264 video. This may be troublesome, for example during a public presentation ;-) Provide our own simplified API (net.h) instead, implemented for the different platforms. 2018-02-15 22:59:21 +01:00			`#include "net.h"`
Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00
			`struct frames;`

Store queue of PTS for pending frames Several frames may be read by read_packet() before they are consumed (returned by av_read_frame()), so we need to store the PTS of frames in order, so that the right PTS is assigned to the right frame. 2018-11-11 15:27:52 +01:00			`struct frame_meta {`
			`uint64_t pts;`
			`struct frame_meta *next;`
			`};`

Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00			`struct decoder {`
			`struct frames *frames;`
Replace SDL_net by custom implementation SDL_net is not very suitable for scrcpy. For example, SDLNet_TCP_Accept() is non-blocking, so we have to wrap it by calling many SDL_Net-specific functions to make it blocking. But above all, SDLNet_TCP_Open() is a server socket only when no IP is provided; otherwise, it's a client socket. Therefore, it is not possible to create a server socket bound to localhost, so it accepts connections from anywhere. This is a problem for scrcpy, because on start, the application listens for nearly 1 second until it accepts the first connection, supposedly from the device. If someone on the local network manages to connect to the server socket first, then they can stream arbitrary H.264 video. This may be troublesome, for example during a public presentation ;-) Provide our own simplified API (net.h) instead, implemented for the different platforms. 2018-02-15 22:59:21 +01:00			`socket_t video_socket;`
Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00			`SDL_Thread *thread;`
Add recorder Implement recording in a separate "class". 2018-11-09 12:21:17 +01:00			`struct recorder *recorder;`
Wrap receiver state into separate struct For readability, wrap the state of the receiver in a separate struct receiver_state. 2018-11-11 12:36:08 +01:00			`struct receiver_state {`
Store queue of PTS for pending frames Several frames may be read by read_packet() before they are consumed (returned by av_read_frame()), so we need to store the PTS of frames in order, so that the right PTS is assigned to the right frame. 2018-11-11 15:27:52 +01:00			`// meta (in order) for frames not consumed yet`
			`struct frame_meta *frame_meta_queue;`
Wrap receiver state into separate struct For readability, wrap the state of the receiver in a separate struct receiver_state. 2018-11-11 12:36:08 +01:00			`size_t remaining; // remaining bytes to receive for the current frame`
			`} receiver_state;`
Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00			`};`

Add recorder Implement recording in a separate "class". 2018-11-09 12:21:17 +01:00			`void decoder_init(struct decoder decoder, struct frames frames,`
			`socket_t video_socket, struct recorder *recoder);`
			`SDL_bool decoder_start(struct decoder *decoder);`
Fix deadlock on exit if SKIP_FRAMES disabled On exit, the renderer will not consume frames anymore, so signal the condition variable to wake up the decoder. 2018-02-09 08:42:39 +01:00			`void decoder_stop(struct decoder *decoder);`
Initial commit Start a new clean history from here. 2017-12-12 15:12:07 +01:00			`void decoder_join(struct decoder *decoder);`

			`#endif`