Lines Matching refs:in_base_pos
558 con->v1.in_base_pos = 0; in prepare_read_banner()
564 con->v1.in_base_pos = 0; in prepare_read_connect()
570 con->v1.in_base_pos = 0; in prepare_read_ack()
576 con->v1.in_base_pos = 0; in prepare_read_seq()
583 con->v1.in_base_pos = 0; in prepare_read_tag()
590 con->v1.in_base_pos = 0; in prepare_read_keepalive_ack()
600 con->v1.in_base_pos = 0; in prepare_read_message()
608 while (con->v1.in_base_pos < end) { in read_partial()
609 int left = end - con->v1.in_base_pos; in read_partial()
614 con->v1.in_base_pos += ret; in read_partial()
628 dout("read_partial_banner %p at %d\n", con, con->v1.in_base_pos); in read_partial_banner()
661 dout("read_partial_connect %p at %d\n", con, con->v1.in_base_pos); in read_partial_connect()
1118 con->v1.in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
1143 con->v1.in_base_pos = -front_len - middle_len - in read_partial_message()
1264 con->v1.in_base_pos); in ceph_con_v1_try_read()
1302 if (con->v1.in_base_pos < 0) { in ceph_con_v1_try_read()
1306 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1309 dout("skipped %d / %d bytes\n", ret, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1310 con->v1.in_base_pos += ret; in ceph_con_v1_try_read()
1311 if (con->v1.in_base_pos) in ceph_con_v1_try_read()
1521 con->v1.in_base_pos = con->v1.in_base_pos - in ceph_con_v1_revoke_incoming()
1531 dout("%s con %p in_base_pos %d\n", __func__, con, con->v1.in_base_pos); in ceph_con_v1_revoke_incoming()