mca_btl_tcp_component 93 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_eager_mutex); \ mca_btl_tcp_component 94 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h OMPI_FREE_LIST_GET_MT(&mca_btl_tcp_component.tcp_frag_eager, item); \ mca_btl_tcp_component 95 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_eager_mutex); \ mca_btl_tcp_component 102 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_max_mutex); \ mca_btl_tcp_component 103 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h OMPI_FREE_LIST_GET_MT(&mca_btl_tcp_component.tcp_frag_max, item); \ mca_btl_tcp_component 104 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_max_mutex); \ mca_btl_tcp_component 111 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_user_mutex); \ mca_btl_tcp_component 112 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h OMPI_FREE_LIST_GET_MT(&mca_btl_tcp_component.tcp_frag_user, item); \ mca_btl_tcp_component 113 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_user_mutex); \ mca_btl_tcp_component 121 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h if( frag->my_list == &mca_btl_tcp_component.tcp_frag_eager ) { \ mca_btl_tcp_component 122 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_eager_mutex); \ mca_btl_tcp_component 124 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_eager_mutex); \ mca_btl_tcp_component 125 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h } else if( frag->my_list == &mca_btl_tcp_component.tcp_frag_max ) { \ mca_btl_tcp_component 126 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_max_mutex); \ mca_btl_tcp_component 128 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_max_mutex); \ mca_btl_tcp_component 130 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h assert( frag->my_list == &mca_btl_tcp_component.tcp_frag_user ); \ mca_btl_tcp_component 131 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_frag_user_mutex); \ mca_btl_tcp_component 133 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_frag_user_mutex); \ mca_btl_tcp_component 81 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 82 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c opal_hash_table_remove_value_uint64(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 84 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 107 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 108 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c rc = opal_hash_table_get_value_uint64(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 111 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 121 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c opal_hash_table_set_value_uint64(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 123 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 715 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 716 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c opal_hash_table_get_value_uint64(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 718 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 44 opal/mca/btl/tcp/btl_tcp.c .btl_component = &mca_btl_tcp_component.super, mca_btl_tcp_component 159 opal/mca/btl/tcp/btl_tcp.h OPAL_MODULE_DECLSPEC extern mca_btl_tcp_component_t mca_btl_tcp_component; mca_btl_tcp_component 111 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component_t mca_btl_tcp_component = { mca_btl_tcp_component 144 opal/mca/btl/tcp/btl_tcp_component.c (void) mca_base_component_var_register(&mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 159 opal/mca/btl/tcp/btl_tcp_component.c (void) mca_base_component_var_register(&mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 174 opal/mca/btl/tcp/btl_tcp_component.c (void) mca_base_component_var_register(&mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 194 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 195 opal/mca/btl/tcp/btl_tcp_component.c opal_list_append(&mca_btl_tcp_component.tcp_events, &event->item); mca_btl_tcp_component 196 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 201 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 202 opal/mca/btl/tcp/btl_tcp_component.c opal_list_remove_item(&mca_btl_tcp_component.tcp_events, &event->item); mca_btl_tcp_component 203 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 221 opal/mca/btl/tcp/btl_tcp_component.c if( mca_btl_tcp_component.tcp_port_min > USHRT_MAX ) { mca_btl_tcp_component 224 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_port_min ); mca_btl_tcp_component 225 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_port_min = 1024; mca_btl_tcp_component 228 opal/mca/btl/tcp/btl_tcp_component.c if( mca_btl_tcp_component.tcp6_port_min > USHRT_MAX ) { mca_btl_tcp_component 231 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_port_min ); mca_btl_tcp_component 232 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_port_min = 1024; mca_btl_tcp_component 249 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_uint("links", NULL, 1, OPAL_INFO_LVL_4, &mca_btl_tcp_component.tcp_num_links); mca_btl_tcp_component 250 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_string("if_include", "Comma-delimited list of devices and/or CIDR notation of networks to use for MPI communication (e.g., \"eth0,192.168.0.0/16\"). Mutually exclusive with btl_tcp_if_exclude.", "", OPAL_INFO_LVL_1, &mca_btl_tcp_component.tcp_if_include); mca_btl_tcp_component 253 opal/mca/btl/tcp/btl_tcp_component.c OPAL_INFO_LVL_1, &mca_btl_tcp_component.tcp_if_exclude); mca_btl_tcp_component 255 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_int ("free_list_num", NULL, 8, OPAL_INFO_LVL_5, &mca_btl_tcp_component.tcp_free_list_num); mca_btl_tcp_component 256 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_int ("free_list_max", NULL, -1, OPAL_INFO_LVL_5, &mca_btl_tcp_component.tcp_free_list_max); mca_btl_tcp_component 257 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_int ("free_list_inc", NULL, 32, OPAL_INFO_LVL_5, &mca_btl_tcp_component.tcp_free_list_inc); mca_btl_tcp_component 264 opal/mca/btl/tcp/btl_tcp_component.c 0, OPAL_INFO_LVL_4, &mca_btl_tcp_component.tcp_sndbuf); mca_btl_tcp_component 271 opal/mca/btl/tcp/btl_tcp_component.c 0, OPAL_INFO_LVL_4, &mca_btl_tcp_component.tcp_rcvbuf); mca_btl_tcp_component 276 opal/mca/btl/tcp/btl_tcp_component.c " endpoint_cache", 30*1024, OPAL_INFO_LVL_4, &mca_btl_tcp_component.tcp_endpoint_cache); mca_btl_tcp_component 278 opal/mca/btl/tcp/btl_tcp_component.c 0, OPAL_INFO_LVL_4, &mca_btl_tcp_component.tcp_not_use_nodelay); mca_btl_tcp_component 281 opal/mca/btl/tcp/btl_tcp_component.c 1024, OPAL_INFO_LVL_2, &mca_btl_tcp_component.tcp_port_min); mca_btl_tcp_component 287 opal/mca/btl/tcp/btl_tcp_component.c (0x1 << 16) - mca_btl_tcp_component.tcp_port_min - 1 ); mca_btl_tcp_component 289 opal/mca/btl/tcp/btl_tcp_component.c (0x1 << 16) - mca_btl_tcp_component.tcp_port_min - 1, mca_btl_tcp_component 290 opal/mca/btl/tcp/btl_tcp_component.c OPAL_INFO_LVL_2, &mca_btl_tcp_component.tcp_port_range); mca_btl_tcp_component 295 opal/mca/btl/tcp/btl_tcp_component.c OPAL_INFO_LVL_2, & mca_btl_tcp_component.tcp6_port_min ); mca_btl_tcp_component 300 opal/mca/btl/tcp/btl_tcp_component.c (0x1 << 16) - mca_btl_tcp_component.tcp6_port_min - 1 ); mca_btl_tcp_component 302 opal/mca/btl/tcp/btl_tcp_component.c (0x1 << 16) - mca_btl_tcp_component.tcp6_port_min - 1, mca_btl_tcp_component 303 opal/mca/btl/tcp/btl_tcp_component.c OPAL_INFO_LVL_2, &mca_btl_tcp_component.tcp6_port_range ); mca_btl_tcp_component 309 opal/mca/btl/tcp/btl_tcp_component.c &mca_btl_tcp_component.tcp_enable_progress_thread); mca_btl_tcp_component 310 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.report_all_unfound_interfaces = false; mca_btl_tcp_component 311 opal/mca/btl/tcp/btl_tcp_component.c (void) mca_base_component_var_register(&mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 316 opal/mca/btl/tcp/btl_tcp_component.c MCA_BASE_VAR_SCOPE_READONLY, &mca_btl_tcp_component.report_all_unfound_interfaces); mca_btl_tcp_component 343 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_base_param_register(&mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 350 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_int ("disable_family", NULL, 0, OPAL_INFO_LVL_2, &mca_btl_tcp_component.tcp_disable_family); mca_btl_tcp_component 362 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_sd = -1; mca_btl_tcp_component 364 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_sd = -1; mca_btl_tcp_component 366 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_num_btls = 0; mca_btl_tcp_component 367 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_addr_count = 0; mca_btl_tcp_component 368 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls = NULL; mca_btl_tcp_component 371 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_lock, opal_mutex_t); mca_btl_tcp_component 372 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_procs, opal_proc_table_t); mca_btl_tcp_component 373 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_events, opal_list_t); mca_btl_tcp_component 374 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_eager, opal_free_list_t); mca_btl_tcp_component 375 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_max, opal_free_list_t); mca_btl_tcp_component 376 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_user, opal_free_list_t); mca_btl_tcp_component 377 opal/mca/btl/tcp/btl_tcp_component.c opal_proc_table_init(&mca_btl_tcp_component.tcp_procs, 16, 256); mca_btl_tcp_component 379 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_eager_mutex, opal_mutex_t); mca_btl_tcp_component 380 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_max_mutex, opal_mutex_t); mca_btl_tcp_component 381 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&mca_btl_tcp_component.tcp_frag_user_mutex, opal_mutex_t); mca_btl_tcp_component 388 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.super.btl_version.mca_type_name, mca_btl_tcp_component 389 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.super.btl_version.mca_component_name, mca_btl_tcp_component 391 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.super.btl_version.mca_type_name, mca_btl_tcp_component 392 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.super.btl_version.mca_component_name, mca_btl_tcp_component 431 opal/mca/btl/tcp/btl_tcp_component.c opal_event_del(&mca_btl_tcp_component.tcp_recv_thread_async_event); mca_btl_tcp_component 442 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_frag_eager_mutex); mca_btl_tcp_component 443 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_frag_max_mutex); mca_btl_tcp_component 448 opal/mca/btl/tcp/btl_tcp_component.c if (NULL != mca_btl_tcp_component.tcp_btls) { mca_btl_tcp_component 449 opal/mca/btl/tcp/btl_tcp_component.c free(mca_btl_tcp_component.tcp_btls); mca_btl_tcp_component 452 opal/mca/btl/tcp/btl_tcp_component.c if (mca_btl_tcp_component.tcp_listen_sd >= 0) { mca_btl_tcp_component 453 opal/mca/btl/tcp/btl_tcp_component.c opal_event_del(&mca_btl_tcp_component.tcp_recv_event); mca_btl_tcp_component 454 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(mca_btl_tcp_component.tcp_listen_sd); mca_btl_tcp_component 455 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_sd = -1; mca_btl_tcp_component 458 opal/mca/btl/tcp/btl_tcp_component.c if (mca_btl_tcp_component.tcp6_listen_sd >= 0) { mca_btl_tcp_component 459 opal/mca/btl/tcp/btl_tcp_component.c opal_event_del(&mca_btl_tcp_component.tcp6_recv_event); mca_btl_tcp_component 460 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(mca_btl_tcp_component.tcp6_listen_sd); mca_btl_tcp_component 461 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_sd = -1; mca_btl_tcp_component 467 opal/mca/btl/tcp/btl_tcp_component.c OPAL_LIST_FOREACH_SAFE(event, next, &mca_btl_tcp_component.tcp_events, mca_btl_tcp_event_t) { mca_btl_tcp_component 472 opal/mca/btl/tcp/btl_tcp_component.c opal_proc_table_remove_value(&mca_btl_tcp_component.tcp_procs, opal_proc_local_get()->proc_name); mca_btl_tcp_component 475 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_procs); mca_btl_tcp_component 476 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_frag_eager); mca_btl_tcp_component 477 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_frag_max); mca_btl_tcp_component 478 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_frag_user); mca_btl_tcp_component 479 opal/mca/btl/tcp/btl_tcp_component.c OBJ_DESTRUCT(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 532 opal/mca/btl/tcp/btl_tcp_component.c 4 != mca_btl_tcp_component.tcp_disable_family) { mca_btl_tcp_component 536 opal/mca/btl/tcp/btl_tcp_component.c 6 != mca_btl_tcp_component.tcp_disable_family) { mca_btl_tcp_component 547 opal/mca/btl/tcp/btl_tcp_component.c for( i = 0; i < (int)mca_btl_tcp_component.tcp_num_links; i++ ) { mca_btl_tcp_component 554 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls[mca_btl_tcp_component.tcp_num_btls++] = btl; mca_btl_tcp_component 694 opal/mca/btl/tcp/btl_tcp_component.c if (reqd || mca_btl_tcp_component.report_all_unfound_interfaces) { mca_btl_tcp_component 783 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls = (mca_btl_tcp_module_t**)malloc(mca_btl_tcp_component.tcp_num_links * mca_btl_tcp_component 785 opal/mca/btl/tcp/btl_tcp_component.c if(NULL == mca_btl_tcp_component.tcp_btls) { mca_btl_tcp_component 790 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_addr_count = if_count; mca_btl_tcp_component 793 opal/mca/btl/tcp/btl_tcp_component.c argv = include = split_and_resolve(&mca_btl_tcp_component.tcp_if_include, mca_btl_tcp_component 811 opal/mca/btl/tcp/btl_tcp_component.c if (mca_btl_tcp_component.tcp_num_btls > 0) { mca_btl_tcp_component 819 opal/mca/btl/tcp/btl_tcp_component.c exclude = split_and_resolve(&mca_btl_tcp_component.tcp_if_exclude, mca_btl_tcp_component 966 opal/mca/btl/tcp/btl_tcp_component.c range = mca_btl_tcp_component.tcp6_port_range; mca_btl_tcp_component 967 opal/mca/btl/tcp/btl_tcp_component.c port = mca_btl_tcp_component.tcp6_port_min; mca_btl_tcp_component 971 opal/mca/btl/tcp/btl_tcp_component.c range = mca_btl_tcp_component.tcp_port_range; mca_btl_tcp_component 972 opal/mca/btl/tcp/btl_tcp_component.c port = mca_btl_tcp_component.tcp_port_min; mca_btl_tcp_component 1003 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_port_min, mca_btl_tcp_component 1004 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_port_min + range)); mca_btl_tcp_component 1009 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_port_min, mca_btl_tcp_component 1010 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_port_min + range)); mca_btl_tcp_component 1026 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_port = ((struct sockaddr_in6*) &inaddr)->sin6_port; mca_btl_tcp_component 1027 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_sd = sd; mca_btl_tcp_component 1030 opal/mca/btl/tcp/btl_tcp_component.c ntohs(mca_btl_tcp_component.tcp6_listen_port)); mca_btl_tcp_component 1035 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_port = ((struct sockaddr_in*) &inaddr)->sin_port; mca_btl_tcp_component 1036 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_sd = sd; mca_btl_tcp_component 1040 opal/mca/btl/tcp/btl_tcp_component.c str, ntohs(mca_btl_tcp_component.tcp_listen_port)); mca_btl_tcp_component 1072 opal/mca/btl/tcp/btl_tcp_component.c if(mca_btl_tcp_component.tcp_enable_progress_thread){ mca_btl_tcp_component 1108 opal/mca/btl/tcp/btl_tcp_component.c opal_event_set(mca_btl_tcp_event_base, &mca_btl_tcp_component.tcp_recv_thread_async_event, mca_btl_tcp_component 1113 opal/mca/btl/tcp/btl_tcp_component.c opal_event_add(&mca_btl_tcp_component.tcp_recv_thread_async_event, 0); mca_btl_tcp_component 1137 opal/mca/btl/tcp/btl_tcp_component.c opal_event_set(mca_btl_tcp_event_base, &mca_btl_tcp_component.tcp_recv_event, mca_btl_tcp_component 1138 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_sd, mca_btl_tcp_component 1142 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_ACTIVATE_EVENT(&mca_btl_tcp_component.tcp_recv_event, 0); mca_btl_tcp_component 1146 opal/mca/btl/tcp/btl_tcp_component.c opal_event_set(mca_btl_tcp_event_base, &mca_btl_tcp_component.tcp6_recv_event, mca_btl_tcp_component 1147 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_sd, mca_btl_tcp_component 1151 opal/mca/btl/tcp/btl_tcp_component.c MCA_BTL_TCP_ACTIVATE_EVENT(&mca_btl_tcp_component.tcp6_recv_event, 0); mca_btl_tcp_component 1166 opal/mca/btl/tcp/btl_tcp_component.c size_t num_btls = mca_btl_tcp_component.tcp_num_btls; mca_btl_tcp_component 1181 opal/mca/btl/tcp/btl_tcp_component.c struct mca_btl_tcp_module_t *btl = mca_btl_tcp_component.tcp_btls[i]; mca_btl_tcp_component 1190 opal/mca/btl/tcp/btl_tcp_component.c addrs[i].addr_port = mca_btl_tcp_component.tcp6_listen_port; mca_btl_tcp_component 1204 opal/mca/btl/tcp/btl_tcp_component.c addrs[i].addr_port = mca_btl_tcp_component.tcp_listen_port; mca_btl_tcp_component 1218 opal/mca/btl/tcp/btl_tcp_component.c &mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 1242 opal/mca/btl/tcp/btl_tcp_component.c opal_free_list_init( &mca_btl_tcp_component.tcp_frag_eager, mca_btl_tcp_component 1248 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_num, mca_btl_tcp_component 1249 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_max, mca_btl_tcp_component 1250 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_inc, mca_btl_tcp_component 1253 opal/mca/btl/tcp/btl_tcp_component.c opal_free_list_init( &mca_btl_tcp_component.tcp_frag_max, mca_btl_tcp_component 1259 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_num, mca_btl_tcp_component 1260 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_max, mca_btl_tcp_component 1261 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_inc, mca_btl_tcp_component 1264 opal/mca/btl/tcp/btl_tcp_component.c opal_free_list_init( &mca_btl_tcp_component.tcp_frag_user, mca_btl_tcp_component 1269 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_num, mca_btl_tcp_component 1270 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_max, mca_btl_tcp_component 1271 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_free_list_inc, mca_btl_tcp_component 1297 opal/mca/btl/tcp/btl_tcp_component.c btls = (mca_btl_base_module_t **)malloc(mca_btl_tcp_component.tcp_num_btls * mca_btl_tcp_component 1305 opal/mca/btl/tcp/btl_tcp_component.c for( i = 0; i < mca_btl_tcp_component.tcp_num_btls; i++) { mca_btl_tcp_component 1306 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls[i]->super.btl_flags |= MCA_BTL_FLAGS_BTL_PROGRESS_THREAD_ENABLED; mca_btl_tcp_component 1321 opal/mca/btl/tcp/btl_tcp_component.c if (mca_btl_tcp_component.tcp_num_btls > 1 && mca_btl_tcp_component 1323 opal/mca/btl/tcp/btl_tcp_component.c for( i = 0; i < mca_btl_tcp_component.tcp_num_btls; i++) { mca_btl_tcp_component 1324 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls[i]->super.btl_flags |= MCA_BTL_FLAGS_SINGLE_ADD_PROCS; mca_btl_tcp_component 1332 opal/mca/btl/tcp/btl_tcp_component.c memcpy(btls, mca_btl_tcp_component.tcp_btls, mca_btl_tcp_component.tcp_num_btls*sizeof(mca_btl_tcp_module_t*)); mca_btl_tcp_component 1333 opal/mca/btl/tcp/btl_tcp_component.c *num_btl_modules = mca_btl_tcp_component.tcp_num_btls; mca_btl_tcp_component 304 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache = (char*)malloc(mca_btl_tcp_component.tcp_endpoint_cache); mca_btl_tcp_component 643 opal/mca/btl/tcp/btl_tcp_endpoint.c optval = !mca_btl_tcp_component.tcp_not_use_nodelay; mca_btl_tcp_component 650 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_component.tcp_sndbuf > 0 && mca_btl_tcp_component 651 opal/mca/btl/tcp/btl_tcp_endpoint.c setsockopt(sd, SOL_SOCKET, SO_SNDBUF, (char *)&mca_btl_tcp_component.tcp_sndbuf, sizeof(int)) < 0) { mca_btl_tcp_component 657 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_component.tcp_rcvbuf > 0 && mca_btl_tcp_component 658 opal/mca/btl/tcp/btl_tcp_endpoint.c setsockopt(sd, SOL_SOCKET, SO_RCVBUF, (char *)&mca_btl_tcp_component.tcp_rcvbuf, sizeof(int)) < 0) { mca_btl_tcp_component 57 opal/mca/btl/tcp/btl_tcp_frag.c frag->my_list = &mca_btl_tcp_component.tcp_frag_eager; mca_btl_tcp_component 63 opal/mca/btl/tcp/btl_tcp_frag.c frag->my_list = &mca_btl_tcp_component.tcp_frag_max; mca_btl_tcp_component 69 opal/mca/btl/tcp/btl_tcp_frag.c frag->my_list = &mca_btl_tcp_component.tcp_frag_user; mca_btl_tcp_component 206 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_component.tcp_endpoint_cache - btl_endpoint->endpoint_cache_length; mca_btl_tcp_component 93 opal/mca/btl/tcp/btl_tcp_frag.h opal_free_list_get (&mca_btl_tcp_component.tcp_frag_eager); \ mca_btl_tcp_component 99 opal/mca/btl/tcp/btl_tcp_frag.h opal_free_list_get (&mca_btl_tcp_component.tcp_frag_max); \ mca_btl_tcp_component 105 opal/mca/btl/tcp/btl_tcp_frag.h opal_free_list_get (&mca_btl_tcp_component.tcp_frag_user); \ mca_btl_tcp_component 92 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_LOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 93 opal/mca/btl/tcp/btl_tcp_proc.c opal_proc_table_remove_value(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 95 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 124 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_LOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 125 opal/mca/btl/tcp/btl_tcp_proc.c rc = opal_proc_table_get_value(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 128 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 146 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_MODEX_RECV(rc, &mca_btl_tcp_component.super.btl_version, mca_btl_tcp_component 216 opal/mca/btl/tcp/btl_tcp_proc.c opal_proc_table_set_value(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 226 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 312 opal/mca/btl/tcp/btl_tcp_proc.c include = opal_argv_split(mca_btl_tcp_component.tcp_if_include,','); mca_btl_tcp_component 313 opal/mca/btl/tcp/btl_tcp_proc.c exclude = opal_argv_split(mca_btl_tcp_component.tcp_if_exclude,','); mca_btl_tcp_component 393 opal/mca/btl/tcp/btl_tcp_proc.c if (4 == mca_btl_tcp_component.tcp_disable_family) { mca_btl_tcp_component 407 opal/mca/btl/tcp/btl_tcp_proc.c if (6 == mca_btl_tcp_component.tcp_disable_family) { mca_btl_tcp_component 528 opal/mca/btl/tcp/btl_tcp_proc.c if(endpoint_addr->addr_inuse >= mca_btl_tcp_component.tcp_num_links) { mca_btl_tcp_component 819 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_LOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 820 opal/mca/btl/tcp/btl_tcp_proc.c opal_proc_table_get_value(&mca_btl_tcp_component.tcp_procs, mca_btl_tcp_component 822 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&mca_btl_tcp_component.tcp_lock); mca_btl_tcp_component 836 opal/mca/btl/tcp/btl_tcp_proc.c for( uint32_t i = 0; i < mca_btl_tcp_component.tcp_num_btls; ++i ) { mca_btl_tcp_component 838 opal/mca/btl/tcp/btl_tcp_proc.c (void) mca_btl_tcp_add_procs (&mca_btl_tcp_component.tcp_btls[i]->super, 1, &opal_proc,