Lines Matching refs:in_base_pos
1644 con->in_base_pos = 0; in prepare_read_banner()
1650 con->in_base_pos = 0; in prepare_read_connect()
1656 con->in_base_pos = 0; in prepare_read_ack()
1662 con->in_base_pos = 0; in prepare_read_seq()
1669 con->in_base_pos = 0; in prepare_read_tag()
1676 con->in_base_pos = 0; in prepare_read_keepalive_ack()
1686 con->in_base_pos = 0; in prepare_read_message()
1695 while (con->in_base_pos < end) { in read_partial()
1696 int left = end - con->in_base_pos; in read_partial()
1701 con->in_base_pos += ret; in read_partial()
1716 dout("read_partial_banner %p at %d\n", con, con->in_base_pos); in read_partial_banner()
1749 dout("read_partial_connect %p at %d\n", con, con->in_base_pos); in read_partial_connect()
2401 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2426 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2670 con->in_base_pos); in try_read()
2710 if (con->in_base_pos < 0) { in try_read()
2714 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->in_base_pos); in try_read()
2717 dout("skipped %d / %d bytes\n", ret, -con->in_base_pos); in try_read()
2718 con->in_base_pos += ret; in try_read()
2719 if (con->in_base_pos) in try_read()
3193 con->in_base_pos = con->in_base_pos - in ceph_msg_revoke_incoming()