66 static void drive_machine(conn *c);
68 static ssize_t tcp_read(conn *arg, void *buf, size_t count);
69 static ssize_t tcp_sendmsg(conn *arg, struct msghdr *msg, int flags);
70 static ssize_t tcp_write(conn *arg, void *buf, size_t count);
79 static int try_read_command_negotiate(conn *c);
80 static int try_read_command_udp(conn *c);
82 static enum try_read_result try_read_network(conn *c);
83 static enum try_read_result try_read_udp(conn *c);
89 static void conn_to_str(const conn *c, char *addr, char *svr_addr);
96 static void conn_close(conn *c);
98 static bool update_event(conn *c, const int new_flags);
99 static void complete_nread(conn *c);
101 static void conn_free(conn *c);
108 conn **conns;
119 static conn *listen_conn = NULL;
131 ssize_t tcp_read(conn *c, void *buf, size_t count) {  in tcp_read()
136 ssize_t tcp_sendmsg(conn *c, struct msghdr *msg, int flags) {  in tcp_sendmsg()
141 ssize_t tcp_write(conn *c, void *buf, size_t count) {  in tcp_write()
146 static enum transmit_result transmit(conn *c);
294     conn *c;  in conn_timeout_thread()
392 static void rbuf_release(conn *c) {  in rbuf_release()
406 static bool rbuf_alloc(conn *c) {  in rbuf_alloc()
424 bool rbuf_switch_to_malloc(conn *c) {  in rbuf_switch_to_malloc()
472     if ((conns = calloc(max_fds, sizeof(conn *))) == NULL) {  in conn_init()
500 void conn_close_idle(conn *c) {  in conn_close_idle()
524 static void _conn_event_readd(conn *c) {  in _conn_event_readd()
536 void conn_worker_readd(conn *c) {  in conn_worker_readd()
579 void conn_io_queue_setup(conn *c) {  in conn_io_queue_setup()
593 static void conn_io_queue_reset(conn *c) {  in conn_io_queue_reset()
611 io_queue_t *conn_io_queue_get(conn *c, int type) {  in conn_io_queue_get()
627 conn *conn_new(const int sfd, enum conn_states init_state,  in conn_new()
632     conn *c;  in conn_new()
638         if (!(c = (conn *)calloc(1, sizeof(conn)))) {  in conn_new()
811 void conn_release_items(conn *c) {  in conn_release_items()
847 static void conn_cleanup(conn *c) {  in conn_cleanup()
870 void conn_free(conn *c) {  in conn_free()
888 static void conn_close(conn *c) {  in conn_close()
968 void conn_set_state(conn *c, enum conn_states state) {  in conn_set_state()
1037 static mc_resp* resp_allocate(conn *c) {  in resp_allocate()
1147 bool resp_start(conn *c) {  in resp_start()
1179 mc_resp *resp_start_unlinked(conn *c) {  in resp_start_unlinked()
1204 mc_resp* resp_finish(conn *c, mc_resp *resp) {  in resp_finish()
1241 bool resp_has_stack(conn *c) {  in resp_has_stack()
1245 void out_string(conn *c, const char *str) {  in out_string()
1289 void out_errstring(conn *c, const char *str) {  in out_errstring()
1298 void out_of_memory(conn *c, char *ascii_error) {  in out_of_memory()
1315                              conn *c) {  in append_bin_stats()
1344                                conn *c) {  in append_ascii_stats()
1361 static bool grow_stats_buf(conn *c, size_t needed) {  in grow_stats_buf()
1403     conn *c = (conn*)cookie;  in append_stats()
1422 static void reset_cmd_handler(conn *c) {  in reset_cmd_handler()
1445 static void complete_nread(conn *c) {  in complete_nread()
1740 void write_and_free(conn *c, char *buf, int bytes) {  in write_and_free()
1751 void append_stat(const char *name, ADD_STAT add_stats, conn *c,  in append_stat()
2047 static inline void get_conn_text(const conn *c, const int af,  in get_conn_text()
2123 static void conn_to_str(const conn *c, char *addr, char *svr_addr) {  in conn_to_str()
2158 static char *conn_queue_to_str(const conn *c, io_queue_t *q) {  in conn_queue_to_str()
2192                 conn *sc = conns[i];  in process_stats_conns()
2378 static int try_read_command_negotiate(conn *c) {
2401 static int try_read_command_udp(conn *c) {
2418 static enum try_read_result try_read_udp(conn *c) {
2464 static enum try_read_result try_read_network(conn *c) {
2529 static bool update_event(conn *c, const int new_flags) {
2547     conn *next;
2588 static int _transmit_pre(conn *c, struct iovec *iovs, int iovused, bool one_resp) {
2657 static void _transmit_post(conn *c, ssize_t res) {
2716 static enum transmit_result transmit(conn *c) {
2813 static enum transmit_result transmit_udp(conn *c) {
2915 static int read_into_chunked_item(conn *c) {
2994 static void drive_machine(conn *c) {
3397     conn *c;
3399     c = (conn *)arg;
3516         conn *listen_conn_add;