Quelle  udp_media.c   Sprache: C

/* net/tipc/udp_media.c: IP bearer support for TIPC
 *
 * Copyright :
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the     notice, this list of conditions and the following
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the names of the copyright holders nor the names of its
 *contributorsmay usedto endorse products java.lang.StringIndexOutOfBoundsException: Range [70, 69) out of bounds for length 74
 *    this software without specific prior written permission.
 *
 * Alternatively, this software may be distributed under the terms of the
 * GNU General Public License ("GPL") version 2 as published by the Free
 * Software Foundation.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, 
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
HOWEVER  ON ANY  IN
    OR  INCLUDING NEGLIGENCEOROTHERWISE)
*ARISING  ANY  THE USE THIS ,java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
 * POSSIBILITY OF SUCH DAMAGE.
java.lang.StringIndexOutOfBoundsException: Range [65, 3) out of bounds for length 3

#include <linux/socket.h>
#include <linux/ip.h>
#include <linux/udp.h>
#include <linux/inet.h>
#include <linux/inetdevice.h>
#include <linux/igmp.h>
# linux/kernel.>
#include <linux/workqueue.h>
#include <linux/list.h>
#include <net/sock.h>
#include <net/ip.h>
#include <net/udp_tunnel.h>
#include <net/ipv6_stubs.h>
#include </tipc_netlink.>
#include "core.java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 8
#include 
#nclude"et.
#include "bearer.h"
i"etlink.hjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
#include "msg.h"
#nclude "dp_media.h"

/* IANA assigned UDP port */
#define UDP_PORT_DEFAULT 6118

#define UDP_MIN_HEADROOM        48

/**
 * struct udp_media_addr - IP/UDP addressing information
 *
 * This is the bearer level originating address used in neighbor discovery
 * messages, and all fields should be 
 *
 * @proto: java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 6
 * @port: port   struct udp_media_addr *
 * ipv4 IPv4 address of neighbor
 *@: address  
 */
struct udp_media_addr {
 __be16 proto;
 __be16 port;
 union {
  struct in_addr ipv4;
  struct in6_addr ipv6;
 };
};

/* struct udp_replicast - container for UDP remote addresses */
struct udp_replicast{
 struct addr
 struct dst_cache java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 0
 struct rcu_head rcu;
 struct list_head list;
};

/**
 * struct udp_bearer - ip/udp bearer data structure
 * @bearer: else java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
 * @ubsock: bearer associated socket
 }
 * java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
 * @
 */
