blob: f4a7689456d4ea60f28b5e4fe96a3ceedfb5f04f [file] [log] [blame]
Yi Tsengbe342052017-11-03 10:21:23 -07001/*
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#include <core.p4>
18#include <v1model.p4>
19
Carmelo Cascone70e816b2019-03-19 16:15:47 -070020#include "include/size.p4"
Yi Tsengbe342052017-11-03 10:21:23 -070021#include "include/control/filtering.p4"
22#include "include/control/forwarding.p4"
Carmelo Casconeb5324e72018-11-25 02:26:32 -080023#include "include/control/acl.p4"
Yi Tsengbe342052017-11-03 10:21:23 -070024#include "include/control/next.p4"
25#include "include/control/packetio.p4"
Yi Tsengbe342052017-11-03 10:21:23 -070026#include "include/header.p4"
27#include "include/checksum.p4"
28#include "include/parser.p4"
29
Carmelo Cascone0c8d73e2018-09-07 16:31:06 -070030#ifdef WITH_PORT_COUNTER
31#include "include/control/port_counter.p4"
32#endif // WITH_PORT_COUNTER
33
Carmelo Casconeb81f4be2018-01-16 23:24:01 -080034#ifdef WITH_SPGW
35#include "include/spgw.p4"
36#endif // WITH_SPGW
37
Jonghwan Hyuned478dc2018-08-06 15:35:18 +090038#ifdef WITH_INT
Carmelo Cascone79a3a312018-08-16 17:14:43 -070039#include "include/int/int_main.p4"
Jonghwan Hyuned478dc2018-08-06 15:35:18 +090040#endif // WITH_INT
41
Carmelo Casconeb5324e72018-11-25 02:26:32 -080042control FabricIngress (inout parsed_headers_t hdr,
43 inout fabric_metadata_t fabric_metadata,
44 inout standard_metadata_t standard_metadata) {
45
Carmelo Cascone8d2d1b22018-08-27 18:33:53 -070046 PacketIoIngress() pkt_io_ingress;
Yi Tsengbe342052017-11-03 10:21:23 -070047 Filtering() filtering;
48 Forwarding() forwarding;
Carmelo Casconeb5324e72018-11-25 02:26:32 -080049 Acl() acl;
Yi Tsengbe342052017-11-03 10:21:23 -070050 Next() next;
Carmelo Cascone0c8d73e2018-09-07 16:31:06 -070051#ifdef WITH_PORT_COUNTER
Yi Tsengbe342052017-11-03 10:21:23 -070052 PortCountersControl() port_counters_control;
Carmelo Cascone0c8d73e2018-09-07 16:31:06 -070053#endif // WITH_PORT_COUNTER
Yi Tsengbe342052017-11-03 10:21:23 -070054
55 apply {
Carmelo Casconefa421582018-09-13 10:05:57 -070056 _PRE_INGRESS
Carmelo Cascone9b0171b2018-08-14 01:43:57 -070057#ifdef WITH_SPGW
58 spgw_normalizer.apply(hdr.gtpu.isValid(), hdr.gtpu_ipv4, hdr.gtpu_udp,
59 hdr.ipv4, hdr.udp, hdr.inner_ipv4, hdr.inner_udp);
60#endif // WITH_SPGW
Carmelo Cascone8d2d1b22018-08-27 18:33:53 -070061 pkt_io_ingress.apply(hdr, fabric_metadata, standard_metadata);
Yi Tsengbe342052017-11-03 10:21:23 -070062 filtering.apply(hdr, fabric_metadata, standard_metadata);
Carmelo Casconeb5324e72018-11-25 02:26:32 -080063#ifdef WITH_SPGW
64 spgw_ingress.apply(hdr.gtpu_ipv4, hdr.gtpu_udp, hdr.gtpu,
65 hdr.ipv4, hdr.udp, fabric_metadata);
66#endif // WITH_SPGW
67 if (fabric_metadata.skip_forwarding == _FALSE) {
68 forwarding.apply(hdr, fabric_metadata, standard_metadata);
69 }
70 acl.apply(hdr, fabric_metadata, standard_metadata);
71 if (fabric_metadata.skip_next == _FALSE) {
72 next.apply(hdr, fabric_metadata, standard_metadata);
Carmelo Cascone0c8d73e2018-09-07 16:31:06 -070073#ifdef WITH_PORT_COUNTER
Carmelo Casconeb5324e72018-11-25 02:26:32 -080074 // FIXME: we're not counting pkts punted to cpu or forwarded via
75 // multicast groups. Remove when gNMI support will be there.
76 port_counters_control.apply(hdr, fabric_metadata, standard_metadata);
Carmelo Cascone0c8d73e2018-09-07 16:31:06 -070077#endif // WITH_PORT_COUNTER
Carmelo Cascone79a3a312018-08-16 17:14:43 -070078#if defined(WITH_INT_SOURCE) || defined(WITH_INT_SINK)
Carmelo Casconeb5324e72018-11-25 02:26:32 -080079 process_set_source_sink.apply(hdr, fabric_metadata, standard_metadata);
Jonghwan Hyuned478dc2018-08-06 15:35:18 +090080#endif
Carmelo Casconeb5324e72018-11-25 02:26:32 -080081 }
Yi Tsengbe342052017-11-03 10:21:23 -070082 }
83}
84
85control FabricEgress (inout parsed_headers_t hdr,
86 inout fabric_metadata_t fabric_metadata,
87 inout standard_metadata_t standard_metadata) {
Carmelo Casconeb5324e72018-11-25 02:26:32 -080088
Yi Tseng1d842672017-11-28 16:06:52 -080089 PacketIoEgress() pkt_io_egress;
Yi Tseng20f9e7b2018-05-24 23:27:39 +080090 EgressNextControl() egress_next;
91
Yi Tsengbe342052017-11-03 10:21:23 -070092 apply {
Carmelo Casconefa421582018-09-13 10:05:57 -070093 _PRE_EGRESS
Yi Tseng1d842672017-11-28 16:06:52 -080094 pkt_io_egress.apply(hdr, fabric_metadata, standard_metadata);
Carmelo Cascone8d2d1b22018-08-27 18:33:53 -070095 egress_next.apply(hdr, fabric_metadata, standard_metadata);
Carmelo Casconeb81f4be2018-01-16 23:24:01 -080096#ifdef WITH_SPGW
Carmelo Cascone33e85c02018-02-01 13:30:18 -080097 spgw_egress.apply(hdr.ipv4, hdr.gtpu_ipv4, hdr.gtpu_udp, hdr.gtpu,
Carmelo Casconeb5324e72018-11-25 02:26:32 -080098 fabric_metadata, standard_metadata);
Carmelo Casconeb81f4be2018-01-16 23:24:01 -080099#endif // WITH_SPGW
Jonghwan Hyuned478dc2018-08-06 15:35:18 +0900100#ifdef WITH_INT
Carmelo Cascone79a3a312018-08-16 17:14:43 -0700101 process_int_main.apply(hdr, fabric_metadata, standard_metadata);
Jonghwan Hyuned478dc2018-08-06 15:35:18 +0900102#endif
Yi Tsengbe342052017-11-03 10:21:23 -0700103 }
104}
105
106V1Switch(
107 FabricParser(),
108 FabricVerifyChecksum(),
109 FabricIngress(),
110 FabricEgress(),
111 FabricComputeChecksum(),
112 FabricDeparser()
113) main;