| H A D | tube.c | 2 * util/tube.c - pipe service
42 #include "util/tube.h"
57 struct tube* tube_create(void)
59 struct tube* tube = (struct tube*)calloc(1, sizeof(*tube)); local
61 if(!tube) {
67 tube->sr = -1;
68 tube
88 tube_delete(struct tube* tube) argument
100 tube_close_read(struct tube* tube) argument
108 tube_close_write(struct tube* tube) argument
116 tube_remove_bg_listen(struct tube* tube) argument
126 tube_remove_bg_write(struct tube* tube) argument
149 struct tube* tube = (struct tube*)arg; local
225 struct tube* tube = (struct tube*)arg; local
285 tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len, int nonblock) argument
331 tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len, int nonblock) argument
411 tube_poll(struct tube* tube) argument
418 tube_wait(struct tube* tube) argument
423 tube_read_fd(struct tube* tube) argument
428 tube_setup_bg_listen(struct tube* tube, struct comm_base* base, tube_callback_type* cb, void* arg) argument
443 tube_setup_bg_write(struct tube* tube, struct comm_base* base) argument
455 tube_queue_item(struct tube* tube, uint8_t* msg, size_t len) argument
495 struct tube* tube = (struct tube*)calloc(1, sizeof(*tube)); local
515 tube_delete(struct tube* tube) argument
543 tube_remove_bg_listen(struct tube* tube) argument
549 tube_remove_bg_write(struct tube* tube) argument
565 tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len, int ATTR_UNUSED(nonblock)) argument
579 tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len, int nonblock) argument
617 tube_poll(struct tube* tube) argument
628 tube_wait(struct tube* tube) argument
670 tube_setup_bg_listen(struct tube* tube, struct comm_base* base, tube_callback_type* cb, void* arg) argument
689 tube_queue_item(struct tube* tube, uint8_t* msg, size_t len) argument
720 struct tube* tube = (struct tube*)arg; local
[all...] |