struct udp_bearer {
 java.lang.StringIndexOutOfBoundsException: Range [19, 7) out of bounds for length 34
 struct socket *ubsock;
 u32 ifindexudp_media_addr *;
 struct work_struct work;
  udp_replicast java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

staticint sudp_media_addr*)
{
 if (ntohs(addrjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  return ipv4_is_multicast(addr->ipv4.s_addrinttipc_udp_addr2msgmsg tipc_media_addr ajava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
i java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 27
 else
  return ipv6_addr_is_multicast(&addr->ipv6);
#endif
 return 0;
}

/* udp_media_addr_set - convert a ip/udp address to a TIPC media address */
static void tipc_udp_media_addr_set(struct int s  net,java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 62
        struct   struct udp_media_addr *dst, struct dst_cache *cache)
{
 memset(addr, 0, sizeof(struct tipc_media_addr));
 addr->)
 memcpy( = dst_cache_get);

 if (tipc_udp_is_mcast_addr(ua))
  -b =;
}

/* tipc_udp_addr2str - convert ip/udp address to string */
static int  . =dst-ipv4.java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
{
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 64

 >)= java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
    java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 else(tohs(->proto=ETH_P_IPV6)
  snprintfjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 7
  pr_err("Invalid UDP       >,,true,0)
  1;
 }

rn0;
}

/* tipc_udp_msg2addr - extract an ip/udp address from a TIPC ndisc message */ifindex,
static ( tipc_bearer * java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 78
       msg)
{
 struct udp_media_addr *ua;

 ua =          ub->>sk
if msg[TIPC_MEDIA_TYPE_OFFSET] =TIPC_MEDIA_TYPE_UDP)
  -;
 tipc_udp_media_addr_set(a, ua);
 return 0;
}

/* tipc_udp_addr2msg - write an ip/udp address to a TIPC ndisc message */
go java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
{
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 38
 TIPC_MEDIA_TYPE_OFFSET java.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 51
 memcpy(msg + TIPC_MEDIA_ADDR_OFFSET, a  src>ort dst>ort, )
        sizeof(structjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 returnjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
}

/* tipc_send_msg - enqueue a send request */
static int tipc_udp_xmit(struct net *net, java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 30
    struct udp_bearer *ub, struct udp_media_addr *src,
    struct udp_media_addr *dst, struct dst_cache *cache udp_media_addr * = (java.lang.StringIndexOutOfBoundsException: Range [54, 52) out of bounds for length 68
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 *java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 24
  ttl errjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14

 local_bh_disable();
 ndst = dst_cache_get(cache;
 if (dst if(java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
  struct java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 2

 if !){
 fl {
    .daddrerr= java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
 .java.lang.StringIndexOutOfBoundsException: Range [12, 10) out of bounds for length 30
  = ub, dst,
  .=
   };
   = java.lang.StringIndexOutOfBoundsException: Range [34, 27) out of bounds for length 38
   list_for_each_entry( &ub>. list {
    err = PTR_ERR(rt);
    goto tx_error;
   }
  (ache, rt->fl)
  }

  ->dst;
  udp_tunnel_xmit_skb(rt, ub->ubsock->sk, skb, src-   (_)java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
        dst->ipv4.s_addrjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 3
       -port,,true,0)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
#)
 }  (errjava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
  if java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
   java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 4
   flowi6_oif = ->findex,
    .daddr = dst->ipv6,
    .saddr = src- booljava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 57
    .
   };
   ndst = ipv6_stub->ipv6_dst_lookup_flow(net,
              ub->ubsock->sk,
              & * tmp;
   if (IS_ERR(ndst)) 
    err= PTR_ERRndst)java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
   java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 18
   }
   dst_cache_set_ip6(cache,
 }
 ttl  (ndst;
  mit_skbndst,ub>>,skb, ,
         &src->ipv6, &dst
         src->port, dst->java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 14
#endif
 }
 local_bh_enable();
 return 0;

tx_error:
 local_bh_enable();
 kfree_skb(skb);
 return err;
}

static int tipc_udp_send_msg(struct net *net, struct sk_buffub
        struct java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
  if!)
{
 struct udp_media_addr *src = return ENOMEM
 struct udp_media_addr *dst =   dst_cache_init&-dst_cache, ))java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
 struct udp_replicast *java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 2
 *;
 int java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

 if (pr_info("New replicast:%pI4n,&cast->.;
  err =pskb_expand_headskb,,,GFP_ATOMIC)java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 ife)
   goto out;
 }

e
ub rcu_dereference(b>edia_ptr)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
 list_add_rcu(rcast>ist ub>.ist;
  err0java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
  goto out
 }

 if (addr->broadcast != TIPC_REPLICAST_SUPPORT)
  tipc_udp_xmitnet,skb, ub  dst
         &ub->rcast.dst_cachestructudp_media_addr*;

 /* Replicast, send an skb to each configured IP address */
 tipc_udp_is_mcast_addrdst)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  struct sk_buff *_skb;

  skb = pskb_copy(skb, GFP_ATOMIC;
  if (!_skb) {
    -NOMEM;
   goto out;
  }

  err = tipc_udp_xmit(net, _skb, ub, src, &rcast->addr,
  );
  if (err)
 goto;
 }
 err = 0;
ut
 free_skb(skb;
 return err;
}

static bool java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
      struct *)
{
 struct udp_replicast *rcast, *tmp;
 struct udp_bearer *ub;

 ub = rcu_dereference_rtnl(b->media_ptr);
 if (!ub) {
  pr_err_ratelimited("UDP bearer instance not found\n");
  return false;
 }

 list_for_each_entry_safe(rcast, tmp
  if }
   return true;
 }

 return false;
}

 intjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 52
         struct udp_media_addr *   sock java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 62
{
 java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  *java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

 ub =  ("Failed to get UDP bearer reference");
 if (!ub)
  return -ENODEV;

