Lines Matching refs:reader
87 static void expect_data(eager_reader_t *reader, void *context) { in expect_data() argument
93 EXPECT_EQ((size_t)1, eager_reader_read(reader, &byte, 1)); in expect_data()
100 static void expect_data_multibyte(eager_reader_t *reader, void *context) { in expect_data_multibyte() argument
107 size_t bytes_read = eager_reader_read(reader, buffer, bytes_to_read); in expect_data_multibyte()
118 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F() local
119 ASSERT_TRUE(reader != NULL); in TEST_F()
120 eager_reader_free(reader); in TEST_F()
124 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F() local
127 eager_reader_register(reader, thread_get_reactor(read_thread), expect_data, (void *)small_data); in TEST_F()
132 eager_reader_free(reader); in TEST_F()
137 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F() local
140 …eager_reader_register(reader, thread_get_reactor(read_thread), expect_data_multibyte, (void *)larg… in TEST_F()
145 eager_reader_free(reader); in TEST_F()