Searched refs:in_seq_acked (Results 1 - 6 of 6) sorted by relevance
| /kernel/linux/linux-6.6/net/ceph/ |
| H A D | messenger_v1.c | 205 if (con->in_seq > con->in_seq_acked) { in prepare_write_message()
206 con->in_seq_acked = con->in_seq; in prepare_write_message()
208 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_message()
270 con->in_seq_acked, con->in_seq); in prepare_write_ack()
271 con->in_seq_acked = con->in_seq; in prepare_write_ack()
277 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_ack()
291 con->in_seq_acked, con->in_seq); in prepare_write_seq()
292 con->in_seq_acked = con->in_seq; in prepare_write_seq()
296 con->v1.out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_seq()
1552 if (con->in_seq > con->in_seq_acked) { in ceph_con_v1_try_write()
[all...] |
| H A D | messenger_v2.c | 1585 dout("%s con %p in_seq_acked %llu -> %llu\n", __func__, con, in prepare_ack()
1586 con->in_seq_acked, con->in_seq); in prepare_ack()
1587 con->in_seq_acked = con->in_seq; in prepare_ack()
1590 ceph_encode_64(&p, con->in_seq_acked); in prepare_ack()
1744 if (con->in_seq > con->in_seq_acked) { in prepare_message()
1745 dout("%s con %p in_seq_acked %llu -> %llu\n", __func__, con, in prepare_message()
1746 con->in_seq_acked, con->in_seq); in prepare_message()
1747 con->in_seq_acked = con->in_seq; in prepare_message()
1754 con->in_seq_acked); in prepare_message()
3350 } else if (con->in_seq > con->in_seq_acked) { in populate_out_iter()
[all...] |
| H A D | messenger.c | 564 con->in_seq_acked = 0; in ceph_con_reset_session()
|
| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | messenger.c | 657 con->in_seq_acked = 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()
1267 con->out_temp_ack = cpu_to_le64(con->in_seq_acked); 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()
1354 con->out_temp_ack = cpu_to_le64(con->in_seq_acked); 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()
1373 con->out_temp_ack = cpu_to_le64(con->in_seq_acked); in prepare_write_seq()
[all...] |
| /kernel/linux/linux-5.10/include/linux/ceph/ |
| H A D | messenger.h | 287 u64 in_seq, in_seq_acked; /* last message received, acked */ member
|
| /kernel/linux/linux-6.6/include/linux/ceph/ |
| H A D | messenger.h | 495 u64 in_seq, in_seq_acked; /* last message received, acked */ member
|
Completed in 13 milliseconds