video_frame.h

Go to the documentation of this file.

#pragma once
 
// C11 stdatomic.h conflicts with MSVC's C++ <atomic> header on Windows.
#if defined(__cplusplus) && defined(_WIN32)
#include <atomic>
#else
#include <stdatomic.h>
#endif
#include <stdint.h>
#include <stdbool.h>
#include <time.h>
#include "platform/abstraction.h"
 
/* ============================================================================
 * Video Frame Constants
 * ============================================================================
 */
 
#define VIDEO_FRAME_BUFFER_SIZE (2 * 1024 * 1024)
#define MAX_FRAME_BUFFERS 2
 
/* ============================================================================
 * Data Structures
 * ============================================================================
 */
 
typedef struct {
  void *data;  
  size_t size; 
  uint32_t width;  
  uint32_t height; 
  uint64_t capture_timestamp_us; 
  uint64_t receive_timestamp_us; 
  uint64_t sequence_number;      
  uint32_t encoding_time_us; 
  bool is_keyframe;          
} video_frame_t;
 
typedef struct {
  video_frame_t *front_buffer; 
  video_frame_t *back_buffer;  
  atomic_bool new_frame_available; 
  mutex_t swap_mutex;              
  video_frame_t frames[2]; 
  atomic_ullong total_frames_received; 
  atomic_ullong total_frames_dropped;  
  atomic_ullong last_frame_sequence;   
  atomic_uint avg_decode_time_us; 
  atomic_uint avg_render_time_us; 
  uint32_t client_id; 
  bool active;        
  size_t allocated_buffer_size; 
} video_frame_buffer_t;
 
typedef struct {
  uint64_t total_frames;
  uint64_t dropped_frames;
  float drop_rate;
  uint32_t avg_decode_time_us;
  uint32_t avg_render_time_us;
} video_frame_stats_t;
 
typedef struct {
  atomic_uintptr_t current_frame; 
  video_frame_t frame_a;          
  video_frame_t frame_b;          
  atomic_bool use_frame_a;        
} simple_frame_swap_t;
 
/* ============================================================================
 * Video Frame Buffer API
 * @{
 */
 
video_frame_buffer_t *video_frame_buffer_create(uint32_t client_id);
 
void video_frame_buffer_destroy(video_frame_buffer_t *vfb);
 
video_frame_t *video_frame_begin_write(video_frame_buffer_t *vfb);
 
void video_frame_commit(video_frame_buffer_t *vfb);
 
const video_frame_t *video_frame_get_latest(video_frame_buffer_t *vfb);
 
void video_frame_get_stats(video_frame_buffer_t *vfb, video_frame_stats_t *stats);
 
/* ============================================================================
 * Simple Frame Swap API (Lightweight Alternative)
 * @{
 */
 
simple_frame_swap_t *simple_frame_swap_create(void);
 
void simple_frame_swap_destroy(simple_frame_swap_t *sfs);
 
void simple_frame_swap_update(simple_frame_swap_t *sfs, const void *data, size_t size);
 
const video_frame_t *simple_frame_swap_get(simple_frame_swap_t *sfs);