network/websocket/internal.h

Go to the documentation of this file.

 
#ifndef ASCIICHAT_NETWORK_WEBSOCKET_INTERNAL_H
#define ASCIICHAT_NETWORK_WEBSOCKET_INTERNAL_H
 
#include <ascii-chat/platform/abstraction.h>
#include <ascii-chat/ringbuffer.h>
#include <stdint.h>
#include <stdbool.h>
#include <stddef.h>
#include <ascii-chat/atomic.h>
 
typedef struct {
  uint8_t *data; 
  size_t len;    
  uint8_t first; 
  uint8_t final; 
} websocket_msg_t;
 
// Alias for backward compatibility
typedef websocket_msg_t websocket_recv_msg_t;
 
typedef struct {
  uint8_t *ptr; 
  size_t size;  
} pending_free_item_t;
 
typedef struct {
  struct lws *wsi;             
  struct lws_context *context; 
  bool owns_context;           
  ringbuffer_t *recv_queue;    
  ringbuffer_t *send_queue;    
  mutex_t recv_mutex;          
  cond_t recv_cond;            
  mutex_t send_mutex;          
  bool is_connected;           
  bool connection_failed;      
  mutex_t state_mutex;         
  cond_t state_cond;           
  uint8_t *send_buffer;        
  size_t send_buffer_capacity; 
 
  // Service thread for client-side transports
  asciichat_thread_t service_thread; 
  volatile bool service_running;     
 
  // Partial message reassembly state (preserved across recv() calls)
  // Fixes issue where slow fragment delivery caused reassembly timeouts
  // and orphaned fragments in the queue
  uint8_t *partial_buffer;      
  size_t partial_size;          
  size_t partial_capacity;      
  uint64_t reassembly_start_ns; 
  int fragment_count;           
  bool reassembling;            
 
  // Deferred buffer freeing for compression layer compatibility
  // permessage-deflate holds buffer references asynchronously after lws_write()
  // We defer freeing to prevent use-after-free in the compression layer
  ringbuffer_t *pending_free_queue; 
  mutex_t pending_free_mutex;       
 
  // Graceful shutdown flag for thread-safe destruction
  // When destroying the transport, this flag is set to true to signal all threads
  // to exit send/recv operations before mutexes are destroyed.
  atomic_t is_destroying;        
 
} websocket_transport_data_t;
 
#endif // ASCIICHAT_NETWORK_WEBSOCKET_INTERNAL_H