| H A D | tube.c | 2 * util/tube.c - pipe service
42 #include "util/tube.h"
56 struct tube* tube_create(void)
58 struct tube* tube = (struct tube*)calloc(1, sizeof(*tube)); local
60 if(!tube) {
66 tube->sr = -1;
67 tube
87 tube_delete(struct tube* tube) argument
99 tube_close_read(struct tube* tube) argument
107 tube_close_write(struct tube* tube) argument
115 tube_remove_bg_listen(struct tube* tube) argument
127 tube_remove_bg_write(struct tube* tube) argument
150 struct tube* tube = (struct tube*)arg; local
226 struct tube* tube = (struct tube*)arg; local
286 tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len, int nonblock) argument
328 tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len, int nonblock) argument
408 tube_poll(struct tube* tube) argument
415 tube_wait(struct tube* tube) argument
420 tube_read_fd(struct tube* tube) argument
425 tube_setup_bg_listen(struct tube* tube, struct comm_base* base, tube_callback_t* cb, void* arg) argument
440 tube_setup_bg_write(struct tube* tube, struct comm_base* base) argument
452 tube_queue_item(struct tube* tube, uint8_t* msg, size_t len) argument
491 struct tube* tube = (struct tube*)calloc(1, sizeof(*tube)); local
511 tube_delete(struct tube* tube) argument
539 tube_remove_bg_listen(struct tube* tube) argument
545 tube_remove_bg_write(struct tube* tube) argument
561 tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len, int ATTR_UNUSED(nonblock)) argument
575 tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len, int nonblock) argument
613 tube_poll(struct tube* tube) argument
624 tube_wait(struct tube* tube) argument
666 tube_setup_bg_listen(struct tube* tube, struct comm_base* base, tube_callback_t* cb, void* arg) argument
684 tube_queue_item(struct tube* tube, uint8_t* msg, size_t len) argument
714 struct tube* tube = (struct tube*)arg; local
[all...] |