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); |
| 42 | transition select(hdr.ethernet.ether_type){ |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 43 | ETHERTYPE_VLAN: parse_vlan_tag; |
| 44 | ETHERTYPE_MPLS: parse_mpls; |
| 45 | ETHERTYPE_ARP: parse_arp; |
| 46 | ETHERTYPE_IPV4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 47 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 48 | ETHERTYPE_IPV6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 49 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 50 | default: accept; |
| 51 | } |
| 52 | } |
| 53 | |
| 54 | state parse_vlan_tag { |
| 55 | packet.extract(hdr.vlan_tag); |
| 56 | transition select(hdr.vlan_tag.ether_type){ |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 57 | ETHERTYPE_ARP: parse_arp; |
| 58 | ETHERTYPE_IPV4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 59 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 60 | ETHERTYPE_IPV6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 61 | #endif // WITH_IPV6 |
Yi Tseng | bd46d05 | 2018-01-22 17:18:16 -0800 | [diff] [blame] | 62 | ETHERTYPE_MPLS: parse_mpls; |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 63 | default: accept; |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | state parse_mpls { |
| 68 | packet.extract(hdr.mpls); |
Yi Tseng | c6844f5 | 2017-12-19 11:58:25 -0800 | [diff] [blame] | 69 | // There is only one MPLS label for this fabric. |
| 70 | // Assume header after MPLS header is IP/IPv6 |
| 71 | // Lookup first 4 bits for version |
Yi Tseng | 3d3956d | 2018-01-31 17:28:05 -0800 | [diff] [blame] | 72 | transition select(packet.lookahead<bit<IP_VER_LENGTH>>()) { |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 73 | //The packet should be either IPv4 or IPv6. |
| 74 | IP_VERSION_4: parse_ipv4; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 75 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 76 | IP_VERSION_6: parse_ipv6; |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 77 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 78 | default: parse_ethernet; |
| 79 | } |
| 80 | } |
| 81 | |
| 82 | state parse_ipv4 { |
| 83 | packet.extract(hdr.ipv4); |
| 84 | fabric_metadata.ip_proto = hdr.ipv4.protocol; |
| 85 | //Need header verification? |
| 86 | transition select(hdr.ipv4.protocol) { |
| 87 | PROTO_TCP: parse_tcp; |
| 88 | PROTO_UDP: parse_udp; |
| 89 | PROTO_ICMP: parse_icmp; |
| 90 | default: accept; |
| 91 | } |
| 92 | } |
| 93 | |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 94 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 95 | state parse_ipv6 { |
| 96 | packet.extract(hdr.ipv6); |
| 97 | fabric_metadata.ip_proto = hdr.ipv6.next_hdr; |
| 98 | transition select(hdr.ipv6.next_hdr) { |
| 99 | PROTO_TCP: parse_tcp; |
| 100 | PROTO_UDP: parse_udp; |
| 101 | PROTO_ICMPV6: parse_icmp; |
| 102 | default: accept; |
| 103 | } |
| 104 | } |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 105 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 106 | |
| 107 | state parse_arp { |
| 108 | packet.extract(hdr.arp); |
| 109 | transition accept; |
| 110 | } |
| 111 | |
| 112 | state parse_tcp { |
| 113 | packet.extract(hdr.tcp); |
| 114 | fabric_metadata.l4_src_port = hdr.tcp.src_port; |
| 115 | fabric_metadata.l4_dst_port = hdr.tcp.dst_port; |
| 116 | transition accept; |
| 117 | } |
| 118 | |
| 119 | state parse_udp { |
| 120 | packet.extract(hdr.udp); |
| 121 | fabric_metadata.l4_src_port = hdr.udp.src_port; |
| 122 | fabric_metadata.l4_dst_port = hdr.udp.dst_port; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 123 | #ifdef WITH_SPGW |
| 124 | transition select(hdr.udp.dst_port) { |
| 125 | UDP_PORT_GTPU: parse_gtpu; |
| 126 | default: accept; |
| 127 | } |
| 128 | #else |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 129 | transition accept; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 130 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 131 | } |
| 132 | |
| 133 | state parse_icmp { |
| 134 | packet.extract(hdr.icmp); |
| 135 | transition accept; |
| 136 | } |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 137 | |
| 138 | #ifdef WITH_SPGW |
| 139 | state parse_gtpu { |
| 140 | packet.extract(hdr.gtpu); |
| 141 | transition parse_ipv4_inner; |
| 142 | } |
| 143 | |
| 144 | state parse_ipv4_inner { |
Carmelo Cascone | b757dbc | 2018-01-25 17:53:17 -0800 | [diff] [blame] | 145 | packet.extract(hdr.gtpu_ipv4); |
| 146 | transition select(hdr.gtpu_ipv4.protocol) { |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 147 | PROTO_TCP: parse_tcp; |
| 148 | PROTO_UDP: parse_udp_inner; |
| 149 | PROTO_ICMP: parse_icmp; |
| 150 | default: accept; |
| 151 | } |
| 152 | } |
| 153 | |
| 154 | state parse_udp_inner { |
Carmelo Cascone | b757dbc | 2018-01-25 17:53:17 -0800 | [diff] [blame] | 155 | packet.extract(hdr.gtpu_udp); |
| 156 | fabric_metadata.l4_src_port = hdr.gtpu_udp.src_port; |
| 157 | fabric_metadata.l4_dst_port = hdr.gtpu_udp.dst_port; |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 158 | transition accept; |
| 159 | } |
| 160 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 161 | } |
| 162 | |
| 163 | control FabricDeparser(packet_out packet, in parsed_headers_t hdr) { |
Yi Tseng | 3d3956d | 2018-01-31 17:28:05 -0800 | [diff] [blame] | 164 | apply { |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 165 | packet.emit(hdr.packet_in); |
| 166 | packet.emit(hdr.ethernet); |
| 167 | packet.emit(hdr.vlan_tag); |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 168 | packet.emit(hdr.mpls); |
| 169 | packet.emit(hdr.arp); |
Carmelo Cascone | b81f4be | 2018-01-16 23:24:01 -0800 | [diff] [blame] | 170 | #ifdef WITH_SPGW |
| 171 | packet.emit(hdr.gtpu_ipv4); |
| 172 | packet.emit(hdr.gtpu_udp); |
| 173 | packet.emit(hdr.gtpu); |
| 174 | #endif // WITH_SPGW |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 175 | packet.emit(hdr.ipv4); |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 176 | #ifdef WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 177 | packet.emit(hdr.ipv6); |
Carmelo Cascone | ed88f2b | 2018-01-26 17:36:34 -0800 | [diff] [blame] | 178 | #endif // WITH_IPV6 |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 179 | packet.emit(hdr.tcp); |
| 180 | packet.emit(hdr.udp); |
Yi Tseng | f73a553 | 2017-11-17 15:58:57 -0800 | [diff] [blame] | 181 | packet.emit(hdr.icmp); |
Yi Tseng | be34205 | 2017-11-03 10:21:23 -0700 | [diff] [blame] | 182 | } |
| 183 | } |
| 184 | |
| 185 | #endif |