1 /* Error message handling (ICMP)
3 * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
12 #include <linux/module.h>
13 #include <linux/net.h>
14 #include <linux/skbuff.h>
15 #include <linux/errqueue.h>
16 #include <linux/udp.h>
18 #include <linux/in6.h>
19 #include <linux/icmp.h>
21 #include <net/af_rxrpc.h>
23 #include "ar-internal.h"
26 * handle an error received on the local endpoint
28 void rxrpc_UDP_error_report(struct sock
*sk
)
30 struct sock_exterr_skb
*serr
;
31 struct rxrpc_transport
*trans
;
32 struct rxrpc_local
*local
= sk
->sk_user_data
;
33 struct rxrpc_peer
*peer
;
38 _enter("%p{%d}", sk
, local
->debug_id
);
40 skb
= sock_dequeue_err_skb(sk
);
42 _leave("UDP socket errqueue empty");
48 serr
= SKB_EXT_ERR(skb
);
49 addr
= *(__be32
*)(skb_network_header(skb
) + serr
->addr_offset
);
52 _net("Rx UDP Error from %pI4:%hu", &addr
, ntohs(port
));
53 _debug("Msg l:%d d:%d", skb
->len
, skb
->data_len
);
55 peer
= rxrpc_find_peer(local
, addr
, port
);
62 trans
= rxrpc_find_transport(local
, peer
);
66 _leave(" [no trans]");
70 if (serr
->ee
.ee_origin
== SO_EE_ORIGIN_ICMP
&&
71 serr
->ee
.ee_type
== ICMP_DEST_UNREACH
&&
72 serr
->ee
.ee_code
== ICMP_FRAG_NEEDED
74 u32 mtu
= serr
->ee
.ee_info
;
76 _net("Rx Received ICMP Fragmentation Needed (%d)", mtu
);
78 /* wind down the local interface MTU */
79 if (mtu
> 0 && peer
->if_mtu
== 65535 && mtu
< peer
->if_mtu
) {
81 _net("I/F MTU %u", mtu
);
85 /* they didn't give us a size, estimate one */
93 if (mtu
< peer
->hdrsize
)
94 mtu
= peer
->hdrsize
+ 4;
98 if (mtu
< peer
->mtu
) {
99 spin_lock_bh(&peer
->lock
);
101 peer
->maxdata
= peer
->mtu
- peer
->hdrsize
;
102 spin_unlock_bh(&peer
->lock
);
103 _net("Net MTU %u (maxdata %u)",
104 peer
->mtu
, peer
->maxdata
);
108 rxrpc_put_peer(peer
);
110 /* pass the transport ref to error_handler to release */
111 skb_queue_tail(&trans
->error_queue
, skb
);
112 rxrpc_queue_work(&trans
->error_handler
);
118 * deal with UDP error messages
120 void rxrpc_UDP_error_handler(struct work_struct
*work
)
122 struct sock_extended_err
*ee
;
123 struct sock_exterr_skb
*serr
;
124 struct rxrpc_transport
*trans
=
125 container_of(work
, struct rxrpc_transport
, error_handler
);
131 skb
= skb_dequeue(&trans
->error_queue
);
135 serr
= SKB_EXT_ERR(skb
);
138 _net("Rx Error o=%d t=%d c=%d e=%d",
139 ee
->ee_origin
, ee
->ee_type
, ee
->ee_code
, ee
->ee_errno
);
143 switch (ee
->ee_origin
) {
144 case SO_EE_ORIGIN_ICMP
:
145 switch (ee
->ee_type
) {
146 case ICMP_DEST_UNREACH
:
147 switch (ee
->ee_code
) {
148 case ICMP_NET_UNREACH
:
149 _net("Rx Received ICMP Network Unreachable");
152 case ICMP_HOST_UNREACH
:
153 _net("Rx Received ICMP Host Unreachable");
156 case ICMP_PORT_UNREACH
:
157 _net("Rx Received ICMP Port Unreachable");
160 case ICMP_FRAG_NEEDED
:
161 _net("Rx Received ICMP Fragmentation Needed (%d)",
163 err
= 0; /* dealt with elsewhere */
165 case ICMP_NET_UNKNOWN
:
166 _net("Rx Received ICMP Unknown Network");
169 case ICMP_HOST_UNKNOWN
:
170 _net("Rx Received ICMP Unknown Host");
174 _net("Rx Received ICMP DestUnreach code=%u",
180 case ICMP_TIME_EXCEEDED
:
181 _net("Rx Received ICMP TTL Exceeded");
185 _proto("Rx Received ICMP error { type=%u code=%u }",
186 ee
->ee_type
, ee
->ee_code
);
191 case SO_EE_ORIGIN_LOCAL
:
192 _proto("Rx Received local error { error=%d }",
196 case SO_EE_ORIGIN_NONE
:
197 case SO_EE_ORIGIN_ICMP6
:
199 _proto("Rx Received error report { orig=%u }",
204 /* terminate all the affected calls if there's an unrecoverable
207 struct rxrpc_call
*call
, *_n
;
209 _debug("ISSUE ERROR %d", err
);
211 spin_lock_bh(&trans
->peer
->lock
);
212 trans
->peer
->net_error
= err
;
214 list_for_each_entry_safe(call
, _n
, &trans
->peer
->error_targets
,
216 write_lock(&call
->state_lock
);
217 if (call
->state
!= RXRPC_CALL_COMPLETE
&&
218 call
->state
< RXRPC_CALL_NETWORK_ERROR
) {
219 call
->state
= RXRPC_CALL_NETWORK_ERROR
;
220 set_bit(RXRPC_CALL_RCVD_ERROR
, &call
->events
);
221 rxrpc_queue_call(call
);
223 write_unlock(&call
->state_lock
);
224 list_del_init(&call
->error_link
);
227 spin_unlock_bh(&trans
->peer
->lock
);
230 if (!skb_queue_empty(&trans
->error_queue
))
231 rxrpc_queue_work(&trans
->error_handler
);
234 rxrpc_put_transport(trans
);
This page took 0.035699 seconds and 6 git commands to generate.