mirror of
https://github.com/adulau/aha.git
synced 2024-12-28 19:56:18 +00:00
[DCCP]: Generalize dccp_v4_send_reset
Renaming it to dccp_send_reset and moving it from the ipv4 specific code to the core dccp code. This fixes some bugs in IPV6 where timers would send v4 resets, etc. Signed-off-by: Arnaldo Carvalho de Melo <acme@mandriva.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
parent
e55d912f5b
commit
017487d7d1
5 changed files with 28 additions and 38 deletions
|
@ -235,9 +235,6 @@ extern void dccp_close(struct sock *sk, long timeout);
|
|||
extern struct sk_buff *dccp_make_response(struct sock *sk,
|
||||
struct dst_entry *dst,
|
||||
struct request_sock *req);
|
||||
extern struct sk_buff *dccp_make_reset(struct sock *sk,
|
||||
struct dst_entry *dst,
|
||||
enum dccp_reset_codes code);
|
||||
|
||||
extern int dccp_connect(struct sock *sk);
|
||||
extern int dccp_disconnect(struct sock *sk, int flags);
|
||||
|
@ -264,8 +261,7 @@ extern int dccp_v4_connect(struct sock *sk, struct sockaddr *uaddr,
|
|||
extern int dccp_v4_checksum(const struct sk_buff *skb,
|
||||
const __be32 saddr, const __be32 daddr);
|
||||
|
||||
extern int dccp_v4_send_reset(struct sock *sk,
|
||||
enum dccp_reset_codes code);
|
||||
extern int dccp_send_reset(struct sock *sk, enum dccp_reset_codes code);
|
||||
extern void dccp_send_close(struct sock *sk, const int active);
|
||||
extern int dccp_invalid_packet(struct sk_buff *skb);
|
||||
|
||||
|
|
|
@ -32,7 +32,7 @@ static void dccp_fin(struct sock *sk, struct sk_buff *skb)
|
|||
|
||||
static void dccp_rcv_close(struct sock *sk, struct sk_buff *skb)
|
||||
{
|
||||
dccp_v4_send_reset(sk, DCCP_RESET_CODE_CLOSED);
|
||||
dccp_send_reset(sk, DCCP_RESET_CODE_CLOSED);
|
||||
dccp_fin(sk, skb);
|
||||
dccp_set_state(sk, DCCP_CLOSED);
|
||||
sk_wake_async(sk, 1, POLL_HUP);
|
||||
|
|
|
@ -457,32 +457,6 @@ void dccp_v4_send_check(struct sock *sk, int len, struct sk_buff *skb)
|
|||
|
||||
EXPORT_SYMBOL_GPL(dccp_v4_send_check);
|
||||
|
||||
int dccp_v4_send_reset(struct sock *sk, enum dccp_reset_codes code)
|
||||
{
|
||||
struct sk_buff *skb;
|
||||
/*
|
||||
* FIXME: what if rebuild_header fails?
|
||||
* Should we be doing a rebuild_header here?
|
||||
*/
|
||||
int err = inet_sk_rebuild_header(sk);
|
||||
|
||||
if (err != 0)
|
||||
return err;
|
||||
|
||||
skb = dccp_make_reset(sk, sk->sk_dst_cache, code);
|
||||
if (skb != NULL) {
|
||||
const struct inet_sock *inet = inet_sk(sk);
|
||||
|
||||
memset(&(IPCB(skb)->opt), 0, sizeof(IPCB(skb)->opt));
|
||||
err = ip_build_and_send_pkt(skb, sk,
|
||||
inet->saddr, inet->daddr, NULL);
|
||||
if (err == NET_XMIT_CN)
|
||||
err = 0;
|
||||
}
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
static inline u64 dccp_v4_init_sequence(const struct sock *sk,
|
||||
const struct sk_buff *skb)
|
||||
{
|
||||
|
|
|
@ -323,8 +323,8 @@ struct sk_buff *dccp_make_response(struct sock *sk, struct dst_entry *dst,
|
|||
|
||||
EXPORT_SYMBOL_GPL(dccp_make_response);
|
||||
|
||||
struct sk_buff *dccp_make_reset(struct sock *sk, struct dst_entry *dst,
|
||||
const enum dccp_reset_codes code)
|
||||
static struct sk_buff *dccp_make_reset(struct sock *sk, struct dst_entry *dst,
|
||||
const enum dccp_reset_codes code)
|
||||
|
||||
{
|
||||
struct dccp_hdr *dh;
|
||||
|
@ -366,14 +366,34 @@ struct sk_buff *dccp_make_reset(struct sock *sk, struct dst_entry *dst,
|
|||
dccp_hdr_set_ack(dccp_hdr_ack_bits(skb), dp->dccps_gsr);
|
||||
|
||||
dccp_hdr_reset(skb)->dccph_reset_code = code;
|
||||
|
||||
dh->dccph_checksum = dccp_v4_checksum(skb, inet_sk(sk)->saddr,
|
||||
inet_sk(sk)->daddr);
|
||||
inet_csk(sk)->icsk_af_ops->send_check(sk, skb->len, skb);
|
||||
|
||||
DCCP_INC_STATS(DCCP_MIB_OUTSEGS);
|
||||
return skb;
|
||||
}
|
||||
|
||||
int dccp_send_reset(struct sock *sk, enum dccp_reset_codes code)
|
||||
{
|
||||
/*
|
||||
* FIXME: what if rebuild_header fails?
|
||||
* Should we be doing a rebuild_header here?
|
||||
*/
|
||||
int err = inet_sk_rebuild_header(sk);
|
||||
|
||||
if (err == 0) {
|
||||
struct sk_buff *skb = dccp_make_reset(sk, sk->sk_dst_cache,
|
||||
code);
|
||||
if (skb != NULL) {
|
||||
memset(&(IPCB(skb)->opt), 0, sizeof(IPCB(skb)->opt));
|
||||
err = inet_csk(sk)->icsk_af_ops->queue_xmit(skb, 0);
|
||||
if (err == NET_XMIT_CN)
|
||||
err = 0;
|
||||
}
|
||||
}
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
/*
|
||||
* Do all connect socket setups that can be done AF independent.
|
||||
*/
|
||||
|
|
|
@ -31,7 +31,7 @@ static void dccp_write_err(struct sock *sk)
|
|||
sk->sk_err = sk->sk_err_soft ? : ETIMEDOUT;
|
||||
sk->sk_error_report(sk);
|
||||
|
||||
dccp_v4_send_reset(sk, DCCP_RESET_CODE_ABORTED);
|
||||
dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED);
|
||||
dccp_done(sk);
|
||||
DCCP_INC_STATS_BH(DCCP_MIB_ABORTONTIMEOUT);
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue