123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532 |
- #include <stdlib.h>
- #include <stdio.h>
- #include <sys/types.h>
- #include <sys/stat.h>
- #include <fcntl.h>
- #include <unistd.h>
- #include "faux/str.h"
- #include "faux/buf.h"
- #include "faux/testc_helpers.h"
- #include "private.h"
- #define CHUNK 100
- int testc_faux_buf(void)
- {
- char *src_fn = NULL;
- char *dst_fn = NULL;
- ssize_t len = 0;
- char *rnd = NULL;
- char *dst = NULL;
- faux_buf_t *buf = NULL;
- ssize_t res = 0;
- ssize_t chunk_num = 0;
- ssize_t e_chunk_num = 0;
- // Prepare files
- len = CHUNK * 3 + 15;
- e_chunk_num = 4;
- rnd = faux_testc_rnd_buf(len);
- src_fn = faux_testc_tmpfile_deploy(rnd, len);
- // Create buf
- buf = faux_buf_new(CHUNK);
- if (!buf) {
- fprintf(stderr, "faux_buf_new() error\n");
- return -1;
- }
- // Write to buffer
- if ((res = faux_buf_write(buf, rnd, len - 5)) != (len - 5)) {
- fprintf(stderr, "faux_buf_write() error %ld\n", res);
- return -1;
- }
- if (faux_buf_write(buf, rnd + len - 5, 5) != 5) {
- fprintf(stderr, "faux_buf_write() the rest error\n");
- return -1;
- }
- // Buf length
- if (faux_buf_len(buf) != len) {
- fprintf(stderr, "faux_buf_len() error\n");
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != e_chunk_num) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%ld\n",
- chunk_num, e_chunk_num);
- return -1;
- }
- // Buf read
- dst = faux_malloc(len);
- if (!dst) {
- fprintf(stderr, "faux_malloc() error\n");
- return -1;
- }
- if (faux_buf_read(buf, dst, len) != len) {
- fprintf(stderr, "faux_buf_read() error\n");
- return -1;
- }
- dst_fn = faux_testc_tmpfile_deploy(dst, len);
- // Buf length == 0
- if (faux_buf_len(buf) != 0) {
- fprintf(stderr, "faux_buf_len() is not 0: error\n");
- return -1;
- }
- // Compare files
- 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);
- return -1;
- }
- faux_free(dst);
- faux_buf_free(buf);
- return 0;
- }
- int testc_faux_buf_boundaries(void)
- {
- char *src_fn = NULL;
- char *dst_fn = NULL;
- ssize_t len = 0;
- char *rnd = NULL;
- char *dst = NULL;
- faux_buf_t *buf = NULL;
- ssize_t chunk_num = 0;
- ssize_t e_chunk_num = 0;
- ssize_t res = 0;
- // Prepare files
- len = CHUNK * 3;
- e_chunk_num = 3;
- rnd = faux_testc_rnd_buf(len);
- src_fn = faux_testc_tmpfile_deploy(rnd, len);
- // Create buf
- printf("faux_buf_new()\n");
- buf = faux_buf_new(CHUNK);
- if (!buf) {
- fprintf(stderr, "faux_buf_new() error\n");
- return -1;
- }
- // Write to buffer
- printf("faux_buf_write() len - CHUNK\n");
- if ((res = faux_buf_write(buf, rnd, len - CHUNK)) != (len - CHUNK)) {
- fprintf(stderr, "faux_buf_write() error %ld\n", res);
- return -1;
- }
- // Buf length
- printf("faux_buf_len()\n");
- if (faux_buf_len(buf) != (len - CHUNK)) {
- fprintf(stderr, "faux_buf_len() error\n");
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != (e_chunk_num - 1)) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%ld\n",
- chunk_num, e_chunk_num - 1);
- return -1;
- }
- printf("faux_buf_write() CHUNK\n");
- if (faux_buf_write(buf, rnd + len - CHUNK, CHUNK) != CHUNK) {
- fprintf(stderr, "faux_buf_write() the rest error\n");
- return -1;
- }
- // Buf length
- printf("faux_buf_len()\n");
- if (faux_buf_len(buf) != len) {
- fprintf(stderr, "faux_buf_len() error\n");
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != e_chunk_num) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%ld\n",
- chunk_num, e_chunk_num);
- return -1;
- }
- // Buf read
- dst = faux_malloc(len);
- if (!dst) {
- fprintf(stderr, "faux_malloc() error\n");
- return -1;
- }
- printf("faux_buf_read()\n");
- if (faux_buf_read(buf, dst, len) != len) {
- fprintf(stderr, "faux_buf_read() error\n");
- return -1;
- }
- dst_fn = faux_testc_tmpfile_deploy(dst, len);
- // Buf length == 0
- printf("faux_buf_len() 2\n");
- if (faux_buf_len(buf) != 0) {
- fprintf(stderr, "faux_buf_len() is not 0: error\n");
- return -1;
- }
- // Compare files
- 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);
- return -1;
- }
- // Write to buffer anoter time
- printf("faux_buf_write() 2\n");
- if (faux_buf_write(buf, rnd, len) != len) {
- fprintf(stderr, "another faux_buf_write() error\n");
- return -1;
- }
- printf("faux_buf_read() 2\n");
- if (faux_buf_read(buf, dst, len) != len) {
- fprintf(stderr, "another faux_buf_read() error\n");
- return -1;
- }
- dst_fn = faux_testc_tmpfile_deploy(dst, len);
- // Compare files another time
- 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);
- return -1;
- }
- faux_free(dst);
- faux_buf_free(buf);
- return 0;
- }
- int testc_faux_buf_direct(void)
- {
- // char *src_fn = NULL;
- // char *dst_fn = NULL;
- ssize_t len = 0;
- char *rnd = NULL;
- char *dst = NULL;
- faux_buf_t *buf = NULL;
- ssize_t chunk_num = 0;
- ssize_t e_chunk_num = 0;
- ssize_t res = 0;
- ssize_t wlocked = 0;
- struct iovec *iov = NULL;
- size_t iov_num = 0;
- struct iovec *riov = NULL;
- size_t riov_num = 0;
- ssize_t bytes_readed = 0;
- // Prepare files
- len = CHUNK * 3;
- e_chunk_num = 3;
- rnd = faux_testc_rnd_buf(len);
- // src_fn = faux_testc_tmpfile_deploy(rnd, len);
- // Create buf
- printf("faux_buf_new()\n");
- buf = faux_buf_new(CHUNK);
- if (!buf) {
- fprintf(stderr, "faux_buf_new() error\n");
- return -1;
- }
- // Write to buffer
- printf("faux_buf_write() len - CHUNK\n");
- if ((res = faux_buf_write(buf, rnd, len - CHUNK)) != (len - CHUNK)) {
- fprintf(stderr, "faux_buf_write() error %ld\n", res);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 2) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 2);
- return -1;
- }
- // Lock buffer for writing
- printf("faux_buf_dwrite_lock()\n");
- if ((wlocked = faux_buf_dwrite_lock(buf, len + 15, &iov, &iov_num)) != (len + 15)) {
- fprintf(stderr, "faux_buf_dwrite_lock() error %ld\n",
- wlocked);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 6) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 6);
- return -1;
- }
- // Buf read
- dst = faux_malloc(len);
- if (!dst) {
- fprintf(stderr, "faux_malloc() error\n");
- return -1;
- }
- printf("faux_buf_dread_lock()\n");
- if ((bytes_readed = faux_buf_dread_lock(buf, len, &riov, &riov_num)) != (len - CHUNK)) {
- fprintf(stderr, "faux_buf_dread_lock() error. need %ld, readed %ld\n",
- len, bytes_readed);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 6) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 6);
- return -1;
- }
- printf("faux_buf_dread_ulock() must be -1\n");
- if ((bytes_readed = faux_buf_dread_unlock(buf, len, riov)) >= 0) {
- fprintf(stderr, "faux_buf_dread_lock() error. need -1, readed %ld\n",
- bytes_readed);
- return -1;
- }
- printf("faux_buf_dread_ulock()\n");
- if ((bytes_readed = faux_buf_dread_unlock(buf, len - CHUNK, riov)) != (len - CHUNK)) {
- fprintf(stderr, "faux_buf_dread_lock() error. need %ld, readed %ld\n",
- len, bytes_readed);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != (e_chunk_num + 1)) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%ld\n",
- chunk_num, e_chunk_num + 1);
- return -1;
- }
- // Unlock buffer for writing
- printf("faux_buf_dwrite_unlock()\n");
- if ((wlocked = faux_buf_dwrite_unlock(buf, len, iov)) != (len)) {
- fprintf(stderr, "faux_buf_dwrite_unlock() error %ld\n",
- wlocked);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 3) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 3);
- return -1;
- }
- printf("faux_buf_read()\n");
- if ((bytes_readed = faux_buf_read(buf, dst, len)) != len) {
- fprintf(stderr, "faux_buf_read() error. need %ld, readed %ld\n",
- len, bytes_readed);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 0) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 0);
- return -1;
- }
- printf("faux_buf_write() CHUNK\n");
- if (faux_buf_write(buf, rnd, CHUNK + 15) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_write() the rest error\n");
- return -1;
- }
- // Buf length
- printf("faux_buf_len()\n");
- if (faux_buf_len(buf) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_len() error\n");
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 2) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 2);
- return -1;
- }
- // Buf read
- printf("faux_buf_read()\n");
- if (faux_buf_read(buf, dst, len) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_read() error\n");
- return -1;
- }
- // Buf length == 0
- printf("faux_buf_len() 2\n");
- if (faux_buf_len(buf) != 0) {
- fprintf(stderr, "faux_buf_len() is not 0: error\n");
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 0) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 0);
- return -1;
- }
- faux_free(dst);
- faux_buf_free(buf);
- return 0;
- }
- int testc_faux_buf_dwrite_unlock0(void)
- {
- // char *src_fn = NULL;
- // char *dst_fn = NULL;
- ssize_t len = 0;
- char *rnd = NULL;
- char *dst = NULL;
- faux_buf_t *buf = NULL;
- ssize_t chunk_num = 0;
- ssize_t res = 0;
- ssize_t wlocked = 0;
- struct iovec *iov = NULL;
- size_t iov_num = 0;
- struct iovec *riov = NULL;
- size_t riov_num = 0;
- ssize_t bytes_readed = 0;
- // Prepare files
- len = CHUNK * 3;
- rnd = faux_testc_rnd_buf(len);
- // src_fn = faux_testc_tmpfile_deploy(rnd, len);
- // Create buf
- printf("faux_buf_new()\n");
- buf = faux_buf_new(CHUNK);
- if (!buf) {
- fprintf(stderr, "faux_buf_new() error\n");
- return -1;
- }
- // Write to buffer
- printf("faux_buf_write() len - CHUNK\n");
- if ((res = faux_buf_write(buf, rnd, CHUNK + 15)) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_write() error %ld\n", res);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 2) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 2);
- return -1;
- }
- // Lock buffer for writing
- printf("faux_buf_dwrite_lock()\n");
- if ((wlocked = faux_buf_dwrite_lock(buf, len, &iov, &iov_num)) != len) {
- fprintf(stderr, "faux_buf_dwrite_lock() error %ld\n",
- wlocked);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 5) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 5);
- return -1;
- }
- // Buf read
- dst = faux_malloc(len);
- if (!dst) {
- fprintf(stderr, "faux_malloc() error\n");
- return -1;
- }
- printf("faux_buf_dread_lock()\n");
- if ((bytes_readed = faux_buf_dread_lock(buf, len, &riov, &riov_num)) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_dread_lock() error. need %d, readed %ld\n",
- CHUNK + 15, bytes_readed);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 5) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 5);
- return -1;
- }
- printf("faux_buf_dread_ulock() must be -1\n");
- if ((bytes_readed = faux_buf_dread_unlock(buf, len, riov)) >= 0) {
- fprintf(stderr, "faux_buf_dread_lock() error. need -1, readed %ld\n",
- bytes_readed);
- return -1;
- }
- printf("faux_buf_dread_ulock()\n");
- if ((bytes_readed = faux_buf_dread_unlock(buf, CHUNK + 15, riov)) != (CHUNK + 15)) {
- fprintf(stderr, "faux_buf_dread_lock() error. need %ld, readed %ld\n",
- len, bytes_readed);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 4) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 4);
- return -1;
- }
- // Unlock buffer for writing
- printf("faux_buf_dwrite_unlock() with 0 len\n");
- if ((wlocked = faux_buf_dwrite_unlock(buf, 0, iov)) != 0) {
- fprintf(stderr, "faux_buf_dwrite_unlock() error %ld\n",
- wlocked);
- return -1;
- }
- // Buf chunk num
- printf("faux_buf_chunk_num()\n");
- if ((chunk_num = faux_buf_chunk_num(buf)) != 0) {
- fprintf(stderr, "faux_buf_chunk_num() error. num=%ld e=%d\n",
- chunk_num, 0);
- return -1;
- }
- faux_free(dst);
- faux_buf_free(buf);
- return 0;
- }
|