* Repository reorganization for 2018 Spring P4 Developer Day. * Port tutorial exercises to P4Runtime with static controller (#156) * Switch VM to a minimal Ubuntu 16.04 desktop image * Add commands to install Protobuf Python bindings to user_bootstrap.sh * Implement P4Runtime static controller for use in exercises From the exercise perspective, the main difference is that control plane rules are now specified using JSON files instead of CLI commands. Such JSON files define rules that use the same name for tables, keys, etc. as in the P4Info file. All P4Runtime requests generated as part of the make run process are logged in the exercise's “logs” directory, making it easier for students to see the actual P4Runtime messages sent to the switch. Only the "basic" exercise has been ported to use P4Runtime. The "p4runtime" exercise has been updated to work with P4Runtime protocol changes. Known issues: - make run hangs in case of errors when running the P4Runtime controller (probably due to gRPC stream channel threads not terminated properly) - missing support for inserting table entries with default action (can specify in P4 program as a workaround) * Force install protobuf python module * Fixing Ctrl-C hang by shutdown switches * Moving gRPC error print to function for readability Unforuntately, if this gets moved out of the file, the process hangs. We'll need to figure out how why later. * Renaming ShutdownAllSwitches -> ShutdownAllSwitchConnections * Reverting counter index change * Porting the ECN exercise to use P4 Runtime Static Controller * updating the README in the ecn exercise to reflect the change in rule files * Allow set table default action in P4Runtime static controller * Fixed undefined match string when printing P4Runtime table entry * Updated basic_tunnel exercise to use P4Runtime controller. * Changed default action in the basic exercise's ipv4_lpm table to drop * Porting the MRI exercise to use P4runtime with static controller * Updating readme to reflect the change of controller for mri * Update calc exercise for P4Runtime static controller * Port source_routing to P4 Runtime static controller (#157) * Port Load Balance to P4 Runtime Static Controller (#158)
257 lines
7.8 KiB
Plaintext
257 lines
7.8 KiB
Plaintext
/* -*- P4_16 -*- */
|
|
|
|
/*
|
|
* P4 Calculator
|
|
*
|
|
* This program implements a simple protocol. It can be carried over Ethernet
|
|
* (Ethertype 0x1234).
|
|
*
|
|
* The Protocol header looks like this:
|
|
*
|
|
* 0 1 2 3
|
|
* +----------------+----------------+----------------+---------------+
|
|
* | P | 4 | Version | Op |
|
|
* +----------------+----------------+----------------+---------------+
|
|
* | Operand A |
|
|
* +----------------+----------------+----------------+---------------+
|
|
* | Operand B |
|
|
* +----------------+----------------+----------------+---------------+
|
|
* | Result |
|
|
* +----------------+----------------+----------------+---------------+
|
|
*
|
|
* P is an ASCII Letter 'P' (0x50)
|
|
* 4 is an ASCII Letter '4' (0x34)
|
|
* Version is currently 0.1 (0x01)
|
|
* Op is an operation to Perform:
|
|
* '+' (0x2b) Result = OperandA + OperandB
|
|
* '-' (0x2d) Result = OperandA - OperandB
|
|
* '&' (0x26) Result = OperandA & OperandB
|
|
* '|' (0x7c) Result = OperandA | OperandB
|
|
* '^' (0x5e) Result = OperandA ^ OperandB
|
|
*
|
|
* The device receives a packet, performs the requested operation, fills in the
|
|
* result and sends the packet back out of the same port it came in on, while
|
|
* swapping the source and destination addresses.
|
|
*
|
|
* If an unknown operation is specified or the header is not valid, the packet
|
|
* is dropped
|
|
*/
|
|
|
|
#include <core.p4>
|
|
#include <v1model.p4>
|
|
|
|
/*
|
|
* Define the headers the program will recognize
|
|
*/
|
|
|
|
/*
|
|
* Standard ethernet header
|
|
*/
|
|
header ethernet_t {
|
|
bit<48> dstAddr;
|
|
bit<48> srcAddr;
|
|
bit<16> etherType;
|
|
}
|
|
|
|
/*
|
|
* This is a custom protocol header for the calculator. We'll use
|
|
* ethertype 0x1234 for is (see parser)
|
|
*/
|
|
const bit<16> P4CALC_ETYPE = 0x1234;
|
|
const bit<8> P4CALC_P = 0x50; // 'P'
|
|
const bit<8> P4CALC_4 = 0x34; // '4'
|
|
const bit<8> P4CALC_VER = 0x01; // v0.1
|
|
const bit<8> P4CALC_PLUS = 0x2b; // '+'
|
|
const bit<8> P4CALC_MINUS = 0x2d; // '-'
|
|
const bit<8> P4CALC_AND = 0x26; // '&'
|
|
const bit<8> P4CALC_OR = 0x7c; // '|'
|
|
const bit<8> P4CALC_CARET = 0x5e; // '^'
|
|
|
|
header p4calc_t {
|
|
bit<8> p;
|
|
bit<8> four;
|
|
bit<8> ver;
|
|
bit<8> op;
|
|
bit<32> operand_a;
|
|
bit<32> operand_b;
|
|
bit<32> res;
|
|
}
|
|
|
|
/*
|
|
* All headers, used in the program needs to be assembed into a single struct.
|
|
* We only need to declare the type, but there is no need to instantiate it,
|
|
* because it is done "by the architecture", i.e. outside of P4 functions
|
|
*/
|
|
struct headers {
|
|
ethernet_t ethernet;
|
|
p4calc_t p4calc;
|
|
}
|
|
|
|
/*
|
|
* All metadata, globally used in the program, also needs to be assembed
|
|
* into a single struct. As in the case of the headers, we only need to
|
|
* declare the type, but there is no need to instantiate it,
|
|
* because it is done "by the architecture", i.e. outside of P4 functions
|
|
*/
|
|
|
|
struct metadata {
|
|
/* In our case it is empty */
|
|
}
|
|
|
|
/*************************************************************************
|
|
*********************** P A R S E R ***********************************
|
|
*************************************************************************/
|
|
parser MyParser(packet_in packet,
|
|
out headers hdr,
|
|
inout metadata meta,
|
|
inout standard_metadata_t standard_metadata) {
|
|
|
|
state start {
|
|
packet.extract(hdr.ethernet);
|
|
transition select(hdr.ethernet.etherType) {
|
|
P4CALC_ETYPE : check_p4calc;
|
|
default : accept;
|
|
}
|
|
}
|
|
|
|
state check_p4calc {
|
|
transition select(packet.lookahead<p4calc_t>().p,
|
|
packet.lookahead<p4calc_t>().four,
|
|
packet.lookahead<p4calc_t>().ver) {
|
|
(P4CALC_P, P4CALC_4, P4CALC_VER) : parse_p4calc;
|
|
default : accept;
|
|
}
|
|
}
|
|
|
|
state parse_p4calc {
|
|
packet.extract(hdr.p4calc);
|
|
transition accept;
|
|
}
|
|
}
|
|
|
|
/*************************************************************************
|
|
************ C H E C K S U M V E R I F I C A T I O N *************
|
|
*************************************************************************/
|
|
control MyVerifyChecksum(inout headers hdr,
|
|
inout metadata meta) {
|
|
apply { }
|
|
}
|
|
|
|
/*************************************************************************
|
|
************** I N G R E S S P R O C E S S I N G *******************
|
|
*************************************************************************/
|
|
control MyIngress(inout headers hdr,
|
|
inout metadata meta,
|
|
inout standard_metadata_t standard_metadata) {
|
|
|
|
action send_back(bit<32> result) {
|
|
bit<48> tmp;
|
|
|
|
/* Put the result back in */
|
|
hdr.p4calc.res = result;
|
|
|
|
/* Swap the MAC addresses */
|
|
tmp = hdr.ethernet.dstAddr;
|
|
hdr.ethernet.dstAddr = hdr.ethernet.srcAddr;
|
|
hdr.ethernet.srcAddr = tmp;
|
|
|
|
/* Send the packet back to the port it came from */
|
|
standard_metadata.egress_spec = standard_metadata.ingress_port;
|
|
}
|
|
|
|
action operation_add() {
|
|
send_back(hdr.p4calc.operand_a + hdr.p4calc.operand_b);
|
|
}
|
|
|
|
action operation_sub() {
|
|
send_back(hdr.p4calc.operand_a - hdr.p4calc.operand_b);
|
|
}
|
|
|
|
action operation_and() {
|
|
send_back(hdr.p4calc.operand_a & hdr.p4calc.operand_b);
|
|
}
|
|
|
|
action operation_or() {
|
|
send_back(hdr.p4calc.operand_a | hdr.p4calc.operand_b);
|
|
}
|
|
|
|
action operation_xor() {
|
|
send_back(hdr.p4calc.operand_a ^ hdr.p4calc.operand_b);
|
|
}
|
|
|
|
action operation_drop() {
|
|
mark_to_drop();
|
|
}
|
|
|
|
table calculate {
|
|
key = {
|
|
hdr.p4calc.op : exact;
|
|
}
|
|
actions = {
|
|
operation_add;
|
|
operation_sub;
|
|
operation_and;
|
|
operation_or;
|
|
operation_xor;
|
|
operation_drop;
|
|
}
|
|
const default_action = operation_drop();
|
|
const entries = {
|
|
P4CALC_PLUS : operation_add();
|
|
P4CALC_MINUS: operation_sub();
|
|
P4CALC_AND : operation_and();
|
|
P4CALC_OR : operation_or();
|
|
P4CALC_CARET: operation_xor();
|
|
}
|
|
}
|
|
|
|
|
|
apply {
|
|
if (hdr.p4calc.isValid()) {
|
|
calculate.apply();
|
|
} else {
|
|
operation_drop();
|
|
}
|
|
}
|
|
}
|
|
|
|
/*************************************************************************
|
|
**************** E G R E S S P R O C E S S I N G *******************
|
|
*************************************************************************/
|
|
control MyEgress(inout headers hdr,
|
|
inout metadata meta,
|
|
inout standard_metadata_t standard_metadata) {
|
|
apply { }
|
|
}
|
|
|
|
/*************************************************************************
|
|
************* C H E C K S U M C O M P U T A T I O N **************
|
|
*************************************************************************/
|
|
|
|
control MyComputeChecksum(inout headers hdr, inout metadata meta) {
|
|
apply { }
|
|
}
|
|
|
|
/*************************************************************************
|
|
*********************** D E P A R S E R *******************************
|
|
*************************************************************************/
|
|
control MyDeparser(packet_out packet, in headers hdr) {
|
|
apply {
|
|
packet.emit(hdr.ethernet);
|
|
packet.emit(hdr.p4calc);
|
|
}
|
|
}
|
|
|
|
/*************************************************************************
|
|
*********************** S W I T T C H **********************************
|
|
*************************************************************************/
|
|
|
|
V1Switch(
|
|
MyParser(),
|
|
MyVerifyChecksum(),
|
|
MyIngress(),
|
|
MyEgress(),
|
|
MyComputeChecksum(),
|
|
MyDeparser()
|
|
) main;
|