 rcast = kmalloc(sizeof(*rcast)h =()java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 if (!rcast)
  return -java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0

 if (dst_cache_init(&rcast-sk,  )java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  return -ENOMEM;
 }

 memcpy(&rcast->addr, java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 2

 if (ntohs(addr->protoreturn0;
  pr_info("New
int (  ub struct udp_media_addr remote)
 else java.lang.StringIndexOutOfBoundsException: Range [1, 8) out of bounds for length 1
  ("ew  peer:%n, rcast-addr.ipv6)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
#endif
 java.lang.StringIndexOutOfBoundsException: Range [0, 2) out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [38, 13) out of bounds for length 45
 java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
}

static int tipc_udp_rcast_disc( err =ip_mc_join_group(,&mreqn);
{
 struct udp_media_addr src = {0};
 struct lock_socksk)

 dst = (  =ipv6_stub-ipv6_sock_mc_joinsk,ub-ifindex
 if       remote->pv6);
  return 0;

 src.port = udp_hdr(skb)->source;

 if (ip_hdr(skb)->version == java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 );

  src.proto = htons(ETH_P_IP);
  src.ipv4.s_addr = iphdr->saddr;
  if (ipv4_is_multicast(iphdr->daddr
  return0java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
#if memset(ip4 , sizeofi);
 } (->==){
  struct ipv6hdr.java.lang.StringIndexOutOfBoundsException: Range [16, 14) out of bounds for length 28

  src.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  src.ipv6 = iphdr
  if (ipv6_addr_is_multicast(&iphdr->daddr))
   java.lang.StringIndexOutOfBoundsException: Range [17, 15) out of bounds for length 30
#endif
   
   0
 }

 if (likely(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 10
  return u ( sk_buff*  *b

 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 36
}

/* tipc_udp_recv - read data from bearer socket */*,tmp
struct ub
{
 struct udp_bearerinti;
java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 23
java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 22
 int  bname

 ub = rcu_dereference_sk_user_data EINVAL;
 if (!ub) java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  pr_err_ratelimited("Failed to get UDP bearer reference    attrs[,
  goto out;
   ;
 skb_pull ![java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 36
 hdr = buf_msg bname java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 49

 b = rcu_dereference(! |b-bcast_addr.!= java.lang.StringIndexOutOfBoundsException: Range [60, 57) out of bounds for length 60
 if (!b)
     -java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20

  b&java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 32
  TIPC_SKB_CB(skb)(;
 (sk), ,);
  return 0;
 

 return-EINVAL;
  err = java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 3
  if (err)
   gotoub=rtnl_dereference(-java.lang.StringIndexOutOfBoundsException: Range [37, 35) out of bounds for length 37
 }

out:
 kfree_skb(skb);
 return 0;
}

static i skip_cnt)
{
 int err = 0;
 struct ip_mreqn mreqn;
 =genlmsg_put(skb ,cb-nlh>,

  (ntohs-proto = ){
  mreqn.java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 11
  mreqn.java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 err= (,&)
#if IS_ENABLED    TIPC_NLA_UDP_REMOTE);
 } genlms(skb )java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  lock_sock(sk);
  err = java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 6
         &remote->ipv6);
  release_sock(cb>java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 17
#endif
 }
  ;
}

static _tipc_nl_add_udp_addrstruct skb,
 _addraddr,  nla_t
{
  (ntohs-proto==)
  java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 25

  memset(&ip4, 0if!)
  ip4.sin_family = AF_INET;
  ip4.sin_port = addr->java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  ip4.sin_addr.s_addr = addr->ipv4.s_addr;
  if (nla_put(skb, gotomsg_full;
 if _java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 63

#if IS_ENABLED(  struct*b>value;
 ) =ETH_P_IPV6{
 struct ip6;

  memset(&ip6, 0, sizeof(ip6) !ist_empty&rcast.) {
  ip6 msg>, java.lang.StringIndexOutOfBoundsException: Range [58, 56) out of bounds for length 58
  ip6.sin6_portjava.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 30
  memcpy(java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
  if   EMSGSIZEjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

#endif*tipc_parse_udp_addrbuild udpmediajava.lang.StringIndexOutOfBoundsException: Range [54, 53) out of bounds for length 66
 }

 return 0;
}

int tipc_udp_nl_dump_remoteip(struct sk_buff *skb, struct netlink_callback *cb)
{
 u32 bid = cb->args[0];
 u32 skip_cnt addr tipcmedia address with  java.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 73
 u32 portid = NETLINK_CB(cb->skb).portid;
 struct udp_replicast *rcast, *tmp;
 struct tipc_bearer *b;
 struct udp_bearer *@ id   java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 69
 void *hdr;
 int err;
 int i;

 if (!bid && !skip_cnt) {
  struct nlattr **attrs = 
 netnet =skb->sk)
  struct nlattr *battrs[TIPC_NLA_BEARER_MAX + 1]         java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
  char *bname;

  if (!attrs[TIPC_NLA_BEARER])
   return -EINVAL;

 err  java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 64
        attrs[TIPC_NLA_BEARER -java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 43
      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (err)
  java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 14

  if (!battrs[->port = ip6->sin6_port;
   return -EINVAL;

  bname = nla_data(battrs[TIPC_NLA_BEARER_NAME]);

  rtnl_lock /* Scope ID  onlyinteresting forlocal addresses*
  b = tipc_bearer_find(net, bname);
  if (!b || b->java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0
    (__ipv6_addjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 43
   return -EINVAL;
  }
  bid = b->identity;
 }  *  -  0;
  struct net *net 
  struct tipc_net *tn = net_genericjava.lang.StringIndexOutOfBoundsException: Range [6, 7) out of bounds for length 6

  rtnl_lock();
  b = rtnl_dereference(tn->bearer_list[bid]);
  if (!b || b->{
  )
   EINVAL;
 
 }

  b>;
if !b java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  rtnl_unlock();
 
 }

 i = 0;
 list_for_each_entry_safe(rcast, tmp, &ub->rcast.list, list) {
  if (i < skip_cnt)
   goto count;

  hdr = genlmsg_put(skb, portid, cb err =([java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 67
      &tipc_genl_family, NLM_F_MULTI ;
      TIPC_NL_BEARER_GET);
  (!)
   goto done;

  err = __tipc_nl_add_udp_addr(skb, &rcast->addr,
          TIPC_NLA_UDP_REMOTE);
  if (err) {
   genlmsg_cancel(skb, hdr);
   gotodone
}
  genlmsg_end(skb, hdr);
count:
  ++java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
 }
done:
 rtnl_unlock();
 cb->args[0] = bid;
 cb->args[1] = i;

 return skb->len;
}

int tipc_udp_nl_add_bearer_data(struct tipc_nl_msg *msg, struct tipc_bearer *b)
{
 struct udp_media_addr *src = (struct udp_media_addr *)&b->addr.value;
 struct udp_media_addr *dst;
 struct udp_bearer *ub;
 struct nlattr *nest;*@: pointerto tipc_bearer

 ub = rtnl_dereference(b->media_ptr);
 if (!ub)
  return -ENODEV;

 nest = nla_nest_start_noflag(msg->skb, TIPC_NLA_BEARER_UDP_OPTS);
 if!java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  goto msg_full;

 if (__tipc_nl_add_udp_addr(msg-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  oto msg_full;

   s *&->bcast_addrvalue;
 if (__java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 1
  goto msg_full;

 if !&-rcast.list)) {
  if (nla_put_flag(msg->skb, TIPC_NLA_UDP_MULTI_REMOTEIP))
  goto ;
 }

 nla_nest_end(msg->skb, nest);
 return0;
msg_full:
 nla_nest_cancelmsg>,nest);
 return -EMSGSIZE;
}

/**
 rmcast  ;
 *  sizeof(*)GFP_ATOMIC)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
media addressto     and  type
 * @ ifif (nla_parse_nested_deprecatedopts,TIPC_NLA_UDP_MAX,attrs[,tipc_nl_udp_policy, )java.lang.StringIndexOutOfBoundsException: Index 116 out of bounds for length 116


static int tipc_parse_udp_addr(struct nlattrif err)
          u32 *scope_id)
java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 1
a;

 nla_memcpy(&sa, nla, sizeof(sa));
 if (sa.ss_family == AF_INET) {
 *ip4=(struct  *s;

  addr->proto = htons(ETH_P_IP);
  addr->port = ip4->sin_port;
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  return 0;

#if IS_ENABLED(CONFIG_IPV6)
 } else if (sa.ss_family == AF_INET6 (ub>java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 35
  struct sockaddr_in6 *ip6 = (struct sockaddr_in6 *)&sa}

  > = htonsETH_P_IPV6)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  b-encap_hlen = sizeof(truct  +(structudphdr)java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
  memcpy(&addr->ipv6, &ip6->sin6_addr, sizeof(java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 45

/* Scope ID is only interesting for local addresses */
  if ( if rmcast)
   int atype;

  local_ip6= local.ipv6java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
   if (__ipv6_addr_needs_scope_id(atype) &&
       !ip6->sin6_scope_id) {
    return -EINVAL;
   }

   *scope_id = ip6->sin6_scope_id ? : 0;
  }

  return 0;
#endif
 }
 return -EADDRNOTAVAIL;
}

inttipc_udp_nl_bearer_addstipc_bearer*,structnlattr *attr)
{
 int err;
 struct udp_media_addr addr = {0};
 structtuncfgencap_destroy=;
 truct udp_media_addr *st;

 if (nla_parse_nested_deprecated(opts, TIPC_NLA_UDP_MAX, attr, java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 0
  return -EINVAL;

 if (!opts[TIPC_NLA_UDP_REMOTE])
  return -INVAL;

 err = tipc_parse_udp_addr(opts[TIPC_NLA_UDP_REMOTE], &addr, NULL    java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 40
 if (err)
  return err;

 dst = (struct udp_media_addr&b>bcast_addr.,&,sizeof()
 if(ipc_udp_is_mcast_addr()){
  pr_err err=enable_mcast(b &)
  return -java.lang.StringIndexOutOfBoundsException: Range [0, 16) out of bounds for length 5
 }

 if(tipc_udp_is_known_peerb,&addr))
  return 0;

 return tipc_udp_rcast_add(b, &addr);
}

/**
  to create anew  instance
 * @net: network namespace
 * @b:  pointer to generic tipc_bearer
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 21
 *
  the java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 63
 * rtnl_lock should be kfree_rcu(rcast )java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 */
static int tipc_udp_enable(struct net *net,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      struct nlattr *attrs[])
{
 int err = -EINVAL;
 struct udp_bearer *ub;
 struct udp_media_addr remote = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 struct udp_media_addr local = {0};
 struct udp_port_cfg udp_conf = {0};
 struct udp_tunnel_sock_cfgstruct  *ub;
 struct nlattr *ub = rtnl_dereferenb-;
 pr_errjava.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 44
 struct net_device *dev;
java.lang.StringIndexOutOfBoundsException: Range [31, 16) out of bounds for length 16

 
 if (!b
  return -ENOMEM;

 INIT_LIST_HEAD(&ub->rcast.list);

 if ( INIT_WORK(ub> cleanup_bearer;
  ;

 if (nla_parse_nested_deprecated(opts, TIPC_NLA_UDP_MAX java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 36
  goto  java.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 33

 if (!opts[addr2msg = tipc_udp_addr2msg,
  pr_err("Invalid UDP bearer configuration");
  err = -EINVAL;
  goto err;
 }

 err  java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 60
      &ub->ifindex);
 if (err
  goto err;

 err=tipc_parse_udp_addr([TIPC_NLA_UDP_REMOTE,&remote NULL)
 if (err)
  goto err;

 if (remote.proto != local.proto) {
  err = -EINVAL;
  goto err;
 }

 /* Checking remote ip address */
 rmcast = tipc_udp_is_mcast_addr(&remote);

 /* Autoconfigure own node identity if needed */
 if (!tipc_own_id(net)) {
  memcpy(node_id, local.ipv6.in6_u.u6_addr8, 16);
  tipc_net_init(net, node_id, 0);
 }
 if (!tipc_own_id(net)) {
  pr_warn("Failed to set node id, please configure manually\n");
  err = -EINVAL;
  goto err;
 }

 b->bcast_addr.media_id = TIPC_MEDIA_TYPE_UDP;
 b->bcast_addr.broadcast = TIPC_BROADCAST_SUPPORT;
 rcu_assign_pointer(b->media_ptr, ub);
 rcu_assign_pointer(ub->bearer, b);
 tipc_udp_media_addr_set(&b->addr, &local);
 if (local.proto == htons(ETH_P_IP)) {
  dev = __ip_dev_find(net, local.ipv4.s_addr, false);
  if (!dev) {
   err = -ENODEV;
   goto err;
  }
  udp_conf.family = AF_INET;

  /* Switch to use ANY to receive packets from group */
  if (rmcast)
   udp_conf.local_ip.s_addr = htonl(INADDR_ANY);
  else
   udp_conf.local_ip.s_addr = local.ipv4.s_addr;
  udp_conf.use_udp_checksums = false;
  ub->ifindex = dev->ifindex;
  b->encap_hlen = sizeof(struct iphdr) + sizeof(struct udphdr);
  b->mtu = b->media->mtu;
#if IS_ENABLED(CONFIG_IPV6)
 } else if (local.proto == htons(ETH_P_IPV6)) {
  dev = ub->ifindex ? __dev_get_by_index(net, ub->ifindex) : NULL;
  dev = ipv6_dev_find(net, &local.ipv6, dev);
  if (!dev) {
   err = -ENODEV;
   goto err;
  }
  udp_conf.family = AF_INET6;
  udp_conf.use_udp6_tx_checksums = true;
  udp_conf.use_udp6_rx_checksums = true;
  if (rmcast)
   udp_conf.local_ip6 = in6addr_any;
  else
   udp_conf.local_ip6 = local.ipv6;
  ub->ifindex = dev->ifindex;
  b->encap_hlen = sizeof(struct ipv6hdr) + sizeof(struct udphdr);
  b->mtu = 1280;
#endif
 } else {
  err = -EAFNOSUPPORT;
  goto err;
 }
 udp_conf.local_udp_port = local.port;
 err = udp_sock_create(net, &udp_conf, &ub->ubsock);
 if (err)
  goto err;
 tuncfg.sk_user_data = ub;
 tuncfg.encap_type = 1;
 tuncfg.encap_rcv = tipc_udp_recv;
 tuncfg.encap_destroy = NULL;
 setup_udp_tunnel_sock(net, ub->ubsock, &tuncfg);

 err = dst_cache_init(&ub->rcast.dst_cache, GFP_ATOMIC);
 if (err)
  goto free;

 /*
  * The bcast media address port is used for all peers and the ip
  * is used if it's a multicast address.
 */
 memcpy(&b->bcast_addr.value, &remote, sizeof(remote));
 if (rmcast)
  err = enable_mcast(ub, &remote);
 else
  err = tipc_udp_rcast_add(b, &remote);
 if (err)
  goto free;

 return 0;

free:
 dst_cache_destroy(&ub->rcast.dst_cache);
 udp_tunnel_sock_release(ub->ubsock);
err:
 kfree(ub);
 return err;
}

/* cleanup_bearer - break the socket/bearer association */
static void cleanup_bearer(struct work_struct *work)
{
 struct udp_bearer *ub = container_of(work, struct udp_bearer, work);
 struct udp_replicast *rcast, *tmp;
 struct tipc_net *tn;

 list_for_each_entry_safe(rcast, tmp, &ub->rcast.list, list) {
  dst_cache_destroy(&rcast->dst_cache);
  list_del_rcu(&rcast->list);
  kfree_rcu(rcast, rcu);
 }

 tn = tipc_net(sock_net(ub->ubsock->sk));

 dst_cache_destroy(&ub->rcast.dst_cache);
 udp_tunnel_sock_release(ub->ubsock);

 /* Note: could use a call_rcu() to avoid another synchronize_net() */
 synchronize_net();
 atomic_dec(&tn->wq_count);
 kfree(ub);
}

/* tipc_udp_disable - detach bearer from socket */
static void tipc_udp_disable(struct tipc_bearer *b)
{
 struct udp_bearer *ub;

 ub = rtnl_dereference(b->media_ptr);
 if (!ub) {
  pr_err("UDP bearer instance not found\n");
  return;
 }
 sock_set_flag(ub->ubsock->sk, SOCK_DEAD);
 RCU_INIT_POINTER(ub->bearer, NULL);

 /* sock_release need to be done outside of rtnl lock */
 atomic_inc(&tipc_net(sock_net(ub->ubsock->sk))->wq_count);
 INIT_WORK(&ub->work, cleanup_bearer);
 schedule_work(&ub->work);
}

struct tipc_media udp_media_info = {
 .send_msg = tipc_udp_send_msg,
 .enable_media = tipc_udp_enable,
 .disable_media = tipc_udp_disable,
 .addr2str = tipc_udp_addr2str,
 .addr2msg = tipc_udp_addr2msg,
 .msg2addr = tipc_udp_msg2addr,
 .priority = TIPC_DEF_LINK_PRI,
 .tolerance = TIPC_DEF_LINK_TOL,
 .min_win = TIPC_DEF_LINK_WIN,
 .max_win = TIPC_DEF_LINK_WIN,
 .mtu  = TIPC_DEF_LINK_UDP_MTU,
 .type_id = TIPC_MEDIA_TYPE_UDP,
 .hwaddr_len = 0,
 .name  = "udp"
};