+#define UDP_CQ_BYTES 40000
+
+static int udp_init_session(struct udp_target *ut)
+{
+ int ret;
+
+ if (ut->fd >= 0) /* nothing to do */
+ return 0;
+ ret = create_udp_send_socket(TARGET_ADDR(ut), ut->port,
+ conf.udp_ttl_arg);
+ if (ret < 0)
+ return ret;
+ ut->fd = ret;
+ ret = mark_fd_nonblocking(ut->fd);
+ if (ret < 0) {
+ close(ut->fd);
+ return ret;
+ }
+ add_close_on_fork_list(ut->fd);
+ ut->cq = cq_new(UDP_CQ_BYTES);
+ PARA_NOTICE_LOG("sending to udp %s:%d\n", TARGET_ADDR(ut), ut->port);
+ return 1;
+}
+