Lines Matching refs:in_base_pos
552 con->v1.in_base_pos = 0; in prepare_read_banner()
558 con->v1.in_base_pos = 0; in prepare_read_connect()
564 con->v1.in_base_pos = 0; in prepare_read_ack()
570 con->v1.in_base_pos = 0; in prepare_read_seq()
577 con->v1.in_base_pos = 0; in prepare_read_tag()
584 con->v1.in_base_pos = 0; in prepare_read_keepalive_ack()
594 con->v1.in_base_pos = 0; in prepare_read_message()
602 while (con->v1.in_base_pos < end) { in read_partial()
603 int left = end - con->v1.in_base_pos; in read_partial()
608 con->v1.in_base_pos += ret; in read_partial()
622 dout("read_partial_banner %p at %d\n", con, con->v1.in_base_pos); in read_partial_banner()
655 dout("read_partial_connect %p at %d\n", con, con->v1.in_base_pos); in read_partial_connect()
1192 con->v1.in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
1217 con->v1.in_base_pos = -front_len - middle_len - in read_partial_message()
1340 con->v1.in_base_pos); in ceph_con_v1_try_read()
1378 if (con->v1.in_base_pos < 0) { in ceph_con_v1_try_read()
1382 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1385 dout("skipped %d / %d bytes\n", ret, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1386 con->v1.in_base_pos += ret; in ceph_con_v1_try_read()
1387 if (con->v1.in_base_pos) in ceph_con_v1_try_read()
1597 con->v1.in_base_pos = con->v1.in_base_pos - in ceph_con_v1_revoke_incoming()
1607 dout("%s con %p in_base_pos %d\n", __func__, con, con->v1.in_base_pos); in ceph_con_v1_revoke_incoming()