ieee8023ad_marker.c revision 1.1.6.2 1 1.1.6.2 kent /* $NetBSD: ieee8023ad_marker.c,v 1.1.6.2 2005/04/29 11:29:32 kent Exp $ */
2 1.1.6.2 kent
3 1.1.6.2 kent /*-
4 1.1.6.2 kent * Copyright (c)2005 YAMAMOTO Takashi,
5 1.1.6.2 kent * All rights reserved.
6 1.1.6.2 kent *
7 1.1.6.2 kent * Redistribution and use in source and binary forms, with or without
8 1.1.6.2 kent * modification, are permitted provided that the following conditions
9 1.1.6.2 kent * are met:
10 1.1.6.2 kent * 1. Redistributions of source code must retain the above copyright
11 1.1.6.2 kent * notice, this list of conditions and the following disclaimer.
12 1.1.6.2 kent * 2. Redistributions in binary form must reproduce the above copyright
13 1.1.6.2 kent * notice, this list of conditions and the following disclaimer in the
14 1.1.6.2 kent * documentation and/or other materials provided with the distribution.
15 1.1.6.2 kent *
16 1.1.6.2 kent * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 1.1.6.2 kent * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 1.1.6.2 kent * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 1.1.6.2 kent * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 1.1.6.2 kent * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 1.1.6.2 kent * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 1.1.6.2 kent * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 1.1.6.2 kent * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 1.1.6.2 kent * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 1.1.6.2 kent * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 1.1.6.2 kent * SUCH DAMAGE.
27 1.1.6.2 kent */
28 1.1.6.2 kent
29 1.1.6.2 kent #include <sys/cdefs.h>
30 1.1.6.2 kent __KERNEL_RCSID(0, "$NetBSD: ieee8023ad_marker.c,v 1.1.6.2 2005/04/29 11:29:32 kent Exp $");
31 1.1.6.2 kent
32 1.1.6.2 kent #include <sys/param.h>
33 1.1.6.2 kent #include <sys/mbuf.h>
34 1.1.6.2 kent #include <sys/systm.h>
35 1.1.6.2 kent
36 1.1.6.2 kent #include <net/if.h>
37 1.1.6.2 kent #include <net/if_ether.h>
38 1.1.6.2 kent
39 1.1.6.2 kent #include <net/agr/if_agrvar_impl.h>
40 1.1.6.2 kent #include <net/agr/ieee8023_slowprotocols.h>
41 1.1.6.2 kent #include <net/agr/ieee8023_tlv.h>
42 1.1.6.2 kent #include <net/agr/ieee8023ad.h>
43 1.1.6.2 kent #include <net/agr/ieee8023ad_marker.h>
44 1.1.6.2 kent
45 1.1.6.2 kent static const struct tlv_template marker_info_tlv_template[] = {
46 1.1.6.2 kent { MARKER_TYPE_INFO, 16 },
47 1.1.6.2 kent { 0, 0 },
48 1.1.6.2 kent };
49 1.1.6.2 kent
50 1.1.6.2 kent static const struct tlv_template marker_response_tlv_template[] = {
51 1.1.6.2 kent { MARKER_TYPE_RESPONSE, 16 },
52 1.1.6.2 kent { 0, 0 },
53 1.1.6.2 kent };
54 1.1.6.2 kent
55 1.1.6.2 kent int
56 1.1.6.2 kent ieee8023ad_marker_input(struct ifnet *ifp, struct mbuf *m)
57 1.1.6.2 kent {
58 1.1.6.2 kent struct markerdu *mdu;
59 1.1.6.2 kent struct agr_port *port;
60 1.1.6.2 kent int error = 0;
61 1.1.6.2 kent
62 1.1.6.2 kent port = ifp->if_agrprivate; /* XXX race with agr_remport. */
63 1.1.6.2 kent KASSERT(port);
64 1.1.6.2 kent if (__predict_false(port->port_flags & AGRPORT_DETACHING)) {
65 1.1.6.2 kent goto bad;
66 1.1.6.2 kent }
67 1.1.6.2 kent
68 1.1.6.2 kent if (m->m_pkthdr.len != sizeof(*mdu)) {
69 1.1.6.2 kent goto bad;
70 1.1.6.2 kent }
71 1.1.6.2 kent
72 1.1.6.2 kent if ((m->m_flags & M_MCAST) == 0) {
73 1.1.6.2 kent goto bad;
74 1.1.6.2 kent }
75 1.1.6.2 kent
76 1.1.6.2 kent if (m->m_len < sizeof(*mdu)) {
77 1.1.6.2 kent m = m_pullup(m, sizeof(*mdu));
78 1.1.6.2 kent if (m == NULL) {
79 1.1.6.2 kent return ENOMEM;
80 1.1.6.2 kent }
81 1.1.6.2 kent }
82 1.1.6.2 kent
83 1.1.6.2 kent mdu = mtod(m, struct markerdu *);
84 1.1.6.2 kent
85 1.1.6.2 kent if (memcmp(&mdu->mdu_eh.ether_dhost,
86 1.1.6.2 kent ðermulticastaddr_slowprotocols, ETHER_ADDR_LEN)) {
87 1.1.6.2 kent goto bad;
88 1.1.6.2 kent }
89 1.1.6.2 kent
90 1.1.6.2 kent KASSERT(mdu->mdu_sph.sph_subtype == SLOWPROTOCOLS_SUBTYPE_MARKER);
91 1.1.6.2 kent if (mdu->mdu_sph.sph_version != 1) {
92 1.1.6.2 kent goto bad;
93 1.1.6.2 kent }
94 1.1.6.2 kent
95 1.1.6.2 kent switch (mdu->mdu_tlv.tlv_type) {
96 1.1.6.2 kent case MARKER_TYPE_INFO:
97 1.1.6.2 kent if (tlv_check(mdu, sizeof(*mdu), &mdu->mdu_tlv,
98 1.1.6.2 kent marker_info_tlv_template, TRUE)) {
99 1.1.6.2 kent goto bad;
100 1.1.6.2 kent }
101 1.1.6.2 kent mdu->mdu_tlv.tlv_type = MARKER_TYPE_RESPONSE;
102 1.1.6.2 kent memcpy(&mdu->mdu_eh.ether_dhost,
103 1.1.6.2 kent ðermulticastaddr_slowprotocols, ETHER_ADDR_LEN);
104 1.1.6.2 kent memcpy(&mdu->mdu_eh.ether_shost,
105 1.1.6.2 kent &port->port_origlladdr, ETHER_ADDR_LEN);
106 1.1.6.2 kent error = agr_xmit_frame(ifp, m);
107 1.1.6.2 kent break;
108 1.1.6.2 kent
109 1.1.6.2 kent case MARKER_TYPE_RESPONSE:
110 1.1.6.2 kent if (tlv_check(mdu, sizeof(*mdu), &mdu->mdu_tlv,
111 1.1.6.2 kent marker_response_tlv_template, TRUE)) {
112 1.1.6.2 kent goto bad;
113 1.1.6.2 kent }
114 1.1.6.2 kent /*
115 1.1.6.2 kent * we are not interested in responses as
116 1.1.6.2 kent * we don't have a marker sender.
117 1.1.6.2 kent */
118 1.1.6.2 kent /* FALLTHROUGH */
119 1.1.6.2 kent default:
120 1.1.6.2 kent goto bad;
121 1.1.6.2 kent }
122 1.1.6.2 kent
123 1.1.6.2 kent return error;
124 1.1.6.2 kent
125 1.1.6.2 kent bad:
126 1.1.6.2 kent m_freem(m);
127 1.1.6.2 kent return EINVAL;
128 1.1.6.2 kent }
129