123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475 |
- #include <stdlib.h>
- #include <stdio.h>
- #include <sys/types.h>
- #include <sys/stat.h>
- #include <fcntl.h>
- #include "faux/str.h"
- #include "faux/async.h"
- #include "faux/testc_helpers.h"
- static bool_t stall_cb(faux_async_t *async, size_t len, void *user_data)
- {
- bool_t *o_flag = (bool_t *)user_data;
- if (!o_flag)
- return BOOL_FALSE;
- *o_flag = BOOL_TRUE;
- printf("Stall callback %lu\n", len);
- async = async;
- return BOOL_TRUE;
- }
- int testc_faux_async(void)
- {
- const size_t len = 9000000l;
- char *src_file = NULL;
- int ret = -1; // Pessimistic return value
- char *src_fn = NULL;
- char *dst_fn = NULL;
- unsigned int i = 0;
- unsigned char counter = 0;
- int fd = -1;
- faux_async_t *out = NULL;
- bool_t o_flag = BOOL_FALSE;
- // Prepare files
- src_file = faux_zmalloc(len);
- for (i = 0; i < len; i++) {
- src_file[i] = counter;
- counter++;
- }
- src_fn = faux_testc_tmpfile_deploy(src_file, len);
- dst_fn = faux_str_sprintf("%s/dst", getenv(FAUX_TESTC_TMPDIR_ENV));
- fd = open(dst_fn, O_WRONLY | O_CREAT | O_TRUNC, 0600);
- out = faux_async_new(fd);
- faux_async_set_stall_cb(out, stall_cb, &o_flag);
- faux_async_set_overflow(out, len + 1);
- if (faux_async_write(out, src_file, len) < 0) {
- fprintf(stderr, "faux_async_write() error\n");
- goto parse_error;
- }
- while (o_flag) {
- o_flag = BOOL_FALSE;
- faux_async_out(out);
- }
- if (faux_testc_file_cmp(dst_fn, src_fn) != 0) {
- fprintf(stderr, "Destination file %s is not equal to source %s\n",
- dst_fn, src_fn);
- goto parse_error;
- }
- ret = 0; // success
- parse_error:
- faux_async_free(out);
- faux_str_free(dst_fn);
- faux_str_free(src_fn);
- return ret;
- }
|