diff options
Diffstat (limited to 'net/dccp')
-rw-r--r-- | net/dccp/dccp.h | 1 | ||||
-rw-r--r-- | net/dccp/input.c | 29 | ||||
-rw-r--r-- | net/dccp/proto.c | 1 | ||||
-rw-r--r-- | net/dccp/sysctl.c | 10 |
4 files changed, 32 insertions, 9 deletions
diff --git a/net/dccp/dccp.h b/net/dccp/dccp.h index e28220183208..a602d9212c64 100644 --- a/net/dccp/dccp.h +++ b/net/dccp/dccp.h | |||
@@ -92,6 +92,7 @@ extern int sysctl_dccp_feat_ack_ratio; | |||
92 | extern int sysctl_dccp_feat_send_ack_vector; | 92 | extern int sysctl_dccp_feat_send_ack_vector; |
93 | extern int sysctl_dccp_feat_send_ndp_count; | 93 | extern int sysctl_dccp_feat_send_ndp_count; |
94 | extern int sysctl_dccp_tx_qlen; | 94 | extern int sysctl_dccp_tx_qlen; |
95 | extern int sysctl_dccp_sync_ratelimit; | ||
95 | 96 | ||
96 | /* | 97 | /* |
97 | * 48-bit sequence number arithmetic (signed and unsigned) | 98 | * 48-bit sequence number arithmetic (signed and unsigned) |
diff --git a/net/dccp/input.c b/net/dccp/input.c index 86ad3ba0649a..19d7e1dbd87e 100644 --- a/net/dccp/input.c +++ b/net/dccp/input.c | |||
@@ -122,6 +122,23 @@ static int dccp_check_seqno(struct sock *sk, struct sk_buff *skb) | |||
122 | (ackno != DCCP_PKT_WITHOUT_ACK_SEQ)) | 122 | (ackno != DCCP_PKT_WITHOUT_ACK_SEQ)) |
123 | dp->dccps_gar = ackno; | 123 | dp->dccps_gar = ackno; |
124 | } else { | 124 | } else { |
125 | unsigned long now = jiffies; | ||
126 | /* | ||
127 | * Step 6: Check sequence numbers | ||
128 | * Otherwise, | ||
129 | * If P.type == Reset, | ||
130 | * Send Sync packet acknowledging S.GSR | ||
131 | * Otherwise, | ||
132 | * Send Sync packet acknowledging P.seqno | ||
133 | * Drop packet and return | ||
134 | * | ||
135 | * These Syncs are rate-limited as per RFC 4340, 7.5.4: | ||
136 | * at most 1 / (dccp_sync_rate_limit * HZ) Syncs per second. | ||
137 | */ | ||
138 | if (time_before(now, (dp->dccps_rate_last + | ||
139 | sysctl_dccp_sync_ratelimit))) | ||
140 | return 0; | ||
141 | |||
125 | DCCP_WARN("DCCP: Step 6 failed for %s packet, " | 142 | DCCP_WARN("DCCP: Step 6 failed for %s packet, " |
126 | "(LSWL(%llu) <= P.seqno(%llu) <= S.SWH(%llu)) and " | 143 | "(LSWL(%llu) <= P.seqno(%llu) <= S.SWH(%llu)) and " |
127 | "(P.ackno %s or LAWL(%llu) <= P.ackno(%llu) <= S.AWH(%llu), " | 144 | "(P.ackno %s or LAWL(%llu) <= P.ackno(%llu) <= S.AWH(%llu), " |
@@ -132,15 +149,9 @@ static int dccp_check_seqno(struct sock *sk, struct sk_buff *skb) | |||
132 | : "exists", | 149 | : "exists", |
133 | (unsigned long long) lawl, (unsigned long long) ackno, | 150 | (unsigned long long) lawl, (unsigned long long) ackno, |
134 | (unsigned long long) dp->dccps_awh); | 151 | (unsigned long long) dp->dccps_awh); |
135 | /* | 152 | |
136 | * Step 6: Check sequence numbers | 153 | dp->dccps_rate_last = now; |
137 | * Otherwise, | 154 | |
138 | * If P.type == Reset, | ||
139 | * Send Sync packet acknowledging S.GSR | ||
140 | * Otherwise, | ||
141 | * Send Sync packet acknowledging P.seqno | ||
142 | * Drop packet and return | ||
143 | */ | ||
144 | if (dh->dccph_type == DCCP_PKT_RESET) | 155 | if (dh->dccph_type == DCCP_PKT_RESET) |
145 | seqno = dp->dccps_gsr; | 156 | seqno = dp->dccps_gsr; |
146 | dccp_send_sync(sk, seqno, DCCP_PKT_SYNC); | 157 | dccp_send_sync(sk, seqno, DCCP_PKT_SYNC); |
diff --git a/net/dccp/proto.c b/net/dccp/proto.c index 14ec1d21452c..604de8bfa068 100644 --- a/net/dccp/proto.c +++ b/net/dccp/proto.c | |||
@@ -219,6 +219,7 @@ int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized) | |||
219 | sk->sk_write_space = dccp_write_space; | 219 | sk->sk_write_space = dccp_write_space; |
220 | icsk->icsk_sync_mss = dccp_sync_mss; | 220 | icsk->icsk_sync_mss = dccp_sync_mss; |
221 | dp->dccps_mss_cache = 536; | 221 | dp->dccps_mss_cache = 536; |
222 | dp->dccps_rate_last = jiffies; | ||
222 | dp->dccps_role = DCCP_ROLE_UNDEFINED; | 223 | dp->dccps_role = DCCP_ROLE_UNDEFINED; |
223 | dp->dccps_service = DCCP_SERVICE_CODE_IS_ABSENT; | 224 | dp->dccps_service = DCCP_SERVICE_CODE_IS_ABSENT; |
224 | dp->dccps_l_ack_ratio = dp->dccps_r_ack_ratio = 1; | 225 | dp->dccps_l_ack_ratio = dp->dccps_r_ack_ratio = 1; |
diff --git a/net/dccp/sysctl.c b/net/dccp/sysctl.c index 1260aabac5e1..9364b2fb4dbd 100644 --- a/net/dccp/sysctl.c +++ b/net/dccp/sysctl.c | |||
@@ -18,6 +18,9 @@ | |||
18 | #error This file should not be compiled without CONFIG_SYSCTL defined | 18 | #error This file should not be compiled without CONFIG_SYSCTL defined |
19 | #endif | 19 | #endif |
20 | 20 | ||
21 | /* rate-limit for syncs in reply to sequence-invalid packets; RFC 4340, 7.5.4 */ | ||
22 | int sysctl_dccp_sync_ratelimit __read_mostly = HZ / 8; | ||
23 | |||
21 | static struct ctl_table dccp_default_table[] = { | 24 | static struct ctl_table dccp_default_table[] = { |
22 | { | 25 | { |
23 | .procname = "seq_window", | 26 | .procname = "seq_window", |
@@ -89,6 +92,13 @@ static struct ctl_table dccp_default_table[] = { | |||
89 | .mode = 0644, | 92 | .mode = 0644, |
90 | .proc_handler = proc_dointvec, | 93 | .proc_handler = proc_dointvec, |
91 | }, | 94 | }, |
95 | { | ||
96 | .procname = "sync_ratelimit", | ||
97 | .data = &sysctl_dccp_sync_ratelimit, | ||
98 | .maxlen = sizeof(sysctl_dccp_sync_ratelimit), | ||
99 | .mode = 0644, | ||
100 | .proc_handler = proc_dointvec_ms_jiffies, | ||
101 | }, | ||
92 | 102 | ||
93 | { .ctl_name = 0, } | 103 | { .ctl_name = 0, } |
94 | }; | 104 | }; |