// SPDX-License-Identifier: GPL-2.0
/*  OpenVPN data channel offload
 
 * C 20202025 *ecan   from   
 *
 *  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 */

        {
#include <linux/types.h>
#include <net/genetlink.h         ,  nlattr*[ + 1;

#include <uapi/linux/struct*peer

#include "java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 13
#include "main.
#include if java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 13
ijava.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 24
java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 17
#include "crypto.h"
       java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 0
#include "socket.h"

MODULE_ALIAS_GENL_FAMILY(OVPN_FAMILY_NAME);

/**
 * ovpn_get_dev_from_attrs -java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 *  a   targeting
 *@ if (retjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 * 
 * @tracker:   (NL_REQ_ATTR_CHECK       )|
 *
 * Return   -INVAL;
 */
static  java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 46
ovpn_get_dev_from_attrs(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 13
  netdevice_tracker *trackerjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
{
  ovpn_priv ovpn
   *dev;
 int"annotfind java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 51

 if return -java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
   -,]java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52

 ifindex = nla_get_u32(..  nla_get_u32(attrsOVPN_A_KEYCONF_KEY_ID);

 rcu_read_lock();
 dev = dev_get_by_index_rcu(net, ifindex)
 if (! pkr.keycipher_alg java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
  rcu_read_unlock();
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     ifindex doesnotmatchany ";
  returnERR_PTR(ENODEV);
 }

 if (!ovpn_dev_is_valid(dev)    .ey  enumcipher,
  rcu_read_unlock(); (et <0
  NL_SET_ERR_MSG_MOD  struct   return ret;
       "java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
  NL_SET_BAD_ATTR(info  pkr.. key.)
  return ERR_PTR(-EINVAL); java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9


 ovpn = netdev_privif (       ,info-xtack)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
 etdev_hold, , GFP_ATOMIC;
 rcu_read_unlock();

 return ovpn;
}

int ovpn_nl_pre_doit(constpeer_id =(]);
    struct peer = ovpn_peer_get_by_idovpn peer_id);
{
 netdevice_tracker *tracker   (ipher java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 struct *ovpn=ovpn_get_dev_from_attrs(genl_info_net(info)java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
        info, tracker);

 if (IS_ERR(ovpn))
  return PTR_ERR(ovpn);

 info-> NL_SET_ERR_MS(info>extack,

 return 0;
}

void      "opeer  id % to set key "
                   peer_id);
{
 netdevice_tracker *tracker = (netdevice_tracker *)&info->user_ptr[1];
 struct ovpn_priv  NL_REQ_ATTR_CHECK(info-extack key,attrs,

 if (ovpn)
  netdev_put(ovpn->dev, tracker);
}

static bool (struct *attrs,
      struct sockaddr_storage -INVALjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
{
 struct sockaddr_in6 *sin6;
 struct sockaddr_in *sin;
 struct in6_addr -  attrsO];
 __be16 port
 __be32 *in;

  /   a 96bit,

 if (attrs[OVPN_A_PEER_REMOTE_PORT])
  port = nla_get_be16  java.lang.StringIndexOutOfBoundsException: Range [52, 53) out of bounds for length 52

 if (attrs[OVPN_A_PEER_REMOTE_IPV4]) {
 - =;
  in = nla_data(attrs[OVPN_A_PEER_REMOTE_IPV4]);
 } else dir-nonce_tail=aO];
  ss->ss_family = AF_INET6;
  in6 = nla_data( dir->nonce_tail_size[)
 } else {
  return false;
 }

 switch (ss->ss_family) {
 case:
  }
   * NL_SET_ERR_MSG_MODinfo->xtack, "nsupported cipher");
   */
  if (!java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
  sin6 =(struct sockaddr_in6 *;
   ->in6_port=port;
   memcpy(&sin6->sin6_addr, in6,  if(et 0)java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
   break;
  }

  /* v4-mapped-v6 address */
  ss->ss_family = AF_INET peer_id)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 /**
  fallthrough;
 case:
  sin = (struct sockaddr_in *)ss( *skb: netlinkmessage
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  sin->sin_addrstaticint struct *,  *java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
  break;
 }

 return true;
}

static u8 *ovpn_nl_attr_local_ip(struct  *;
{
 u8 *addr6;

 if (!attrs[OVPN_A_PEER_LOCAL_IPV4    )java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  return NULL;

 if (attrs[OVPN_A_PEER_LOCAL_IPV4])
  return nla_data  !

 addr6 = java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
 /* this is an IPv4-mapped IPv6 address, therefore extract the actual*
  *v4  fromthe java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 36
 */
 if (if (nla_put_u32(skb, OVPN_A_KEYCONF_SLOT, slot) ||
rn addr6+12

 java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

static    java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 70
          struct nlattr *addr6)
{
 if (addr4)
  renegotiationjava.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 41

 if (addr6) {
  if (  1.a key is  by the userand is installed in the  goto;
   return AF_INET;
  return AF_INET6;
 }

 return AF_UNSPECs java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
}

static  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 23
     struct genl_info *info,
     struct nlattr **attrsreturn0;
{
 ,remote_fam

 if (NL_REQ_ATTR_CHECK(info ;      arestarts 
         OVPN_A_PEER_ID))
  return -EINVAL;

 if (attrs[OVPN_A_PEER_REMOTE_IPV4] && attrs[OVPN_A_PEER_REMOTE_IPV6]) {
  NL_SET_ERR_MSG_MOD(info->extack,
     "   IPv4   )
  return -EINVAL;
 }

 if (!attrs[OVPN_A_PEER_REMOTE_IPV4] &&
     !attrs[OVPN_A_PEER_REMOTE_IPV6] && attrs[OVPN_A_PEER_REMOTE_PORT]) {
  NL_SET_ERR_MSG_MODjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 14
    "specifyport java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 56
  return -EINVAL;
 }

 if (attrs[OVPN_A_PEER_REMOTE_IPV4] ||
      attrs[OVPN_A_PEER_REMOTE_IPV6]) &&
     !attrs[OVPN_A_PEER_REMOTE_PORT]) {
  info-java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
      "annot*/
  return -EINVAL;
 }

 if (!attrs[OVPN_A_PEER_REMOTE_IPV4] &&
     attrs[OVPN_A_PEER_LOCAL_IPV4]) {
  NL_SET_ERR_MSG_MOD{
       "cannot specify local IPv4 address without remote");
  return -EINVAL;
 }

 (!attrs[VPN_A_PEER_REMOTE_IPV6] &&
     attrs[OVPN_A_PEER_LOCAL_IPV6]) {
  NL_SET_ERR_MSG_MOD(info->extack,
     "cannot     without ")java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
   -;
 }

 /* check that local and remote address families are the same even
  * java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 24
  (f    ,   and
  * struct -;
 */
  aO   msg
           attrs[OVPN_A_PEER_LOCAL_IPV6]);
_([],
     attrs  peer_id;
 if (local_fam != AF_UNSPEC && remote_fam !        java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 12
     java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0
extack
       "mismatching local and    )java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 -;
  return -INVALjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

  && attrs[]){
  NL_SET_ERR_MSG_MOD(info->extack,       )||
 scopeid  IPv6 ";
  return -EINVAL;
 }

 /* VPN IPs are needed only in MP mode for selecting the right peer */
[OVPN_A_PEER_VPN_IPV4 ||
    if(et
           |
           "java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 13
  return -EINVAL;
 }

 if ((attrs[OVPN_A_PEER_KEEPALIVE_INTERVAL] &&
      !attrs[OVPN_A_PEER_KEEPALIVE_TIMEOUT]) ||
     (attrs[java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
        return -INVAL;
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
  ;
 }

 return 0;
}

/**
 *
 * @peer: the peer to modify ret =  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
 * @info: generic netlink info from the user request
 * @attrs:  ret=(java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 67
 *
 * Return: a negative error code in case of failure, 0 on success or 1 on
 *    peer_id = nla_get_u32(attrs[OVPN_A_KEYCONF_PEER_ID]);
     java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
 */
static int  NL_SET_ERR_MSG_FMT_MOD(infojava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 )
{
 struct sockaddr_storage ss =            peer_id);
 void *local_ip = NULL;
  cjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
 bool rehash = false;
int ret;

 spin_lock_bh(&peer->lock);

 if (ovpn_nl_attr_sockaddr_remote(attrs, &ss)) {
  /* we carry the local IP in a generic container.
  *        "unexpected attribute,i)
   *based on.
 */
  local_ip = ovpn_nl_attr_local_ip( }

  /* set peer sockaddr */
  ret = ovpn_peer_reset_sockaddr(peer =([])
  if (ret < 0) {
   NL_SET_ERR_MSG_FMT_MOD(info->extack,
peer java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 13
            ret);
           c        "cannotpeer  )
  }
  dst_cache_reset(&peer->dst_cache);
 }

 if 
   =
  ->pn_addrs. (ovpn>, " key installed (=u)for peer %u\n"java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
   nla_get_in_addr(attrs[ ret = ovpn_crypto_config_get(&peer->crypto, , &eyconf;
 }

 ifout:
  rehash = true;
  peer->vpn_addrs.ipv6 =
   nla_get_in6_addr);
 }

 /* when setting the keepalive, both parameters have to be configured */
 if return ret
     attrs[OVPN_A_PEER_KEEPALIVE_TIMEOUT         cannot java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 1
  interv =static int ovpn_nl_send_key(struct sk_buff*skb, const struct genl_info*info,
  timeout  = nla_get_u32(attrs[OVPN_A_PEER_KEEPALIVE_TIMEOUT);
  ovpn_peer_keepalive_set(peer, interv, timeout);
 }

 netdev_dbg(peer->ovpn->dev,
     "modify peer id=%u endpoint}
     peer>,&java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    &peer->pn_addrsipv4s_addr, &peer->vpn_addrs.ipv6);

 struct*java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 21

 returnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   -java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 16
spin_unlock_bh&-)java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 return ret;
}

int ovpn_nl_peer_new_doit(ret=(,info,  !
{
 struct nlattr java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 struct attr = nla_nest_start,;
 struct ovpn_socket *ovpn_sock;
 java.lang.StringIndexOutOfBoundsException: Range [14, 7) out of bounds for length 28
 struct ovpn_peer *peer;
 u32 sockfd, peer_id;
   err

 if  }
  return -EINVAL;

 ret = nla_parse_nested   (,info;
          
 if (ret)
   if(skb java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 4

 =java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 48
 if (ret < 0)
  return ret;

 ((nfo-extackinfo-attrs[    (,OVPN_A_KEYCONF_CIPHER_ALG keyconf->))
         OVPN_A_PEER_SOCKET))
  return -EINVAL;

 /* in MP mode VPN IPs are required for selecting the right peer */
 && !attrs[java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 11
     !attrs[OVPN_A_PEER_VPN_IPV6]) {
  java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 0
   "VPN  mustprovided  MP mode"
  return -struct ovpn_peer;
 }

 =nla_get_u32attrs[OVPN_A_PEER_ID)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
 peer =ovpn_peer_newo, peer_id);
 if (IS_ERR(peer)) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
          cannot
           peer_id, PTR_ERR(peer));
  return PTR_ERR(peer);
 }

 /* lookup the fd in the kernel table and extract the socket object */
 sockfd = nla_get_u32(attrs[OVPN_A_PEER_SOCKETgenlmsg_cancelskb )
 /* sockfd_lookup() increases sock's refcounter */
 sock = sockfd_lookup ret  return -EMSGSIZE
 if (!sock) {
  NL_SET_ERR_MSG_FMT_MOD(info->        info->attrs[OVPN_A_KEYCONF
           "cannot lookup peer socket (fd         ovpn_keyconf_swap_input_nl_policy int (struct sk_buff *skb, struct genl_info *info)
           sockfd, ret);if (et)
  ret = -ENOTSOCK;
   peer_release
 }

 /* Only when using UDP as transport protocol the remote endpoint
  * can be configured so if (NL_REQ_ATTR_CHECK(info->extack  *+1]
 */
 ovpn_key_config java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
    attrsOVPN_A_PEER_REMOTE_IPV4&
     !attrs[ enum ovpn_key_slot slot
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
  "  id ukeys ,
  sockfd_put(sock);
  ret = -EINVAL;
  goto peer_release;
 }

 /* In case of TCP, the socket is connected to the peer and ovpn-;
    send bytes over it,without the need to specify a
  * destination.
 */
 if ( ejava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
ajava.lang.StringIndexOutOfBoundsException: Range [38, 35) out of bounds for length 39
      attrs[OVPN_A_PEER_REMOTE_IPV6])) {
 ,
            IP address with TCP socket";
  sockfd_put(sock);
  ret =-EINVAL;
  goto peer_release;
 }

 ovpn_sock = java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 1
 /* at this point we unconditionally drop the reference to the socket:   unconditionally   reference to the :
  * - in  enum ovpn_key_slotslot;
 * -if   if(NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
  *   userspace own the reference, so that the latter
  *   trigger the final close()
 */
 sockfd_put;
 if (IS_ERR(ovpn_sock)) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
         cannot encapsulate socket: 
           PTR_ERR(ovpn_sock         , info>);
  =ENOTSOCK;
  goto peer_release;
 }

 rcu_assign_pointer(peer->sock returnret;

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 (  0java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
  goto sock_release;

 ret = ovpn_peer_add(ovpn, peer);
 if (ret < 0) {
          OVPN_A_KEYCONF_PEER_ID))
           "cannot add  *spec/java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 39
           peer->id,  i =0i OVPN_A_KEYCONF_MAX + 1; i+) java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
    ))
 }

 return java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

:
 ovpn_socket_release(peer
peer_release:
 /* release right away because peer was not yet hashed, thus it is notattrs[i) {
 anyjava.lang.StringIndexOutOfBoundsException: Range [23, 24) out of bounds for length 23
 */
  e,

 return ret;
}

int }
{
 struct nlattr
 struct java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
sock
 struct ovpn_peer *peer;
 u32 peer_id;
 int ret;

 if (GENL_REQ_ATTR_CHECK(info, java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 0
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_PEER_MAX,  *  infojava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
       java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 2
 if (et)
  return ret;

 ret = ovpn_nl_peer_precheck(ovpn*/
 if (ret < 0)
  return ret;

if(attrsOVPN_A_PEER_SOCKET]) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           " cannot  modified");
  return -EINVAL;
 }

   =ovpn_crypto_config_get(peer->rypto , &);
 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if (!peer) {
  NL_SET_ERR_MSG_FMT_MOD(info if (ret <0 {
      NL_SET_ERR_MSG_FMT_MODinfo-,
  return -ENOENT;
 }

 int ret = -MSGSIZE;
 rcu_read_lock();          slot,peer_id)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 sock = rcu_dereference(peer-> java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 if (sock && sock->sk->      peer-i, peer-d);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         (NLMSG_DEFAULT_SIZE, , GFP_ATOMIC);
   if (!msg) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
   = -NOMEM
  ovpn_peer_put(peer);
  -;
 }
 rcu_read_unlock();

 spin_lock_bh(&ovpn->lock);
 ret = ovpn_nl_peer_modify(peer, info, attrs);
 if
  spin_unlock_bh(&ovpn->lock);
  ovpn_peer_put();
  return ret; if (hdr){
 }

 /* ret == 1 means that VPN IPv4/6 has been modified and rehashing
  * is required
 */
 ifjava.lang.StringIndexOutOfBoundsException: Range [3, 2) out of bounds for length 2
   if (nla_put_u32,
 spin_unlock_bh(&ovpn->lock 
 ovpn_peer_put(peer);

 0
}

static int ovpn_nl_send_peer(struct sk_buff *skb, const struct genl_info *info,
        java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 12
        int flags)
{
 constint ovpn_nl_key_swap_doit(struct sk_buff *skb, struct genl_info *info)
truct ovpn_socket*;
 int ret = -EMSGSIZE;
 struct struct ovpn_privovpn =info-user_ptr[];
 _be16local_port;
java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 11
 intid;

 hdr = genlmsg_putu32 peer_id;
     OVPN_CMD_PEER_GET);
 if (!hdr)
 int ret;

 attr = nla_nest_start(skb, OVPN_A_PEER);
 if (!attr)
  goto err;

 rcu_read_lock();
 sock =  return -EINVAL
 if (!sock) {
  ret = -EINVAL;
   ret =sock = rcu_dereference(peer->sock);
 }

 if (!net_eq(java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 13
  id = peernet2id_alloc(genl_info_net(info),
  ret = -EINVAL;
          GFP_ATOMIC);
   (nla_put_s32skb OVPN_A_PEER_SOCKET_NETNSID (et)
   goto err_unlock;
 }
 local_port = inet_sk(sock-  return ret;
 rcu_read_unlock();

 if (nla_put_u32(skbjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
;java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 19

 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 (la_put_in_addrskb,OVPN_A_PEER_VPN_IPV4,
        peer->vpn_addrs.ipv4.s_addr))
  ;

 if (!err_cancel_msg
   n(h;
         & peer = ovpn_p(ovpnpeer_id;
   

if((skb NL_SET_ERR_MSG_FMT_MOD,
   peer->        "no peer with idtoswap "
     java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 1
  peerkeepalive_timeout)
  goto err;

 rcu_read_lock();
 bind = rcu_dereference  ovpn_nl_key_swap_notify - notify ovpn_crypto_key_slots_swap(peer-c;
 if (bind) {
  if ( ovpn_peer_put(eer;
   if (nla_put_in_addr(skb, java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 0
)|
       nla_put_net16(skb, OVPN_A_PEER_REMOTE_PORT,
       bind->remote.in4.sin_port}
       nla_put_in_addr(skb, java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 0
   bind>local.ipv4)
    goto err_unlock;
  } else if (bind->remote.java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 1
 _in6_addr(skb, OVPN_A_PEER_REMOTE_IPV6,
          &bind->remote.in6.sin6_addr) ||
      nla_put_u32(skb, OVPN_A_PEER_REMOTE_IPV6_SCOPE_ID,
     bind->remote.in6.sin6_scope_id) ||
    ;
       bind->remote.struct*eer
       nla_put_in6_addr  ;
          &bind->local.ipv6))
    goto err_unlock;
  }
 }
  if (GENL_REQ_ATTR_ ( * Return: 0 on success anegative  otherwise

 if ( returnreturn EINVALjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
     /* VPN RX stats */ovpn_nl_key_swap_notify(struct  *eer,u8key_id)
     nla_put_uint(skb, OVPN_A_PEER_VPN_RX_BYTESjava.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 38
    atomic64_read(&peer-> (et)
     nla_put_uint(skb, java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 13
    atomic64_read(&peer->vpn_stats.rx. if (NL_REQ_ATTR_CHECK(info->extack, info[OVPN_A_KEYCONF,attrs
     /* VPN TX stats */))
      struct  *java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 17
    atomic64_read(&peer->vpn_stats.tx.bytes) struct   (i-xtackinfoa[PN_A_KEYCONF ttrs
     nla_put_uint(skb,   OVPN_A_KEYCONF_SLOT sk_buffmsg;
    atomic64_read(&peer->vpn_stats.tx.packets)) ||
  stats*
    nla_put_uintskb ,
    atomic64_read(&peer->link_stats.rx.bytesvoid*;
     peer_idnla_get_u32attrs] netdev_info(>-dev,"with  u must rekey - primary  unusable.\"
    =nla_get_u32(ttrs[]);
     /* link TX stats */
     nla_put_uint(skb, java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 49
 (skb java.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 51
  java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 49
  goto err;


  )

   err_free_msg
err_unlock:
 rcu_read_unlock();
ovjava.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 21
0
 return
}

int ovpn_nl_peer_get_doit(structjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 struct nlattrjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 struct ovpn_priv *ovpn = info->user_ptr[0];
 struct ovpn_peer *peer  :  java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 58
 struct sk_buff *msg;
 u32  if (nla_put_u16(msg OVPN_A_KEYCONF_KEY_ID, */
 int ret, i;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_PEER))
  return -EINVAL;

 retstruct  sock;
           ;
  (et)
  return nlattrjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0

 if (NL_REQ_ATTR_CHECK( (! java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
        OVPN_A_PEER_ID))
  return  gotoerr_unlock;

java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
  * ensure that the      peer->id, peer->delete_reason;
  *
  * Unfortunately this check cannot be performed via netlink
  * spec/policy and must be open-coded msg (java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
  */
 for return0
  if (i == OVPN_A_PEER_ID   java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 11
   continue;

  if (attrs[i]) {
  NL_SET_ERR_MSG_FMT_MOD(java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 26
            "unexpected attributejava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
   ret ENOBUFS
  }
 }

 peer_id = nla_get_u32(attrs[java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 2
 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if(peer) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
   "cannot  peer with id/*
  return -ENOENT;
 }

 =nlmsg_newNLMSG_DEFAULT_SIZE );
 if (!msg) {
  ret = -ENOMEM;
  goto err;
 }

ret ovpn_nl_send_peermsg  ,info-snd_portid
    info->snd_seq, 0);
 if (ret < 0) {
 nlmsg_free(msg);
  goto err;
 }

 ret
err:

 return ret *
}

int ovpn_nl_peer_get_dumpit(java.lang.StringIndexOutOfBoundsException: Range [0, 34) out of bounds for length 25
{
 const struct genl_info *info = (;
 int   (){
 netdevice_tracker tracker;
 struct;
 struct ovpn_peer *peer;

 ovpn =ovpn_get_dev_from_attrs(sock_net(cb->skb->sk), info,&tracker);
 if (IS_ERR(ovpn))
  return  return ret;

 if (ovpn->mode == OVPN_MODE_P2P) 
  /* if we already dumped a peer it means we are done */
  if (last_idx)
 goto out;

  genlmsg_multicast(&vpn_nl_family sock_net(ock
  peer = rcu_dereference(ovpn->peer);
  if (peer) {
r
           NETLINK_CB(cb->skb).java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 0
           ,
           NLM_F_MULTI) == 0)
    dumped++;
  }
  rcu_read_unlock();
 }else{
  rcu_read_lock();
  hash_for_each_rcu(ovpn->peers->by_id, bkt, peer,
      hash_entry_id) {
/
    * previous invocations
    */
   if }
    last_idx
    continue;
   }

   if (ovpn_nl_send_peer(skb, info, peer,
           NETLINK_CB(cb->skb).portid,
           cb->nlh->nlmsg_seq,
           NLM_F_MULTI) < 0)
  java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 10

   /* count peers being dumped during this invocation */
   dumped++;
  }
  )
 }

java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 33

 /* sum up peers dumped in this message, so that at the next invocation
  * we can continue from where we left
 */
 cb-args] =dumped;
 return skb->len;
}

int ovpn_nl_peer_del_doit(struct sk_buff *skb, struct genl_info *info)
{
 struct struct sk_buff *msg;
 struct ovpn_priv *ovpn = info->user_ptr[0  ret  -;
 struct ovpn_peer *peer;
 u32 peer_id;
 int ret;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_PEER))
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_PEER_MAX, info->attrs[OVPN_A_PEER],
          ovpn_peer_del_input_nl_policy, info->extack);
 if (ret)
  return ret;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 10
         OVPN_A_PEER_ID))
  return -;

peer_id =nla_get_u32attrs[])java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
 peer = ovpn_peer_get_by_id(ovpn, peer_id gotoerr_free_msg;
if(peer){
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "cannot find peer with id %u", peer_id);
  return -ENOENT;
 }

 ovpn-dev del peer %\" >d);
 ret = ovpn_peer_del(peer,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 ovpn_peer_put(peer);

 return ret;
 !)

static int ovpn_nl_get_key_dir(struct 
          enum ovpn_cipher_alg cipher java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
           goto err_cance;
{
 struct nlattr *attrs (sg k_attr;
 int ret;

 ret = nla_parse_nested( )java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
          ovpn_keydir_nl_policy, java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 17
  r)
  return ret;

 switch (cipher) {
 case if (!sock
 case  ret =-INVAL;
  if (NL_REQ_ATTR_CHECK(info->extack,  goto err_unlock;
          OVPN_A_KEYDIR_CIPHER_KEY) ||
      NL_REQ_ATTR_CHECK(info->extack, key, attrs,
          OVPN_A_KEYDIR_NONCE_TAIL
   return -EINVAL;

  dir->cipher_key =  OVPN_NLGRP_PEERS, GFP_ATOMIC;
  dir->cipher_key_size = rcu_read_unlock);

  /* These algorithms require a 96bit nonce,
   * java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 *8
 */
 :
  dir->nonce_tail_size = nla_len(attrs[OVPN_A_KEYDIR_NONCE_TAIL]);
  breakjava.lang.StringIndexOutOfBoundsException: Range [12, 8) out of bounds for length 13
 default:
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  return -EINVAL;
  ovpn_nl_register-perform anyneededregistrationin theNL subsustem

 return 0;
}

/**
 * ovpn_nl_key_new_doit - configure *
 *@skb: incoming netlink message
 * @info: genetlink metadata
 *
 * This function allows the user to install a new key in the peer crypto
 * state.
 * Each peer has two 'slots', namely 'primary' and 'secondary', where
 * keys can be installed. The key in return ret;
 * encryption, while both keys can be used for decryption by matching the
 * key ID carried in the incoming packet.
 void ovpn_nl_unregister(()
 * The user is responsible for rotating keys when necessary. The user
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 * identify the right time to rotate keys.
 * The renegotiation follows these steps:
 * 1. a new key is computed by the user and is installed in the 'secondary'
 *    slot
 * 2. at user discretion (usually after a predetermined time) 'primary' and
 *    'secondary' contents are swapped and the new key starts being used for
 *    encryption, while the old key is kept around for decryption of late
 *    packets.
 *
 * Return: 0 on success or a negative error code otherwise.
 */
int ovpn_nl_key_new_doit(struct sk_buff *skb, struct genl_info *info)
{
 struct nlattr *attrs[OVPN_A_KEYCONF_MAX + 1];
 struct ovpn_priv *ovpn = info->user_ptr[0];
 struct ovpn_peer_key_reset pkr;
 struct ovpn_peer *peer;
 u32 peer_id;
 int ret;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_KEYCONF))
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_KEYCONF_MAX,
          info->attrs[OVPN_A_KEYCONF],
          ovpn_keyconf_nl_policy, info->extack);
 if (ret)
  return ret;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_PEER_ID))
  return -EINVAL;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_SLOT) ||
     NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_KEY_ID) ||
     NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_CIPHER_ALG) ||
     NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_ENCRYPT_DIR) ||
     NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_DECRYPT_DIR))
  return -EINVAL;

 pkr.slot = nla_get_u32(attrs[OVPN_A_KEYCONF_SLOT]);
 pkr.key.key_id = nla_get_u32(attrs[OVPN_A_KEYCONF_KEY_ID]);
 pkr.key.cipher_alg = nla_get_u32(attrs[OVPN_A_KEYCONF_CIPHER_ALG]);

 ret = ovpn_nl_get_key_dir(info, attrs[OVPN_A_KEYCONF_ENCRYPT_DIR],
      pkr.key.cipher_alg, &pkr.key.encrypt);
 if (ret < 0)
  return ret;

 ret = ovpn_nl_get_key_dir(info, attrs[OVPN_A_KEYCONF_DECRYPT_DIR],
      pkr.key.cipher_alg, &pkr.key.decrypt);
 if (ret < 0)
  return ret;

 peer_id = nla_get_u32(attrs[OVPN_A_KEYCONF_PEER_ID]);
 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if (!peer) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "no peer with id %u to set key for",
           peer_id);
  return -ENOENT;
 }

 ret = ovpn_crypto_state_reset(&peer->crypto, &pkr);
 if (ret < 0) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "cannot install new key for peer %u",
           peer_id);
  goto out;
 }

 netdev_dbg(ovpn->dev, "new key installed (id=%u) for peer %u\n",
     pkr.key.key_id, peer_id);
out:
 ovpn_peer_put(peer);
 return ret;
}

static int ovpn_nl_send_key(struct sk_buff *skb, const struct genl_info *info,
       u32 peer_id, enum ovpn_key_slot slot,
       const struct ovpn_key_config *keyconf)
{
 struct nlattr *attr;
 void *hdr;

 hdr = genlmsg_put(skb, info->snd_portid, info->snd_seq, &ovpn_nl_family,
     0, OVPN_CMD_KEY_GET);
 if (!hdr)
  return -ENOBUFS;

 attr = nla_nest_start(skb, OVPN_A_KEYCONF);
 if (!attr)
  goto err;

 if (nla_put_u32(skb, OVPN_A_KEYCONF_PEER_ID, peer_id))
  goto err;

 if (nla_put_u32(skb, OVPN_A_KEYCONF_SLOT, slot) ||
     nla_put_u32(skb, OVPN_A_KEYCONF_KEY_ID, keyconf->key_id) ||
     nla_put_u32(skb, OVPN_A_KEYCONF_CIPHER_ALG, keyconf->cipher_alg))
  goto err;

 nla_nest_end(skb, attr);
 genlmsg_end(skb, hdr);

 return 0;
err:
 genlmsg_cancel(skb, hdr);
 return -EMSGSIZE;
}

int ovpn_nl_key_get_doit(struct sk_buff *skb, struct genl_info *info)
{
 struct nlattr *attrs[OVPN_A_KEYCONF_MAX + 1];
 struct ovpn_priv *ovpn = info->user_ptr[0];
 struct ovpn_key_config keyconf = { 0 };
 enum ovpn_key_slot slot;
 struct ovpn_peer *peer;
 struct sk_buff *msg;
 u32 peer_id;
 int ret, i;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_KEYCONF))
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_KEYCONF_MAX,
          info->attrs[OVPN_A_KEYCONF],
          ovpn_keyconf_get_nl_policy, info->extack);
 if (ret)
  return ret;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_PEER_ID))
  return -EINVAL;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_SLOT))
  return -EINVAL;

 /* OVPN_CMD_KEY_GET expects only the PEER_ID and the SLOT, therefore
  * ensure that the user hasn't specified any other attribute.
  *
  * Unfortunately this check cannot be performed via netlink
  * spec/policy and must be open-coded.
 */
 for (i = 0; i < OVPN_A_KEYCONF_MAX + 1; i++) {
  if (i == OVPN_A_KEYCONF_PEER_ID ||
      i == OVPN_A_KEYCONF_SLOT)
   continue;

  if (attrs[i]) {
   NL_SET_ERR_MSG_FMT_MOD(info->extack,
            "unexpected attribute %u", i);
   return -EINVAL;
  }
 }

 peer_id = nla_get_u32(attrs[OVPN_A_KEYCONF_PEER_ID]);
 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if (!peer) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "cannot find peer with id %u", peer_id);
  return -ENOENT;
 }

 slot = nla_get_u32(attrs[OVPN_A_KEYCONF_SLOT]);

 ret = ovpn_crypto_config_get(&peer->crypto, slot, &keyconf);
 if (ret < 0) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "cannot extract key from slot %u for peer %u",
           slot, peer_id);
  goto err;
 }

 msg = nlmsg_new(NLMSG_DEFAULT_SIZE, GFP_KERNEL);
 if (!msg) {
  ret = -ENOMEM;
  goto err;
 }

 ret = ovpn_nl_send_key(msg, info, peer->id, slot, &keyconf);
 if (ret < 0) {
  nlmsg_free(msg);
  goto err;
 }

 ret = genlmsg_reply(msg, info);
err:
 ovpn_peer_put(peer);
 return ret;
}

int ovpn_nl_key_swap_doit(struct sk_buff *skb, struct genl_info *info)
{
 struct ovpn_priv *ovpn = info->user_ptr[0];
 struct nlattr *attrs[OVPN_A_PEER_MAX + 1];
 struct ovpn_peer *peer;
 u32 peer_id;
 int ret;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_KEYCONF))
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_KEYCONF_MAX,
          info->attrs[OVPN_A_KEYCONF],
          ovpn_keyconf_swap_input_nl_policy, info->extack);
 if (ret)
  return ret;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_PEER_ID))
  return -EINVAL;

 peer_id = nla_get_u32(attrs[OVPN_A_KEYCONF_PEER_ID]);
 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if (!peer) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "no peer with id %u to swap keys for",
           peer_id);
  return -ENOENT;
 }

 ovpn_crypto_key_slots_swap(&peer->crypto);
 ovpn_peer_put(peer);

 return 0;
}

