diff options
Diffstat (limited to 'fluent-bit/tests/internal/pipe.c')
-rw-r--r-- | fluent-bit/tests/internal/pipe.c | 89 |
1 files changed, 0 insertions, 89 deletions
diff --git a/fluent-bit/tests/internal/pipe.c b/fluent-bit/tests/internal/pipe.c deleted file mode 100644 index f8a08e0d..00000000 --- a/fluent-bit/tests/internal/pipe.c +++ /dev/null @@ -1,89 +0,0 @@ -/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ - -#include <fluent-bit/flb_info.h> -#include <fluent-bit/flb_pipe.h> -#ifdef FLB_SYSTEM_WINDOWS -#include <fluent-bit/flb_compat.h> -#endif - -#include <inttypes.h> -#include "flb_tests_internal.h" - -struct data { - int x; - char str[32]; -}; - -static void test_pipe_usage() -{ - int i; - int ret; - char *b; - ssize_t bytes; - flb_pipefd_t p[2]; - struct data data; - struct data rec; -#ifdef FLB_SYSTEM_WINDOWS - WSADATA wsa_data; -#endif - -#ifdef FLB_SYSTEM_WINDOWS - WSAStartup(0x0201, &wsa_data); -#endif - /* Create pipe */ - ret = flb_pipe_create(p); - TEST_CHECK(ret == 0); - - /* Prepare test */ - memset(&data, '\0', sizeof(struct data)); - data.x = 2017; - memcpy(data.str, "this is a test\n", 15); - data.str[15] = '\0'; - - /* Simple write/read */ - bytes = flb_pipe_w(p[1], &data, sizeof(struct data)); - TEST_CHECK(bytes > 0); - - bytes = flb_pipe_r(p[0], &rec, sizeof(struct data)); - TEST_CHECK(bytes > 0); - TEST_CHECK(rec.x == 2017); - TEST_CHECK(strlen(rec.str) == 15); - - /* Iterate write, all_read */ - b = (char *) &data; - for (i = 0; i < sizeof(struct data); i++, b++) { - bytes = flb_pipe_w(p[1], b, 1); - TEST_CHECK(bytes == 1); - } - - b = (char *) &rec; - memset(&rec, '\0', sizeof(struct data)); - for (i = 0; i < sizeof(struct data); i++, b++) { - bytes = flb_pipe_read_all(p[0], b, 1); - TEST_CHECK(bytes == 1); - } - TEST_CHECK(rec.x == 2017); - TEST_CHECK(strlen(rec.str) == 15); - - /* All write, all read */ - bytes = flb_pipe_write_all(p[1], &data, sizeof(struct data)); - TEST_CHECK(bytes == sizeof(struct data)); - - memset(&rec, '\0', sizeof(struct data)); - bytes = flb_pipe_read_all(p[0], &rec, sizeof(struct data)); - TEST_CHECK(bytes == sizeof(struct data)); - TEST_CHECK(rec.x == 2017); - TEST_CHECK(strlen(rec.str) == 15); - - /* Close pipe channels */ - flb_pipe_close(p[0]); - flb_pipe_close(p[1]); -#ifdef FLB_SYSTEM_WINDOWS - WSACleanup(); -#endif -} - -TEST_LIST = { - { "pipe_usage", test_pipe_usage}, - { 0 } -}; |