Lines Matching refs:cur_resp
156 static struct io_buffer cur_comm, cur_resp; variable
467 if (cur_resp.start == 0 && cur_resp.len == 0) in response_pending()
469 if (cur_resp.start + cur_resp.len == 1 && cur_resp.data[0] == '+') in response_pending()
488 io_buffer_reset(&cur_resp); in close_connection()
552 if (cur_resp.len == 0) { in send_pending_data()
556 nwritten = write(fd, io_buffer_head(&cur_resp), cur_resp.len); in send_pending_data()
561 io_buffer_advance(&cur_resp, nwritten); in send_pending_data()
562 if (cur_resp.len == 0) in send_pending_data()
573 io_buffer_grow(&cur_resp, 1); in send_char()
574 *io_buffer_tail(&cur_resp) = data; in send_char()
575 cur_resp.len++; in send_char()
583 io_buffer_grow(&cur_resp, len); in send_data()
584 memcpy(io_buffer_tail(&cur_resp), data, len); in send_data()
585 cur_resp.len += len; in send_data()
623 debug("-> %.*s\n", (int)cur_resp.len, io_buffer_head(&cur_resp)); in finish_packet()
1992 io_buffer_reset(&cur_resp); in check_command()
2003 cur_resp.len += cur_resp.start; in check_command()
2004 cur_resp.start = 0; in check_command()
2005 if (cur_resp.data[0] == '+') in check_command()
2006 io_buffer_advance(&cur_resp, 1); in check_command()
2007 debug("-> %.*s\n", (int)cur_resp.len, in check_command()
2008 io_buffer_head(&cur_resp)); in check_command()
2019 io_buffer_reset(&cur_resp); in check_command()