+ udp_main_t *um = &udp_main;
+ ip46_address_t lcl_addr;
+ udp_connection_t *uc;
+ u32 thread_index;
+ u16 lcl_port;
+ int rv;
+
+ rv = transport_alloc_local_endpoint (TRANSPORT_PROTO_UDP, rmt, &lcl_addr,
+ &lcl_port);
+ if (rv)
+ return rv;
+
+ if (udp_is_valid_dst_port (lcl_port, rmt->is_ip4))
+ {
+ /* If specific source port was requested abort */
+ if (rmt->peer.port)
+ {
+ transport_release_local_endpoint (TRANSPORT_PROTO_UDP, &lcl_addr,
+ lcl_port);
+ return SESSION_E_PORTINUSE;
+ }
+
+ /* Try to find a port that's not used */
+ while (udp_is_valid_dst_port (lcl_port, rmt->is_ip4))
+ {
+ transport_release_local_endpoint (TRANSPORT_PROTO_UDP, &lcl_addr,
+ lcl_port);
+ lcl_port =
+ transport_alloc_local_port (TRANSPORT_PROTO_UDP, &lcl_addr, rmt);
+ if (lcl_port < 1)
+ return SESSION_E_PORTINUSE;
+ }
+ }
+
+ /* We don't poll main thread if we have workers */
+ thread_index = transport_cl_thread ();
+
+ uc = udp_connection_alloc (thread_index);
+ ip_copy (&uc->c_rmt_ip, &rmt->ip, rmt->is_ip4);
+ ip_copy (&uc->c_lcl_ip, &lcl_addr, rmt->is_ip4);
+ uc->c_rmt_port = rmt->port;
+ uc->c_lcl_port = clib_host_to_net_u16 (lcl_port);
+ uc->c_is_ip4 = rmt->is_ip4;
+ uc->c_proto = TRANSPORT_PROTO_UDP;
+ uc->c_fib_index = rmt->fib_index;
+ uc->c_dscp = rmt->dscp;
+ uc->mss = rmt->mss ? rmt->mss : udp_default_mtu (um, uc->c_is_ip4);
+ if (rmt->peer.sw_if_index != ENDPOINT_INVALID_INDEX)
+ uc->sw_if_index = rmt->peer.sw_if_index;
+ uc->flags |= UDP_CONN_F_OWNS_PORT;
+ if (rmt->transport_flags & TRANSPORT_CFG_F_CONNECTED)