int ovpn_nl_key_del_doit(struct sk_buff *skb, struct genl_info *info)
{
 struct nlattr *attrs[OVPN_A_KEYCONF_MAX + 1];
 struct ovpn_priv *ovpn = info->user_ptr[0];
 enum ovpn_key_slot slot;
 struct ovpn_peer *peer;
 u32 peer_id;
 int ret;

 if (GENL_REQ_ATTR_CHECK(info, OVPN_A_KEYCONF))
  return -EINVAL;

 ret = nla_parse_nested(attrs, OVPN_A_KEYCONF_MAX,
          info->attrs[OVPN_A_KEYCONF],
          ovpn_keyconf_del_input_nl_policy, info->extack);
 if (ret)
  return ret;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_PEER_ID))
  return -EINVAL;

 if (NL_REQ_ATTR_CHECK(info->extack, info->attrs[OVPN_A_KEYCONF], attrs,
         OVPN_A_KEYCONF_SLOT))
  return -EINVAL;

 peer_id = nla_get_u32(attrs[OVPN_A_KEYCONF_PEER_ID]);
 slot = nla_get_u32(attrs[OVPN_A_KEYCONF_SLOT]);

 peer = ovpn_peer_get_by_id(ovpn, peer_id);
 if (!peer) {
  NL_SET_ERR_MSG_FMT_MOD(info->extack,
           "no peer with id %u to delete key for",
           peer_id);
  return -ENOENT;
 }

 ovpn_crypto_key_slot_delete(&peer->crypto, slot);
 ovpn_peer_put(peer);

 return 0;
}

