Lines Matching refs:in_base_pos
1631 con->in_base_pos = 0; in prepare_read_banner()
1637 con->in_base_pos = 0; in prepare_read_connect()
1643 con->in_base_pos = 0; in prepare_read_ack()
1649 con->in_base_pos = 0; in prepare_read_seq()
1656 con->in_base_pos = 0; in prepare_read_tag()
1667 con->in_base_pos = 0; in prepare_read_message()
1676 while (con->in_base_pos < end) { in read_partial()
1677 int left = end - con->in_base_pos; in read_partial()
1682 con->in_base_pos += ret; in read_partial()
1697 dout("read_partial_banner %p at %d\n", con, con->in_base_pos); in read_partial_banner()
1728 dout("read_partial_connect %p at %d\n", con, con->in_base_pos); in read_partial_connect()
2335 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2367 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2604 con->in_base_pos); in try_read()
2644 if (con->in_base_pos < 0) { in try_read()
2651 int skip = min((int) sizeof (buf), -con->in_base_pos); in try_read()
2653 dout("skipping %d / %d bytes\n", skip, -con->in_base_pos); in try_read()
2657 con->in_base_pos += ret; in try_read()
2658 if (con->in_base_pos) in try_read()
3112 con->in_base_pos = con->in_base_pos - in ceph_msg_revoke_incoming()