Searched refs:in_seq (Results 1 - 14 of 14) 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()
270 con->in_seq_acked, con->in_seq); in prepare_write_ack()
271 con->in_seq_acked = con->in_seq; 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()
1187 if ((s64)seq - (s64)con->in_seq < 1) { in read_partial_message()
1191 seq, con->in_seq + 1); in read_partial_message()
1196 } else if ((s64)seq - (s64)con->in_seq > 1) { in read_partial_message()
1198 seq, con->in_seq in read_partial_message()
[all...] |
| H A D | messenger_v2.c | 1541 dout("%s con %p my_addr %s/%u client_cookie 0x%llx server_cookie 0x%llx global_seq %llu connect_seq %llu in_seq %llu\n", in prepare_session_reconnect()
1544 con->v2.connect_seq, con->in_seq); in prepare_session_reconnect()
1559 ceph_encode_64(&p, con->in_seq); in prepare_session_reconnect()
1586 con->in_seq_acked, con->in_seq); in prepare_ack()
1587 con->in_seq_acked = con->in_seq; in prepare_ack()
1744 if (con->in_seq > con->in_seq_acked) { 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()
2132 con->in_seq++; in __finish_skip()
2872 if ((s64)seq - (s64)con->in_seq < in process_message_header()
[all...] |
| H A D | messenger.c | 563 con->in_seq = 0; in ceph_con_reset_session()
1412 con->in_seq++; in ceph_con_process_message()
|
| /kernel/linux/linux-5.10/net/netfilter/ipvs/ |
| H A D | ip_vs_app.c | 385 vs_fix_ack_seq(&cp->in_seq, th); in app_tcp_pkt_out()
460 vs_fix_seq(&cp->in_seq, th); in app_tcp_pkt_in()
477 vs_seq_update(cp, &cp->in_seq, in app_tcp_pkt_in()
|
| H A D | ip_vs_sync.c | 91 struct ip_vs_seq in_seq; /* incoming seq. struct */ member
751 hton_seq((struct ip_vs_seq *)p, &cp->in_seq); in ip_vs_sync_conn()
925 cp->in_seq = opt->in_seq; in ip_vs_proc_conn()
1044 ntoh_seq(&topt->in_seq, &opt->in_seq); in ip_vs_proc_seqopt()
|
| H A D | ip_vs_conn.c | 999 cp->in_seq.delta = 0; in ip_vs_conn_new()
|
| /kernel/linux/linux-6.6/net/netfilter/ipvs/ |
| H A D | ip_vs_app.c | 385 vs_fix_ack_seq(&cp->in_seq, th); in app_tcp_pkt_out()
460 vs_fix_seq(&cp->in_seq, th); in app_tcp_pkt_in()
477 vs_seq_update(cp, &cp->in_seq, in app_tcp_pkt_in()
|
| H A D | ip_vs_sync.c | 91 struct ip_vs_seq in_seq; /* incoming seq. struct */ member
751 hton_seq((struct ip_vs_seq *)p, &cp->in_seq); in ip_vs_sync_conn()
925 cp->in_seq = opt->in_seq; in ip_vs_proc_conn()
1044 ntoh_seq(&topt->in_seq, &opt->in_seq); in ip_vs_proc_seqopt()
|
| H A D | ip_vs_conn.c | 998 cp->in_seq.delta = 0; in ip_vs_conn_new()
|
| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | messenger.c | 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 > in read_partial_message()
[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
|
| /kernel/linux/linux-5.10/include/net/ |
| H A D | ip_vs.h | 553 struct ip_vs_seq in_seq; /* incoming seq. struct */
|
| /kernel/linux/linux-6.6/include/net/ |
| H A D | ip_vs.h | 614 struct ip_vs_seq in_seq; /* incoming seq. struct */
|
Completed in 38 milliseconds