Line data Source code
1 : /* 2 : *------------------------------------------------------------------ 3 : * pppoe_api.c - pppoe api 4 : * 5 : * Copyright (c) 2017 Intel and/or its affiliates. 6 : * Licensed under the Apache License, Version 2.0 (the "License"); 7 : * you may not use this file except in compliance with the License. 8 : * You may obtain a copy of the License at: 9 : * 10 : * http://www.apache.org/licenses/LICENSE-2.0 11 : * 12 : * Unless required by applicable law or agreed to in writing, software 13 : * distributed under the License is distributed on an "AS IS" BASIS, 14 : * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 15 : * See the License for the specific language governing permissions and 16 : * limitations under the License. 17 : *------------------------------------------------------------------ 18 : */ 19 : 20 : #include <vnet/interface.h> 21 : #include <vnet/api_errno.h> 22 : #include <vnet/feature/feature.h> 23 : #include <vnet/fib/fib_table.h> 24 : #include <vnet/ip/ip_types_api.h> 25 : #include <vppinfra/byte_order.h> 26 : #include <vlibmemory/api.h> 27 : 28 : 29 : #include <pppoe/pppoe.h> 30 : 31 : #include <vnet/format_fns.h> 32 : #include <pppoe/pppoe.api_enum.h> 33 : #include <pppoe/pppoe.api_types.h> 34 : 35 : #define REPLY_MSG_ID_BASE pem->msg_id_base 36 : #include <vlibapi/api_helper_macros.h> 37 : 38 18 : static void vl_api_pppoe_add_del_session_t_handler 39 : (vl_api_pppoe_add_del_session_t * mp) 40 : { 41 : vl_api_pppoe_add_del_session_reply_t *rmp; 42 18 : int rv = 0; 43 : u32 decap_fib_index; 44 18 : ip4_main_t *im = &ip4_main; 45 18 : pppoe_main_t *pem = &pppoe_main; 46 : 47 18 : uword *p = hash_get (im->fib_index_by_table_id, ntohl (mp->decap_vrf_id)); 48 18 : if (!p) 49 : { 50 0 : rv = VNET_API_ERROR_NO_SUCH_INNER_FIB; 51 0 : goto out; 52 : } 53 18 : decap_fib_index = p[0]; 54 : 55 18 : vnet_pppoe_add_del_session_args_t a = { 56 18 : .is_add = mp->is_add, 57 : .decap_fib_index = decap_fib_index, 58 18 : .session_id = ntohs (mp->session_id), 59 : }; 60 18 : ip_address_decode (&mp->client_ip, &a.client_ip); 61 18 : clib_memcpy (a.client_mac, mp->client_mac, 6); 62 : 63 18 : u32 sw_if_index = ~0; 64 18 : rv = vnet_pppoe_add_del_session (&a, &sw_if_index); 65 : 66 18 : out: 67 : /* *INDENT-OFF* */ 68 18 : REPLY_MACRO2(VL_API_PPPOE_ADD_DEL_SESSION_REPLY, 69 : ({ 70 : rmp->sw_if_index = ntohl (sw_if_index); 71 : })); 72 : /* *INDENT-ON* */ 73 : } 74 : 75 0 : static void send_pppoe_session_details 76 : (pppoe_session_t * t, vl_api_registration_t * reg, u32 context) 77 : { 78 : vl_api_pppoe_session_details_t *rmp; 79 0 : ip4_main_t *im4 = &ip4_main; 80 0 : ip6_main_t *im6 = &ip6_main; 81 0 : u8 is_ipv6 = !ip46_address_is_ip4 (&t->client_ip); 82 : 83 0 : rmp = vl_msg_api_alloc (sizeof (*rmp)); 84 0 : clib_memset (rmp, 0, sizeof (*rmp)); 85 0 : rmp->_vl_msg_id = ntohs (VL_API_PPPOE_SESSION_DETAILS); 86 0 : ip_address_encode (&t->client_ip, is_ipv6 ? IP46_TYPE_IP6 : IP46_TYPE_IP4, 87 : &rmp->client_ip); 88 : 89 0 : if (is_ipv6) 90 : { 91 0 : rmp->decap_vrf_id = htonl (im6->fibs[t->decap_fib_index].ft_table_id); 92 : } 93 : else 94 : { 95 0 : rmp->decap_vrf_id = htonl (im4->fibs[t->decap_fib_index].ft_table_id); 96 : } 97 0 : rmp->session_id = htons (t->session_id); 98 0 : rmp->encap_if_index = htonl (t->encap_if_index); 99 0 : clib_memcpy (rmp->local_mac, t->local_mac, 6); 100 0 : clib_memcpy (rmp->client_mac, t->client_mac, 6); 101 0 : rmp->sw_if_index = htonl (t->sw_if_index); 102 0 : rmp->context = context; 103 : 104 0 : vl_api_send_msg (reg, (u8 *) rmp); 105 0 : } 106 : 107 : static void 108 0 : vl_api_pppoe_session_dump_t_handler (vl_api_pppoe_session_dump_t * mp) 109 : { 110 : vl_api_registration_t *reg; 111 0 : pppoe_main_t *pem = &pppoe_main; 112 : pppoe_session_t *t; 113 : u32 sw_if_index; 114 : 115 0 : reg = vl_api_client_index_to_registration (mp->client_index); 116 0 : if (!reg) 117 0 : return; 118 : 119 0 : sw_if_index = ntohl (mp->sw_if_index); 120 : 121 0 : if (~0 == sw_if_index) 122 : { 123 : /* *INDENT-OFF* */ 124 0 : pool_foreach (t, pem->sessions) 125 : { 126 0 : send_pppoe_session_details(t, reg, mp->context); 127 : } 128 : /* *INDENT-ON* */ 129 : } 130 : else 131 : { 132 0 : if ((sw_if_index >= vec_len (pem->session_index_by_sw_if_index)) || 133 0 : (~0 == pem->session_index_by_sw_if_index[sw_if_index])) 134 : { 135 0 : return; 136 : } 137 0 : t = &pem->sessions[pem->session_index_by_sw_if_index[sw_if_index]]; 138 0 : send_pppoe_session_details (t, reg, mp->context); 139 : } 140 : } 141 : 142 : static void 143 0 : vl_api_pppoe_add_del_cp_t_handler (vl_api_pppoe_add_del_cp_t * mp) 144 : { 145 : vl_api_pppoe_add_del_cp_reply_t *rmp; 146 0 : i32 rv = 0; 147 0 : pppoe_main_t *pem = &pppoe_main; 148 : 149 0 : rv = pppoe_add_del_cp (ntohl (mp->sw_if_index), mp->is_add); 150 : 151 : /* *INDENT-OFF* */ 152 0 : REPLY_MACRO(VL_API_PPPOE_ADD_DEL_CP_REPLY); 153 : /* *INDENT-ON* */ 154 : } 155 : 156 : #include <pppoe/pppoe.api.c> 157 : static clib_error_t * 158 575 : pppoe_api_hookup (vlib_main_t * vm) 159 : { 160 575 : pppoe_main_t *pem = &pppoe_main; 161 : 162 575 : pem->msg_id_base = setup_message_id_table (); 163 575 : return 0; 164 : } 165 : 166 1151 : VLIB_API_INIT_FUNCTION (pppoe_api_hookup); 167 : 168 : /* 169 : * fd.io coding-style-patch-verification: ON 170 : * 171 : * Local Variables: 172 : * eval: (c-set-style "gnu") 173 : * End: 174 : */