video_frame.h

Go to the documentation of this file.

#pragma once
#include <libplatform/mutex.h>

 
// C11 stdatomic.h conflicts with MSVC's C++ <atomic> header on Windows.
#if defined(__cplusplus) && defined(_WIN32)
#include <atomic>
#else
#include <libplatform/atomic.h>
#endif
#include <stdint.h>
#include <stdbool.h>
#include <time.h>
#include <ascii-chat/common/buffer_sizes.h>
 
/* ============================================================================
 * Video Frame Constants
 * ============================================================================
 */

#define VIDEO_FRAME_BUFFER_SIZE MAX_FRAME_BUFFER_SIZE
#define MAX_FRAME_BUFFERS 2
 
/* ============================================================================
 * Data Structures
 * ============================================================================
 */

typedef struct {
  void *data;  
  size_t size; 

  uint32_t width;  
  uint32_t height; 

  uint64_t capture_timestamp_ns; 
  uint64_t receive_timestamp_ns; 
  uint64_t sequence_number;      

  uint64_t encoding_time_ns; 
  bool is_keyframe;          
} video_frame_t;

typedef struct {
  video_frame_t *front_buffer; 
  video_frame_t *back_buffer;  

  atomic_t new_frame_available; 
  mutex_t swap_mutex;           

  video_frame_t frames[2]; 

  atomic_t total_frames_received; 
  atomic_t total_frames_dropped;  
  atomic_t last_frame_sequence;   

  atomic_t avg_decode_time_ns; 
  atomic_t avg_render_time_ns; 

  const char *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;
  uint64_t avg_decode_time_ns;
  uint64_t avg_render_time_ns;
} video_frame_stats_t;

typedef struct {
  atomic_t current_frame; 
  video_frame_t frame_a;  
  video_frame_t frame_b;  
  atomic_t use_frame_a;   
} simple_frame_swap_t;
 
/* ============================================================================
 * Video Frame Buffer API
 * @{
 */

video_frame_buffer_t *video_frame_buffer_create(const char *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);

const video_frame_t *video_frame_peek_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);