Lines Matching refs:in_seq
656 con->in_seq = 0; in reset_connection()
1264 if (con->in_seq > con->in_seq_acked) { in prepare_write_message()
1265 con->in_seq_acked = con->in_seq; in prepare_write_message()
1347 con->in_seq_acked, con->in_seq); in prepare_write_ack()
1348 con->in_seq_acked = con->in_seq; in prepare_write_ack()
1368 con->in_seq_acked, con->in_seq); in prepare_write_seq()
1369 con->in_seq_acked = con->in_seq; in prepare_write_seq()
2396 if ((s64)seq - (s64)con->in_seq < 1) { in read_partial_message()
2400 seq, con->in_seq + 1); in read_partial_message()
2405 } else if ((s64)seq - (s64)con->in_seq > 1) { in read_partial_message()
2407 seq, con->in_seq + 1); in read_partial_message()
2429 con->in_seq++; in read_partial_message()
2528 con->in_seq++; in process_message()
2638 if (con->in_seq > con->in_seq_acked) { in try_write()
3202 con->in_seq++; in ceph_msg_revoke_incoming()