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/ringbuffer.h>
#include <ascii-chat/network/acip/transport.h>
#include <stdint.h>
#include <stdbool.h>
#include <stddef.h>
#include <libplatform/atomic.h>

typedef struct {
  uint8_t *data; 
  size_t len;    
  uint8_t first; 
  uint8_t final; 
} websocket_msg_t;

asciichat_error_t websocket_transport_send(acip_transport_t *transport, const void *data, size_t len);
 
// Alias for backward compatibility
typedef websocket_msg_t websocket_recv_msg_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;           
 
  // Service thread for client-side transports
  platform_thread_t service_thread; 
  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;            
 
  size_t pending_send_bytes; 
  size_t inflight_bytes;
  uint8_t *inflight_buffer; 
 
  // 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 server_handler_owned;
  atomic_t server_detached;
  atomic_t is_destroying; 
 
} websocket_transport_data_t;
 
void websocket_transport_write_pending(struct lws *wsi, websocket_transport_data_t *ws_data);
 
#endif // ASCIICHAT_NETWORK_WEBSOCKET_INTERNAL_H