mca_oob_tcp_component 101 orte/mca/oob/tcp/oob_tcp_common.c &mca_oob_tcp_component.keepalive_time, mca_oob_tcp_component 102 orte/mca/oob/tcp/oob_tcp_common.c sizeof(mca_oob_tcp_component.keepalive_time)) < 0) { mca_oob_tcp_component 113 orte/mca/oob/tcp/oob_tcp_common.c &mca_oob_tcp_component.keepalive_time, mca_oob_tcp_component 114 orte/mca/oob/tcp/oob_tcp_common.c sizeof(mca_oob_tcp_component.keepalive_time)) < 0) { mca_oob_tcp_component 126 orte/mca/oob/tcp/oob_tcp_common.c &mca_oob_tcp_component.keepalive_intvl, mca_oob_tcp_component 127 orte/mca/oob/tcp/oob_tcp_common.c sizeof(mca_oob_tcp_component.keepalive_intvl)) < 0) { mca_oob_tcp_component 139 orte/mca/oob/tcp/oob_tcp_common.c &mca_oob_tcp_component.keepalive_probes, mca_oob_tcp_component 140 orte/mca/oob/tcp/oob_tcp_common.c sizeof(mca_oob_tcp_component.keepalive_probes)) < 0) { mca_oob_tcp_component 166 orte/mca/oob/tcp/oob_tcp_common.c if (mca_oob_tcp_component.tcp_sndbuf > 0 && mca_oob_tcp_component 167 orte/mca/oob/tcp/oob_tcp_common.c setsockopt(sd, SOL_SOCKET, SO_SNDBUF, (char *)&mca_oob_tcp_component.tcp_sndbuf, sizeof(int)) < 0) { mca_oob_tcp_component 176 orte/mca/oob/tcp/oob_tcp_common.c if (mca_oob_tcp_component.tcp_rcvbuf > 0 && mca_oob_tcp_component 177 orte/mca/oob/tcp/oob_tcp_common.c setsockopt(sd, SOL_SOCKET, SO_RCVBUF, (char *)&mca_oob_tcp_component.tcp_rcvbuf, sizeof(int)) < 0) { mca_oob_tcp_component 186 orte/mca/oob/tcp/oob_tcp_common.c if (0 < mca_oob_tcp_component.keepalive_time) { mca_oob_tcp_component 197 orte/mca/oob/tcp/oob_tcp_common.c if (OPAL_SUCCESS != opal_hash_table_get_value_uint64(&mca_oob_tcp_component.peers, ui64, (void**)&peer)) { mca_oob_tcp_component 114 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component_t mca_oob_tcp_component = { mca_oob_tcp_component 148 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.next_base = 0; mca_oob_tcp_component 149 orte/mca/oob/tcp/oob_tcp_component.c OBJ_CONSTRUCT(&mca_oob_tcp_component.peers, opal_hash_table_t); mca_oob_tcp_component 150 orte/mca/oob/tcp/oob_tcp_component.c opal_hash_table_init(&mca_oob_tcp_component.peers, 32); mca_oob_tcp_component 151 orte/mca/oob/tcp/oob_tcp_component.c OBJ_CONSTRUCT(&mca_oob_tcp_component.ev_bases, opal_pointer_array_t); mca_oob_tcp_component 152 orte/mca/oob/tcp/oob_tcp_component.c opal_pointer_array_init(&mca_oob_tcp_component.ev_bases, mca_oob_tcp_component 155 orte/mca/oob/tcp/oob_tcp_component.c OBJ_CONSTRUCT(&mca_oob_tcp_component.listeners, opal_list_t); mca_oob_tcp_component 157 orte/mca/oob/tcp/oob_tcp_component.c OBJ_CONSTRUCT(&mca_oob_tcp_component.listen_thread, opal_thread_t); mca_oob_tcp_component 158 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.listen_thread_active = false; mca_oob_tcp_component 159 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.listen_thread_tv.tv_sec = 3600; mca_oob_tcp_component 160 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.listen_thread_tv.tv_usec = 0; mca_oob_tcp_component 162 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.addr_count = 0; mca_oob_tcp_component 163 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.ipv4conns = NULL; mca_oob_tcp_component 164 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.ipv4ports = NULL; mca_oob_tcp_component 165 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.ipv6conns = NULL; mca_oob_tcp_component 166 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.ipv6ports = NULL; mca_oob_tcp_component 171 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.super.oob_base.mca_type_name, mca_oob_tcp_component 172 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.super.oob_base.mca_component_name, mca_oob_tcp_component 174 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.super.oob_base.mca_type_name, mca_oob_tcp_component 175 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.super.oob_base.mca_component_name, mca_oob_tcp_component 190 orte/mca/oob/tcp/oob_tcp_component.c OPAL_LIST_DESTRUCT(&mca_oob_tcp_component.listeners); mca_oob_tcp_component 192 orte/mca/oob/tcp/oob_tcp_component.c OBJ_DESTRUCT(&mca_oob_tcp_component.peers); mca_oob_tcp_component 194 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.ipv4conns) { mca_oob_tcp_component 195 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.ipv4conns); mca_oob_tcp_component 197 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.ipv4ports) { mca_oob_tcp_component 198 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.ipv4ports); mca_oob_tcp_component 202 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.ipv6conns) { mca_oob_tcp_component 203 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.ipv6conns); mca_oob_tcp_component 205 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.ipv6ports) { mca_oob_tcp_component 206 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.ipv6ports); mca_oob_tcp_component 210 orte/mca/oob/tcp/oob_tcp_component.c OBJ_DESTRUCT(&mca_oob_tcp_component.ev_bases); mca_oob_tcp_component 226 orte/mca/oob/tcp/oob_tcp_component.c mca_base_component_t *component = &mca_oob_tcp_component.super.oob_base; mca_oob_tcp_component 230 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.peer_limit = -1; mca_oob_tcp_component 236 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.peer_limit); mca_oob_tcp_component 238 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.max_retries = 2; mca_oob_tcp_component 244 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.max_retries); mca_oob_tcp_component 246 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_sndbuf = 0; mca_oob_tcp_component 252 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.tcp_sndbuf); mca_oob_tcp_component 254 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_rcvbuf = 0; mca_oob_tcp_component 260 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.tcp_rcvbuf); mca_oob_tcp_component 262 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.if_include = NULL; mca_oob_tcp_component 268 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.if_include); mca_oob_tcp_component 272 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.if_exclude = NULL; mca_oob_tcp_component 278 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.if_exclude); mca_oob_tcp_component 283 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.if_include && mca_oob_tcp_component 284 orte/mca/oob/tcp/oob_tcp_component.c NULL != mca_oob_tcp_component.if_exclude) { mca_oob_tcp_component 288 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.if_include, mca_oob_tcp_component 289 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.if_exclude); mca_oob_tcp_component 303 orte/mca/oob/tcp/oob_tcp_component.c orte_util_parse_range_options(static_port_string, &mca_oob_tcp_component.tcp_static_ports); mca_oob_tcp_component 304 orte/mca/oob/tcp/oob_tcp_component.c if (0 == strcmp(mca_oob_tcp_component.tcp_static_ports[0], "-1")) { mca_oob_tcp_component 305 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.tcp_static_ports); mca_oob_tcp_component 306 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_static_ports = NULL; mca_oob_tcp_component 309 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_static_ports = NULL; mca_oob_tcp_component 323 orte/mca/oob/tcp/oob_tcp_component.c orte_util_parse_range_options(static_port_string6, &mca_oob_tcp_component.tcp6_static_ports); mca_oob_tcp_component 324 orte/mca/oob/tcp/oob_tcp_component.c if (0 == strcmp(mca_oob_tcp_component.tcp6_static_ports[0], "-1")) { mca_oob_tcp_component 325 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.tcp6_static_ports); mca_oob_tcp_component 326 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp6_static_ports = NULL; mca_oob_tcp_component 329 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp6_static_ports = NULL; mca_oob_tcp_component 333 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.tcp_static_ports || mca_oob_tcp_component 334 orte/mca/oob/tcp/oob_tcp_component.c NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 349 orte/mca/oob/tcp/oob_tcp_component.c char *err = opal_argv_join(mca_oob_tcp_component.tcp_static_ports, ','); mca_oob_tcp_component 355 orte/mca/oob/tcp/oob_tcp_component.c orte_util_parse_range_options(dyn_port_string, &mca_oob_tcp_component.tcp_dyn_ports); mca_oob_tcp_component 356 orte/mca/oob/tcp/oob_tcp_component.c if (0 == strcmp(mca_oob_tcp_component.tcp_dyn_ports[0], "-1")) { mca_oob_tcp_component 357 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.tcp_dyn_ports); mca_oob_tcp_component 358 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_dyn_ports = NULL; mca_oob_tcp_component 361 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp_dyn_ports = NULL; mca_oob_tcp_component 377 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.tcp_static_ports) { mca_oob_tcp_component 378 orte/mca/oob/tcp/oob_tcp_component.c err4 = opal_argv_join(mca_oob_tcp_component.tcp_static_ports, ','); mca_oob_tcp_component 380 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 381 orte/mca/oob/tcp/oob_tcp_component.c err6 = opal_argv_join(mca_oob_tcp_component.tcp6_static_ports, ','); mca_oob_tcp_component 395 orte/mca/oob/tcp/oob_tcp_component.c orte_util_parse_range_options(dyn_port_string6, &mca_oob_tcp_component.tcp6_dyn_ports); mca_oob_tcp_component 396 orte/mca/oob/tcp/oob_tcp_component.c if (0 == strcmp(mca_oob_tcp_component.tcp6_dyn_ports[0], "-1")) { mca_oob_tcp_component 397 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.tcp6_dyn_ports); mca_oob_tcp_component 398 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp6_dyn_ports = NULL; mca_oob_tcp_component 401 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.tcp6_dyn_ports = NULL; mca_oob_tcp_component 405 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.disable_ipv4_family = false; mca_oob_tcp_component 411 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.disable_ipv4_family); mca_oob_tcp_component 414 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.disable_ipv6_family = false; mca_oob_tcp_component 420 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.disable_ipv6_family); mca_oob_tcp_component 424 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.keepalive_time = 300; mca_oob_tcp_component 430 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.keepalive_time); mca_oob_tcp_component 433 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.keepalive_intvl = 20; mca_oob_tcp_component 439 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.keepalive_intvl); mca_oob_tcp_component 442 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.keepalive_probes = 9; mca_oob_tcp_component 448 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.keepalive_probes); mca_oob_tcp_component 450 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.retry_delay = 0; mca_oob_tcp_component 456 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.retry_delay); mca_oob_tcp_component 458 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.max_recon_attempts = 10; mca_oob_tcp_component 464 orte/mca/oob/tcp/oob_tcp_component.c &mca_oob_tcp_component.max_recon_attempts); mca_oob_tcp_component 489 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != mca_oob_tcp_component.if_include) { mca_oob_tcp_component 490 orte/mca/oob/tcp/oob_tcp_component.c interfaces = split_and_resolve(&mca_oob_tcp_component.if_include, mca_oob_tcp_component 494 orte/mca/oob/tcp/oob_tcp_component.c } else if (NULL != mca_oob_tcp_component.if_exclude) { mca_oob_tcp_component 495 orte/mca/oob/tcp/oob_tcp_component.c interfaces = split_and_resolve(&mca_oob_tcp_component.if_exclude, mca_oob_tcp_component 589 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_append_nosize(&mca_oob_tcp_component.ipv4conns, opal_net_get_hostname((struct sockaddr*) &my_ss)); mca_oob_tcp_component 597 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_append_nosize(&mca_oob_tcp_component.ipv6conns, opal_net_get_hostname((struct sockaddr*) &my_ss)); mca_oob_tcp_component 612 orte/mca/oob/tcp/oob_tcp_component.c if (0 == opal_argv_count(mca_oob_tcp_component.ipv4conns) mca_oob_tcp_component 614 orte/mca/oob/tcp/oob_tcp_component.c && 0 == opal_argv_count(mca_oob_tcp_component.ipv6conns) mca_oob_tcp_component 618 orte/mca/oob/tcp/oob_tcp_component.c orte_show_help("help-oob-tcp.txt", "no-included-found", true, mca_oob_tcp_component.if_include); mca_oob_tcp_component 620 orte/mca/oob/tcp/oob_tcp_component.c orte_show_help("help-oob-tcp.txt", "excluded-all", true, mca_oob_tcp_component.if_exclude); mca_oob_tcp_component 642 orte/mca/oob/tcp/oob_tcp_component.c opal_pointer_array_add(&mca_oob_tcp_component.ev_bases, orte_oob_base.ev_base); mca_oob_tcp_component 647 orte/mca/oob/tcp/oob_tcp_component.c opal_pointer_array_add(&mca_oob_tcp_component.ev_bases, evb); mca_oob_tcp_component 648 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_append_nosize(&mca_oob_tcp_component.ev_threads, tmp); mca_oob_tcp_component 682 orte/mca/oob/tcp/oob_tcp_component.c opal_progress_thread_finalize(mca_oob_tcp_component.ev_threads[i]); mca_oob_tcp_component 683 orte/mca/oob/tcp/oob_tcp_component.c opal_pointer_array_set_item(&mca_oob_tcp_component.ev_bases, i, NULL); mca_oob_tcp_component 685 orte/mca/oob/tcp/oob_tcp_component.c opal_argv_free(mca_oob_tcp_component.ev_threads); mca_oob_tcp_component 688 orte/mca/oob/tcp/oob_tcp_component.c if (ORTE_PROC_IS_HNP && mca_oob_tcp_component.listen_thread_active) { mca_oob_tcp_component 689 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_component.listen_thread_active = false; mca_oob_tcp_component 691 orte/mca/oob/tcp/oob_tcp_component.c write(mca_oob_tcp_component.stop_thread[1], &i, sizeof(int)); mca_oob_tcp_component 692 orte/mca/oob/tcp/oob_tcp_component.c opal_thread_join(&mca_oob_tcp_component.listen_thread, NULL); mca_oob_tcp_component 699 orte/mca/oob/tcp/oob_tcp_component.c rc = opal_hash_table_get_first_key_uint64(&mca_oob_tcp_component.peers, &key, mca_oob_tcp_component 704 orte/mca/oob/tcp/oob_tcp_component.c rc = opal_hash_table_set_value_uint64(&mca_oob_tcp_component.peers, key, NULL); mca_oob_tcp_component 709 orte/mca/oob/tcp/oob_tcp_component.c rc = opal_hash_table_get_next_key_uint64(&mca_oob_tcp_component.peers, &key, mca_oob_tcp_component 740 orte/mca/oob/tcp/oob_tcp_component.c if (!mca_oob_tcp_component.disable_ipv4_family && mca_oob_tcp_component 741 orte/mca/oob/tcp/oob_tcp_component.c NULL != mca_oob_tcp_component.ipv4conns) { mca_oob_tcp_component 742 orte/mca/oob/tcp/oob_tcp_component.c tmp = opal_argv_join(mca_oob_tcp_component.ipv4conns, ','); mca_oob_tcp_component 743 orte/mca/oob/tcp/oob_tcp_component.c tp = opal_argv_join(mca_oob_tcp_component.ipv4ports, ','); mca_oob_tcp_component 749 orte/mca/oob/tcp/oob_tcp_component.c if (!mca_oob_tcp_component.disable_ipv6_family && mca_oob_tcp_component 750 orte/mca/oob/tcp/oob_tcp_component.c NULL != mca_oob_tcp_component.ipv6conns) { mca_oob_tcp_component 764 orte/mca/oob/tcp/oob_tcp_component.c tmp = opal_argv_join(mca_oob_tcp_component.ipv6conns, ','); mca_oob_tcp_component 765 orte/mca/oob/tcp/oob_tcp_component.c tp = opal_argv_join(mca_oob_tcp_component.ipv6ports, ','); mca_oob_tcp_component 910 orte/mca/oob/tcp/oob_tcp_component.c if (NULL == mca_oob_tcp_component.ipv6conns || mca_oob_tcp_component 911 orte/mca/oob/tcp/oob_tcp_component.c NULL == mca_oob_tcp_component.ipv6conns[0]) { mca_oob_tcp_component 914 orte/mca/oob/tcp/oob_tcp_component.c host = mca_oob_tcp_component.ipv6conns[0]; mca_oob_tcp_component 917 orte/mca/oob/tcp/oob_tcp_component.c if (NULL == mca_oob_tcp_component.ipv4conns || mca_oob_tcp_component 918 orte/mca/oob/tcp/oob_tcp_component.c NULL == mca_oob_tcp_component.ipv4conns[0]) { mca_oob_tcp_component 921 orte/mca/oob/tcp/oob_tcp_component.c host = mca_oob_tcp_component.ipv4conns[0]; mca_oob_tcp_component 937 orte/mca/oob/tcp/oob_tcp_component.c if (OPAL_SUCCESS != opal_hash_table_set_value_uint64(&mca_oob_tcp_component.peers, ui64, pr)) { mca_oob_tcp_component 948 orte/mca/oob/tcp/oob_tcp_component.c rc = opal_hash_table_set_value_uint64(&mca_oob_tcp_component.peers, ui64, NULL); mca_oob_tcp_component 1034 orte/mca/oob/tcp/oob_tcp_component.c opal_bitmap_set_bit(&bpr->addressable, mca_oob_tcp_component.super.idx); mca_oob_tcp_component 1035 orte/mca/oob/tcp/oob_tcp_component.c bpr->component = &mca_oob_tcp_component.super; mca_oob_tcp_component 1062 orte/mca/oob/tcp/oob_tcp_component.c opal_bitmap_clear_bit(&bpr->addressable, mca_oob_tcp_component.super.idx); mca_oob_tcp_component 1101 orte/mca/oob/tcp/oob_tcp_component.c opal_bitmap_clear_bit(&bpr->addressable, mca_oob_tcp_component.super.idx); mca_oob_tcp_component 1156 orte/mca/oob/tcp/oob_tcp_component.c opal_bitmap_clear_bit(&bpr->addressable, mca_oob_tcp_component.super.idx); mca_oob_tcp_component 1170 orte/mca/oob/tcp/oob_tcp_component.c opal_bitmap_clear_bit(&bpr->addressable, mca_oob_tcp_component.super.idx); mca_oob_tcp_component 91 orte/mca/oob/tcp/oob_tcp_component.h ORTE_MODULE_DECLSPEC extern mca_oob_tcp_component_t mca_oob_tcp_component; mca_oob_tcp_component 101 orte/mca/oob/tcp/oob_tcp_component.h ++mca_oob_tcp_component.next_base; \ mca_oob_tcp_component 102 orte/mca/oob/tcp/oob_tcp_component.h if (orte_oob_base.num_threads <= mca_oob_tcp_component.next_base) { \ mca_oob_tcp_component 103 orte/mca/oob/tcp/oob_tcp_component.h mca_oob_tcp_component.next_base = 0; \ mca_oob_tcp_component 105 orte/mca/oob/tcp/oob_tcp_component.h (p)->ev_base = (opal_event_base_t*)opal_pointer_array_get_item(&mca_oob_tcp_component.ev_bases, mca_oob_tcp_component.next_base); \ mca_oob_tcp_component 203 orte/mca/oob/tcp/oob_tcp_connection.c if (mca_oob_tcp_component.max_retries < addr->retries) { mca_oob_tcp_component 263 orte/mca/oob/tcp/oob_tcp_connection.c if (addr->retries < mca_oob_tcp_component.max_retries) { mca_oob_tcp_component 290 orte/mca/oob/tcp/oob_tcp_connection.c if (0 < mca_oob_tcp_component.retry_delay) { mca_oob_tcp_component 291 orte/mca/oob/tcp/oob_tcp_connection.c if (mca_oob_tcp_component.max_recon_attempts < 0 || mca_oob_tcp_component 292 orte/mca/oob/tcp/oob_tcp_connection.c peer->num_retries < mca_oob_tcp_component.max_recon_attempts) { mca_oob_tcp_component 302 orte/mca/oob/tcp/oob_tcp_connection.c tv.tv_sec = mca_oob_tcp_component.retry_delay; mca_oob_tcp_component 809 orte/mca/oob/tcp/oob_tcp_connection.c if (OPAL_SUCCESS != opal_hash_table_set_value_uint64(&mca_oob_tcp_component.peers, (*ui64), peer)) { mca_oob_tcp_component 105 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL == mca_oob_tcp_component.ipv4conns mca_oob_tcp_component 107 orte/mca/oob/tcp/oob_tcp_listener.c && NULL == mca_oob_tcp_component.ipv6conns mca_oob_tcp_component 132 orte/mca/oob/tcp/oob_tcp_listener.c if (0 > pipe(mca_oob_tcp_component.stop_thread)) { mca_oob_tcp_component 139 orte/mca/oob/tcp/oob_tcp_listener.c if (opal_fd_set_cloexec(mca_oob_tcp_component.stop_thread[0]) != OPAL_SUCCESS || mca_oob_tcp_component 140 orte/mca/oob/tcp/oob_tcp_listener.c opal_fd_set_cloexec(mca_oob_tcp_component.stop_thread[1]) != OPAL_SUCCESS) { mca_oob_tcp_component 141 orte/mca/oob/tcp/oob_tcp_listener.c close(mca_oob_tcp_component.stop_thread[0]); mca_oob_tcp_component 142 orte/mca/oob/tcp/oob_tcp_listener.c close(mca_oob_tcp_component.stop_thread[1]); mca_oob_tcp_component 147 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_component.listen_thread_active = true; mca_oob_tcp_component 148 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_component.listen_thread.t_run = listen_thread; mca_oob_tcp_component 149 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_component.listen_thread.t_arg = NULL; mca_oob_tcp_component 150 orte/mca/oob/tcp/oob_tcp_listener.c if (OPAL_SUCCESS != (rc = opal_thread_start(&mca_oob_tcp_component.listen_thread))) { mca_oob_tcp_component 158 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { mca_oob_tcp_component 198 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp_static_ports) { mca_oob_tcp_component 202 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp_static_ports[0]); mca_oob_tcp_component 205 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp_dyn_ports) { mca_oob_tcp_component 207 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp_dyn_ports); mca_oob_tcp_component 215 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp_static_ports) { mca_oob_tcp_component 219 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp_static_ports[0]); mca_oob_tcp_component 222 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp_dyn_ports) { mca_oob_tcp_component 224 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp_dyn_ports); mca_oob_tcp_component 232 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp_static_ports) { mca_oob_tcp_component 240 orte/mca/oob/tcp/oob_tcp_listener.c (nrank+1) < opal_argv_count(mca_oob_tcp_component.tcp_static_ports)) { mca_oob_tcp_component 242 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp_static_ports[nrank+1]); mca_oob_tcp_component 250 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp_dyn_ports) { mca_oob_tcp_component 252 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp_dyn_ports); mca_oob_tcp_component 267 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp_static_ports) { mca_oob_tcp_component 395 orte/mca/oob/tcp/oob_tcp_listener.c opal_list_append(&mca_oob_tcp_component.listeners, &conn->item); mca_oob_tcp_component 398 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&mca_oob_tcp_component.ipv4ports, tconn); mca_oob_tcp_component 414 orte/mca/oob/tcp/oob_tcp_listener.c if (0 == opal_list_get_size(&mca_oob_tcp_component.listeners)) { mca_oob_tcp_component 451 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 455 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp6_static_ports[0]); mca_oob_tcp_component 458 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp6_dyn_ports) { mca_oob_tcp_component 460 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp6_dyn_ports); mca_oob_tcp_component 468 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 472 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp6_static_ports[0]); mca_oob_tcp_component 475 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp6_dyn_ports) { mca_oob_tcp_component 477 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp6_dyn_ports); mca_oob_tcp_component 485 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 493 orte/mca/oob/tcp/oob_tcp_listener.c (nrank+1) < opal_argv_count(mca_oob_tcp_component.tcp6_static_ports)) { mca_oob_tcp_component 495 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&ports, mca_oob_tcp_component.tcp6_static_ports[nrank+1]); mca_oob_tcp_component 503 orte/mca/oob/tcp/oob_tcp_listener.c } else if (NULL != mca_oob_tcp_component.tcp6_dyn_ports) { mca_oob_tcp_component 505 orte/mca/oob/tcp/oob_tcp_listener.c ports = opal_argv_copy(mca_oob_tcp_component.tcp6_dyn_ports); mca_oob_tcp_component 520 orte/mca/oob/tcp/oob_tcp_listener.c if (NULL != mca_oob_tcp_component.tcp6_static_ports) { mca_oob_tcp_component 636 orte/mca/oob/tcp/oob_tcp_listener.c opal_list_append(&mca_oob_tcp_component.listeners, &conn->item); mca_oob_tcp_component 639 orte/mca/oob/tcp/oob_tcp_listener.c opal_argv_append_nosize(&mca_oob_tcp_component.ipv6ports, tconn); mca_oob_tcp_component 652 orte/mca/oob/tcp/oob_tcp_listener.c if (0 == opal_list_get_size(&mca_oob_tcp_component.listeners)) { mca_oob_tcp_component 687 orte/mca/oob/tcp/oob_tcp_listener.c while (mca_oob_tcp_component.listen_thread_active) { mca_oob_tcp_component 690 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { mca_oob_tcp_component 695 orte/mca/oob/tcp/oob_tcp_listener.c FD_SET(mca_oob_tcp_component.stop_thread[0], &readfds); mca_oob_tcp_component 696 orte/mca/oob/tcp/oob_tcp_listener.c max = (mca_oob_tcp_component.stop_thread[0] > max) ? mca_oob_tcp_component.stop_thread[0] : max; mca_oob_tcp_component 699 orte/mca/oob/tcp/oob_tcp_listener.c timeout.tv_sec = mca_oob_tcp_component.listen_thread_tv.tv_sec; mca_oob_tcp_component 700 orte/mca/oob/tcp/oob_tcp_listener.c timeout.tv_usec = mca_oob_tcp_component.listen_thread_tv.tv_usec; mca_oob_tcp_component 706 orte/mca/oob/tcp/oob_tcp_listener.c if (!mca_oob_tcp_component.listen_thread_active) { mca_oob_tcp_component 708 orte/mca/oob/tcp/oob_tcp_listener.c close(mca_oob_tcp_component.stop_thread[0]); mca_oob_tcp_component 709 orte/mca/oob/tcp/oob_tcp_listener.c close(mca_oob_tcp_component.stop_thread[1]); mca_oob_tcp_component 725 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { mca_oob_tcp_component 844 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) {