/* * node.c: gre packet processing * * Copyright (c) 2012 Cisco and/or its affiliates. * 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. */ #include #include #include #include #include #define foreach_gre_input_next \ _(PUNT, "error-punt") \ _(DROP, "error-drop") \ _(ETHERNET_INPUT, "ethernet-input") \ _(IP4_INPUT, "ip4-input") \ _(IP6_INPUT, "ip6-input") \ _(MPLS_INPUT, "mpls-input") typedef enum { #define _(s,n) GRE_INPUT_NEXT_##s, foreach_gre_input_next #undef _ GRE_INPUT_N_NEXT, } gre_input_next_t; typedef struct { u32 tunnel_id; u32 length; ip46_address_t src; ip46_address_t dst; } gre_rx_trace_t; extern u8 *format_gre_rx_trace (u8 * s, va_list * args); #ifndef CLIB_MARCH_VARIANT u8 * format_gre_rx_trace (u8 * s, va_list * args) { CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *); CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *); gre_rx_trace_t *t = va_arg (*args, gre_rx_trace_t *); s = format (s, "GRE: tunnel %d len %d src %U dst %U", t->tunnel_id, clib_net_to_host_u16 (t->length), format_ip46_address, &t->src, IP46_TYPE_ANY, format_ip46_address, &t->dst, IP46_TYPE_ANY); return s; } #endif /* CLIB_MARCH_VARIANT */ typedef struct { /* Sparse vector mapping gre protocol in network byte order to next index. */ u16 *next_by_protocol; } gre_input_runtime_t; always_inline void gre_trace (vlib_main_t * vm, vlib_node_runtime_t * node, vlib_buffer_t * b, u32 tun_sw_if_index, const ip6_header_t * ip6, const ip4_header_t * ip4, int is_ipv6) { gre_rx_trace_t *tr = vlib_add_trace (vm, node, b, sizeof (*tr)); tr->tunnel_id = tun_sw_if_index; if (is_ipv6) { tr->length = ip6->payload_length; tr->src.ip6.as_u64[0] = ip6->src_address.as_u64[0]; tr->src.ip6.as_u64[1] = ip6->src_address.as_u64[1]; tr->dst.ip6.as_u64[0] = ip6->dst_address.as_u64[0]; tr->dst.ip6.as_u64[1] = ip6->dst_address.as_u64[1]; } else { tr->length = ip4->length; tr->src.as_u64[0] = tr->src.as_u64[1] = 0; tr->dst.as_u64[0] = tr->dst.as_u64[1] = 0; tr->src.ip4.as_u32 = ip4->src_address.as_u32; tr->dst.ip4.as_u32 = ip4->dst_address.as_u32; } } always_inline void gre_tunnel_get (const gre_main_t * gm, vlib_node_runtime_t * node, vlib_buffer_t * b, u16 * next, const gre_tunnel_key_t * key, gre_tunnel_key_t * cached_key, u32 * tun_sw_if_index, u32 * cached_tun_sw_if_index, int is_ipv6) { const uword *p; p = is_ipv6 ? hash_get_mem (gm->tunnel_by_key6, &key->gtk_v6) : hash_get_mem (gm->tunnel_by_key4, &key->gtk_v4); if (PREDICT_FALSE (!p)) { *next = GRE_INPUT_NEXT_DROP; b->error = node->errors[GRE_ERROR_NO_SUCH_TUNNEL]; *tun_sw_if_index = ~0; } else { const gre_tunnel_t *tun; tun = pool_elt_at_index (gm->tunnels, *p); *cached_tun_sw_if_index = *tun_sw_if_index = tun->sw_if_index; if (is_ipv6) cached_key->gtk_v6 = key->gtk_v6; else cached_key->gtk_v4 = key->gtk_v4; } } always_inline uword gre_input (vlib_main_t * vm, vlib_node_runtime_t * node, vlib_frame_t * frame, const int is_ipv6) { gre_main_t *gm = &gre_main; u32 *from, n_left_from; vlib_buffer_t *bufs[VLIB_FRAME_SIZE], **b = bufs; u16 nexts[VLIB_FRAME_SIZE], *next = nexts; u16 cached_protocol = ~0; u32 cached_next_index = SPARSE_VEC_INVALID_INDEX; u32 cached_tun_sw_if_index = ~0; gre_tunnel_key_t cached_key; from = vlib_frame_vector_args (frame); n_left_from = frame->n_vectors; vlib_get_buffers (vm, from, bufs, n_left_from); if (is_ipv6) clib_memset (&cached_key.gtk_v6, 0xff, sizeof (cached_key.gtk_v6)); else clib_memset (&cached_key.gtk_v4, 0xff, sizeof (cached_key.gtk_v4)); while (n_left_from >= 2) { const ip6_header_t *ip6[2]; const ip4_header_t *ip4[2]; const gre_header_t *gre[2]; u32 nidx[2]; next_info_t ni[2]; u8 type[2]; u16 version[2]; u32 len[2]; gre_tunnel_key_t key[2]; u8 matched[2]; u32 tun_sw_if_index[2]; if (PREDICT_TRUE (n_left_from >= 6)) { vlib_prefetch_buffer_data (b[2], LOAD); vlib_prefetch_buffer_data (b[3], LOAD); vlib_prefetch_buffer_header (b[4], STORE); vlib_prefetch_buffer_header (b[5], STORE); } if (is_ipv6) { /* ip6_local hands us the ip header, not the gre header */ ip6[0] = vlib_buffer_get_current (b[0]); ip6[1] = vlib_buffer_get_current (b[1]); gre[0] = (void *) (ip6[0] + 1); gre[1] = (void *) (ip6[1] + 1); vlib_buffer_advance (b[0], sizeof (*ip6[0]) + sizeof (*gre[0])); vlib_buffer_advance (b[1], sizeof (*ip6[0]) + sizeof (*gre[0])); } else { /* ip4_local hands us the ip header, not the gre header */ ip4[0] = vlib_buffer_get_current (b[0]); ip4[1] = vlib_buffer_get_current (b[1]); gre[0] = (void *) (ip4[0] + 1); gre[1] = (void *) (ip4[1] + 1); vlib_buffer_advance (b[0], sizeof (*ip4[0]) + sizeof (*gre[0])); vlib_buffer_advance (b[1], sizeof (*ip4[0]) + sizeof (*gre[0])); } if (PREDICT_TRUE (cached_protocol == gre[0]->protocol)) { nidx[0] = cached_next_index; } else { cached_next_index = nidx[0] = sparse_vec_index (gm->next_by_protocol, gre[0]->protocol); cached_protocol = gre[0]->protocol; } if (PREDICT_TRUE (cached_protocol == gre[1]->protocol)) { nidx[1] = cached_next_index; } else { cached_next_index = nidx[1] = sparse_vec_index (gm->next_by_protocol, gre[1]->protocol); cached_protocol = gre[1]->protocol; } ni[0] = vec_elt (gm->next_by_protocol, nidx[0]); ni[1] = vec_elt (gm->next_by_protocol, nidx[1]); next[0] = ni[0].next_index; next[1] = ni[1].next_index; type[0] = ni[0].
/*
 * Copyright (c) 2019 Cisco and/or its affiliates.
 * 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.
 */


#ifndef SRC_VNET_SESSION_APPLICATION_LOCAL_H_
#define SRC_VNET_SESSION_APPLICATION_LOCAL_H_

#include <vnet/session/application.h>
#include <vnet/session/transport.h>

typedef struct ct_connection_
{
  transport_connection_t connection;
  u32 client_wrk;
  u32 server_wrk;
  u32 transport_listener_index;
  transport_proto_t actual_tp;
  u32 client_opaque;
  u32 peer_index;
  u64 segment_handle;
  svm_fifo_t *client_rx_fifo;
  svm_fifo_t *client_tx_fifo;
  u8