X-Git-Url: https://git.tcpdump.org/tcpdump/blobdiff_plain/fd35562d7e7153a339fdcdd02408f877e34a49fb..e6eab7bccfbf8fe9c386e16a9c5441e7a57066ae:/print-openflow.c diff --git a/print-openflow.c b/print-openflow.c index 2a702dd0..63666336 100644 --- a/print-openflow.c +++ b/print-openflow.c @@ -30,49 +30,74 @@ * POSSIBILITY OF SUCH DAMAGE. */ +/* \summary: version-independent OpenFlow printer */ + #ifdef HAVE_CONFIG_H -#include "config.h" +#include #endif -#include +#include "netdissect-stdinc.h" -#include "interface.h" +#include "netdissect.h" #include "extract.h" +#include "openflow.h" +#include "oui.h" + -#define OF_HEADER_LEN 8 #define OF_VER_1_0 0x01 +const struct tok onf_exp_str[] = { + { ONF_EXP_ONF, "ONF Extensions" }, + { ONF_EXP_BUTE, "Budapest University of Technology and Economics" }, + { ONF_EXP_NOVIFLOW, "NoviFlow" }, + { ONF_EXP_L3, "L3+ Extensions, Vendor Neutral" }, + { ONF_EXP_L4L7, "L4-L7 Extensions" }, + { ONF_EXP_WMOB, "Wireless and Mobility Extensions" }, + { ONF_EXP_FABS, "Forwarding Abstractions Extensions" }, + { ONF_EXP_OTRANS, "Optical Transport Extensions" }, + { 0, NULL } +}; + +const char * +of_vendor_name(const uint32_t vendor) +{ + const struct tok *table = (vendor & 0xff000000) == 0 ? oui_values : onf_exp_str; + return tok2str(table, "unknown", vendor); +} + static void -of_header_print(const uint8_t version, const uint8_t type, - const uint16_t length, const uint32_t xid) { - printf("\n\tversion unknown (0x%02x), type 0x%02x, length %u, xid 0x%08x", +of_header_print(netdissect_options *ndo, const uint8_t version, const uint8_t type, + const uint16_t length, const uint32_t xid) +{ + ND_PRINT("\n\tversion unknown (0x%02x), type 0x%02x, length %u, xid 0x%08x", version, type, length, xid); } /* Print a single OpenFlow message. */ static const u_char * -of_header_body_print(const u_char *cp, const u_char *ep) { +of_header_body_print(netdissect_options *ndo, const u_char *cp, const u_char *ep) +{ uint8_t version, type; uint16_t length; uint32_t xid; if (ep < cp + OF_HEADER_LEN) - goto corrupt; + goto invalid; /* version */ - TCHECK2(*cp, 1); - version = *cp; + ND_TCHECK_1(cp); + version = GET_U_1(cp); cp += 1; /* type */ - TCHECK2(*cp, 1); - type = *cp; + ND_TCHECK_1(cp); + type = GET_U_1(cp); cp += 1; /* length */ - TCHECK2(*cp, 2); - length = EXTRACT_16BITS(cp); + ND_TCHECK_2(cp); + length = GET_BE_U_2(cp); cp += 2; /* xid */ - TCHECK2(*cp, 4); - xid = EXTRACT_32BITS(cp); + ND_TCHECK_4(cp); + xid = GET_BE_U_4(cp); cp += 4; /* Message length includes the header length and a message always includes * the basic header. A message length underrun fails decoding of the rest of @@ -80,36 +105,36 @@ of_header_body_print(const u_char *cp, const u_char *ep) { * message as possible even when it does not end within the current TCP * segment. */ if (length < OF_HEADER_LEN) { - of_header_print(version, type, length, xid); - goto corrupt; + of_header_print(ndo, version, type, length, xid); + goto invalid; } /* Decode known protocol versions further without printing the header (the * type decoding is version-specific. */ switch (version) { case OF_VER_1_0: - return of10_header_body_print(cp, ep, type, length, xid); + return of10_header_body_print(ndo, cp, ep, type, length, xid); default: - of_header_print(version, type, length, xid); - TCHECK2(*cp, length - OF_HEADER_LEN); + of_header_print(ndo, version, type, length, xid); + ND_TCHECK_LEN(cp, length - OF_HEADER_LEN); return cp + length - OF_HEADER_LEN; /* done with current message */ } -corrupt: /* fail current packet */ - printf(" (corrupt)"); - TCHECK2(*cp, ep - cp); +invalid: /* fail current packet */ + nd_print_invalid(ndo); + ND_TCHECK_LEN(cp, ep - cp); return ep; trunc: - printf(" [|openflow]"); + nd_print_trunc(ndo); return ep; } /* Print a TCP segment worth of OpenFlow messages presuming the segment begins * on a message boundary. */ void -openflow_print(const u_char *cp, const u_int len) { - const u_char *ep = cp + len; - - printf(": OpenFlow"); - while (cp < ep) - cp = of_header_body_print(cp, ep); +openflow_print(netdissect_options *ndo, const u_char *cp, const u_int len _U_) +{ + ndo->ndo_protocol = "openflow"; + ND_PRINT(": OpenFlow"); + while (cp < ndo->ndo_snapend) + cp = of_header_body_print(ndo, cp, ndo->ndo_snapend); }