Lines Matching refs:in_base_pos
1672 con->in_base_pos = 0; in prepare_read_banner()
1678 con->in_base_pos = 0; in prepare_read_connect()
1684 con->in_base_pos = 0; in prepare_read_ack()
1690 con->in_base_pos = 0; in prepare_read_seq()
1697 con->in_base_pos = 0; in prepare_read_tag()
1704 con->in_base_pos = 0; in prepare_read_keepalive_ack()
1714 con->in_base_pos = 0; in prepare_read_message()
1723 while (con->in_base_pos < end) { in read_partial()
1724 int left = end - con->in_base_pos; in read_partial()
1729 con->in_base_pos += ret; in read_partial()
1744 dout("read_partial_banner %p at %d\n", con, con->in_base_pos); in read_partial_banner()
1775 dout("read_partial_connect %p at %d\n", con, con->in_base_pos); in read_partial_connect()
2431 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2456 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2700 con->in_base_pos); in try_read()
2740 if (con->in_base_pos < 0) { in try_read()
2744 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->in_base_pos); in try_read()
2747 dout("skipped %d / %d bytes\n", ret, -con->in_base_pos); in try_read()
2748 con->in_base_pos += ret; in try_read()
2749 if (con->in_base_pos) in try_read()
3212 con->in_base_pos = con->in_base_pos - in ceph_msg_revoke_incoming()