btl_proc 1037 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_proc_t* btl_proc; btl_proc 1064 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl_proc = mca_btl_tcp2_proc_lookup(&guid); btl_proc 1065 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(NULL == btl_proc) { btl_proc 1079 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(mca_btl_tcp2_proc_accept(btl_proc, (struct sockaddr*)&addr, sd) == false) { btl_proc 340 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_proc_t* btl_proc = mca_btl_tcp2_proc_local(); btl_proc 341 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c orte_process_name_t guid = btl_proc->proc_ompi->proc_name; btl_proc 503 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_proc_t* btl_proc = btl_endpoint->endpoint_proc; btl_proc 511 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c &btl_proc->proc_ompi->proc_name, btl_proc 105 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c mca_btl_tcp2_proc_t* btl_proc; btl_proc 109 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c hash, (void**)&btl_proc); btl_proc 112 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c return btl_proc; btl_proc 115 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc = OBJ_NEW(mca_btl_tcp2_proc_t); btl_proc 116 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(NULL == btl_proc) btl_proc 118 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_ompi = ompi_proc; btl_proc 122 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c hash, btl_proc); btl_proc 128 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c (void**)&btl_proc->proc_addrs, btl_proc 132 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c OBJ_RELEASE(btl_proc); btl_proc 140 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_addr_count = size / sizeof(mca_btl_tcp2_addr_t); btl_proc 143 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_endpoints = (mca_btl_base_endpoint_t**) btl_proc 144 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c malloc((1 + btl_proc->proc_addr_count) * btl_proc 146 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(NULL == btl_proc->proc_endpoints) { btl_proc 147 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c OBJ_RELEASE(btl_proc); btl_proc 151 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c mca_btl_tcp2_component.tcp_local = btl_proc; btl_proc 159 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c for (i = 0; i < btl_proc->proc_addr_count; i++) { btl_proc 160 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if (MCA_BTL_TCP_AF_INET == btl_proc->proc_addrs[i].addr_family) { btl_proc 161 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_addrs[i].addr_family = AF_INET; btl_proc 164 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if (MCA_BTL_TCP_AF_INET6 == btl_proc->proc_addrs[i].addr_family) { btl_proc 165 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_addrs[i].addr_family = AF_INET6; btl_proc 170 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c return btl_proc; btl_proc 374 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c int mca_btl_tcp2_proc_insert( mca_btl_tcp2_proc_t* btl_proc, btl_proc 388 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if (btl_proc->proc_ompi->super.proc_arch & OPAL_ARCH_ISBIGENDIAN) { btl_proc 394 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_proc = btl_proc; btl_proc 395 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_endpoints[btl_proc->proc_endpoint_count++] = btl_endpoint; btl_proc 419 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c for( i = 0; i < btl_proc->proc_addr_count; i++ ) { btl_proc 423 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c mca_btl_tcp2_addr_t* endpoint_addr = btl_proc->proc_addrs + i; btl_proc 516 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c && !opal_ifislocal(btl_proc->proc_ompi->proc_hostname))) { btl_proc 557 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c && !opal_ifislocal(btl_proc->proc_ompi->proc_hostname))) { btl_proc 682 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c int mca_btl_tcp2_proc_remove(mca_btl_tcp2_proc_t* btl_proc, mca_btl_base_endpoint_t* btl_endpoint) btl_proc 685 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&btl_proc->proc_lock); btl_proc 686 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c for( i = 0; i < btl_proc->proc_endpoint_count; i++ ) { btl_proc 687 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(btl_proc->proc_endpoints[i] == btl_endpoint) { btl_proc 688 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c memmove(btl_proc->proc_endpoints+i, btl_proc->proc_endpoints+i+1, btl_proc 689 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c (btl_proc->proc_endpoint_count-i-1)*sizeof(mca_btl_base_endpoint_t*)); btl_proc 690 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(--btl_proc->proc_endpoint_count == 0) { btl_proc 691 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock); btl_proc 692 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c OBJ_RELEASE(btl_proc); btl_proc 704 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&btl_proc->proc_lock); btl_proc 726 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c bool mca_btl_tcp2_proc_accept(mca_btl_tcp2_proc_t* btl_proc, struct sockaddr* addr, int sd) btl_proc 729 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&btl_proc->proc_lock); btl_proc 730 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c for( i = 0; i < btl_proc->proc_endpoint_count; i++ ) { btl_proc 731 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c mca_btl_base_endpoint_t* btl_endpoint = btl_proc->proc_endpoints[i]; btl_proc 759 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&btl_proc->proc_lock); btl_proc 763 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&btl_proc->proc_lock); btl_proc 222 ompi/mca/bml/bml.h struct ompi_proc_t* btl_proc; /**< backpointer to target ompi_proc_t */ btl_proc 163 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_proc = proc; btl_proc 1394 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_proc_t* btl_proc; btl_proc 1506 opal/mca/btl/tcp/btl_tcp_component.c btl_proc = mca_btl_tcp_proc_lookup(&guid); btl_proc 1507 opal/mca/btl/tcp/btl_tcp_component.c if(NULL == btl_proc) { btl_proc 1530 opal/mca/btl/tcp/btl_tcp_component.c (void)mca_btl_tcp_proc_accept(btl_proc, (struct sockaddr*)&addr, sd); btl_proc 1535 opal/mca/btl/tcp/btl_tcp_component.c OPAL_NAME_PRINT(btl_proc->proc_opal->proc_name)); btl_proc 593 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_proc_t* btl_proc = btl_endpoint->endpoint_proc; btl_proc 628 opal/mca/btl/tcp/btl_tcp_endpoint.c if (0 != opal_compare_proc(btl_proc->proc_opal->proc_name, guid)) { btl_proc 119 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_tcp_proc_t* btl_proc; btl_proc 126 opal/mca/btl/tcp/btl_tcp_proc.c proc->proc_name, (void**)&btl_proc); btl_proc 129 opal/mca/btl/tcp/btl_tcp_proc.c return btl_proc; btl_proc 133 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc = OBJ_NEW(mca_btl_tcp_proc_t); btl_proc 134 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL == btl_proc) { btl_proc 163 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addr_count = size / sizeof(mca_btl_tcp_modex_addr_t); btl_proc 164 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs = malloc(btl_proc->proc_addr_count * btl_proc 166 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL == btl_proc->proc_addrs) { btl_proc 173 opal/mca/btl/tcp/btl_tcp_proc.c for (i = 0 ; i < btl_proc->proc_addr_count ; i++) { btl_proc 175 opal/mca/btl/tcp/btl_tcp_proc.c memcpy(&btl_proc->proc_addrs[i].addr_inet, btl_proc 177 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_port = remote_addrs[i].addr_port; btl_proc 178 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_ifkindex = remote_addrs[i].addr_ifkindex; btl_proc 179 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_family = AF_INET; btl_proc 180 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_inuse = false; btl_proc 183 opal/mca/btl/tcp/btl_tcp_proc.c memcpy(&btl_proc->proc_addrs[i].addr_inet6, btl_proc 185 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_port = remote_addrs[i].addr_port; btl_proc 186 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_ifkindex = remote_addrs[i].addr_ifkindex; btl_proc 187 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_family = AF_INET6; btl_proc 188 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_addrs[i].addr_inuse = false; btl_proc 204 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_endpoints = (mca_btl_base_endpoint_t**) btl_proc 205 opal/mca/btl/tcp/btl_tcp_proc.c malloc((1 + btl_proc->proc_addr_count) * btl_proc 207 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL == btl_proc->proc_endpoints) { btl_proc 214 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_opal = proc; /* link with the proc */ btl_proc 217 opal/mca/btl/tcp/btl_tcp_proc.c proc->proc_name, btl_proc); btl_proc 219 opal/mca/btl/tcp/btl_tcp_proc.c if (btl_proc) { btl_proc 220 opal/mca/btl/tcp/btl_tcp_proc.c OBJ_RELEASE(btl_proc); /* release the local proc */ btl_proc 222 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc = NULL; btl_proc 228 opal/mca/btl/tcp/btl_tcp_proc.c return btl_proc; btl_proc 439 opal/mca/btl/tcp/btl_tcp_proc.c int mca_btl_tcp_proc_insert( mca_btl_tcp_proc_t* btl_proc, btl_proc 452 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL == (proc_hostname = opal_get_proc_hostname(btl_proc->proc_opal))) { btl_proc 468 opal/mca/btl/tcp/btl_tcp_proc.c if (btl_proc->proc_opal->proc_arch & OPAL_ARCH_ISBIGENDIAN) { btl_proc 474 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_proc = btl_proc; btl_proc 475 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_endpoints[btl_proc->proc_endpoint_count++] = btl_endpoint; btl_proc 498 opal/mca/btl/tcp/btl_tcp_proc.c for( i = 0; i < btl_proc->proc_addr_count; i++ ) { btl_proc 502 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_tcp_addr_t* endpoint_addr = btl_proc->proc_addrs + i; btl_proc 732 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_NAME_PRINT(btl_proc->proc_opal->proc_name)); btl_proc 783 opal/mca/btl/tcp/btl_tcp_proc.c int mca_btl_tcp_proc_remove(mca_btl_tcp_proc_t* btl_proc, mca_btl_base_endpoint_t* btl_endpoint) btl_proc 786 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL != btl_proc) { btl_proc 787 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_LOCK(&btl_proc->proc_lock); btl_proc 788 opal/mca/btl/tcp/btl_tcp_proc.c for(i = 0; i < btl_proc->proc_endpoint_count; i++) { btl_proc 789 opal/mca/btl/tcp/btl_tcp_proc.c if(btl_proc->proc_endpoints[i] == btl_endpoint) { btl_proc 790 opal/mca/btl/tcp/btl_tcp_proc.c memmove(btl_proc->proc_endpoints+i, btl_proc->proc_endpoints+i+1, btl_proc 791 opal/mca/btl/tcp/btl_tcp_proc.c (btl_proc->proc_endpoint_count-i-1)*sizeof(mca_btl_base_endpoint_t*)); btl_proc 792 opal/mca/btl/tcp/btl_tcp_proc.c if(--btl_proc->proc_endpoint_count == 0) { btl_proc 793 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock); btl_proc 794 opal/mca/btl/tcp/btl_tcp_proc.c OBJ_RELEASE(btl_proc); btl_proc 806 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock); btl_proc 854 opal/mca/btl/tcp/btl_tcp_proc.c void mca_btl_tcp_proc_accept(mca_btl_tcp_proc_t* btl_proc, struct sockaddr* addr, int sd) btl_proc 856 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_LOCK(&btl_proc->proc_lock); btl_proc 860 opal/mca/btl/tcp/btl_tcp_proc.c for( size_t i = 0; i < btl_proc->proc_endpoint_count; i++ ) { btl_proc 861 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_base_endpoint_t* btl_endpoint = btl_proc->proc_endpoints[i]; btl_proc 876 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_NAME_PRINT(btl_proc->proc_opal->proc_name), btl_proc 881 opal/mca/btl/tcp/btl_tcp_proc.c (int)i, (int)btl_proc->proc_endpoint_count); btl_proc 897 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_NAME_PRINT(btl_proc->proc_opal->proc_name), btl_proc 902 opal/mca/btl/tcp/btl_tcp_proc.c (int)i, (int)btl_proc->proc_endpoint_count); btl_proc 918 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock); btl_proc 926 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock); btl_proc 936 opal/mca/btl/tcp/btl_tcp_proc.c for (size_t i = 0; i < btl_proc->proc_endpoint_count; i++) { btl_proc 937 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_base_endpoint_t* btl_endpoint = btl_proc->proc_endpoints[i]; btl_proc 955 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_opal->proc_hostname, btl_proc 956 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_NAME_PRINT(btl_proc->proc_opal->proc_name), btl_proc 958 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_endpoint_count, btl_proc 964 opal/mca/btl/tcp/btl_tcp_proc.c OPAL_THREAD_UNLOCK(&btl_proc->proc_lock);