/**
 * ovpn_nl_peer_del_notify - notify userspace about peer being deleted
 * @peer: the peer being deleted
 *
 * Return: 0 on success or a negative error code otherwise
 */
int ovpn_nl_peer_del_notify(struct ovpn_peer *peer)
{
 struct ovpn_socket *sock;
 struct sk_buff *msg;
 struct nlattr *attr;
 int ret = -EMSGSIZE;
 void *hdr;

 netdev_info(peer->ovpn->dev, "deleting peer with id %u, reason %d\n",
      peer->id, peer->delete_reason);

 msg = nlmsg_new(NLMSG_DEFAULT_SIZE, GFP_ATOMIC);
 if (!msg)
  return -ENOMEM;

 hdr = genlmsg_put(msg, 0, 0, &ovpn_nl_family, 0, OVPN_CMD_PEER_DEL_NTF);
 if (!hdr) {
  ret = -ENOBUFS;
  goto err_free_msg;
 }

 if (nla_put_u32(msg, OVPN_A_IFINDEX, peer->ovpn->dev->ifindex))
  goto err_cancel_msg;

 attr = nla_nest_start(msg, OVPN_A_PEER);
 if (!attr)
  goto err_cancel_msg;

 if (nla_put_u32(msg, OVPN_A_PEER_DEL_REASON, peer->delete_reason))
  goto err_cancel_msg;

 if (nla_put_u32(msg, OVPN_A_PEER_ID, peer->id))
  goto err_cancel_msg;

 nla_nest_end(msg, attr);

 genlmsg_end(msg, hdr);

 rcu_read_lock();
 sock = rcu_dereference(peer->sock);
 if (!sock) {
  ret = -EINVAL;
  goto err_unlock;
 }
 genlmsg_multicast_netns(&ovpn_nl_family, sock_net(sock->sk), msg, 0,
    OVPN_NLGRP_PEERS, GFP_ATOMIC);
 rcu_read_unlock();

 return 0;

err_unlock:
 rcu_read_unlock();
err_cancel_msg:
 genlmsg_cancel(msg, hdr);
err_free_msg:
 nlmsg_free(msg);
 return ret;
}

