66 static void drive_machine(conn *c);
68 static int try_read_command(conn *c);
77 static enum try_read_result try_read_network(conn *c);
78 static enum try_read_result try_read_udp(conn *c);
80 static void conn_set_state(conn *c, enum conn_states state);
85 static void server_stats(ADD_STAT add_stats, conn *c);
87 static void conn_to_str(const conn *c, char *buf);
95 static void conn_close(conn *c);
97 static bool update_event(conn *c, const int new_flags);
98 static void complete_nread(conn *c);
99 static void process_command(conn *c, char *command);
100 static void write_and_free(conn *c, char *buf, int bytes);
101 static int ensure_iov_space(conn *c);
102 static int add_iov(conn *c, const void *buf, int len);
103 static int add_chunked_item_iovs(conn *c, item *it, int len);
104 static int add_msghdr(conn *c);
105 static void write_bin_error(conn *c, protocol_binary_response_status err,
108 static void conn_free(conn *c);
115 conn **conns;
121 static conn *listen_conn = NULL;
132 static enum transmit_result transmit(conn *c);
256 static int add_msghdr(conn *c)  in add_msghdr()
307     conn *c;  in conn_timeout_thread()
409     if ((conns = calloc(max_fds, sizeof(conn *))) == NULL) {  in conn_init()
432 void conn_close_idle(conn *c) {  in conn_close_idle()
452 conn *conn_new(const int sfd, enum conn_states init_state,  in conn_new()
456     conn *c;  in conn_new()
462         if (!(c = (conn *)calloc(1, sizeof(conn)))) {  in conn_new()
593 static void conn_release_items(conn *c) {  in conn_release_items()
619 static void conn_cleanup(conn *c) {  in conn_cleanup()
643 void conn_free(conn *c) {  in conn_free()
668 static void conn_close(conn *c) {  in conn_close()
702 static void conn_shrink(conn *c) {  in conn_shrink()
776 static void conn_set_state(conn *c, enum conn_states state) {  in conn_set_state()
800 static int ensure_iov_space(conn *c) {  in ensure_iov_space()
834 static int add_iov(conn *c, const void *buf, int len) {  in add_iov()
883 static int add_chunked_item_iovs(conn *c, item *it, int len) {  in add_chunked_item_iovs()
900 static int build_udp_headers(conn *c) {  in build_udp_headers()
943 static void out_string(conn *c, const char *str) {  in out_string()
986 static void out_of_memory(conn *c, char *ascii_error) {  in out_of_memory()
1005 static void complete_nread_ascii(conn *c) {  in complete_nread_ascii()
1106 static void* binary_get_request(conn *c) {  in binary_get_request()
1118 static char* binary_get_key(conn *c) {  in binary_get_key()
1122 static void add_bin_header(conn *c, uint16_t err, uint8_t hdr_len, uint16_t key_len, uint32_t body_…  in add_bin_header()
1172 static void write_bin_error(conn *c, protocol_binary_response_status err,  in write_bin_error()
1231 static void write_bin_response(conn *c, void *d, int hlen, int keylen, int dlen) {  in write_bin_response()
1245 static void complete_incr_bin(conn *c) {  in complete_incr_bin()
1344 static void complete_update_bin(conn *c) {  in complete_update_bin()
1434 static void process_bin_get_or_touch(conn *c) {  in process_bin_get_or_touch()
1559                              conn *c) {  in append_bin_stats()
1588                                conn *c) {  in append_ascii_stats()
1605 static bool grow_stats_buf(conn *c, size_t needed) {  in grow_stats_buf()
1647     conn *c = (conn*)cookie;  in append_stats()
1666 static void process_bin_stat(conn *c) {  in process_bin_stat()
1732 static void bin_read_key(conn *c, enum bin_substates next_substate, int extra) {  in bin_read_key()
1785 static void handle_binary_protocol_error(conn *c) {  in handle_binary_protocol_error()
1794 static void init_sasl_conn(conn *c) {  in init_sasl_conn()
1817 static void bin_list_sasl_mechs(conn *c) {  in bin_list_sasl_mechs()
1846 static void process_bin_sasl_auth(conn *c) {  in process_bin_sasl_auth()
1885 static void process_bin_complete_sasl_auth(conn *c) {  in process_bin_complete_sasl_auth()
1962 static bool authenticated(conn *c) {  in authenticated()
1985 static void dispatch_bin_command(conn *c) {  in dispatch_bin_command()
2171 static void process_bin_update(conn *c) {  in process_bin_update()
2270 static void process_bin_append_prepend(conn *c) {  in process_bin_append_prepend()
2325 static void process_bin_flush(conn *c) {  in process_bin_flush()
2360 static void process_bin_delete(conn *c) {  in process_bin_delete()
2405 static void complete_nread_binary(conn *c) {  in complete_nread_binary()
2449 static void reset_cmd_handler(conn *c) {  in reset_cmd_handler()
2464 static void complete_nread(conn *c) {  in complete_nread()
2559 enum store_item_type do_store_item(item *it, int comm, conn *c, const uint32_t hv) {  in do_store_item()
2741 static void write_and_free(conn *c, char *buf, int bytes) {  in write_and_free()
2753 static inline bool set_noreply_maybe(conn *c, token_t *tokens, size_t ntokens)  in set_noreply_maybe()
2771 void append_stat(const char *name, ADD_STAT add_stats, conn *c,  in append_stat()
2789 inline static void process_stats_detail(conn *c, const char *command) {  in process_stats_detail()
2811 static void server_stats(ADD_STAT add_stats, conn *c) {  in server_stats()
2957 static void conn_to_str(const conn *c, char *buf) {  in conn_to_str()
3064 static void process_stat(conn *c, token_t *tokens, const size_t ntokens) {  in process_stat()
3143 static inline void process_get_command(conn *c, token_t *tokens, size_t ntokens, bool return_cas) {  in process_get_command()
3334 static void process_update_command(conn *c, token_t *tokens, const size_t ntokens, int comm, bool h…  in process_update_command()
3428 static void process_touch_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_touch_command()
3471 static void process_arithmetic_command(conn *c, token_t *tokens, const size_t ntokens, const bool i…  in process_arithmetic_command()
3531 enum delta_result_type do_add_delta(conn *c, const char *key, const size_t nkey,  in do_add_delta()
3633 static void process_delete_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_delete_command()
3685 static void process_verbosity_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_verbosity_command()
3698 static void process_slabs_automove_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_slabs_automove_command()
3719 static void process_watch_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_watch_command()
3758 static void process_memlimit_command(conn *c, token_t *tokens, const size_t ntokens) {  in process_memlimit_command()
3783 static void process_command(conn *c, char *command) {  in process_command()
4039 static int try_read_command(conn *c) {  in try_read_command()
4174 static enum try_read_result try_read_udp(conn *c) {  in try_read_udp()
4221 static enum try_read_result try_read_network(conn *c) {  in try_read_network()
4283 static bool update_event(conn *c, const int new_flags) {  in update_event()
4301     conn *next;  in do_accept_new_conns()
4349 static enum transmit_result transmit(conn *c) {  in transmit()
4411 static int read_into_chunked_item(conn *c) {  in read_into_chunked_item()
4467 static void drive_machine(conn *c) {  in drive_machine()
4815     conn *c;  in event_handler()
4817     c = (conn *)arg;  in event_handler()
4928         conn *listen_conn_add;  in server_socket()