static size_t comp_read_from_dc(zckCtx *zck, zckComp *comp, char *dst,
size_t dst_size) {
VALIDATE_INT(zck);
- _VALIDATE_INT(comp);
- _VALIDATE_INT(dst);
+ ALLOCD_INT(comp);
+ ALLOCD_INT(dst);
size_t dl_size = dst_size;
if(dl_size > comp->dc_data_size - comp->dc_data_loc)
static int comp_add_to_data(zckCtx *zck, zckComp *comp, const char *src,
size_t src_size) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
- _VALIDATE_BOOL(src);
+ ALLOCD_BOOL(comp);
+ ALLOCD_BOOL(src);
comp->data = realloc(comp->data, comp->data_size + src_size);
if(comp->data == NULL) {
}
int comp_reset(zckCtx *zck) {
- _VALIDATE_BOOL(zck);
+ ALLOCD_BOOL(zck);
zck->comp.started = 0;
if(zck->comp.dc_data) {
}
int comp_close(zckCtx *zck) {
- _VALIDATE_BOOL(zck);
+ ALLOCD_BOOL(zck);
zck_log(ZCK_LOG_DEBUG, "Closing compression");
if(zck->comp.data) {
int comp_add_to_dc(zckCtx *zck, zckComp *comp, const char *src,
size_t src_size) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
- _VALIDATE_BOOL(src);
+ ALLOCD_BOOL(comp);
+ ALLOCD_BOOL(src);
/* Get rid of any already read data and allocate space for new data */
char *temp = zmalloc(comp->dc_data_size - comp->dc_data_loc + src_size);
static int init(zckCtx *zck, zckComp *comp) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
+ ALLOCD_BOOL(comp);
comp->cctx = ZSTD_createCCtx();
comp->dctx = ZSTD_createDCtx();
const size_t src_size, char **dst, size_t *dst_size,
int use_dict) {
VALIDATE_INT(zck);
- _VALIDATE_INT(comp);
+ ALLOCD_INT(comp);
comp->dc_data = realloc(comp->dc_data, comp->dc_data_size + src_size);
if(comp->dc_data == NULL) {
static int end_cchunk(zckCtx *zck, zckComp *comp, char **dst, size_t *dst_size,
int use_dict) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
+ ALLOCD_BOOL(comp);
size_t max_size = ZSTD_compressBound(comp->dc_data_size);
if(ZSTD_isError(max_size)) {
static int decompress(zckCtx *zck, zckComp *comp, const int use_dict) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
+ ALLOCD_BOOL(comp);
return True;
}
static int end_dchunk(zckCtx *zck, zckComp *comp, const int use_dict,
const size_t fd_size) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(comp);
+ ALLOCD_BOOL(comp);
char *src = comp->data;
size_t src_size = comp->data_size;
/* Check whether last downloaded chunk is valid and zero it out if it isn't */
static int set_chunk_valid(zckDL *dl) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
VALIDATE_BOOL(dl->zck);
int retval = validate_chunk(dl->zck, dl->tgt_check, ZCK_LOG_WARNING,
/* Write length or to end of current chunk, whichever comes first */
static int dl_write(zckDL *dl, const char *at, size_t length) {
- _VALIDATE_INT(dl);
+ ALLOCD_INT(dl);
VALIDATE_INT(dl->zck);
int wb = 0;
/* Split current read into the appropriate chunks and write appropriately */
int dl_write_range(zckDL *dl, const char *at, size_t length) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
VALIDATE_BOOL(dl->zck);
if(dl->range == NULL) {
}
ssize_t PUBLIC zck_dl_get_bytes_downloaded(zckDL *dl) {
- _VALIDATE_INT(dl);
+ ALLOCD_INT(dl);
return dl->dl;
}
ssize_t PUBLIC zck_dl_get_bytes_uploaded(zckDL *dl) {
- _VALIDATE_INT(dl);
+ ALLOCD_INT(dl);
return dl->ul;
}
}
zckCtx PUBLIC *zck_dl_get_zck(zckDL *dl) {
- _VALIDATE_PTR(dl);
+ ALLOCD_PTR(dl);
return dl->zck;
}
int PUBLIC zck_dl_set_zck(zckDL *dl, zckCtx *zck) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->zck = zck;
return True;
}
int PUBLIC zck_dl_set_range(zckDL *dl, zckRange *range) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->range = range;
return True;
}
zckRange PUBLIC *zck_dl_get_range(zckDL *dl) {
- _VALIDATE_PTR(dl);
+ ALLOCD_PTR(dl);
return dl->range;
}
int PUBLIC zck_dl_set_header_cb(zckDL *dl, zck_wcb func) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->header_cb = func;
return True;
}
int PUBLIC zck_dl_set_header_data(zckDL *dl, void *data) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->header_data = data;
return True;
}
int PUBLIC zck_dl_set_write_cb(zckDL *dl, zck_wcb func) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->write_cb = func;
return True;
}
int PUBLIC zck_dl_set_write_data(zckDL *dl, void *data) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
dl->write_data = data;
return True;
*******************************************************************/
size_t PUBLIC zck_header_cb(char *b, size_t l, size_t c, void *dl_v) {
- _VALIDATE_BOOL(dl_v);
+ ALLOCD_BOOL(dl_v);
zckDL *dl = (zckDL*)dl_v;
if(multipart_get_boundary(dl, b, c*l) == 0)
}
size_t PUBLIC zck_write_zck_header_cb(void *ptr, size_t l, size_t c, void *dl_v) {
- _VALIDATE_BOOL(dl_v);
+ ALLOCD_BOOL(dl_v);
zckDL *dl = (zckDL*)dl_v;
size_t wb = 0;
}
size_t PUBLIC zck_write_chunk_cb(void *ptr, size_t l, size_t c, void *dl_v) {
- _VALIDATE_BOOL(dl_v);
+ ALLOCD_BOOL(dl_v);
zckDL *dl = (zckDL*)dl_v;
size_t wb = 0;
}
static int gen_regex(zckDL *dl) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
VALIDATE_BOOL(dl->zck);
char *next = "\r\n--%s\r\ncontent-type:.*\r\n" \
}
size_t multipart_extract(zckDL *dl, char *b, size_t l) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
VALIDATE_BOOL(dl->zck);
if(dl == NULL || dl->mp == NULL)
}
size_t multipart_get_boundary(zckDL *dl, char *b, size_t size) {
- _VALIDATE_BOOL(dl);
+ ALLOCD_BOOL(dl);
VALIDATE_BOOL(dl->zck);
if(dl == NULL)
}
int PUBLIC zck_get_range_count(zckRange *range) {
- _VALIDATE_INT(range);
+ ALLOCD_INT(range);
return range->count;
}
static int finish_chunk(zckIndex *index, zckChunk *item, char *digest,
int valid, zckCtx *zck) {
VALIDATE_BOOL(zck);
- _VALIDATE_BOOL(index);
- _VALIDATE_BOOL(item);
+ ALLOCD_BOOL(index);
+ ALLOCD_BOOL(item);
item->digest = zmalloc(index->digest_size);
if(item->digest == NULL) {
}
zckChunk PUBLIC *zck_get_next_chunk(zckChunk *idx) {
- _VALIDATE_PTR(idx);
+ ALLOCD_PTR(idx);
return idx->next;
}
ssize_t PUBLIC zck_get_chunk_start(zckChunk *idx) {
- _VALIDATE_INT(idx);
+ ALLOCD_INT(idx);
if(idx->zck) {
VALIDATE_INT(idx->zck);
}
ssize_t PUBLIC zck_get_chunk_size(zckChunk *idx) {
- _VALIDATE_INT(idx);
+ ALLOCD_INT(idx);
return idx->length;
}
ssize_t PUBLIC zck_get_chunk_comp_size(zckChunk *idx) {
- _VALIDATE_INT(idx);
+ ALLOCD_INT(idx);
return idx->comp_length;
}
int PUBLIC zck_get_chunk_valid(zckChunk *idx) {
- _VALIDATE_INT(idx);
+ ALLOCD_INT(idx);
return idx->valid;
}
int PUBLIC zck_compare_chunk_digest(zckChunk *a, zckChunk *b) {
- _VALIDATE_BOOL(a);
- _VALIDATE_BOOL(b);
+ ALLOCD_BOOL(a);
+ ALLOCD_BOOL(b);
if(a->digest_size != b->digest_size)
return False;
#define set_error(zck, ...) set_error_wf(zck, 0, __func__, __VA_ARGS__)
#define set_fatal_error(zck, ...) set_error_wf(zck, 1, __func__, __VA_ARGS__)
-#define _VALIDATE_BOOL(f) if(!f) { \
+#define ALLOCD_BOOL(f) if(!f) { \
zck_log(ZCK_LOG_NONE, \
"Object not initialized"); \
return False; \
}
-#define _VALIDATE_INT(f) if(!f) { \
+#define ALLOCD_INT(f) if(!f) { \
zck_log(ZCK_LOG_NONE, \
"Object not initialized"); \
return -1; \
}
-#define _VALIDATE_PTR(f) if(!f) { \
+#define ALLOCD_PTR(f) if(!f) { \
zck_log(ZCK_LOG_NONE, \
"Object not initialized"); \
return NULL; \
}
-#define VALIDATE_BOOL(f) _VALIDATE_BOOL(f) \
+#define VALIDATE_BOOL(f) ALLOCD_BOOL(f) \
if((f)->error_state > 0) return False;
-#define VALIDATE_INT(f) _VALIDATE_INT(f) \
+#define VALIDATE_INT(f) ALLOCD_INT(f) \
if((f)->error_state > 0) return -1;
-#define VALIDATE_PTR(f) _VALIDATE_PTR(f) \
+#define VALIDATE_PTR(f) ALLOCD_PTR(f) \
if((f)->error_state > 0) return NULL;
#define VALIDATE_READ_BOOL(f) VALIDATE_BOOL(f); \