Deleted Added
full compact
tcp_offload.c (180648) tcp_offload.c (180674)
1/*-
2 * Copyright (c) 2007, Chelsio Inc.
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 * 1. Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer.
10 *
11 * 2. Neither the name of the Chelsio Corporation nor the names of its
12 * contributors may be used to endorse or promote products derived from
13 * this software without specific prior written permission.
14 *
15 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
16 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
19 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
20 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
21 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
22 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
23 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
24 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
25 * POSSIBILITY OF SUCH DAMAGE.
26 */
27
28#include <sys/cdefs.h>
1/*-
2 * Copyright (c) 2007, Chelsio Inc.
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 * 1. Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer.
10 *
11 * 2. Neither the name of the Chelsio Corporation nor the names of its
12 * contributors may be used to endorse or promote products derived from
13 * this software without specific prior written permission.
14 *
15 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
16 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
19 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
20 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
21 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
22 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
23 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
24 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
25 * POSSIBILITY OF SUCH DAMAGE.
26 */
27
28#include <sys/cdefs.h>
29__FBSDID("$FreeBSD: head/sys/netinet/tcp_offload.c 180648 2008-07-21 02:23:02Z kmacy $");
29__FBSDID("$FreeBSD: head/sys/netinet/tcp_offload.c 180674 2008-07-21 21:22:56Z kmacy $");
30
31#include <sys/param.h>
32#include <sys/systm.h>
33#include <sys/types.h>
34#include <sys/malloc.h>
35#include <sys/kernel.h>
36#include <sys/sysctl.h>
37#include <sys/mbuf.h>
38#include <sys/socket.h>
39#include <sys/socketvar.h>
40
41#include <net/if.h>
42#include <net/if_types.h>
43#include <net/if_var.h>
44
45#include <netinet/in.h>
46#include <netinet/in_systm.h>
47#include <netinet/in_pcb.h>
48#include <netinet/tcp.h>
49#include <netinet/tcp_var.h>
50#include <netinet/tcp_offload.h>
51#include <netinet/toedev.h>
52
53int
54tcp_offload_connect(struct socket *so, struct sockaddr *nam)
55{
56 struct ifnet *ifp;
57 struct toedev *tdev;
58 struct rtentry *rt;
59 int error;
60
61 /*
62 * Look up the route used for the connection to
63 * determine if it uses an interface capable of
64 * offloading the connection.
65 */
66 rt = rtalloc1(nam, 1 /*report*/, 0 /*ignflags*/);
67 if (rt)
68 RT_UNLOCK(rt);
69 else
70 return (EHOSTUNREACH);
71
72 ifp = rt->rt_ifp;
73 if ((ifp->if_capenable & IFCAP_TOE) == 0) {
74 error = EINVAL;
75 goto fail;
76 }
77
78 tdev = TOEDEV(ifp);
79 if (tdev == NULL) {
80 error = EPERM;
81 goto fail;
82 }
83
84 if (tdev->tod_can_offload(tdev, so) == 0) {
85 error = EPERM;
86 goto fail;
87 }
88
89 return (tdev->tod_connect(tdev, so, rt, nam));
90fail:
91 RTFREE(rt);
92 return (error);
93}
94
95
96/*
97 * This file contains code as a short-term staging area before it is moved in
98 * to sys/netinet/tcp_offload.c
99 */
100
101void
102tcp_offload_twstart(struct tcpcb *tp)
103{
104
105 INP_INFO_WLOCK(&tcbinfo);
30
31#include <sys/param.h>
32#include <sys/systm.h>
33#include <sys/types.h>
34#include <sys/malloc.h>
35#include <sys/kernel.h>
36#include <sys/sysctl.h>
37#include <sys/mbuf.h>
38#include <sys/socket.h>
39#include <sys/socketvar.h>
40
41#include <net/if.h>
42#include <net/if_types.h>
43#include <net/if_var.h>
44
45#include <netinet/in.h>
46#include <netinet/in_systm.h>
47#include <netinet/in_pcb.h>
48#include <netinet/tcp.h>
49#include <netinet/tcp_var.h>
50#include <netinet/tcp_offload.h>
51#include <netinet/toedev.h>
52
53int
54tcp_offload_connect(struct socket *so, struct sockaddr *nam)
55{
56 struct ifnet *ifp;
57 struct toedev *tdev;
58 struct rtentry *rt;
59 int error;
60
61 /*
62 * Look up the route used for the connection to
63 * determine if it uses an interface capable of
64 * offloading the connection.
65 */
66 rt = rtalloc1(nam, 1 /*report*/, 0 /*ignflags*/);
67 if (rt)
68 RT_UNLOCK(rt);
69 else
70 return (EHOSTUNREACH);
71
72 ifp = rt->rt_ifp;
73 if ((ifp->if_capenable & IFCAP_TOE) == 0) {
74 error = EINVAL;
75 goto fail;
76 }
77
78 tdev = TOEDEV(ifp);
79 if (tdev == NULL) {
80 error = EPERM;
81 goto fail;
82 }
83
84 if (tdev->tod_can_offload(tdev, so) == 0) {
85 error = EPERM;
86 goto fail;
87 }
88
89 return (tdev->tod_connect(tdev, so, rt, nam));
90fail:
91 RTFREE(rt);
92 return (error);
93}
94
95
96/*
97 * This file contains code as a short-term staging area before it is moved in
98 * to sys/netinet/tcp_offload.c
99 */
100
101void
102tcp_offload_twstart(struct tcpcb *tp)
103{
104
105 INP_INFO_WLOCK(&tcbinfo);
106 inp_wlock(tp->t_inpcb);
106 INP_WLOCK(tp->t_inpcb);
107 tcp_twstart(tp);
108 INP_INFO_WUNLOCK(&tcbinfo);
109}
110
107 tcp_twstart(tp);
108 INP_INFO_WUNLOCK(&tcbinfo);
109}
110
111void
112tcp_offload_twstart_disconnect(struct tcpcb *tp)
113{
114 struct socket *so;
115
116 INP_INFO_WLOCK(&tcbinfo);
117 inp_wlock(tp->t_inpcb);
118 so = tp->t_inpcb->inp_socket;
119 tcp_twstart(tp);
120 if (so)
121 soisdisconnected(so);
122 INP_INFO_WUNLOCK(&tcbinfo);
123}
124
125struct tcpcb *
126tcp_offload_close(struct tcpcb *tp)
127{
128
129 INP_INFO_WLOCK(&tcbinfo);
130 INP_WLOCK(tp->t_inpcb);
131 tp = tcp_close(tp);
132 INP_INFO_WUNLOCK(&tcbinfo);
133 if (tp)
134 INP_WUNLOCK(tp->t_inpcb);
135
136 return (tp);
137}
138
139struct tcpcb *
140tcp_offload_drop(struct tcpcb *tp, int error)
141{
142
143 INP_INFO_WLOCK(&tcbinfo);
144 INP_WLOCK(tp->t_inpcb);
145 tp = tcp_drop(tp, error);
146 INP_INFO_WUNLOCK(&tcbinfo);
147 if (tp)
148 INP_WUNLOCK(tp->t_inpcb);
149
150 return (tp);
151}
152
111struct tcpcb *
112tcp_offload_close(struct tcpcb *tp)
113{
114
115 INP_INFO_WLOCK(&tcbinfo);
116 INP_WLOCK(tp->t_inpcb);
117 tp = tcp_close(tp);
118 INP_INFO_WUNLOCK(&tcbinfo);
119 if (tp)
120 INP_WUNLOCK(tp->t_inpcb);
121
122 return (tp);
123}
124
125struct tcpcb *
126tcp_offload_drop(struct tcpcb *tp, int error)
127{
128
129 INP_INFO_WLOCK(&tcbinfo);
130 INP_WLOCK(tp->t_inpcb);
131 tp = tcp_drop(tp, error);
132 INP_INFO_WUNLOCK(&tcbinfo);
133 if (tp)
134 INP_WUNLOCK(tp->t_inpcb);
135
136 return (tp);
137}
138