Searched refs:in_seq (Results 1 – 8 of 8) sorted by relevance
| /linux/net/ceph/ |
| H A D | messenger_v1.c | 204 if (con->in_seq > con->in_seq_acked) { in prepare_write_message() 205 con->in_seq_acked = con->in_seq; 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() 287 con->in_seq_acked, con->in_seq); in prepare_write_seq() 288 con->in_seq_acked = con->in_seq; in prepare_write_seq() 1183 if ((s64)seq - (s64)con->in_seq < 1) { in read_partial_message() 1187 seq, con->in_seq + 1); in read_partial_message() 1192 } else if ((s64)seq - (s64)con->in_seq > 1) { in read_partial_message() 1194 seq, con->in_seq + 1); in read_partial_message() [all …]
|
| H A D | messenger_v2.c | 1513 con->v2.connect_seq, con->in_seq); in prepare_session_reconnect() 1528 ceph_encode_64(&p, con->in_seq); in prepare_session_reconnect() 1554 con->in_seq_acked, con->in_seq); in prepare_ack() 1555 con->in_seq_acked = con->in_seq; in prepare_ack() 1713 if (con->in_seq > con->in_seq_acked) { in prepare_message() 1715 con->in_seq_acked, con->in_seq); in prepare_message() 1716 con->in_seq_acked = con->in_seq; in prepare_message() 2104 con->in_seq++; in __finish_skip() 2846 if ((s64)seq - (s64)con->in_seq < 1) { in process_message_header() 2850 seq, con->in_seq + 1); in process_message_header() [all …]
|
| H A D | messenger.c | 564 con->in_seq = 0; in ceph_con_reset_session() 1413 con->in_seq++; in ceph_con_process_message()
|
| /linux/net/netfilter/ipvs/ |
| H A D | ip_vs_app.c | 384 vs_fix_ack_seq(&cp->in_seq, th); in app_tcp_pkt_out() 459 vs_fix_seq(&cp->in_seq, th); in app_tcp_pkt_in() 476 vs_seq_update(cp, &cp->in_seq, in app_tcp_pkt_in()
|
| H A D | ip_vs_sync.c | 90 struct ip_vs_seq in_seq; /* incoming seq. struct */ member 750 hton_seq((struct ip_vs_seq *)p, &cp->in_seq); in ip_vs_sync_conn() 924 cp->in_seq = opt->in_seq; in ip_vs_proc_conn() 1043 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()
|
| /linux/include/linux/ceph/ |
| H A D | messenger.h | 497 u64 in_seq, in_seq_acked; /* last message received, acked */ member
|
| /linux/include/net/ |
| H A D | ip_vs.h | 614 struct ip_vs_seq in_seq; /* incoming seq. struct */
|