pipeline: add SWX instruction verifier
[dpdk.git] / lib / librte_pipeline / rte_swx_pipeline.c
index 8876684..d51fec8 100644 (file)
@@ -352,6 +352,90 @@ enum instruction_type {
 
        /* table TABLE */
        INSTR_TABLE,
+
+       /* extern e.obj.func */
+       INSTR_EXTERN_OBJ,
+
+       /* extern f.func */
+       INSTR_EXTERN_FUNC,
+
+       /* jmp LABEL
+        * Unconditional jump
+        */
+       INSTR_JMP,
+
+       /* jmpv LABEL h.header
+        * Jump if header is valid
+        */
+       INSTR_JMP_VALID,
+
+       /* jmpnv LABEL h.header
+        * Jump if header is invalid
+        */
+       INSTR_JMP_INVALID,
+
+       /* jmph LABEL
+        * Jump if table lookup hit
+        */
+       INSTR_JMP_HIT,
+
+       /* jmpnh LABEL
+        * Jump if table lookup miss
+        */
+       INSTR_JMP_MISS,
+
+       /* jmpa LABEL ACTION
+        * Jump if action run
+        */
+       INSTR_JMP_ACTION_HIT,
+
+       /* jmpna LABEL ACTION
+        * Jump if action not run
+        */
+       INSTR_JMP_ACTION_MISS,
+
+       /* jmpeq LABEL a b
+        * Jump is a is equal to b
+        * a = HMEFT, b = HMEFTI
+        */
+       INSTR_JMP_EQ,   /* (a, b) = (MEFT, MEFT) or (a, b) = (H, H) */
+       INSTR_JMP_EQ_S, /* (a, b) = (MEFT, H) or (a, b) = (H, MEFT) */
+       INSTR_JMP_EQ_I, /* (a, b) = (MEFT, I) or (a, b) = (H, I) */
+
+       /* jmpneq LABEL a b
+        * Jump is a is not equal to b
+        * a = HMEFT, b = HMEFTI
+        */
+       INSTR_JMP_NEQ,   /* (a, b) = (MEFT, MEFT) or (a, b) = (H, H) */
+       INSTR_JMP_NEQ_S, /* (a, b) = (MEFT, H) or (a, b) = (H, MEFT) */
+       INSTR_JMP_NEQ_I, /* (a, b) = (MEFT, I) or (a, b) = (H, I) */
+
+       /* jmplt LABEL a b
+        * Jump if a is less than b
+        * a = HMEFT, b = HMEFTI
+        */
+       INSTR_JMP_LT,    /* a = MEF, b = MEF */
+       INSTR_JMP_LT_MH, /* a = MEF, b = H */
+       INSTR_JMP_LT_HM, /* a = H, b = MEF */
+       INSTR_JMP_LT_HH, /* a = H, b = H */
+       INSTR_JMP_LT_MI, /* a = MEF, b = I */
+       INSTR_JMP_LT_HI, /* a = H, b = I */
+
+       /* jmpgt LABEL a b
+        * Jump if a is greater than b
+        * a = HMEFT, b = HMEFTI
+        */
+       INSTR_JMP_GT,    /* a = MEF, b = MEF */
+       INSTR_JMP_GT_MH, /* a = MEF, b = H */
+       INSTR_JMP_GT_HM, /* a = H, b = MEF */
+       INSTR_JMP_GT_HH, /* a = H, b = H */
+       INSTR_JMP_GT_MI, /* a = MEF, b = I */
+       INSTR_JMP_GT_HI, /* a = H, b = I */
+
+       /* return
+        * Return from action
+        */
+       INSTR_RETURN,
 };
 
 struct instr_operand {
@@ -383,6 +467,15 @@ struct instr_table {
        uint8_t table_id;
 };
 
+struct instr_extern_obj {
+       uint8_t ext_obj_id;
+       uint8_t func_id;
+};
+
+struct instr_extern_func {
+       uint8_t ext_func_id;
+};
+
 struct instr_dst_src {
        struct instr_operand dst;
        union {
@@ -404,6 +497,21 @@ struct instr_dma {
        uint16_t n_bytes[8];
 };
 
+struct instr_jmp {
+       struct instruction *ip;
+
+       union {
+               struct instr_operand a;
+               uint8_t header_id;
+               uint8_t action_id;
+       };
+
+       union {
+               struct instr_operand b;
+               uint32_t b_val;
+       };
+};
+
 struct instruction {
        enum instruction_type type;
        union {
@@ -413,6 +521,9 @@ struct instruction {
                struct instr_dma dma;
                struct instr_dst_src alu;
                struct instr_table table;
+               struct instr_extern_obj ext_obj;
+               struct instr_extern_func ext_func;
+               struct instr_jmp jmp;
        };
 };
 
@@ -527,6 +638,9 @@ struct thread {
 #define MASK64_BIT_SET(mask, pos) ((mask) | (1LLU << (pos)))
 #define MASK64_BIT_CLR(mask, pos) ((mask) & ~(1LLU << (pos)))
 
+#define HEADER_VALID(thread, header_id) \
+       MASK64_BIT_GET((thread)->valid_headers, header_id)
+
 #define ALU(thread, ip, operator)  \
 {                                                                              \
        uint8_t *dst_struct = (thread)->structs[(ip)->alu.dst.struct_id];      \
@@ -708,6 +822,118 @@ struct thread {
        *dst64_ptr = (dst64 & ~dst64_mask) | (src & dst64_mask);               \
 }
 
+#define JMP_CMP(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a64_mask = UINT64_MAX >> (64 - (ip)->jmp.a.n_bits);           \
+       uint64_t a = a64 & a64_mask;                                           \
+                                                                              \
+       uint8_t *b_struct = (thread)->structs[(ip)->jmp.b.struct_id];          \
+       uint64_t *b64_ptr = (uint64_t *)&b_struct[(ip)->jmp.b.offset];         \
+       uint64_t b64 = *b64_ptr;                                               \
+       uint64_t b64_mask = UINT64_MAX >> (64 - (ip)->jmp.b.n_bits);           \
+       uint64_t b = b64 & b64_mask;                                           \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#if RTE_BYTE_ORDER == RTE_LITTLE_ENDIAN
+
+#define JMP_CMP_S(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a64_mask = UINT64_MAX >> (64 - (ip)->jmp.a.n_bits);           \
+       uint64_t a = a64 & a64_mask;                                           \
+                                                                              \
+       uint8_t *b_struct = (thread)->structs[(ip)->jmp.b.struct_id];          \
+       uint64_t *b64_ptr = (uint64_t *)&b_struct[(ip)->jmp.b.offset];         \
+       uint64_t b64 = *b64_ptr;                                               \
+       uint64_t b = ntoh64(b64) >> (64 - (ip)->jmp.b.n_bits);                 \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#define JMP_CMP_MH JMP_CMP_S
+
+#define JMP_CMP_HM(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a = ntoh64(a64) >> (64 - (ip)->jmp.a.n_bits);                 \
+                                                                              \
+       uint8_t *b_struct = (thread)->structs[(ip)->jmp.b.struct_id];          \
+       uint64_t *b64_ptr = (uint64_t *)&b_struct[(ip)->jmp.b.offset];         \
+       uint64_t b64 = *b64_ptr;                                               \
+       uint64_t b64_mask = UINT64_MAX >> (64 - (ip)->jmp.b.n_bits);           \
+       uint64_t b = b64 & b64_mask;                                           \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#define JMP_CMP_HH(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a = ntoh64(a64) >> (64 - (ip)->jmp.a.n_bits);                 \
+                                                                              \
+       uint8_t *b_struct = (thread)->structs[(ip)->jmp.b.struct_id];          \
+       uint64_t *b64_ptr = (uint64_t *)&b_struct[(ip)->jmp.b.offset];         \
+       uint64_t b64 = *b64_ptr;                                               \
+       uint64_t b = ntoh64(b64) >> (64 - (ip)->jmp.b.n_bits);                 \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#else
+
+#define JMP_CMP_S JMP_CMP
+#define JMP_CMP_MH JMP_CMP
+#define JMP_CMP_HM JMP_CMP
+#define JMP_CMP_HH JMP_CMP
+
+#endif
+
+#define JMP_CMP_I(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a64_mask = UINT64_MAX >> (64 - (ip)->jmp.a.n_bits);           \
+       uint64_t a = a64 & a64_mask;                                           \
+                                                                              \
+       uint64_t b = (ip)->jmp.b_val;                                          \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#define JMP_CMP_MI JMP_CMP_I
+
+#if RTE_BYTE_ORDER == RTE_LITTLE_ENDIAN
+
+#define JMP_CMP_HI(thread, ip, operator)  \
+{                                                                              \
+       uint8_t *a_struct = (thread)->structs[(ip)->jmp.a.struct_id];          \
+       uint64_t *a64_ptr = (uint64_t *)&a_struct[(ip)->jmp.a.offset];         \
+       uint64_t a64 = *a64_ptr;                                               \
+       uint64_t a = ntoh64(a64) >> (64 - (ip)->jmp.a.n_bits);                 \
+                                                                              \
+       uint64_t b = (ip)->jmp.b_val;                                          \
+                                                                              \
+       (thread)->ip = (a operator b) ? (ip)->jmp.ip : ((thread)->ip + 1);     \
+}
+
+#else
+
+#define JMP_CMP_HI JMP_CMP_I
+
+#endif
+
 #define METADATA_READ(thread, offset, n_bits)                                  \
 ({                                                                             \
        uint64_t *m64_ptr = (uint64_t *)&(thread)->metadata[offset];           \
@@ -1271,6 +1497,50 @@ extern_obj_find(struct rte_swx_pipeline *p, const char *name)
        return NULL;
 }
 
+static struct extern_type_member_func *
+extern_obj_member_func_parse(struct rte_swx_pipeline *p,
+                            const char *name,
+                            struct extern_obj **obj)
+{
+       struct extern_obj *object;
+       struct extern_type_member_func *func;
+       char *object_name, *func_name;
+
+       if (name[0] != 'e' || name[1] != '.')
+               return NULL;
+
+       object_name = strdup(&name[2]);
+       if (!object_name)
+               return NULL;
+
+       func_name = strchr(object_name, '.');
+       if (!func_name) {
+               free(object_name);
+               return NULL;
+       }
+
+       *func_name = 0;
+       func_name++;
+
+       object = extern_obj_find(p, object_name);
+       if (!object) {
+               free(object_name);
+               return NULL;
+       }
+
+       func = extern_type_member_func_find(object->type, func_name);
+       if (!func) {
+               free(object_name);
+               return NULL;
+       }
+
+       if (obj)
+               *obj = object;
+
+       free(object_name);
+       return func;
+}
+
 static struct field *
 extern_obj_mailbox_field_parse(struct rte_swx_pipeline *p,
                               const char *name,
@@ -1553,6 +1823,16 @@ extern_func_find(struct rte_swx_pipeline *p, const char *name)
        return NULL;
 }
 
+static struct extern_func *
+extern_func_parse(struct rte_swx_pipeline *p,
+                 const char *name)
+{
+       if (name[0] != 'f' || name[1] != '.')
+               return NULL;
+
+       return extern_func_find(p, &name[2]);
+}
+
 static struct field *
 extern_func_mailbox_field_parse(struct rte_swx_pipeline *p,
                                const char *name,
@@ -1977,6 +2257,42 @@ metadata_free(struct rte_swx_pipeline *p)
 /*
  * Instruction.
  */
+static int
+instruction_is_jmp(struct instruction *instr)
+{
+       switch (instr->type) {
+       case INSTR_JMP:
+       case INSTR_JMP_VALID:
+       case INSTR_JMP_INVALID:
+       case INSTR_JMP_HIT:
+       case INSTR_JMP_MISS:
+       case INSTR_JMP_ACTION_HIT:
+       case INSTR_JMP_ACTION_MISS:
+       case INSTR_JMP_EQ:
+       case INSTR_JMP_EQ_S:
+       case INSTR_JMP_EQ_I:
+       case INSTR_JMP_NEQ:
+       case INSTR_JMP_NEQ_S:
+       case INSTR_JMP_NEQ_I:
+       case INSTR_JMP_LT:
+       case INSTR_JMP_LT_MH:
+       case INSTR_JMP_LT_HM:
+       case INSTR_JMP_LT_HH:
+       case INSTR_JMP_LT_MI:
+       case INSTR_JMP_LT_HI:
+       case INSTR_JMP_GT:
+       case INSTR_JMP_GT_MH:
+       case INSTR_JMP_GT_HM:
+       case INSTR_JMP_GT_HH:
+       case INSTR_JMP_GT_MI:
+       case INSTR_JMP_GT_HI:
+               return 1;
+
+       default:
+               return 0;
+       }
+}
+
 static struct field *
 action_field_parse(struct action *action, const char *name);
 
@@ -2065,6 +2381,12 @@ thread_ip_reset(struct rte_swx_pipeline *p, struct thread *t)
        t->ip = p->instructions;
 }
 
+static inline void
+thread_ip_set(struct thread *t, struct instruction *ip)
+{
+       t->ip = ip;
+}
+
 static inline void
 thread_ip_action_call(struct rte_swx_pipeline *p,
                      struct thread *t,
@@ -2097,6 +2419,12 @@ thread_yield(struct rte_swx_pipeline *p)
        p->thread_id = (p->thread_id + 1) & (RTE_SWX_PIPELINE_THREADS_MAX - 1);
 }
 
+static inline void
+thread_yield_cond(struct rte_swx_pipeline *p, int cond)
+{
+       p->thread_id = (p->thread_id + cond) & (RTE_SWX_PIPELINE_THREADS_MAX - 1);
+}
+
 /*
  * rx.
  */
@@ -2760,6 +3088,94 @@ instr_table_exec(struct rte_swx_pipeline *p)
        thread_ip_action_call(p, t, action_id);
 }
 
+/*
+ * extern.
+ */
+static int
+instr_extern_translate(struct rte_swx_pipeline *p,
+                      struct action *action __rte_unused,
+                      char **tokens,
+                      int n_tokens,
+                      struct instruction *instr,
+                      struct instruction_data *data __rte_unused)
+{
+       char *token = tokens[1];
+
+       CHECK(n_tokens == 2, EINVAL);
+
+       if (token[0] == 'e') {
+               struct extern_obj *obj;
+               struct extern_type_member_func *func;
+
+               func = extern_obj_member_func_parse(p, token, &obj);
+               CHECK(func, EINVAL);
+
+               instr->type = INSTR_EXTERN_OBJ;
+               instr->ext_obj.ext_obj_id = obj->id;
+               instr->ext_obj.func_id = func->id;
+
+               return 0;
+       }
+
+       if (token[0] == 'f') {
+               struct extern_func *func;
+
+               func = extern_func_parse(p, token);
+               CHECK(func, EINVAL);
+
+               instr->type = INSTR_EXTERN_FUNC;
+               instr->ext_func.ext_func_id = func->id;
+
+               return 0;
+       }
+
+       CHECK(0, EINVAL);
+}
+
+static inline void
+instr_extern_obj_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       uint32_t obj_id = ip->ext_obj.ext_obj_id;
+       uint32_t func_id = ip->ext_obj.func_id;
+       struct extern_obj_runtime *obj = &t->extern_objs[obj_id];
+       rte_swx_extern_type_member_func_t func = obj->funcs[func_id];
+
+       TRACE("[Thread %2u] extern obj %u member func %u\n",
+             p->thread_id,
+             obj_id,
+             func_id);
+
+       /* Extern object member function execute. */
+       uint32_t done = func(obj->obj, obj->mailbox);
+
+       /* Thread. */
+       thread_ip_inc_cond(t, done);
+       thread_yield_cond(p, done ^ 1);
+}
+
+static inline void
+instr_extern_func_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       uint32_t ext_func_id = ip->ext_func.ext_func_id;
+       struct extern_func_runtime *ext_func = &t->extern_funcs[ext_func_id];
+       rte_swx_extern_func_t func = ext_func->func;
+
+       TRACE("[Thread %2u] extern func %u\n",
+             p->thread_id,
+             ext_func_id);
+
+       /* Extern function execute. */
+       uint32_t done = func(ext_func->mailbox);
+
+       /* Thread. */
+       thread_ip_inc_cond(t, done);
+       thread_yield_cond(p, done ^ 1);
+}
+
 /*
  * mov.
  */
@@ -4186,73 +4602,751 @@ instr_alu_ckadd_struct_exec(struct rte_swx_pipeline *p)
        thread_ip_inc(p);
 }
 
-#define RTE_SWX_INSTRUCTION_TOKENS_MAX 16
+/*
+ * jmp.
+ */
+static struct action *
+action_find(struct rte_swx_pipeline *p, const char *name);
 
 static int
-instr_translate(struct rte_swx_pipeline *p,
-               struct action *action,
-               char *string,
-               struct instruction *instr,
-               struct instruction_data *data)
+instr_jmp_translate(struct rte_swx_pipeline *p __rte_unused,
+                   struct action *action __rte_unused,
+                   char **tokens,
+                   int n_tokens,
+                   struct instruction *instr,
+                   struct instruction_data *data)
 {
-       char *tokens[RTE_SWX_INSTRUCTION_TOKENS_MAX];
-       int n_tokens = 0, tpos = 0;
+       CHECK(n_tokens == 2, EINVAL);
 
-       /* Parse the instruction string into tokens. */
-       for ( ; ; ) {
-               char *token;
+       strcpy(data->jmp_label, tokens[1]);
 
-               token = strtok_r(string, " \t\v", &string);
-               if (!token)
-                       break;
+       instr->type = INSTR_JMP;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       return 0;
+}
 
-               CHECK(n_tokens < RTE_SWX_INSTRUCTION_TOKENS_MAX, EINVAL);
+static int
+instr_jmp_valid_translate(struct rte_swx_pipeline *p,
+                         struct action *action __rte_unused,
+                         char **tokens,
+                         int n_tokens,
+                         struct instruction *instr,
+                         struct instruction_data *data)
+{
+       struct header *h;
 
-               tokens[n_tokens] = token;
-               n_tokens++;
-       }
+       CHECK(n_tokens == 3, EINVAL);
 
-       CHECK(n_tokens, EINVAL);
+       strcpy(data->jmp_label, tokens[1]);
 
-       /* Handle the optional instruction label. */
-       if ((n_tokens >= 2) && !strcmp(tokens[1], ":")) {
-               strcpy(data->label, tokens[0]);
+       h = header_parse(p, tokens[2]);
+       CHECK(h, EINVAL);
 
-               tpos += 2;
-               CHECK(n_tokens - tpos, EINVAL);
-       }
+       instr->type = INSTR_JMP_VALID;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.header_id = h->id;
+       return 0;
+}
 
-       /* Identify the instruction type. */
-       if (!strcmp(tokens[tpos], "rx"))
-               return instr_rx_translate(p,
-                                         action,
-                                         &tokens[tpos],
-                                         n_tokens - tpos,
-                                         instr,
-                                         data);
+static int
+instr_jmp_invalid_translate(struct rte_swx_pipeline *p,
+                           struct action *action __rte_unused,
+                           char **tokens,
+                           int n_tokens,
+                           struct instruction *instr,
+                           struct instruction_data *data)
+{
+       struct header *h;
 
-       if (!strcmp(tokens[tpos], "tx"))
-               return instr_tx_translate(p,
-                                         action,
-                                         &tokens[tpos],
-                                         n_tokens - tpos,
-                                         instr,
-                                         data);
+       CHECK(n_tokens == 2, EINVAL);
 
-       if (!strcmp(tokens[tpos], "extract"))
-               return instr_hdr_extract_translate(p,
-                                                  action,
-                                                  &tokens[tpos],
-                                                  n_tokens - tpos,
-                                                  instr,
-                                                  data);
+       strcpy(data->jmp_label, tokens[1]);
 
-       if (!strcmp(tokens[tpos], "emit"))
-               return instr_hdr_emit_translate(p,
-                                               action,
-                                               &tokens[tpos],
-                                               n_tokens - tpos,
-                                               instr,
+       h = header_parse(p, tokens[2]);
+       CHECK(h, EINVAL);
+
+       instr->type = INSTR_JMP_INVALID;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.header_id = h->id;
+       return 0;
+}
+
+static int
+instr_jmp_hit_translate(struct rte_swx_pipeline *p __rte_unused,
+                       struct action *action,
+                       char **tokens,
+                       int n_tokens,
+                       struct instruction *instr,
+                       struct instruction_data *data)
+{
+       CHECK(!action, EINVAL);
+       CHECK(n_tokens == 2, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       instr->type = INSTR_JMP_HIT;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       return 0;
+}
+
+static int
+instr_jmp_miss_translate(struct rte_swx_pipeline *p __rte_unused,
+                        struct action *action,
+                        char **tokens,
+                        int n_tokens,
+                        struct instruction *instr,
+                        struct instruction_data *data)
+{
+       CHECK(!action, EINVAL);
+       CHECK(n_tokens == 2, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       instr->type = INSTR_JMP_MISS;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       return 0;
+}
+
+static int
+instr_jmp_action_hit_translate(struct rte_swx_pipeline *p,
+                              struct action *action,
+                              char **tokens,
+                              int n_tokens,
+                              struct instruction *instr,
+                              struct instruction_data *data)
+{
+       struct action *a;
+
+       CHECK(!action, EINVAL);
+       CHECK(n_tokens == 3, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       a = action_find(p, tokens[2]);
+       CHECK(a, EINVAL);
+
+       instr->type = INSTR_JMP_ACTION_HIT;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.action_id = a->id;
+       return 0;
+}
+
+static int
+instr_jmp_action_miss_translate(struct rte_swx_pipeline *p,
+                               struct action *action,
+                               char **tokens,
+                               int n_tokens,
+                               struct instruction *instr,
+                               struct instruction_data *data)
+{
+       struct action *a;
+
+       CHECK(!action, EINVAL);
+       CHECK(n_tokens == 3, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       a = action_find(p, tokens[2]);
+       CHECK(a, EINVAL);
+
+       instr->type = INSTR_JMP_ACTION_MISS;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.action_id = a->id;
+       return 0;
+}
+
+static int
+instr_jmp_eq_translate(struct rte_swx_pipeline *p,
+                      struct action *action,
+                      char **tokens,
+                      int n_tokens,
+                      struct instruction *instr,
+                      struct instruction_data *data)
+{
+       char *a = tokens[2], *b = tokens[3];
+       struct field *fa, *fb;
+       uint32_t a_struct_id, b_struct_id, b_val;
+
+       CHECK(n_tokens == 4, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       fa = struct_field_parse(p, action, a, &a_struct_id);
+       CHECK(fa, EINVAL);
+
+       /* JMP_EQ or JMP_EQ_S. */
+       fb = struct_field_parse(p, action, b, &b_struct_id);
+       if (fb) {
+               instr->type = INSTR_JMP_EQ;
+               if ((a[0] == 'h' && b[0] != 'h') ||
+                   (a[0] != 'h' && b[0] == 'h'))
+                       instr->type = INSTR_JMP_EQ_S;
+               instr->jmp.ip = NULL; /* Resolved later. */
+
+               instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+               instr->jmp.a.n_bits = fa->n_bits;
+               instr->jmp.a.offset = fa->offset / 8;
+               instr->jmp.b.struct_id = (uint8_t)b_struct_id;
+               instr->jmp.b.n_bits = fb->n_bits;
+               instr->jmp.b.offset = fb->offset / 8;
+               return 0;
+       }
+
+       /* JMP_EQ_I. */
+       b_val = strtoul(b, &b, 0);
+       CHECK(!b[0], EINVAL);
+
+       if (a[0] == 'h')
+               b_val = htonl(b_val);
+
+       instr->type = INSTR_JMP_EQ_I;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+       instr->jmp.a.n_bits = fa->n_bits;
+       instr->jmp.a.offset = fa->offset / 8;
+       instr->jmp.b_val = (uint32_t)b_val;
+       return 0;
+}
+
+static int
+instr_jmp_neq_translate(struct rte_swx_pipeline *p,
+                       struct action *action,
+                       char **tokens,
+                       int n_tokens,
+                       struct instruction *instr,
+                       struct instruction_data *data)
+{
+       char *a = tokens[2], *b = tokens[3];
+       struct field *fa, *fb;
+       uint32_t a_struct_id, b_struct_id, b_val;
+
+       CHECK(n_tokens == 4, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       fa = struct_field_parse(p, action, a, &a_struct_id);
+       CHECK(fa, EINVAL);
+
+       /* JMP_NEQ or JMP_NEQ_S. */
+       fb = struct_field_parse(p, action, b, &b_struct_id);
+       if (fb) {
+               instr->type = INSTR_JMP_NEQ;
+               if ((a[0] == 'h' && b[0] != 'h') ||
+                   (a[0] != 'h' && b[0] == 'h'))
+                       instr->type = INSTR_JMP_NEQ_S;
+               instr->jmp.ip = NULL; /* Resolved later. */
+
+               instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+               instr->jmp.a.n_bits = fa->n_bits;
+               instr->jmp.a.offset = fa->offset / 8;
+               instr->jmp.b.struct_id = (uint8_t)b_struct_id;
+               instr->jmp.b.n_bits = fb->n_bits;
+               instr->jmp.b.offset = fb->offset / 8;
+               return 0;
+       }
+
+       /* JMP_NEQ_I. */
+       b_val = strtoul(b, &b, 0);
+       CHECK(!b[0], EINVAL);
+
+       if (a[0] == 'h')
+               b_val = htonl(b_val);
+
+       instr->type = INSTR_JMP_NEQ_I;
+       instr->jmp.ip = NULL; /* Resolved later. */
+       instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+       instr->jmp.a.n_bits = fa->n_bits;
+       instr->jmp.a.offset = fa->offset / 8;
+       instr->jmp.b_val = (uint32_t)b_val;
+       return 0;
+}
+
+static int
+instr_jmp_lt_translate(struct rte_swx_pipeline *p,
+                      struct action *action,
+                      char **tokens,
+                      int n_tokens,
+                      struct instruction *instr,
+                      struct instruction_data *data)
+{
+       char *a = tokens[2], *b = tokens[3];
+       struct field *fa, *fb;
+       uint32_t a_struct_id, b_struct_id, b_val;
+
+       CHECK(n_tokens == 4, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       fa = struct_field_parse(p, action, a, &a_struct_id);
+       CHECK(fa, EINVAL);
+
+       /* JMP_LT, JMP_LT_MH, JMP_LT_HM, JMP_LT_HH. */
+       fb = struct_field_parse(p, action, b, &b_struct_id);
+       if (fb) {
+               instr->type = INSTR_JMP_LT;
+               if (a[0] == 'h' && b[0] == 'm')
+                       instr->type = INSTR_JMP_LT_HM;
+               if (a[0] == 'm' && b[0] == 'h')
+                       instr->type = INSTR_JMP_LT_MH;
+               if (a[0] == 'h' && b[0] == 'h')
+                       instr->type = INSTR_JMP_LT_HH;
+               instr->jmp.ip = NULL; /* Resolved later. */
+
+               instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+               instr->jmp.a.n_bits = fa->n_bits;
+               instr->jmp.a.offset = fa->offset / 8;
+               instr->jmp.b.struct_id = (uint8_t)b_struct_id;
+               instr->jmp.b.n_bits = fb->n_bits;
+               instr->jmp.b.offset = fb->offset / 8;
+               return 0;
+       }
+
+       /* JMP_LT_MI, JMP_LT_HI. */
+       b_val = strtoul(b, &b, 0);
+       CHECK(!b[0], EINVAL);
+
+       instr->type = INSTR_JMP_LT_MI;
+       if (a[0] == 'h')
+               instr->type = INSTR_JMP_LT_HI;
+       instr->jmp.ip = NULL; /* Resolved later. */
+
+       instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+       instr->jmp.a.n_bits = fa->n_bits;
+       instr->jmp.a.offset = fa->offset / 8;
+       instr->jmp.b_val = (uint32_t)b_val;
+       return 0;
+}
+
+static int
+instr_jmp_gt_translate(struct rte_swx_pipeline *p,
+                      struct action *action,
+                      char **tokens,
+                      int n_tokens,
+                      struct instruction *instr,
+                      struct instruction_data *data)
+{
+       char *a = tokens[2], *b = tokens[3];
+       struct field *fa, *fb;
+       uint32_t a_struct_id, b_struct_id, b_val;
+
+       CHECK(n_tokens == 4, EINVAL);
+
+       strcpy(data->jmp_label, tokens[1]);
+
+       fa = struct_field_parse(p, action, a, &a_struct_id);
+       CHECK(fa, EINVAL);
+
+       /* JMP_GT, JMP_GT_MH, JMP_GT_HM, JMP_GT_HH. */
+       fb = struct_field_parse(p, action, b, &b_struct_id);
+       if (fb) {
+               instr->type = INSTR_JMP_GT;
+               if (a[0] == 'h' && b[0] == 'm')
+                       instr->type = INSTR_JMP_GT_HM;
+               if (a[0] == 'm' && b[0] == 'h')
+                       instr->type = INSTR_JMP_GT_MH;
+               if (a[0] == 'h' && b[0] == 'h')
+                       instr->type = INSTR_JMP_GT_HH;
+               instr->jmp.ip = NULL; /* Resolved later. */
+
+               instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+               instr->jmp.a.n_bits = fa->n_bits;
+               instr->jmp.a.offset = fa->offset / 8;
+               instr->jmp.b.struct_id = (uint8_t)b_struct_id;
+               instr->jmp.b.n_bits = fb->n_bits;
+               instr->jmp.b.offset = fb->offset / 8;
+               return 0;
+       }
+
+       /* JMP_GT_MI, JMP_GT_HI. */
+       b_val = strtoul(b, &b, 0);
+       CHECK(!b[0], EINVAL);
+
+       instr->type = INSTR_JMP_GT_MI;
+       if (a[0] == 'h')
+               instr->type = INSTR_JMP_GT_HI;
+       instr->jmp.ip = NULL; /* Resolved later. */
+
+       instr->jmp.a.struct_id = (uint8_t)a_struct_id;
+       instr->jmp.a.n_bits = fa->n_bits;
+       instr->jmp.a.offset = fa->offset / 8;
+       instr->jmp.b_val = (uint32_t)b_val;
+       return 0;
+}
+
+static inline void
+instr_jmp_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmp\n", p->thread_id);
+
+       thread_ip_set(t, ip->jmp.ip);
+}
+
+static inline void
+instr_jmp_valid_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       uint32_t header_id = ip->jmp.header_id;
+
+       TRACE("[Thread %2u] jmpv\n", p->thread_id);
+
+       t->ip = HEADER_VALID(t, header_id) ? ip->jmp.ip : (t->ip + 1);
+}
+
+static inline void
+instr_jmp_invalid_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       uint32_t header_id = ip->jmp.header_id;
+
+       TRACE("[Thread %2u] jmpnv\n", p->thread_id);
+
+       t->ip = HEADER_VALID(t, header_id) ? (t->ip + 1) : ip->jmp.ip;
+}
+
+static inline void
+instr_jmp_hit_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       struct instruction *ip_next[] = {t->ip + 1, ip->jmp.ip};
+
+       TRACE("[Thread %2u] jmph\n", p->thread_id);
+
+       t->ip = ip_next[t->hit];
+}
+
+static inline void
+instr_jmp_miss_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+       struct instruction *ip_next[] = {ip->jmp.ip, t->ip + 1};
+
+       TRACE("[Thread %2u] jmpnh\n", p->thread_id);
+
+       t->ip = ip_next[t->hit];
+}
+
+static inline void
+instr_jmp_action_hit_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpa\n", p->thread_id);
+
+       t->ip = (ip->jmp.action_id == t->action_id) ? ip->jmp.ip : (t->ip + 1);
+}
+
+static inline void
+instr_jmp_action_miss_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpna\n", p->thread_id);
+
+       t->ip = (ip->jmp.action_id == t->action_id) ? (t->ip + 1) : ip->jmp.ip;
+}
+
+static inline void
+instr_jmp_eq_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpeq\n", p->thread_id);
+
+       JMP_CMP(t, ip, ==);
+}
+
+static inline void
+instr_jmp_eq_s_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpeq (s)\n", p->thread_id);
+
+       JMP_CMP_S(t, ip, ==);
+}
+
+static inline void
+instr_jmp_eq_i_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpeq (i)\n", p->thread_id);
+
+       JMP_CMP_I(t, ip, ==);
+}
+
+static inline void
+instr_jmp_neq_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpneq\n", p->thread_id);
+
+       JMP_CMP(t, ip, !=);
+}
+
+static inline void
+instr_jmp_neq_s_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpneq (s)\n", p->thread_id);
+
+       JMP_CMP_S(t, ip, !=);
+}
+
+static inline void
+instr_jmp_neq_i_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpneq (i)\n", p->thread_id);
+
+       JMP_CMP_I(t, ip, !=);
+}
+
+static inline void
+instr_jmp_lt_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt\n", p->thread_id);
+
+       JMP_CMP(t, ip, <);
+}
+
+static inline void
+instr_jmp_lt_mh_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt (mh)\n", p->thread_id);
+
+       JMP_CMP_MH(t, ip, <);
+}
+
+static inline void
+instr_jmp_lt_hm_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt (hm)\n", p->thread_id);
+
+       JMP_CMP_HM(t, ip, <);
+}
+
+static inline void
+instr_jmp_lt_hh_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt (hh)\n", p->thread_id);
+
+       JMP_CMP_HH(t, ip, <);
+}
+
+static inline void
+instr_jmp_lt_mi_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt (mi)\n", p->thread_id);
+
+       JMP_CMP_MI(t, ip, <);
+}
+
+static inline void
+instr_jmp_lt_hi_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmplt (hi)\n", p->thread_id);
+
+       JMP_CMP_HI(t, ip, <);
+}
+
+static inline void
+instr_jmp_gt_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt\n", p->thread_id);
+
+       JMP_CMP(t, ip, >);
+}
+
+static inline void
+instr_jmp_gt_mh_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt (mh)\n", p->thread_id);
+
+       JMP_CMP_MH(t, ip, >);
+}
+
+static inline void
+instr_jmp_gt_hm_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt (hm)\n", p->thread_id);
+
+       JMP_CMP_HM(t, ip, >);
+}
+
+static inline void
+instr_jmp_gt_hh_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt (hh)\n", p->thread_id);
+
+       JMP_CMP_HH(t, ip, >);
+}
+
+static inline void
+instr_jmp_gt_mi_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt (mi)\n", p->thread_id);
+
+       JMP_CMP_MI(t, ip, >);
+}
+
+static inline void
+instr_jmp_gt_hi_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+       struct instruction *ip = t->ip;
+
+       TRACE("[Thread %2u] jmpgt (hi)\n", p->thread_id);
+
+       JMP_CMP_HI(t, ip, >);
+}
+
+/*
+ * return.
+ */
+static int
+instr_return_translate(struct rte_swx_pipeline *p __rte_unused,
+                      struct action *action,
+                      char **tokens __rte_unused,
+                      int n_tokens,
+                      struct instruction *instr,
+                      struct instruction_data *data __rte_unused)
+{
+       CHECK(action, EINVAL);
+       CHECK(n_tokens == 1, EINVAL);
+
+       instr->type = INSTR_RETURN;
+       return 0;
+}
+
+static inline void
+instr_return_exec(struct rte_swx_pipeline *p)
+{
+       struct thread *t = &p->threads[p->thread_id];
+
+       TRACE("[Thread %2u] return\n", p->thread_id);
+
+       t->ip = t->ret;
+}
+
+#define RTE_SWX_INSTRUCTION_TOKENS_MAX 16
+
+static int
+instr_translate(struct rte_swx_pipeline *p,
+               struct action *action,
+               char *string,
+               struct instruction *instr,
+               struct instruction_data *data)
+{
+       char *tokens[RTE_SWX_INSTRUCTION_TOKENS_MAX];
+       int n_tokens = 0, tpos = 0;
+
+       /* Parse the instruction string into tokens. */
+       for ( ; ; ) {
+               char *token;
+
+               token = strtok_r(string, " \t\v", &string);
+               if (!token)
+                       break;
+
+               CHECK(n_tokens < RTE_SWX_INSTRUCTION_TOKENS_MAX, EINVAL);
+
+               tokens[n_tokens] = token;
+               n_tokens++;
+       }
+
+       CHECK(n_tokens, EINVAL);
+
+       /* Handle the optional instruction label. */
+       if ((n_tokens >= 2) && !strcmp(tokens[1], ":")) {
+               strcpy(data->label, tokens[0]);
+
+               tpos += 2;
+               CHECK(n_tokens - tpos, EINVAL);
+       }
+
+       /* Identify the instruction type. */
+       if (!strcmp(tokens[tpos], "rx"))
+               return instr_rx_translate(p,
+                                         action,
+                                         &tokens[tpos],
+                                         n_tokens - tpos,
+                                         instr,
+                                         data);
+
+       if (!strcmp(tokens[tpos], "tx"))
+               return instr_tx_translate(p,
+                                         action,
+                                         &tokens[tpos],
+                                         n_tokens - tpos,
+                                         instr,
+                                         data);
+
+       if (!strcmp(tokens[tpos], "extract"))
+               return instr_hdr_extract_translate(p,
+                                                  action,
+                                                  &tokens[tpos],
+                                                  n_tokens - tpos,
+                                                  instr,
+                                                  data);
+
+       if (!strcmp(tokens[tpos], "emit"))
+               return instr_hdr_emit_translate(p,
+                                               action,
+                                               &tokens[tpos],
+                                               n_tokens - tpos,
+                                               instr,
                                                data);
 
        if (!strcmp(tokens[tpos], "validate"))
@@ -4367,9 +5461,125 @@ instr_translate(struct rte_swx_pipeline *p,
                                             instr,
                                             data);
 
+       if (!strcmp(tokens[tpos], "extern"))
+               return instr_extern_translate(p,
+                                             action,
+                                             &tokens[tpos],
+                                             n_tokens - tpos,
+                                             instr,
+                                             data);
+
+       if (!strcmp(tokens[tpos], "jmp"))
+               return instr_jmp_translate(p,
+                                          action,
+                                          &tokens[tpos],
+                                          n_tokens - tpos,
+                                          instr,
+                                          data);
+
+       if (!strcmp(tokens[tpos], "jmpv"))
+               return instr_jmp_valid_translate(p,
+                                                action,
+                                                &tokens[tpos],
+                                                n_tokens - tpos,
+                                                instr,
+                                                data);
+
+       if (!strcmp(tokens[tpos], "jmpnv"))
+               return instr_jmp_invalid_translate(p,
+                                                  action,
+                                                  &tokens[tpos],
+                                                  n_tokens - tpos,
+                                                  instr,
+                                                  data);
+
+       if (!strcmp(tokens[tpos], "jmph"))
+               return instr_jmp_hit_translate(p,
+                                              action,
+                                              &tokens[tpos],
+                                              n_tokens - tpos,
+                                              instr,
+                                              data);
+
+       if (!strcmp(tokens[tpos], "jmpnh"))
+               return instr_jmp_miss_translate(p,
+                                               action,
+                                               &tokens[tpos],
+                                               n_tokens - tpos,
+                                               instr,
+                                               data);
+
+       if (!strcmp(tokens[tpos], "jmpa"))
+               return instr_jmp_action_hit_translate(p,
+                                                     action,
+                                                     &tokens[tpos],
+                                                     n_tokens - tpos,
+                                                     instr,
+                                                     data);
+
+       if (!strcmp(tokens[tpos], "jmpna"))
+               return instr_jmp_action_miss_translate(p,
+                                                      action,
+                                                      &tokens[tpos],
+                                                      n_tokens - tpos,
+                                                      instr,
+                                                      data);
+
+       if (!strcmp(tokens[tpos], "jmpeq"))
+               return instr_jmp_eq_translate(p,
+                                             action,
+                                             &tokens[tpos],
+                                             n_tokens - tpos,
+                                             instr,
+                                             data);
+
+       if (!strcmp(tokens[tpos], "jmpneq"))
+               return instr_jmp_neq_translate(p,
+                                              action,
+                                              &tokens[tpos],
+                                              n_tokens - tpos,
+                                              instr,
+                                              data);
+
+       if (!strcmp(tokens[tpos], "jmplt"))
+               return instr_jmp_lt_translate(p,
+                                             action,
+                                             &tokens[tpos],
+                                             n_tokens - tpos,
+                                             instr,
+                                             data);
+
+       if (!strcmp(tokens[tpos], "jmpgt"))
+               return instr_jmp_gt_translate(p,
+                                             action,
+                                             &tokens[tpos],
+                                             n_tokens - tpos,
+                                             instr,
+                                             data);
+
+       if (!strcmp(tokens[tpos], "return"))
+               return instr_return_translate(p,
+                                             action,
+                                             &tokens[tpos],
+                                             n_tokens - tpos,
+                                             instr,
+                                             data);
+
        CHECK(0, EINVAL);
 }
 
