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 <ascii-chat/atomic.h>
#endif
#include <stdint.h>
#include <stdbool.h>
#include <time.h>
#include <ascii-chat/platform/abstraction.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);