src/vnet/ipsec/ipsec.c

   1 /*
   2  * decap.c : IPSec tunnel support
   3  *
   4  * Copyright (c) 2015 Cisco and/or its affiliates.
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at:
   8  *
   9  *     http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  */
  17
  18 #include <vnet/vnet.h>
  19 #include <vnet/api_errno.h>
  20 #include <vnet/ip/ip.h>
  21 #include <vnet/interface.h>
  22 #include <vnet/udp/udp.h>
  23
  24 #include <vnet/ipsec/ipsec.h>
  25 #include <vnet/ipsec/ikev2.h>
  26 #include <vnet/ipsec/esp.h>
  27 #include <vnet/ipsec/ah.h>
  28
  29
  30 ipsec_main_t ipsec_main;
  31
  32 u32
  33 ipsec_get_sa_index_by_sa_id (u32 sa_id)
  34 {
  35   ipsec_main_t *im = &ipsec_main;
  36   uword *p = hash_get (im->sa_index_by_sa_id, sa_id);
  37   if (!p)
  38     return ~0;
  39
  40   return p[0];
  41 }
  42
  43 int
  44 ipsec_set_interface_spd (vlib_main_t * vm, u32 sw_if_index, u32 spd_id,
  45                          int is_add)
  46 {
  47   ipsec_main_t *im = &ipsec_main;
  48   ip4_ipsec_config_t config;
  49
  50   u32 spd_index;
  51   uword *p;
  52
  53   p = hash_get (im->spd_index_by_spd_id, spd_id);
  54   if (!p)
  55     return VNET_API_ERROR_SYSCALL_ERROR_1;      /* no such spd-id */
  56
  57   spd_index = p[0];
  58
  59   p = hash_get (im->spd_index_by_sw_if_index, sw_if_index);
  60   if (p && is_add)
  61     return VNET_API_ERROR_SYSCALL_ERROR_1;      /* spd already assigned */
  62
  63   if (is_add)
  64     {
  65       hash_set (im->spd_index_by_sw_if_index, sw_if_index, spd_index);
  66     }
  67   else
  68     {
  69       hash_unset (im->spd_index_by_sw_if_index, sw_if_index);
  70     }
  71
  72   clib_warning ("sw_if_index %u spd_id %u spd_index %u",
  73                 sw_if_index, spd_id, spd_index);
  74
  75   /* enable IPsec on TX */
  76   vnet_feature_enable_disable ("ip4-output", "ipsec-output-ip4", sw_if_index,
  77                                is_add, 0, 0);
  78   vnet_feature_enable_disable ("ip6-output", "ipsec-output-ip6", sw_if_index,
  79                                is_add, 0, 0);
  80
  81   /* enable IPsec on RX */
  82   vnet_feature_enable_disable ("ip4-unicast", "ipsec-input-ip4", sw_if_index,
  83                                is_add, &config, sizeof (config));
  84   vnet_feature_enable_disable ("ip6-unicast", "ipsec-input-ip6", sw_if_index,
  85                                is_add, &config, sizeof (config));
  86
  87   return 0;
  88 }
  89
  90 int
  91 ipsec_add_del_spd (vlib_main_t * vm, u32 spd_id, int is_add)
  92 {
  93   ipsec_main_t *im = &ipsec_main;
  94   ipsec_spd_t *spd = 0;
  95   uword *p;
  96   u32 spd_index, k, v;
  97
  98   p = hash_get (im->spd_index_by_spd_id, spd_id);
  99   if (p && is_add)
 100     return VNET_API_ERROR_INVALID_VALUE;
 101   if (!p && !is_add)
 102     return VNET_API_ERROR_INVALID_VALUE;
 103
 104   if (!is_add)                  /* delete */
 105     {
 106       spd_index = p[0];
 107       spd = pool_elt_at_index (im->spds, spd_index);
 108       if (!spd)
 109         return VNET_API_ERROR_INVALID_VALUE;
 110       /* *INDENT-OFF* */
 111       hash_foreach (k, v, im->spd_index_by_sw_if_index, ({
 112         if (v == spd_index)
 113           ipsec_set_interface_spd(vm, k, spd_id, 0);
 114       }));
 115       /* *INDENT-ON* */
 116       hash_unset (im->spd_index_by_spd_id, spd_id);
 117       pool_free (spd->policies);
 118       vec_free (spd->ipv4_outbound_policies);
 119       vec_free (spd->ipv6_outbound_policies);
 120       vec_free (spd->ipv4_inbound_protect_policy_indices);
 121       vec_free (spd->ipv4_inbound_policy_discard_and_bypass_indices);
 122       pool_put (im->spds, spd);
 123     }
 124   else                          /* create new SPD */
 125     {
 126       pool_get (im->spds, spd);
 127       memset (spd, 0, sizeof (*spd));
 128       spd_index = spd - im->spds;
 129       spd->id = spd_id;
 130       hash_set (im->spd_index_by_spd_id, spd_id, spd_index);
 131     }
 132   return 0;
 133 }
 134
 135 static int
 136 ipsec_spd_entry_sort (void *a1, void *a2)
 137 {
 138   u32 *id1 = a1;
 139   u32 *id2 = a2;
 140   ipsec_spd_t *spd = ipsec_main.spd_to_sort;
 141   ipsec_policy_t *p1, *p2;
 142
 143   p1 = pool_elt_at_index (spd->policies, *id1);
 144   p2 = pool_elt_at_index (spd->policies, *id2);
 145   if (p1 && p2)
 146     return p2->priority - p1->priority;
 147
 148   return 0;
 149 }
 150
 151 int
 152 ipsec_add_del_policy (vlib_main_t * vm, ipsec_policy_t * policy, int is_add)
 153 {
 154   ipsec_main_t *im = &ipsec_main;
 155   ipsec_spd_t *spd = 0;
 156   ipsec_policy_t *vp;
 157   uword *p;
 158   u32 spd_index;
 159
 160   clib_warning ("policy-id %u priority %d is_outbound %u", policy->id,
 161                 policy->priority, policy->is_outbound);
 162
 163   if (policy->policy == IPSEC_POLICY_ACTION_PROTECT)
 164     {
 165       p = hash_get (im->sa_index_by_sa_id, policy->sa_id);
 166       if (!p)
 167         return VNET_API_ERROR_SYSCALL_ERROR_1;
 168       policy->sa_index = p[0];
 169     }
 170
 171   p = hash_get (im->spd_index_by_spd_id, policy->id);
 172
 173   if (!p)
 174     return VNET_API_ERROR_SYSCALL_ERROR_1;
 175
 176   spd_index = p[0];
 177   spd = pool_elt_at_index (im->spds, spd_index);
 178   if (!spd)
 179     return VNET_API_ERROR_SYSCALL_ERROR_1;
 180
 181   if (is_add)
 182     {
 183       u32 policy_index;
 184
 185       pool_get (spd->policies, vp);
 186       clib_memcpy (vp, policy, sizeof (*vp));
 187       policy_index = vp - spd->policies;
 188
 189       ipsec_main.spd_to_sort = spd;
 190
 191       if (policy->is_outbound)
 192         {
 193           if (policy->is_ipv6)
 194             {
 195               vec_add1 (spd->ipv6_outbound_policies, policy_index);
 196               clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 197               vec_sort_with_function (spd->ipv6_outbound_policies,
 198                                       ipsec_spd_entry_sort);
 199             }
 200           else
 201             {
 202               vec_add1 (spd->ipv4_outbound_policies, policy_index);
 203               clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 204               vec_sort_with_function (spd->ipv4_outbound_policies,
 205                                       ipsec_spd_entry_sort);
 206             }
 207         }
 208       else
 209         {
 210           if (policy->is_ipv6)
 211             {
 212               if (policy->policy == IPSEC_POLICY_ACTION_PROTECT)
 213                 {
 214                   vec_add1 (spd->ipv6_inbound_protect_policy_indices,
 215                             policy_index);
 216                   clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 217                   vec_sort_with_function
 218                     (spd->ipv6_inbound_protect_policy_indices,
 219                      ipsec_spd_entry_sort);
 220                 }
 221               else
 222                 {
 223                   vec_add1
 224                     (spd->ipv6_inbound_policy_discard_and_bypass_indices,
 225                      policy_index);
 226                   clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 227                   vec_sort_with_function
 228                     (spd->ipv6_inbound_policy_discard_and_bypass_indices,
 229                      ipsec_spd_entry_sort);
 230                 }
 231             }
 232           else
 233             {
 234               if (policy->policy == IPSEC_POLICY_ACTION_PROTECT)
 235                 {
 236                   vec_add1 (spd->ipv4_inbound_protect_policy_indices,
 237                             policy_index);
 238                   clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 239                   vec_sort_with_function
 240                     (spd->ipv4_inbound_protect_policy_indices,
 241                      ipsec_spd_entry_sort);
 242                 }
 243               else
 244                 {
 245                   vec_add1
 246                     (spd->ipv4_inbound_policy_discard_and_bypass_indices,
 247                      policy_index);
 248                   clib_memcpy (vp, policy, sizeof (ipsec_policy_t));
 249                   vec_sort_with_function
 250                     (spd->ipv4_inbound_policy_discard_and_bypass_indices,
 251                      ipsec_spd_entry_sort);
 252                 }
 253             }
 254         }
 255
 256       ipsec_main.spd_to_sort = NULL;
 257     }
 258   else
 259     {
 260       u32 i, j;
 261       /* *INDENT-OFF* */
 262       pool_foreach_index(i, spd->policies, ({
 263         vp = pool_elt_at_index(spd->policies, i);
 264         if (vp->priority != policy->priority)
 265           continue;
 266         if (vp->is_outbound != policy->is_outbound)
 267           continue;
 268         if (vp->policy != policy->policy)
 269           continue;
 270         if (vp->sa_id != policy->sa_id)
 271           continue;
 272         if (vp->protocol != policy->protocol)
 273           continue;
 274         if (vp->lport.start != policy->lport.start)
 275           continue;
 276         if (vp->lport.stop != policy->lport.stop)
 277           continue;
 278         if (vp->rport.start != policy->rport.start)
 279           continue;
 280         if (vp->rport.stop != policy->rport.stop)
 281           continue;
 282         if (vp->is_ipv6 != policy->is_ipv6)
 283           continue;
 284         if (policy->is_ipv6)
 285           {
 286             if (vp->laddr.start.ip6.as_u64[0] != policy->laddr.start.ip6.as_u64[0])
 287               continue;
 288             if (vp->laddr.start.ip6.as_u64[1] != policy->laddr.start.ip6.as_u64[1])
 289               continue;
 290             if (vp->laddr.stop.ip6.as_u64[0] != policy->laddr.stop.ip6.as_u64[0])
 291               continue;
 292             if (vp->laddr.stop.ip6.as_u64[1] != policy->laddr.stop.ip6.as_u64[1])
 293               continue;
 294             if (vp->raddr.start.ip6.as_u64[0] != policy->raddr.start.ip6.as_u64[0])
 295               continue;
 296             if (vp->raddr.start.ip6.as_u64[1] != policy->raddr.start.ip6.as_u64[1])
 297               continue;
 298             if (vp->raddr.stop.ip6.as_u64[0] != policy->raddr.stop.ip6.as_u64[0])
 299               continue;
 300            if (vp->laddr.stop.ip6.as_u64[1] != policy->laddr.stop.ip6.as_u64[1])
 301               continue;
 302            if (policy->is_outbound)
 303              {
 304                vec_foreach_index(j, spd->ipv6_outbound_policies) {
 305                  if (vec_elt(spd->ipv6_outbound_policies, j) == i) {
 306                    vec_del1 (spd->ipv6_outbound_policies, j);
 307                    break;
 308                  }
 309                }
 310              }
 311            else
 312              {
 313                if (policy->policy == IPSEC_POLICY_ACTION_PROTECT)
 314                  {
 315                    vec_foreach_index(j, spd->ipv6_inbound_protect_policy_indices) {
 316                      if (vec_elt(spd->ipv6_inbound_protect_policy_indices, j) == i) {
 317                        vec_del1 (spd->ipv6_inbound_protect_policy_indices, j);
 318                        break;
 319                      }
 320                    }
 321                  }
 322                else
 323                  {
 324                    vec_foreach_index(j, spd->ipv6_inbound_policy_discard_and_bypass_indices) {
 325                      if (vec_elt(spd->ipv6_inbound_policy_discard_and_bypass_indices, j) == i) {
 326                        vec_del1 (spd->ipv6_inbound_policy_discard_and_bypass_indices, j);
 327                        break;
 328                      }
 329                    }
 330                  }
 331              }
 332           }
 333         else
 334           {
 335             if (vp->laddr.start.ip4.as_u32 != policy->laddr.start.ip4.as_u32)
 336               continue;
 337             if (vp->laddr.stop.ip4.as_u32 != policy->laddr.stop.ip4.as_u32)
 338               continue;
 339             if (vp->raddr.start.ip4.as_u32 != policy->raddr.start.ip4.as_u32)
 340               continue;
 341             if (vp->raddr.stop.ip4.as_u32 != policy->raddr.stop.ip4.as_u32)
 342               continue;
 343             if (policy->is_outbound)
 344               {
 345                 vec_foreach_index(j, spd->ipv4_outbound_policies) {
 346                   if (vec_elt(spd->ipv4_outbound_policies, j) == i) {
 347                     vec_del1 (spd->ipv4_outbound_policies, j);
 348                     break;
 349                   }
 350                 }
 351               }
 352             else
 353               {
 354                 if (policy->policy == IPSEC_POLICY_ACTION_PROTECT)
 355                   {
 356                     vec_foreach_index(j, spd->ipv4_inbound_protect_policy_indices) {
 357                       if (vec_elt(spd->ipv4_inbound_protect_policy_indices, j) == i) {
 358                         vec_del1 (spd->ipv4_inbound_protect_policy_indices, j);
 359                         break;
 360                       }
 361                     }
 362                   }
 363                 else
 364                   {
 365                     vec_foreach_index(j, spd->ipv4_inbound_policy_discard_and_bypass_indices) {
 366                       if (vec_elt(spd->ipv4_inbound_policy_discard_and_bypass_indices, j) == i) {
 367                         vec_del1 (spd->ipv4_inbound_policy_discard_and_bypass_indices, j);
 368                         break;
 369                       }
 370                     }
 371                   }
 372               }
 373           }
 374           pool_put (spd->policies, vp);
 375           break;
 376       }));
 377       /* *INDENT-ON* */
 378     }
 379
 380   return 0;
 381 }
 382
 383 u8
 384 ipsec_is_sa_used (u32 sa_index)
 385 {
 386   ipsec_main_t *im = &ipsec_main;
 387   ipsec_spd_t *spd;
 388   ipsec_policy_t *p;
 389   ipsec_tunnel_if_t *t;
 390
 391   /* *INDENT-OFF* */
 392   pool_foreach(spd, im->spds, ({
 393     pool_foreach(p, spd->policies, ({
 394       if (p->policy == IPSEC_POLICY_ACTION_PROTECT)
 395         {
 396           if (p->sa_index == sa_index)
 397             return 1;
 398         }
 399     }));
 400   }));
 401
 402   pool_foreach(t, im->tunnel_interfaces, ({
 403     if (t->input_sa_index == sa_index)
 404       return 1;
 405     if (t->output_sa_index == sa_index)
 406       return 1;
 407   }));
 408   /* *INDENT-ON* */
 409
 410   return 0;
 411 }
 412
 413 int
 414 ipsec_add_del_sa (vlib_main_t * vm, ipsec_sa_t * new_sa, int is_add)
 415 {
 416   ipsec_main_t *im = &ipsec_main;
 417   ipsec_sa_t *sa = 0;
 418   uword *p;
 419   u32 sa_index;
 420   clib_error_t *err;
 421
 422   clib_warning ("id %u spi %u", new_sa->id, new_sa->spi);
 423
 424   p = hash_get (im->sa_index_by_sa_id, new_sa->id);
 425   if (p && is_add)
 426     return VNET_API_ERROR_SYSCALL_ERROR_1;      /* already exists */
 427   if (!p && !is_add)
 428     return VNET_API_ERROR_SYSCALL_ERROR_1;
 429
 430   if (!is_add)                  /* delete */
 431     {
 432       sa_index = p[0];
 433       sa = pool_elt_at_index (im->sad, sa_index);
 434       if (ipsec_is_sa_used (sa_index))
 435         {
 436           clib_warning ("sa_id %u used in policy", sa->id);
 437           return VNET_API_ERROR_SYSCALL_ERROR_1;        /* sa used in policy */
 438         }
 439       hash_unset (im->sa_index_by_sa_id, sa->id);
 440       if (im->cb.add_del_sa_sess_cb)
 441         {
 442           err = im->cb.add_del_sa_sess_cb (sa_index, 0);
 443           if (err)
 444             return VNET_API_ERROR_SYSCALL_ERROR_1;
 445         }
 446       pool_put (im->sad, sa);
 447     }
 448   else                          /* create new SA */
 449     {
 450       pool_get (im->sad, sa);
 451       clib_memcpy (sa, new_sa, sizeof (*sa));
 452       sa_index = sa - im->sad;
 453       hash_set (im->sa_index_by_sa_id, sa->id, sa_index);
 454       if (im->cb.add_del_sa_sess_cb)
 455         {
 456           err = im->cb.add_del_sa_sess_cb (sa_index, 1);
 457           if (err)
 458             return VNET_API_ERROR_SYSCALL_ERROR_1;
 459         }
 460     }
 461   return 0;
 462 }
 463
 464 int
 465 ipsec_set_sa_key (vlib_main_t * vm, ipsec_sa_t * sa_update)
 466 {
 467   ipsec_main_t *im = &ipsec_main;
 468   uword *p;
 469   u32 sa_index;
 470   ipsec_sa_t *sa = 0;
 471   clib_error_t *err;
 472
 473   p = hash_get (im->sa_index_by_sa_id, sa_update->id);
 474   if (!p)
 475     return VNET_API_ERROR_SYSCALL_ERROR_1;      /* no such sa-id */
 476
 477   sa_index = p[0];
 478   sa = pool_elt_at_index (im->sad, sa_index);
 479
 480   /* new crypto key */
 481   if (0 < sa_update->crypto_key_len)
 482     {
 483       clib_memcpy (sa->crypto_key, sa_update->crypto_key,
 484                    sa_update->crypto_key_len);
 485       sa->crypto_key_len = sa_update->crypto_key_len;
 486     }
 487
 488   /* new integ key */
 489   if (0 < sa_update->integ_key_len)
 490     {
 491       clib_memcpy (sa->integ_key, sa_update->integ_key,
 492                    sa_update->integ_key_len);
 493       sa->integ_key_len = sa_update->integ_key_len;
 494     }
 495
 496   if (0 < sa_update->crypto_key_len || 0 < sa_update->integ_key_len)
 497     {
 498       if (im->cb.add_del_sa_sess_cb)
 499         {
 500           err = im->cb.add_del_sa_sess_cb (sa_index, 0);
 501           if (err)
 502             return VNET_API_ERROR_SYSCALL_ERROR_1;
 503         }
 504     }
 505
 506   return 0;
 507 }
 508
 509 static void
 510 ipsec_rand_seed (void)
 511 {
 512   struct
 513   {
 514     time_t time;
 515     pid_t pid;
 516     void *p;
 517   } seed_data;
 518
 519   seed_data.time = time (NULL);
 520   seed_data.pid = getpid ();
 521   seed_data.p = (void *) &seed_data;
 522
 523   RAND_seed ((const void *) &seed_data, sizeof (seed_data));
 524 }
 525
 526 static clib_error_t *
 527 ipsec_check_support (ipsec_sa_t * sa)
 528 {
 529   if (sa->crypto_alg == IPSEC_CRYPTO_ALG_AES_GCM_128)
 530     return clib_error_return (0, "unsupported aes-gcm-128 crypto-alg");
 531   if (sa->integ_alg == IPSEC_INTEG_ALG_NONE)
 532     return clib_error_return (0, "unsupported none integ-alg");
 533
 534   return 0;
 535 }
 536
 537 static clib_error_t *
 538 ipsec_init (vlib_main_t * vm)
 539 {
 540   clib_error_t *error;
 541   ipsec_main_t *im = &ipsec_main;
 542   vlib_thread_main_t *tm = vlib_get_thread_main ();
 543   vlib_node_t *node;
 544
 545   ipsec_rand_seed ();
 546
 547   memset (im, 0, sizeof (im[0]));
 548
 549   im->vnet_main = vnet_get_main ();
 550   im->vlib_main = vm;
 551
 552   im->spd_index_by_spd_id = hash_create (0, sizeof (uword));
 553   im->sa_index_by_sa_id = hash_create (0, sizeof (uword));
 554   im->spd_index_by_sw_if_index = hash_create (0, sizeof (uword));
 555
 556   vec_validate_aligned (im->empty_buffers, tm->n_vlib_mains - 1,
 557                         CLIB_CACHE_LINE_BYTES);
 558
 559   node = vlib_get_node_by_name (vm, (u8 *) "error-drop");
 560   ASSERT (node);
 561   im->error_drop_node_index = node->index;
 562
 563   node = vlib_get_node_by_name (vm, (u8 *) "esp-encrypt");
 564   ASSERT (node);
 565   im->esp_encrypt_node_index = node->index;
 566
 567   node = vlib_get_node_by_name (vm, (u8 *) "esp-decrypt");
 568   ASSERT (node);
 569   im->esp_decrypt_node_index = node->index;
 570
 571   node = vlib_get_node_by_name (vm, (u8 *) "ah-encrypt");
 572   ASSERT (node);
 573   im->ah_encrypt_node_index = node->index;
 574
 575   node = vlib_get_node_by_name (vm, (u8 *) "ah-decrypt");
 576   ASSERT (node);
 577   im->ah_decrypt_node_index = node->index;
 578
 579   im->esp_encrypt_next_index = IPSEC_OUTPUT_NEXT_ESP_ENCRYPT;
 580   im->esp_decrypt_next_index = IPSEC_INPUT_NEXT_ESP_DECRYPT;
 581   im->ah_encrypt_next_index = IPSEC_OUTPUT_NEXT_AH_ENCRYPT;
 582   im->ah_decrypt_next_index = IPSEC_INPUT_NEXT_AH_DECRYPT;
 583
 584   im->cb.check_support_cb = ipsec_check_support;
 585
 586   if ((error = vlib_call_init_function (vm, ipsec_cli_init)))
 587     return error;
 588
 589   if ((error = vlib_call_init_function (vm, ipsec_tunnel_if_init)))
 590     return error;
 591
 592   ipsec_proto_init ();
 593
 594   if ((error = ikev2_init (vm)))
 595     return error;
 596
 597   return 0;
 598 }
 599
 600 VLIB_INIT_FUNCTION (ipsec_init);
 601
 602 /*
 603  * fd.io coding-style-patch-verification: ON
 604  *
 605  * Local Variables:
 606  * eval: (c-set-style "gnu")
 607  * End:
 608  */