seq.h

Go to the documentation of this file.

 
#ifndef __CWIST_CORE_SEQ_SEQ_H__
#define __CWIST_CORE_SEQ_SEQ_H__
 
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
#define CWIST_SEQ_HEADER_SIZE 8
 
#define CWIST_SEQ_DEFAULT_CHUNK_PAYLOAD 1024
 
#define CWIST_SEQ_MAX_CHUNKS 8192
#define CWIST_SEQ_MAX_REASSEMBLED_SIZE (64U * 1024U * 1024U)
 
typedef struct cwist_seq_chunk {
    uint16_t seq;           
    uint16_t total;         
    uint16_t payload_len;   
    uint16_t chunk_size;    
    const uint8_t *payload; 
} cwist_seq_chunk_t;
 
typedef struct cwist_seq_message {
    uint8_t **chunks;    
    size_t *chunk_lens;  
    size_t count;        
} cwist_seq_message_t;
 
typedef struct cwist_seq_assembler cwist_seq_assembler_t;
 
bool cwist_seq_chunk_parse(const uint8_t *data, size_t len, cwist_seq_chunk_t *out);
 
void cwist_seq_chunk_build_header(uint8_t out[CWIST_SEQ_HEADER_SIZE], uint16_t seq, uint16_t total,
                                  uint16_t payload_len, uint16_t chunk_size);
 
bool cwist_seq_split(const uint8_t *data, size_t len, uint16_t chunk_payload_size,
                     cwist_seq_message_t *out);
 
void cwist_seq_message_free(cwist_seq_message_t *msg);
 
cwist_seq_assembler_t *cwist_seq_assembler_create(void);
 
cwist_seq_assembler_t *cwist_seq_assembler_create_limited(size_t max_data_len);
 
void cwist_seq_assembler_destroy(cwist_seq_assembler_t *a);
 
bool cwist_seq_assembler_feed(cwist_seq_assembler_t *a, const cwist_seq_chunk_t *chunk);
 
bool cwist_seq_assembler_is_complete(const cwist_seq_assembler_t *a);
 
size_t cwist_seq_assembler_recovery_targets(const cwist_seq_assembler_t *a, uint16_t *out,
                                            size_t out_cap);
 
bool cwist_seq_assembler_get_data(cwist_seq_assembler_t *a, const uint8_t **out_data,
                                  size_t *out_len);
 
void cwist_seq_assembler_reset(cwist_seq_assembler_t *a);
 
#ifdef __cplusplus
}
#endif
 
#endif /* __CWIST_CORE_SEQ_SEQ_H__ */