Home
last modified time | relevance | path

Searched refs:in_seq_acked (Results 1 – 4 of 4) sorted by relevance

/linux/net/ceph/
H A Dmessenger_v1.c204 if (con->in_seq > con->in_seq_acked) { in prepare_write_message()
205 con->in_seq_acked = con->in_seq; in prepare_write_message()
207 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_message()
266 con->in_seq_acked, con->in_seq); in prepare_write_ack()
267 con->in_seq_acked = con->in_seq; in prepare_write_ack()
273 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_ack()
287 con->in_seq_acked, con->in_seq); in prepare_write_seq()
288 con->in_seq_acked = con->in_seq; in prepare_write_seq()
292 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_seq()
1550 if (con->in_seq > con->in_seq_acked) { in ceph_con_v1_try_write()
H A Dmessenger_v2.c1552 dout("%s con %p in_seq_acked %llu -> %llu\n", __func__, con, in prepare_ack()
1553 con->in_seq_acked, con->in_seq); in prepare_ack()
1554 con->in_seq_acked = con->in_seq; in prepare_ack()
1557 ceph_encode_64(&p, con->in_seq_acked); in prepare_ack()
1712 if (con->in_seq > con->in_seq_acked) { in prepare_message()
1713 dout("%s con %p in_seq_acked %llu -> %llu\n", __func__, con, in prepare_message()
1714 con->in_seq_acked, con->in_seq); in prepare_message()
1715 con->in_seq_acked = con->in_seq; in prepare_message()
1722 con->in_seq_acked); in prepare_message()
3335 } else if (con->in_seq > con->in_seq_acked) { in populate_out_iter()
[all...]
H A Dmessenger.c565 con->in_seq_acked = 0; in ceph_con_reset_session()
/linux/include/linux/ceph/
H A Dmessenger.h497 u64 in_seq, in_seq_acked; /* last message received, acked */ member