Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright 2017-present Open Networking Foundation |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | #ifndef __PARSER__ |
| 18 | #define __PARSER__ |
| 19 | |
| 20 | #include "define.p4" |
| 21 | |
| 22 | parser FabricParser ( |
| 23 | packet_in packet, |
| 24 | out parsed_headers_t hdr, |
| 25 | inout fabric_metadata_t fabric_metadata, |
| 26 | inout standard_metadata_t standard_metadata) { |
Yi Tseng | 1d84267 | 2017-11-28 16:06:52 -0800 | [diff] [blame] | 27 | |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 28 | state start { |
| 29 | transition select(standard_metadata.ingress_port) { |
| 30 | CPU_PORT: parse_packet_out; |
| 31 | default: parse_ethernet; |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | state parse_packet_out { |
| 36 | packet.extract(hdr.packet_out); |
| 37 | transition parse_ethernet; |
| 38 | } |
| 39 | |
| 40 | state parse_ethernet { |
| 41 | packet.extract(hdr.ethernet); |
Yi Tseng | 1d84267 | 2017-11-28 16:06:52 -0800 | [diff] [blame] | 42 | fabric_metadata.original_ether_type = hdr.ethernet.ether_type; |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 43 | transition select(hdr.ethernet.ether_type){ |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 44 | ETHERTYPE_VLAN: parse_vlan_tag; |
| 45 | ETHERTYPE_MPLS: parse_mpls; |
| 46 | ETHERTYPE_ARP: parse_arp; |
| 47 | ETHERTYPE_IPV4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 48 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 49 | ETHERTYPE_IPV6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 50 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 51 | default: accept; |
| 52 | } |
| 53 | } |
| 54 | |
| 55 | state parse_vlan_tag { |
| 56 | packet.extract(hdr.vlan_tag); |
| 57 | transition select(hdr.vlan_tag.ether_type){ |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 58 | ETHERTYPE_ARP: parse_arp; |
| 59 | ETHERTYPE_IPV4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 60 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 61 | ETHERTYPE_IPV6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 62 | #endif // WITH_IPV6 |
Yi Tseng | bd46d05 | 2018-01-22 17:18:16 -0800 | [diff] [blame] | 63 | ETHERTYPE_MPLS: parse_mpls; |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 64 | default: accept; |
| 65 | } |
| 66 | } |
| 67 | |
| 68 | state parse_mpls { |
| 69 | packet.extract(hdr.mpls); |
Yi Tseng | c6844f5 | 2017-12-19 11:58:25 -0800 | [diff] [blame] | 70 | // There is only one MPLS label for this fabric. |
| 71 | // Assume header after MPLS header is IP/IPv6 |
| 72 | // Lookup first 4 bits for version |
Yi Tseng | 3d3956d | 2018-01-31 17:28:05 -0800 | [diff] [blame] | 73 | transition select(packet.lookahead<bit<IP_VER_LENGTH>>()) { |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 74 | //The packet should be either IPv4 or IPv6. |
| 75 | IP_VERSION_4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 76 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 77 | IP_VERSION_6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 78 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 79 | default: parse_ethernet; |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | state parse_ipv4 { |
| 84 | packet.extract(hdr.ipv4); |
| 85 | fabric_metadata.ip_proto = hdr.ipv4.protocol; |
| 86 | //Need header verification? |
| 87 | transition select(hdr.ipv4.protocol) { |
| 88 | PROTO_TCP: parse_tcp; |
| 89 | PROTO_UDP: parse_udp; |
| 90 | PROTO_ICMP: parse_icmp; |
| 91 | default: accept; |
| 92 | } |
| 93 | } |
| 94 | |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 95 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 96 | state parse_ipv6 { |
| 97 | packet.extract(hdr.ipv6); |
| 98 | fabric_metadata.ip_proto = hdr.ipv6.next_hdr; |
| 99 | transition select(hdr.ipv6.next_hdr) { |
| 100 | PROTO_TCP: parse_tcp; |
| 101 | PROTO_UDP: parse_udp; |
| 102 | PROTO_ICMPV6: parse_icmp; |
| 103 | default: accept; |
| 104 | } |
| 105 | } |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 106 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 107 | |
| 108 | state parse_arp { |
| 109 | packet.extract(hdr.arp); |
| 110 | transition accept; |
| 111 | } |
| 112 | |
| 113 | state parse_tcp { |
| 114 | packet.extract(hdr.tcp); |
| 115 | fabric_metadata.l4_src_port = hdr.tcp.src_port; |
| 116 | fabric_metadata.l4_dst_port = hdr.tcp.dst_port; |
| 117 | transition accept; |
| 118 | } |
| 119 | |
| 120 | state parse_udp { |
| 121 | packet.extract(hdr.udp); |
| 122 | fabric_metadata.l4_src_port = hdr.udp.src_port; |
| 123 | fabric_metadata.l4_dst_port = hdr.udp.dst_port; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 124 | #ifdef WITH_SPGW |
| 125 | transition select(hdr.udp.dst_port) { |
| 126 | UDP_PORT_GTPU: parse_gtpu; |
| 127 | default: accept; |
| 128 | } |
| 129 | #else |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 130 | transition accept; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 131 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 132 | } |
| 133 | |
| 134 | state parse_icmp { |
| 135 | packet.extract(hdr.icmp); |
| 136 | transition accept; |
| 137 | } |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 138 | |
| 139 | #ifdef WITH_SPGW |
| 140 | state parse_gtpu { |
| 141 | packet.extract(hdr.gtpu); |
| 142 | transition parse_ipv4_inner; |
| 143 | } |
| 144 | |
| 145 | state parse_ipv4_inner { |
Carmelo Cascone | b757dbc | 2018-01-25 17:53:17 -0800 | [diff] [blame] | 146 | packet.extract(hdr.gtpu_ipv4); |
| 147 | transition select(hdr.gtpu_ipv4.protocol) { |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 148 | PROTO_TCP: parse_tcp; |
| 149 | PROTO_UDP: parse_udp_inner; |
| 150 | PROTO_ICMP: parse_icmp; |
| 151 | default: accept; |
| 152 | } |
| 153 | } |
| 154 | |
| 155 | state parse_udp_inner { |
Carmelo Cascone | b757dbc | 2018-01-25 17:53:17 -0800 | [diff] [blame] | 156 | packet.extract(hdr.gtpu_udp); |
| 157 | fabric_metadata.l4_src_port = hdr.gtpu_udp.src_port; |
| 158 | fabric_metadata.l4_dst_port = hdr.gtpu_udp.dst_port; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 159 | transition accept; |
| 160 | } |
| 161 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 162 | } |
| 163 | |
| 164 | control FabricDeparser(packet_out packet, in parsed_headers_t hdr) { |
Yi Tseng | 3d3956d | 2018-01-31 17:28:05 -0800 | [diff] [blame] | 165 | apply { |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 166 | packet.emit(hdr.packet_in); |
| 167 | packet.emit(hdr.ethernet); |
| 168 | packet.emit(hdr.vlan_tag); |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 169 | packet.emit(hdr.mpls); |
| 170 | packet.emit(hdr.arp); |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 171 | #ifdef WITH_SPGW |
| 172 | packet.emit(hdr.gtpu_ipv4); |
| 173 | packet.emit(hdr.gtpu_udp); |
| 174 | packet.emit(hdr.gtpu); |
| 175 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 176 | packet.emit(hdr.ipv4); |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 177 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 178 | packet.emit(hdr.ipv6); |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 179 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 180 | packet.emit(hdr.tcp); |
| 181 | packet.emit(hdr.udp); |
Yi Tseng | f73a553 | 2017-11-17 15:58:57 -0800 | [diff] [blame] | 182 | packet.emit(hdr.icmp); |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 183 | } |
| 184 | } |
| 185 | |
| 186 | #endif |