#define ZCK_PUBLIC_API __attribute__((visibility("default")))
#endif
-#ifdef _WIN32
-#define ZCK_LOG_ERROR(...) fprintf(stderr, __VA_ARGS__)
-#else
-#define ZCK_LOG_ERROR(...) dprintf(STDERR_FILENO, __VA_ARGS__)
-#endif
-
/*******************************************************************
* Reading a zchunk file
*******************************************************************/
if(!arguments.std_out) {
if(strlen(arguments.args[0]) < 5 ||
strcmp(arguments.args[0] + strlen(arguments.args[0]) - 4, ".zck") != 0) {
- ZCK_LOG_ERROR("Not a *.zck file: %s\n", arguments.args[0]);
+ LOG_ERROR("Not a *.zck file: %s\n", arguments.args[0]);
exit(1);
}
}
int src_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
if(src_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[0]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[0]);
perror("");
exit(1);
}
if(!arguments.std_out) {
dst_fd = open(out_name, O_TRUNC | O_WRONLY | O_CREAT | O_BINARY, 0666);
if(dst_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s", out_name);
+ LOG_ERROR("Unable to open %s", out_name);
perror("");
free(out_name);
exit(1);
char *data = NULL;
zckCtx *zck = zck_create();
if(!zck_init_read(zck, src_fd)) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
zckChunk *dict = zck_get_first_chunk(zck);
ssize_t dict_size = zck_get_chunk_size(dict);
if(dict_size < 0) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
data = calloc(dict_size, 1);
ssize_t read_size = zck_get_chunk_data(dict, data, dict_size);
if(read_size != dict_size) {
if(read_size < 0)
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
else
- ZCK_LOG_ERROR(
+ LOG_ERROR(
"Dict size doesn't match expected size: %li != %li\n",
read_size, dict_size);
goto error2;
}
if(write(dst_fd, data, dict_size) != dict_size) {
- ZCK_LOG_ERROR("Error writing to %s\n", out_name);
+ LOG_ERROR("Error writing to %s\n", out_name);
goto error2;
}
if(dict_size > 0) {
int ret = zck_get_chunk_valid(dict);
if(ret < 1) {
if(ret == -1)
- ZCK_LOG_ERROR("Data checksum failed verification\n");
+ LOG_ERROR("Data checksum failed verification\n");
else
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
}
int ret = zck_validate_data_checksum(zck);
if(ret < 1) {
if(ret == -1)
- ZCK_LOG_ERROR("Data checksum failed verification\n");
+ LOG_ERROR("Data checksum failed verification\n");
goto error2;
}
while(true) {
ssize_t read = zck_read(zck, data, BUF_SIZE);
if(read < 0) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
if(read == 0)
break;
if(write(dst_fd, data, read) != read) {
- ZCK_LOG_ERROR("Error writing to %s\n", out_name);
+ LOG_ERROR("Error writing to %s\n", out_name);
goto error2;
}
total += read;
}
if(!zck_close(zck)) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
if(arguments.log_level <= ZCK_LOG_INFO)
- ZCK_LOG_ERROR("Decompressed %lu bytes\n", (unsigned long)total);
+ LOG_ERROR("Decompressed %lu bytes\n", (unsigned long)total);
good_exit = true;
error2:
free(data);
char* basename(char*);
#endif
+#ifdef _WIN32
+#define LOG_ERROR(...) fprintf(stderr, __VA_ARGS__)
+#else
+#define LOG_ERROR(...) dprintf(STDERR_FILENO, __VA_ARGS__)
+#endif
+
#endif
else if (!strcmp(arg, "sha512_128"))
arguments->chunk_hashtype = ZCK_HASH_SHA512_128;
else {
- ZCK_LOG_ERROR("Wrong value for chunk hashtype. \n "
+ LOG_ERROR("Wrong value for chunk hashtype. \n "
"It should be one of sha1|sha256|sha512|sha512_128 instead of %s\n", arg);
return -EINVAL;
}
if(arguments.dict != NULL) {
int dict_fd = open(arguments.dict, O_RDONLY | O_BINARY);
if(dict_fd < 0) {
- ZCK_LOG_ERROR("Unable to open dictionary %s for reading",
+ LOG_ERROR("Unable to open dictionary %s for reading",
arguments.dict);
perror("");
exit(1);
int dst_fd = open(out_name, O_TRUNC | O_WRONLY | O_CREAT | O_BINARY, 0666);
if(dst_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s", out_name);
+ LOG_ERROR("Unable to open %s", out_name);
perror("");
if(dict) {
free(dict);
zckCtx *zck = zck_create();
if(zck == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
exit(1);
}
if(!zck_init_write(zck, dst_fd)) {
- ZCK_LOG_ERROR("Unable to write to %s: %s", out_name,
+ LOG_ERROR("Unable to write to %s: %s", out_name,
zck_get_error(zck));
exit(1);
}
if(arguments.compression_format) {
if(strncmp(arguments.compression_format, "zstd", 4) == 0) {
if(!zck_set_ioption(zck, ZCK_COMP_TYPE, ZCK_COMP_ZSTD)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zck));
+ LOG_ERROR("%s\n", zck_get_error(zck));
exit(1);
}
} else if(strncmp(arguments.compression_format, "none", 4) == 0) {
if(!zck_set_ioption(zck, ZCK_COMP_TYPE, ZCK_COMP_NONE)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zck));
+ LOG_ERROR("%s\n", zck_get_error(zck));
exit(1);
}
} else {
- ZCK_LOG_ERROR("Unknown compression type: %s\n", arguments.compression_format);
+ LOG_ERROR("Unknown compression type: %s\n", arguments.compression_format);
exit(1);
}
}
if(dict_size > 0) {
if(!zck_set_soption(zck, ZCK_COMP_DICT, dict, dict_size)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zck));
+ LOG_ERROR("%s\n", zck_get_error(zck));
exit(1);
}
}
free(dict);
if(arguments.manual_chunk) {
if(!zck_set_ioption(zck, ZCK_MANUAL_CHUNK, 1)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zck));
+ LOG_ERROR("%s\n", zck_get_error(zck));
exit(1);
}
}
if(arguments.uncompressed) {
if(!zck_set_ioption(zck, ZCK_UNCOMP_HEADER, 1)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zck));
+ LOG_ERROR("%s\n", zck_get_error(zck));
exit(1);
}
}
if (arguments.chunk_hashtype != ZCK_HASH_UNKNOWN) {
if(!zck_set_ioption(zck, ZCK_HASH_CHUNK_TYPE, arguments.chunk_hashtype)) {
- ZCK_LOG_ERROR("Unable to set hash type %s\n", zck_get_error(zck));
+ LOG_ERROR("Unable to set hash type %s\n", zck_get_error(zck));
exit(1);
}
}
int in_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
off_t in_size = 0;
if(in_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s for reading",
+ LOG_ERROR("Unable to open %s for reading",
arguments.args[0]);
perror("");
exit(1);
}
in_size = lseek(in_fd, 0, SEEK_END);
if(in_size < 0) {
- ZCK_LOG_ERROR("Unable to seek to end of input file");
+ LOG_ERROR("Unable to seek to end of input file");
exit(1);
}
if(lseek(in_fd, 0, SEEK_SET) < 0) {
data = malloc(in_size);
assert(data);
if(read(in_fd, data, in_size) < in_size) {
- ZCK_LOG_ERROR("Unable to read from input file\n");
+ LOG_ERROR("Unable to read from input file\n");
exit(1);
}
close(in_fd);
/* Buzhash rolling window */
} else {
if(zck_write(zck, data, in_size) < 0) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
exit(1);
}
}
exit(1);
}
if(arguments.log_level <= ZCK_LOG_INFO) {
- ZCK_LOG_ERROR("Wrote %lu bytes in %lu chunks\n",
+ LOG_ERROR("Wrote %lu bytes in %lu chunks\n",
(unsigned long)(zck_get_data_length(zck) +
zck_get_header_length(zck)),
(long)zck_get_chunk_count(zck));
int src_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
if(src_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[0]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[0]);
perror("");
exit(1);
}
zckCtx *zck_src = zck_create();
if(zck_src == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
exit(1);
}
if(!zck_init_read(zck_src, src_fd)) {
- ZCK_LOG_ERROR("Error reading %s: %s", arguments.args[0],
+ LOG_ERROR("Error reading %s: %s", arguments.args[0],
zck_get_error(zck_src));
zck_free(&zck_src);
exit(1);
int tgt_fd = open(arguments.args[1], O_RDONLY | O_BINARY);
if(tgt_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[1]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[1]);
perror("");
zck_free(&zck_src);
exit(1);
}
zckCtx *zck_tgt = zck_create();
if(zck_tgt == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
zck_free(&zck_src);
exit(1);
}
if(!zck_init_read(zck_tgt, tgt_fd)) {
- ZCK_LOG_ERROR("Error reading %s: %s", arguments.args[1],
+ LOG_ERROR("Error reading %s: %s", arguments.args[1],
zck_get_error(zck_tgt));
zck_free(&zck_src);
zck_free(&zck_tgt);
close(tgt_fd);
if(zck_get_chunk_hash_type(zck_tgt) != zck_get_chunk_hash_type(zck_src)) {
- ZCK_LOG_ERROR("ERROR: Chunk hash types don't match:\n");
- ZCK_LOG_ERROR(" %s: %s\n", arguments.args[0],
+ LOG_ERROR("ERROR: Chunk hash types don't match:\n");
+ LOG_ERROR(" %s: %s\n", arguments.args[0],
zck_hash_name_from_type(zck_get_chunk_hash_type(zck_tgt)));
- ZCK_LOG_ERROR(" %s: %s\n", arguments.args[1],
+ LOG_ERROR(" %s: %s\n", arguments.args[1],
zck_hash_name_from_type(zck_get_chunk_hash_type(zck_src)));
zck_free(&zck_src);
zck_free(&zck_tgt);
exit(1);
if(!zck_compare_chunk_digest(tgt_idx, src_idx))
- ZCK_LOG_ERROR("WARNING: Dicts don't match\n");
+ LOG_ERROR("WARNING: Dicts don't match\n");
ssize_t dl_size = zck_get_header_length(zck_tgt);
if(dl_size < 0)
exit(1);
int src_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
if(src_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[0]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[0]);
perror("");
exit(1);
}
zckCtx *zck_src = zck_create();
if(zck_src == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
exit(1);
}
if(!zck_init_read(zck_src, src_fd)) {
- ZCK_LOG_ERROR("Error reading %s: %s", arguments.args[0],
+ LOG_ERROR("Error reading %s: %s", arguments.args[0],
zck_get_error(zck_src));
zck_free(&zck_src);
exit(1);
int tgt_fd = open(arguments.args[1], O_RDONLY | O_BINARY);
if(tgt_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[1]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[1]);
perror("");
zck_free(&zck_src);
exit(1);
}
zckCtx *zck_tgt = zck_create();
if(zck_tgt == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
zck_free(&zck_src);
exit(1);
}
if(!zck_init_read(zck_tgt, tgt_fd)) {
- ZCK_LOG_ERROR("Error reading %s: %s", arguments.args[1],
+ LOG_ERROR("Error reading %s: %s", arguments.args[1],
zck_get_error(zck_tgt));
zck_free(&zck_src);
zck_free(&zck_tgt);
close(tgt_fd);
if(zck_get_chunk_hash_type(zck_tgt) != zck_get_chunk_hash_type(zck_src)) {
- ZCK_LOG_ERROR("ERROR: Chunk hash types don't match:\n");
- ZCK_LOG_ERROR(" %s: %s\n", arguments.args[0],
+ LOG_ERROR("ERROR: Chunk hash types don't match:\n");
+ LOG_ERROR(" %s: %s\n", arguments.args[0],
zck_hash_name_from_type(zck_get_chunk_hash_type(zck_tgt)));
- ZCK_LOG_ERROR(" %s: %s\n", arguments.args[1],
+ LOG_ERROR(" %s: %s\n", arguments.args[1],
zck_hash_name_from_type(zck_get_chunk_hash_type(zck_src)));
zck_free(&zck_src);
zck_free(&zck_tgt);
exit(1);
if(!zck_compare_chunk_digest(tgt_idx, src_idx))
- ZCK_LOG_ERROR("WARNING: Dicts don't match\n");
+ LOG_ERROR("WARNING: Dicts don't match\n");
ssize_t dl_size = zck_get_header_length(zck_tgt);
if(dl_size < 0)
exit(1);
// Get the current working directory:
if ((prev_cwd = _getcwd( NULL, 0 )) == NULL)
{
- ZCK_LOG_ERROR("Could not find current workdir");
+ LOG_ERROR("Could not find current workdir");
return NULL;
}
if (chdir(tmpdir) != 0)
{
- ZCK_LOG_ERROR("Could not change to Temp Dir");
+ LOG_ERROR("Could not change to Temp Dir");
return NULL;
}
printf("generating temp name: ... \n");
errno_t err = _mktemp_s(template, 14);
if (err)
{
- ZCK_LOG_ERROR("Could not generate temporary name");
+ LOG_ERROR("Could not generate temporary name");
return NULL;
}
if (_mkdir(template) != 0)
{
- ZCK_LOG_ERROR("Could not create temp folder");
+ LOG_ERROR("Could not create temp folder");
return NULL;
}
assert(chdir(template) == 0);
int src_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
if(src_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s\n", arguments.args[0]);
+ LOG_ERROR("Unable to open %s\n", arguments.args[0]);
perror("");
exit(1);
}
char *data = NULL;
zckCtx *zck = zck_create();
if(!zck_init_read(zck, src_fd)) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
int ret = zck_validate_data_checksum(zck);
if(ret < 1) {
if(ret == -1)
- ZCK_LOG_ERROR("Data checksum failed verification\n");
+ LOG_ERROR("Data checksum failed verification\n");
goto error2;
}
continue;
ssize_t chunk_size = zck_get_chunk_size(idx);
if(chunk_size < 0) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
data = calloc(chunk_size, 1);
ssize_t read_size = zck_get_chunk_data(idx, data, chunk_size);
if(read_size != chunk_size) {
if(read_size < 0)
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
else
- ZCK_LOG_ERROR(
+ LOG_ERROR(
"Chunk %li size doesn't match expected size: %li != %li\n",
zck_get_chunk_number(idx), read_size, chunk_size);
goto error2;
dir, out_name, zck_get_chunk_number(idx));
int dst_fd = open(dict_block, O_TRUNC | O_WRONLY | O_CREAT | O_BINARY, 0666);
if(dst_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s", dict_block);
+ LOG_ERROR("Unable to open %s", dict_block);
perror("");
free(dict_block);
goto error2;
}
if(write(dst_fd, data, chunk_size) != chunk_size) {
- ZCK_LOG_ERROR("Error writing to %s\n", dict_block);
+ LOG_ERROR("Error writing to %s\n", dict_block);
free(dict_block);
goto error2;
}
snprintf(out_name + strlen(base_name) - 4, 7, ".zdict");
if(!zck_close(zck)) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
goto error2;
}
int w = system(buf);
if (w < 0)
{
- ZCK_LOG_ERROR("Error generating dict\n");
+ LOG_ERROR("Error generating dict\n");
goto error2;
}
#else
int pid = fork();
if(pid == 0) {
execl("/usr/bin/zstd", "zstd", "--train", dir, "-r", "-o", out_name, NULL);
- ZCK_LOG_ERROR("Unable to find /usr/bin/zstd\n");
+ LOG_ERROR("Unable to find /usr/bin/zstd\n");
exit(1);
}
int wstatus = 0;
int w = waitpid(pid, &wstatus, 0);
if (w == -1) {
- ZCK_LOG_ERROR("Error waiting for zstd\n");
+ LOG_ERROR("Error waiting for zstd\n");
perror("");
goto error2;
}
if(WEXITSTATUS(wstatus) != 0) {
- ZCK_LOG_ERROR("Error generating dict\n");
+ LOG_ERROR("Error generating dict\n");
goto error2;
}
#endif
DIR *dfd;
if ((dfd = opendir(dir)) == NULL) {
- ZCK_LOG_ERROR("Unable to read %s\n", dir);
+ LOG_ERROR("Unable to read %s\n", dir);
goto error2;
}
snprintf(full_path, strlen(dir) + strlen(dp->d_name) + 2, "%s/%s",
dir, dp->d_name);
if(unlink(full_path) != 0) {
- ZCK_LOG_ERROR("Unable to remove %s\n", full_path);
+ LOG_ERROR("Unable to remove %s\n", full_path);
perror("");
err = true;
} else {
if(arguments.log_level <= ZCK_LOG_INFO)
- ZCK_LOG_ERROR("Removed %s\n", full_path);
+ LOG_ERROR("Removed %s\n", full_path);
}
free(full_path);
}
closedir(dfd);
if(!err) {
if(rmdir(dir) != 0) {
- ZCK_LOG_ERROR("Unable to remove %s\n", dir);
+ LOG_ERROR("Unable to remove %s\n", dir);
perror("");
}
} else {
- ZCK_LOG_ERROR("Errors encountered, not removing %s\n",
+ LOG_ERROR("Errors encountered, not removing %s\n",
dir);
}
}
zckCtx *zck = zck_create();
if(zck == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
exit(1);
}
if(!zck_init_read(zck, src_fd)) {
- ZCK_LOG_ERROR("Error reading zchunk header: %s",
+ LOG_ERROR("Error reading zchunk header: %s",
zck_get_error(zck));
zck_free(&zck);
exit(1);
chk=zck_get_next_chunk(chk)) {
char *digest = zck_get_chunk_digest(chk);
if(digest == NULL) {
- ZCK_LOG_ERROR("%s", zck_get_error(zck));
+ LOG_ERROR("%s", zck_get_error(zck));
exit(1);
}
char *digest_uncompressed = zck_get_chunk_digest_uncompressed(chk);
#define O_BINARY 0
#endif
+#ifdef _WIN32
+#define LOG_ERROR(...) fprintf(stderr, __VA_ARGS__)
+#else
+#define LOG_ERROR(...) dprintf(STDERR_FILENO, __VA_ARGS__)
+#endif
+
char *get_hash(char *data, size_t length, int type)
ZCK_WARN_UNUSED;
exit(retval);
if (argc < 1) {
- ZCK_LOG_ERROR("Usage : %s filename", argv[0]);
+ LOG_ERROR("Usage : %s filename", argv[0]);
exit(1);
}
zckCtx *zckSrc = zck_create();
zckCtx *zckDst = zck_create();
if(!zckSrc || !zckDst) {
- ZCK_LOG_ERROR("%s", zck_get_error(NULL));
+ LOG_ERROR("%s", zck_get_error(NULL));
zck_clear_error(NULL);
exit(1);
}
if(!zck_init_write(zckSrc, dst_fd)) {
- ZCK_LOG_ERROR("Unable to write %s ",
+ LOG_ERROR("Unable to write %s ",
zck_get_error(zckSrc));
exit(1);
}
int in_fd = open(arguments.args[0], O_RDONLY | O_BINARY);
off_t in_size = 0;
if(in_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s for reading",
+ LOG_ERROR("Unable to open %s for reading",
arguments.args[0]);
perror("");
exit(1);
*/
int zck_fd = open(arguments.args[1], O_RDONLY | O_BINARY);
if(zck_fd < 0) {
- ZCK_LOG_ERROR("Unable to open %s for reading",
+ LOG_ERROR("Unable to open %s for reading",
arguments.args[1]);
perror("");
exit(1);
}
if(!zck_init_read(zckDst, zck_fd)) {
- ZCK_LOG_ERROR("Error reading zchunk header: %s",
+ LOG_ERROR("Error reading zchunk header: %s",
zck_get_error(zckDst));
zck_free(&zckSrc);
zck_free(&zckDst);
in_size = lseek(in_fd, 0, SEEK_END);
if(in_size < 0) {
- ZCK_LOG_ERROR("Unable to seek to end of input file");
+ LOG_ERROR("Unable to seek to end of input file");
exit(1);
}
if(lseek(in_fd, 0, SEEK_SET) < 0) {
}
if(!zck_set_ioption(zckSrc, ZCK_UNCOMP_HEADER, 1)) {
- ZCK_LOG_ERROR("%s\n", zck_get_error(zckSrc));
+ LOG_ERROR("%s\n", zck_get_error(zckSrc));
exit(1);
}
if(!zck_set_ioption(zckSrc, ZCK_COMP_TYPE, ZCK_COMP_NONE))
exit(1);
if(!zck_set_ioption(zckSrc, ZCK_HASH_CHUNK_TYPE, ZCK_HASH_SHA256)) {
- ZCK_LOG_ERROR("Unable to set hash type %s\n", zck_get_error(zckSrc));
+ LOG_ERROR("Unable to set hash type %s\n", zck_get_error(zckSrc));
exit(1);
}
char *buf = malloc(BUFSIZE);
if (!buf) {
- ZCK_LOG_ERROR("Unable to allocate buffer\n");
+ LOG_ERROR("Unable to allocate buffer\n");
exit(1);
}
ssize_t n;
while ((n = read(in_fd, buf, BUFSIZE)) > 0) {
if (zck_write(zckSrc, buf, n) < 0) {
- ZCK_LOG_ERROR("zck_write failed: %s\n", zck_get_error(zckSrc));
+ LOG_ERROR("zck_write failed: %s\n", zck_get_error(zckSrc));
exit(1);
}
}