blob: 29537bf97284027c50c42ffaa4cb671f12fff2e0 [file] [log] [blame]
/*
* Copyright 2019-present Open Networking Foundation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/*
* BNG processor implementation. Provides upstream and downstream termination
* based on double VLAN tags (s_tag, c_tag) and PPPoE.
*
* This implementation is based on the P4 Service Edge (p4se) contribution from
* Deutsche Telekom:
* https://github.com/opencord/p4se
*/
#ifndef __BNG__
#define __BNG__
#define BNG_SUBSC_IPV6_NET_PREFIX_LEN 64
control bng_ingress_upstream(
inout parsed_headers_t hdr,
inout fabric_metadata_t fmeta,
inout standard_metadata_t smeta) {
counter(BNG_MAX_SUBSC, CounterType.bytes) c_terminated;
counter(BNG_MAX_SUBSC, CounterType.bytes) c_dropped;
counter(BNG_MAX_SUBSC, CounterType.packets) c_control;
// TABLE: t_pppoe_cp
// Punt to CPU for PPPeE control packets.
action punt_to_cpu() {
smeta.egress_spec = CPU_PORT;
// Clean the multicast group, otherwise multicast decision
// will override the punting to CPU action
smeta.mcast_grp = 0;
c_control.count(fmeta.bng.line_id);
}
table t_pppoe_cp {
key = {
hdr.pppoe.code : exact @name("pppoe_code");
hdr.pppoe.protocol : ternary @name("pppoe_protocol");
}
actions = {
punt_to_cpu;
@defaultonly nop;
}
size = 16;
const default_action = nop;
}
// TABLE: PPPoE termination for IPv4
// Check subscriber IPv4 source address, line_id, and pppoe_session_id
// (antispoofing), if line is enabled, pop PPPoE and double VLANs.
@hidden
action term_enabled(bit<16> eth_type) {
hdr.eth_type.value = eth_type;
hdr.pppoe.setInvalid();
c_terminated.count(fmeta.bng.line_id);
}
action term_disabled() {
fmeta.bng.type = BNG_TYPE_INVALID;
mark_to_drop(smeta);
}
action term_enabled_v4() {
term_enabled(ETHERTYPE_IPV4);
}
// TODO: add match on hdr.ethernet.src_addr for antispoofing
// Take into account that MAC src address is modified by the Next control block
// when doing routing functionality.
table t_pppoe_term_v4 {
key = {
fmeta.bng.line_id : exact @name("line_id");
hdr.ipv4.src_addr : exact @name("ipv4_src");
hdr.pppoe.session_id : exact @name("pppoe_session_id");
}
actions = {
term_enabled_v4;
@defaultonly term_disabled;
}
size = BNG_MAX_SUBSC_NET;
const default_action = term_disabled;
}
#ifdef WITH_IPV6
action term_enabled_v6() {
term_enabled(ETHERTYPE_IPV6);
}
// TODO: add match on hdr.ethernet.src_addr for antispoofing
// Match on unmodified metadata field, taking into account that MAC src address
// is modified by the Next control block when doing routing functionality.
table t_pppoe_term_v6 {
key = {
fmeta.bng.line_id : exact @name("line_id");
hdr.ipv6.src_addr[127:64] : exact @name("ipv6_src_net_id");
hdr.pppoe.session_id : exact @name("pppoe_session_id");
}
actions = {
term_enabled_v6;
@defaultonly term_disabled;
}
size = BNG_MAX_SUBSC_NET;
const default_action = term_disabled;
}
#endif // WITH_IPV6
apply {
if(t_pppoe_cp.apply().hit) {
return;
}
if (hdr.ipv4.isValid()) {
switch(t_pppoe_term_v4.apply().action_run) {
term_disabled: {
c_dropped.count(fmeta.bng.line_id);
}
}
}
#ifdef WITH_IPV6
else if (hdr.ipv6.isValid()) {
switch(t_pppoe_term_v6.apply().action_run) {
term_disabled: {
c_dropped.count(fmeta.bng.line_id);
}
}
}
#endif // WITH_IPV6
}
}
control bng_ingress_downstream(
inout parsed_headers_t hdr,
inout fabric_metadata_t fmeta,
inout standard_metadata_t smeta) {
counter(BNG_MAX_SUBSC, CounterType.bytes) c_line_rx;
meter(BNG_MAX_SUBSC, MeterType.bytes) m_besteff;
meter(BNG_MAX_SUBSC, MeterType.bytes) m_prio;
action set_session(bit<16> pppoe_session_id) {
fmeta.bng.type = BNG_TYPE_DOWNSTREAM;
fmeta.bng.pppoe_session_id = pppoe_session_id;
c_line_rx.count(fmeta.bng.line_id);
}
action drop() {
fmeta.bng.type = BNG_TYPE_DOWNSTREAM;
c_line_rx.count(fmeta.bng.line_id);
mark_to_drop(smeta);
}
table t_line_session_map {
key = {
fmeta.bng.line_id : exact @name("line_id");
}
actions = {
@defaultonly nop;
set_session;
drop;
}
size = BNG_MAX_SUBSC;
const default_action = nop;
}
// Downstream QoS tables.
// Provide coarse metering before prioritazion in the OLT. By default
// everything is tagged and metered as best-effort traffic.
action qos_prio() {
// no-op
}
action qos_besteff() {
// no-op
}
table t_qos_v4 {
key = {
fmeta.bng.line_id : ternary @name("line_id");
hdr.ipv4.src_addr : lpm @name("ipv4_src");
hdr.ipv4.dscp : ternary @name("ipv4_dscp");
hdr.ipv4.ecn : ternary @name("ipv4_ecn");
}
actions = {
qos_prio;
qos_besteff;
}
size = 256;
const default_action = qos_besteff;
}
#ifdef WITH_IPV6
table t_qos_v6 {
key = {
fmeta.bng.line_id : ternary @name("line_id");
hdr.ipv6.src_addr : lpm @name("ipv6_src");
hdr.ipv6.traffic_class : ternary @name("ipv6_traffic_class");
}
actions = {
qos_prio;
qos_besteff;
}
size = 256;
const default_action = qos_besteff;
}
#endif // WITH_IPV6
apply {
// We are not sure the pkt is a BNG downstream one, first we need to
// verify the line_id matches the one of a subscriber...
// IPv4
if (t_line_session_map.apply().hit) {
// Apply QoS only to subscriber traffic. This makes sense only
// if the downstream ports are used to receive IP traffic NOT
// destined to subscribers, e.g. to services in the compute
// nodes.
if (hdr.ipv4.isValid()) {
switch (t_qos_v4.apply().action_run) {
qos_prio: {
m_prio.execute_meter(fmeta.bng.line_id, fmeta.bng.ds_meter_result);
}
qos_besteff: {
m_besteff.execute_meter(fmeta.bng.line_id, fmeta.bng.ds_meter_result);
}
}
}
#ifdef WITH_IPV6
// IPv6
else if (hdr.ipv6.isValid()) {
switch (t_qos_v6.apply().action_run) {
qos_prio: {
m_prio.execute_meter(fmeta.bng.line_id, fmeta.bng.ds_meter_result);
}
qos_besteff: {
m_besteff.execute_meter(fmeta.bng.line_id, fmeta.bng.ds_meter_result);
}
}
}
#endif // WITH_IPV6
}
}
}
control bng_egress_downstream(
inout parsed_headers_t hdr,
inout fabric_metadata_t fmeta,
inout standard_metadata_t smeta) {
counter(BNG_MAX_SUBSC, CounterType.bytes) c_line_tx;
@hidden
action encap() {
// Here we add PPPoE and modify the Ethernet Type.
hdr.eth_type.value = ETHERTYPE_PPPOES;
hdr.pppoe.setValid();
hdr.pppoe.version = 4w1;
hdr.pppoe.type_id = 4w1;
hdr.pppoe.code = 8w0; // 0 means session stage.
hdr.pppoe.session_id = fmeta.bng.pppoe_session_id;
c_line_tx.count(fmeta.bng.line_id);
}
action encap_v4() {
encap();
hdr.pppoe.length = hdr.ipv4.total_len + 16w2;
hdr.pppoe.protocol = PPPOE_PROTOCOL_IP4;
}
#ifdef WITH_IPV6
action encap_v6() {
encap();
hdr.pppoe.length = hdr.ipv6.payload_len + 16w42;
hdr.pppoe.protocol = PPPOE_PROTOCOL_IP6;
}
#endif // WITH_IPV6
apply {
if (hdr.ipv4.isValid()) {
encap_v4();
}
#ifdef WITH_IPV6
// IPv6
else if (hdr.ipv6.isValid()) {
encap_v6();
}
#endif // WITH_IPV6
}
}
control bng_ingress(
inout parsed_headers_t hdr,
inout fabric_metadata_t fmeta,
inout standard_metadata_t smeta) {
bng_ingress_upstream() upstream;
bng_ingress_downstream() downstream;
// TABLE: t_line_map
// Map s_tag and c_tag to a line ID to uniquely identify a subscriber
action set_line(bit<32> line_id) {
fmeta.bng.line_id = line_id;
}
table t_line_map {
key = {
fmeta.bng.s_tag : exact @name("s_tag");
fmeta.bng.c_tag : exact @name("c_tag");
}
actions = {
set_line;
}
size = BNG_MAX_SUBSC;
// By default set the line ID to 0
const default_action = set_line(0);
}
apply {
// First map the double VLAN tags to a line ID
// If table miss line ID will be 0.
t_line_map.apply();
if (hdr.pppoe.isValid()) {
fmeta.bng.type = BNG_TYPE_UPSTREAM;
upstream.apply(hdr, fmeta, smeta);
} else {
downstream.apply(hdr, fmeta, smeta);
}
}
}
control bng_egress(
inout parsed_headers_t hdr,
inout fabric_metadata_t fmeta,
inout standard_metadata_t smeta) {
bng_egress_downstream() downstream;
apply {
if (fmeta.bng.type == BNG_TYPE_DOWNSTREAM) {
downstream.apply(hdr, fmeta, smeta);
}
}
}
#endif