/**
 * ovpn_nl_key_swap_notify - notify userspace peer's key must be renewed
 * @peer: the peer whose key needs to be renewed
 * @key_id: the ID of the key that needs to be renewed
 *
 * Return: 0 on success or a negative error code otherwise
 */
int ovpn_nl_key_swap_notify(struct ovpn_peer *peer, u8 key_id)
{
 struct ovpn_socket *sock;
 struct nlattr *k_attr;
 struct sk_buff *msg;
 int ret = -EMSGSIZE;
 void *hdr;

 netdev_info(peer->ovpn->dev, "peer with id %u must rekey - primary key unusable.\n",
      peer->id);

 msg = nlmsg_new(NLMSG_DEFAULT_SIZE, GFP_ATOMIC);
 if (!msg)
  return -ENOMEM;

 hdr = genlmsg_put(msg, 0, 0, &ovpn_nl_family, 0, OVPN_CMD_KEY_SWAP_NTF);
 if (!hdr) {
  ret = -ENOBUFS;
  goto err_free_msg;
 }

 if (nla_put_u32(msg, OVPN_A_IFINDEX, peer->ovpn->dev->ifindex))
  goto err_cancel_msg;

 k_attr = nla_nest_start(msg, OVPN_A_KEYCONF);
 if (!k_attr)
  goto err_cancel_msg;

 if (nla_put_u32(msg, OVPN_A_KEYCONF_PEER_ID, peer->id))
  goto err_cancel_msg;

 if (nla_put_u16(msg, OVPN_A_KEYCONF_KEY_ID, key_id))
  goto err_cancel_msg;

 nla_nest_end(msg, k_attr);
 genlmsg_end(msg, hdr);

 rcu_read_lock();
 sock = rcu_dereference(peer->sock);
 if (!sock) {
  ret = -EINVAL;
  goto err_unlock;
 }
 genlmsg_multicast_netns(&ovpn_nl_family, sock_net(sock->sk), msg, 0,
    OVPN_NLGRP_PEERS, GFP_ATOMIC);
 rcu_read_unlock();

 return 0;
err_unlock:
 rcu_read_unlock();
err_cancel_msg:
 genlmsg_cancel(msg, hdr);
err_free_msg:
 nlmsg_free(msg);
 return ret;
}

/**
 * ovpn_nl_register - perform any needed registration in the NL subsustem
 *
 * Return: 0 on success, a negative error code otherwise
 */
int __init ovpn_nl_register(void)
{
 int ret = genl_register_family(&ovpn_nl_family);

 if (ret) {
  pr_err("ovpn: genl_register_family failed: %d\n", ret);
  return ret;
 }

 return 0;
}

/**
 * ovpn_nl_unregister - undo any module wide netlink registration
 */
void ovpn_nl_unregister(void)
{
 genl_unregister_family(&ovpn_nl_family);
}