Lines Matching refs:eager_reader_t
44 struct eager_reader_t { struct
61 static bool has_byte(const eager_reader_t *reader); argument
65 eager_reader_t *eager_reader_new( in eager_reader_new()
78 eager_reader_t *ret = osi_calloc(sizeof(eager_reader_t)); in eager_reader_new()
118 void eager_reader_free(eager_reader_t *reader) { in eager_reader_free()
141 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, voi… in eager_reader_register()
154 void eager_reader_unregister(eager_reader_t *reader) { in eager_reader_unregister()
164 size_t eager_reader_read(eager_reader_t *reader, uint8_t *buffer, size_t max_size) { in eager_reader_read()
209 thread_t* eager_reader_get_read_thread(const eager_reader_t *reader) { in eager_reader_get_read_thread()
214 static bool has_byte(const eager_reader_t *reader) { in has_byte()
239 eager_reader_t *reader = (eager_reader_t *)context; in inbound_data_waiting()
274 eager_reader_t *reader = (eager_reader_t *)context; in internal_outbound_read_ready()