ra8_fmt_host_fd_internal.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
 
#include "ra8_attributes.h"
#include "ra8_fmt_stream.h"

typedef enum : uint32_t {
  k_ra8_fmt_host_path_cap = 1024U, 
  k_ra8_fmt_host_name_cap = 256U,  
} ra8_fmt_host_limit_t;

typedef struct {
  uint64_t device;     
  uint64_t inode;      
  uint64_t size;       
  int64_t  mtime_sec;  
  int64_t  mtime_nsec; 
  int64_t  ctime_sec;  
  int64_t  ctime_nsec; 
} ra8_fmt_host_snapshot_t;

typedef struct {
  int                     fd;       
  ra8_fmt_source_t        source;   
  ra8_fmt_host_snapshot_t snapshot; 
} ra8_fmt_host_source_t;

typedef struct {
  int fd; 
} ra8_fmt_host_fd_sink_t;

typedef struct {
  int      parent_fd;                           
  int      stage_fd;                            
  uint64_t position;                            
  char     stage_name[k_ra8_fmt_host_name_cap]; 
  char     final_name[k_ra8_fmt_host_name_cap]; 
  bool     stage_exists;                        
  bool     active;                              
} ra8_fmt_host_transaction_t;

RA8_PRIV [[nodiscard]] ra8_err_t
priv_fmt_host_source_open(const char* path, uint64_t max_size, ra8_fmt_host_source_t* out);

RA8_PRIV [[nodiscard]] bool priv_fmt_host_sources_same(const ra8_fmt_host_source_t* first,
                                                       const ra8_fmt_host_source_t* second);

RA8_PRIV [[nodiscard]] ra8_err_t
priv_fmt_host_source_unchanged(const ra8_fmt_host_source_t* source);

RA8_PRIV void priv_fmt_host_source_close(ra8_fmt_host_source_t* source);

RA8_PRIV [[nodiscard]] ra8_fmt_sink_t priv_fmt_host_fd_sink(ra8_fmt_host_fd_sink_t* state);

RA8_PRIV void priv_fmt_host_log_byte(void* ctx, uint8_t byte);

RA8_PRIV [[nodiscard]] ra8_err_t priv_fmt_host_transaction_begin(const char*                 path,
                                                                 ra8_fmt_host_transaction_t* state,
                                                                 ra8_fmt_transaction_t*      out);