-u8 *
-format_udp_listener_session_ip4 (u8 * s, va_list * args)
-{
- u32 tci = va_arg (*args, u32);
- udp_connection_t *tc = udp_listener_get (tci);
- s = format (s, "[%s] %U:%d->%U:%d", "udp", format_ip4_address,
- &tc->c_lcl_ip4, clib_net_to_host_u16 (tc->c_lcl_port),
- format_ip4_address, &tc->c_rmt_ip4,
- clib_net_to_host_u16 (tc->c_rmt_port));
- return s;
+ if (udp_is_valid_dst_port (lcl_port, rmt->is_ip4))
+ {
+ /* If specific source port was requested abort */
+ if (rmt->peer.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))
+ {
+ lcl_port = transport_alloc_local_port (TRANSPORT_PROTO_UDP,
+ &lcl_addr);
+ if (lcl_port < 1)
+ return SESSION_E_PORTINUSE;
+ }
+ }
+
+conn_alloc:
+
+ udp_connection_register_port (lcl_port, rmt->is_ip4);
+
+ /* 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)
+ {
+ uc->flags |= UDP_CONN_F_CONNECTED;
+ }
+ else
+ {
+ clib_spinlock_init (&uc->rx_lock);
+ uc->c_flags |= TRANSPORT_CONNECTION_F_CLESS;
+ }
+ if (!um->csum_offload)
+ uc->cfg_flags |= UDP_CFG_F_NO_CSUM_OFFLOAD;
+ uc->next_node_index = rmt->next_node_index;
+ uc->next_node_opaque = rmt->next_node_opaque;
+
+ return uc->c_c_index;