static size_t comp_read_from_dc(zckCtx *zck, zckComp *comp, char *dst,
size_t dst_size) {
- VALIDATE_TRI(zck);
- _VALIDATE_TRI(comp);
- _VALIDATE_TRI(dst);
+ VALIDATE_INT(zck);
+ _VALIDATE_INT(comp);
+ _VALIDATE_INT(dst);
size_t dl_size = dst_size;
if(dl_size > comp->dc_data_size - comp->dc_data_loc)
}
static ssize_t comp_end_dchunk(zckCtx *zck, int use_dict, size_t fd_size) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
ssize_t rb = zck->comp.end_dchunk(zck, &(zck->comp), use_dict, fd_size);
if(validate_current_chunk(zck) < 1)
}
static ssize_t comp_write(zckCtx *zck, const char *src, const size_t src_size) {
- VALIDATE_WRITE_TRI(zck);
+ VALIDATE_WRITE_INT(zck);
if(!zck->comp.started && !comp_init(zck))
return -1;
}
ssize_t comp_read(zckCtx *zck, char *dst, size_t dst_size, int use_dict) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
if(!zck->comp.started) {
set_error(zck, "Compression hasn't been initialized yet");
}
ssize_t PUBLIC zck_end_chunk(zckCtx *zck) {
- VALIDATE_WRITE_TRI(zck);
+ VALIDATE_WRITE_INT(zck);
if(!zck->comp.started && !comp_init(zck))
return -1;
}
ssize_t PUBLIC zck_read(zckCtx *zck, char *dst, size_t dst_size) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
return comp_read(zck, dst, dst_size, 1);
}
static ssize_t compress(zckCtx *zck, zckComp *comp, const char *src,
const size_t src_size, char **dst, size_t *dst_size,
int use_dict) {
- VALIDATE_TRI(zck);
- _VALIDATE_TRI(comp);
+ VALIDATE_INT(zck);
+ _VALIDATE_INT(comp);
comp->dc_data = realloc(comp->dc_data, comp->dc_data_size + src_size);
if(comp->dc_data == NULL) {
/* Write length or to end of current chunk, whichever comes first */
static int dl_write(zckDL *dl, const char *at, size_t length) {
- _VALIDATE_TRI(dl);
- VALIDATE_TRI(dl->zck);
+ _VALIDATE_INT(dl);
+ VALIDATE_INT(dl->zck);
int wb = 0;
if(dl->write_in_chunk > 0) {
}
ssize_t PUBLIC zck_dl_get_bytes_downloaded(zckDL *dl) {
- _VALIDATE_TRI(dl);
+ _VALIDATE_INT(dl);
return dl->dl;
}
ssize_t PUBLIC zck_dl_get_bytes_uploaded(zckDL *dl) {
- _VALIDATE_TRI(dl);
+ _VALIDATE_INT(dl);
return dl->ul;
}
}
int PUBLIC zck_get_range_count(zckRange *range) {
- _VALIDATE_TRI(range);
+ _VALIDATE_INT(range);
return range->count;
}
}
int PUBLIC zck_get_full_hash_type(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->hash_type.type;
}
ssize_t PUBLIC zck_get_full_digest_size(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->hash_type.digest_size;
}
int PUBLIC zck_get_chunk_hash_type(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->index.hash_type;
}
ssize_t PUBLIC zck_get_chunk_digest_size(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->index.digest_size;
}
}
ssize_t PUBLIC zck_get_header_length(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->lead_size + zck->header_length;
}
ssize_t PUBLIC zck_get_lead_length(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->lead_size;
}
ssize_t PUBLIC zck_get_data_length(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
zckChunk *idx = zck->index.first;
while(idx->next != NULL)
idx = idx->next;
}
ssize_t PUBLIC zck_get_length(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck_get_header_length(zck) + zck_get_data_length(zck);
}
}
ssize_t PUBLIC zck_get_chunk_count(zckCtx *zck) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
return zck->index.count;
}
}
ssize_t PUBLIC zck_get_chunk_start(zckChunk *idx) {
- _VALIDATE_TRI(idx);
+ _VALIDATE_INT(idx);
if(idx->zck) {
- VALIDATE_TRI(idx->zck);
+ VALIDATE_INT(idx->zck);
return idx->start + zck_get_header_length(idx->zck);
} else {
return idx->start;
}
ssize_t PUBLIC zck_get_chunk_size(zckChunk *idx) {
- _VALIDATE_TRI(idx);
+ _VALIDATE_INT(idx);
return idx->length;
}
ssize_t PUBLIC zck_get_chunk_comp_size(zckChunk *idx) {
- _VALIDATE_TRI(idx);
+ _VALIDATE_INT(idx);
return idx->comp_length;
}
int PUBLIC zck_get_chunk_valid(zckChunk *idx) {
- _VALIDATE_TRI(idx);
+ _VALIDATE_INT(idx);
return idx->valid;
}
}
int PUBLIC zck_missing_chunks(zckCtx *zck) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
int missing = 0;
for(zckChunk *idx = zck->index.first; idx; idx=idx->next)
}
int PUBLIC zck_failed_chunks(zckCtx *zck) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
int failed = 0;
for(zckChunk *idx = zck->index.first; idx; idx=idx->next)
#include "zck_private.h"
ssize_t read_data(zckCtx *zck, char *data, size_t length) {
- VALIDATE_READ_TRI(zck);
+ VALIDATE_READ_INT(zck);
if(length == 0)
return 0;
}
int write_data(zckCtx *zck, int fd, const char *data, size_t length) {
- VALIDATE_WRITE_TRI(zck);
+ VALIDATE_WRITE_INT(zck);
if(length == 0)
return True;
}
int seek_data(zckCtx *zck, off_t offset, int whence) {
- VALIDATE_TRI(zck);
+ VALIDATE_INT(zck);
if(lseek(zck->fd, offset, whence) == -1) {
char *wh_str = NULL;
"Object not initialized"); \
return False; \
}
-#define _VALIDATE_TRI(f) if(!f) { \
+#define _VALIDATE_INT(f) if(!f) { \
zck_log(ZCK_LOG_NONE, \
"Object not initialized"); \
return -1; \
}
#define VALIDATE_BOOL(f) _VALIDATE_BOOL(f) \
if((f)->error_state > 0) return False;
-#define VALIDATE_TRI(f) _VALIDATE_TRI(f) \
+#define VALIDATE_INT(f) _VALIDATE_INT(f) \
if((f)->error_state > 0) return -1;
#define VALIDATE_CHAR(f) _VALIDATE_CHAR(f) \
if((f)->error_state > 0) return NULL;
"zckCtx not opened for reading"); \
return False; \
}
-#define VALIDATE_READ_TRI(f) VALIDATE_TRI(f); \
+#define VALIDATE_READ_INT(f) VALIDATE_INT(f); \
if(f->mode != ZCK_MODE_READ) { \
set_error(f, \
"zckCtx not opened for reading"); \
"zckCtx not opened for writing"); \
return False; \
}
-#define VALIDATE_WRITE_TRI(f) VALIDATE_TRI(f); \
+#define VALIDATE_WRITE_INT(f) VALIDATE_INT(f); \
if(f->mode != ZCK_MODE_WRITE) { \
set_error(f, \
"zckCtx not opened for writing"); \