udp_listener      578 opal/mca/btl/usnic/btl_usnic_cagent.c     agent_udp_port_listener_t *udp_listener;
udp_listener      579 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener = agent_thread_find_listener(cmd.ipv4_addr, &udp_port);
udp_listener      580 opal/mca/btl/usnic/btl_usnic_cagent.c     if (NULL != udp_listener) {
udp_listener      587 opal/mca/btl/usnic/btl_usnic_cagent.c         if (NULL == udp_listener->module) {
udp_listener      588 opal/mca/btl/usnic/btl_usnic_cagent.c             udp_listener->module = cmd.module;
udp_listener      597 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener = OBJ_NEW(agent_udp_port_listener_t);
udp_listener      598 opal/mca/btl/usnic/btl_usnic_cagent.c     if (NULL == udp_listener) {
udp_listener      604 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->module = cmd.module;
udp_listener      605 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->max_msg_size = cmd.max_msg_size;
udp_listener      606 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->ipv4_addr = cmd.ipv4_addr;
udp_listener      607 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->netmask = cmd.netmask;
udp_listener      608 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->usnic_name = strdup(cmd.usnic_name);
udp_listener      613 opal/mca/btl/usnic/btl_usnic_cagent.c     opal_btl_usnic_snprintf_ipv4_addr(udp_listener->ipv4_addr_str,
udp_listener      614 opal/mca/btl/usnic/btl_usnic_cagent.c                                       sizeof(udp_listener->ipv4_addr_str),
udp_listener      617 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->buffer = malloc(udp_listener->max_msg_size);
udp_listener      618 opal/mca/btl/usnic/btl_usnic_cagent.c     if (NULL == udp_listener->buffer) {
udp_listener      625 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->fd = socket(AF_INET, SOCK_DGRAM, 0);
udp_listener      626 opal/mca/btl/usnic/btl_usnic_cagent.c     if (udp_listener->fd < 0) {
udp_listener      627 opal/mca/btl/usnic/btl_usnic_cagent.c         OPAL_ERROR_LOG(udp_listener->fd);
udp_listener      639 opal/mca/btl/usnic/btl_usnic_cagent.c     ret = bind(udp_listener->fd, (struct sockaddr*) &inaddr, sizeof(inaddr));
udp_listener      648 opal/mca/btl/usnic/btl_usnic_cagent.c     ret = getsockname(udp_listener->fd, (struct sockaddr*) &inaddr, &addrlen);
udp_listener      654 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->udp_port = ntohs(inaddr.sin_port);
udp_listener      658 opal/mca/btl/usnic/btl_usnic_cagent.c                         udp_listener->ipv4_addr_str,
udp_listener      659 opal/mca/btl/usnic/btl_usnic_cagent.c                         udp_listener->udp_port,
udp_listener      660 opal/mca/btl/usnic/btl_usnic_cagent.c                         udp_listener->usnic_name);
udp_listener      667 opal/mca/btl/usnic/btl_usnic_cagent.c     ret = setsockopt(udp_listener->fd, IPPROTO_IP, IP_MTU_DISCOVER,
udp_listener      677 opal/mca/btl/usnic/btl_usnic_cagent.c     temp = (int) udp_listener->max_msg_size;
udp_listener      678 opal/mca/btl/usnic/btl_usnic_cagent.c     if ((ret = setsockopt(udp_listener->fd, SOL_SOCKET, SO_RCVBUF,
udp_listener      680 opal/mca/btl/usnic/btl_usnic_cagent.c         (ret = setsockopt(udp_listener->fd, SOL_SOCKET, SO_SNDBUF,
udp_listener      689 opal/mca/btl/usnic/btl_usnic_cagent.c                    &udp_listener->event, udp_listener->fd,
udp_listener      691 opal/mca/btl/usnic/btl_usnic_cagent.c                    agent_thread_receive_ping, udp_listener);
udp_listener      692 opal/mca/btl/usnic/btl_usnic_cagent.c     opal_event_add(&udp_listener->event, 0);
udp_listener      695 opal/mca/btl/usnic/btl_usnic_cagent.c     opal_list_append(&udp_port_listeners, &udp_listener->super);
udp_listener      697 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener->active = true;
udp_listener      701 opal/mca/btl/usnic/btl_usnic_cagent.c                                         cmd.ipv4_addr, udp_listener->udp_port);
udp_listener      842 opal/mca/btl/usnic/btl_usnic_cagent.c     agent_udp_port_listener_t *udp_listener;
udp_listener      843 opal/mca/btl/usnic/btl_usnic_cagent.c     OPAL_LIST_FOREACH(udp_listener, &udp_port_listeners,
udp_listener      845 opal/mca/btl/usnic/btl_usnic_cagent.c         if (udp_listener->ipv4_addr == cmd.src_ipv4_addr) {
udp_listener      864 opal/mca/btl/usnic/btl_usnic_cagent.c     ap->listener = udp_listener;
udp_listener      934 opal/mca/btl/usnic/btl_usnic_cagent.c     agent_udp_port_listener_t *udp_listener;
udp_listener      935 opal/mca/btl/usnic/btl_usnic_cagent.c     udp_listener = agent_thread_find_listener(cmd.ipv4_addr, &udp_port);
udp_listener      936 opal/mca/btl/usnic/btl_usnic_cagent.c     if (NULL != udp_listener) {
udp_listener      937 opal/mca/btl/usnic/btl_usnic_cagent.c         OBJ_RELEASE(udp_listener);
udp_listener     1107 opal/mca/btl/usnic/btl_usnic_cagent.c     agent_udp_port_listener_t *udp_listener, *ulnext;
udp_listener     1108 opal/mca/btl/usnic/btl_usnic_cagent.c     OPAL_LIST_FOREACH_SAFE(udp_listener, ulnext, &udp_port_listeners,
udp_listener     1110 opal/mca/btl/usnic/btl_usnic_cagent.c         OBJ_RELEASE(udp_listener);