+static struct instruction_data *
+label_find(struct instruction_data *data, uint32_t n, const char *label)
+{
+       uint32_t i;
+
+       for (i = 0; i < n; i++)
+               if (!strcmp(label, data[i].label))
+                       return &data[i];
+
+       return NULL;
+}
+
 static uint32_t
 label_is_used(struct instruction_data *data, uint32_t n, const char *label)
 {
@@ -4417,6 +5627,79 @@ instr_label_check(struct instruction_data *instruction_data,
        return 0;
 }
 
+static int
+instr_jmp_resolve(struct instruction *instructions,
+                 struct instruction_data *instruction_data,
+                 uint32_t n_instructions)
+{
+       uint32_t i;
+
+       for (i = 0; i < n_instructions; i++) {
+               struct instruction *instr = &instructions[i];
+               struct instruction_data *data = &instruction_data[i];
+               struct instruction_data *found;
+
+               if (!instruction_is_jmp(instr))
+                       continue;
+
+               found = label_find(instruction_data,
+                                  n_instructions,
+                                  data->jmp_label);
+               CHECK(found, EINVAL);
+
+               instr->jmp.ip = &instr[found - instruction_data];
+       }
+
+       return 0;
+}
+
+static int
+instr_verify(struct rte_swx_pipeline *p __rte_unused,
+            struct action *a,
+            struct instruction *instr,
+            struct instruction_data *data __rte_unused,
+            uint32_t n_instructions)
+{
+       if (!a) {
+               enum instruction_type type;
+               uint32_t i;
+
+               /* Check that the first instruction is rx. */
+               CHECK(instr[0].type == INSTR_RX, EINVAL);
+
+               /* Check that there is at least one tx instruction. */
+               for (i = 0; i < n_instructions; i++) {
+                       type = instr[i].type;
+
+                       if (instr[i].type == INSTR_TX)
+                               break;
+               }
+               CHECK(i < n_instructions, EINVAL);
+
+               /* Check that the last instruction is either tx or unconditional
+                * jump.
+                */
+               type = instr[n_instructions - 1].type;
+               CHECK((type == INSTR_TX) || (type == INSTR_JMP), EINVAL);
+       }
+
+       if (a) {
+               enum instruction_type type;
+               uint32_t i;
+
+               /* Check that there is at least one return or tx instruction. */
+               for (i = 0; i < n_instructions; i++) {
+                       type = instr[i].type;
+
+                       if ((type == INSTR_RETURN) || (type == INSTR_TX))
+                               break;
+               }
+               CHECK(i < n_instructions, EINVAL);
+       }
+
+       return 0;
+}
+
 static int
 instruction_config(struct rte_swx_pipeline *p,
                   struct action *a,
@@ -4465,6 +5748,14 @@ instruction_config(struct rte_swx_pipeline *p,
        if (err)
                goto error;
 
+       err = instr_verify(p, a, instr, data, n_instructions);
+       if (err)
+               goto error;
+
+       err = instr_jmp_resolve(instr, data, n_instructions);
+       if (err)
+               goto error;
+
        free(data);
 
        if (a) {
@@ -4571,6 +5862,40 @@ static instr_exec_t instruction_table[] = {
        [INSTR_ALU_SHR_HI] = instr_alu_shr_hi_exec,
 
        [INSTR_TABLE] = instr_table_exec,
+       [INSTR_EXTERN_OBJ] = instr_extern_obj_exec,
+       [INSTR_EXTERN_FUNC] = instr_extern_func_exec,
+
+       [INSTR_JMP] = instr_jmp_exec,
+       [INSTR_JMP_VALID] = instr_jmp_valid_exec,
+       [INSTR_JMP_INVALID] = instr_jmp_invalid_exec,
+       [INSTR_JMP_HIT] = instr_jmp_hit_exec,
+       [INSTR_JMP_MISS] = instr_jmp_miss_exec,
+       [INSTR_JMP_ACTION_HIT] = instr_jmp_action_hit_exec,
+       [INSTR_JMP_ACTION_MISS] = instr_jmp_action_miss_exec,
+
+       [INSTR_JMP_EQ] = instr_jmp_eq_exec,
+       [INSTR_JMP_EQ_S] = instr_jmp_eq_s_exec,
+       [INSTR_JMP_EQ_I] = instr_jmp_eq_i_exec,
+
+       [INSTR_JMP_NEQ] = instr_jmp_neq_exec,
+       [INSTR_JMP_NEQ_S] = instr_jmp_neq_s_exec,
+       [INSTR_JMP_NEQ_I] = instr_jmp_neq_i_exec,
+
+       [INSTR_JMP_LT] = instr_jmp_lt_exec,
+       [INSTR_JMP_LT_MH] = instr_jmp_lt_mh_exec,
+       [INSTR_JMP_LT_HM] = instr_jmp_lt_hm_exec,
+       [INSTR_JMP_LT_HH] = instr_jmp_lt_hh_exec,
+       [INSTR_JMP_LT_MI] = instr_jmp_lt_mi_exec,
+       [INSTR_JMP_LT_HI] = instr_jmp_lt_hi_exec,
+
+       [INSTR_JMP_GT] = instr_jmp_gt_exec,
+       [INSTR_JMP_GT_MH] = instr_jmp_gt_mh_exec,
+       [INSTR_JMP_GT_HM] = instr_jmp_gt_hm_exec,
+       [INSTR_JMP_GT_HH] = instr_jmp_gt_hh_exec,
+       [INSTR_JMP_GT_MI] = instr_jmp_gt_mi_exec,
+       [INSTR_JMP_GT_HI] = instr_jmp_gt_hi_exec,
+
+       [INSTR_RETURN] = instr_return_exec,
 };
 
 static inline void