btl_endpoint 107 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_construct(mca_btl_base_endpoint_t* btl_endpoint); btl_endpoint 108 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_destruct(mca_btl_base_endpoint_t* btl_endpoint); btl_endpoint 123 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c void mca_btl_tcp_endpoint_dump(mca_btl_base_endpoint_t* btl_endpoint, const char* msg) btl_endpoint 136 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( -1 != btl_endpoint->endpoint_sd ) { btl_endpoint 137 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c getsockname(btl_endpoint->endpoint_sd, (struct sockaddr*)&inaddr, &addrlen); btl_endpoint 149 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c getpeername(btl_endpoint->endpoint_sd, (struct sockaddr*)&inaddr, &addrlen); btl_endpoint 162 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if((flags = fcntl(btl_endpoint->endpoint_sd, F_GETFL, 0)) < 0) { btl_endpoint 169 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_SNDBUF, (char *)&sndbuf, &obtlen) < 0) { btl_endpoint 178 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_RCVBUF, (char *)&rcvbuf, &obtlen) < 0) { btl_endpoint 187 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, IPPROTO_TCP, TCP_NODELAY, (char *)&nodelay, &obtlen) < 0) { btl_endpoint 197 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), msg, (void*)btl_endpoint, src, dst, nodelay, sndbuf, rcvbuf, flags); btl_endpoint 199 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 218 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c msg, btl_endpoint->endpoint_sd, status, btl_endpoint 219 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c (btl_endpoint->endpoint_nbo ? "true" : "false"), btl_endpoint->endpoint_retries, btl_endpoint 221 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache, btl_endpoint->endpoint_cache_length, btl_endpoint->endpoint_cache_pos - btl_endpoint->endpoint_cache, btl_endpoint 223 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c (void*)btl_endpoint->endpoint_send_frag, (void*)btl_endpoint->endpoint_recv_frag ); btl_endpoint 224 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c for(item = opal_list_get_first(&btl_endpoint->endpoint_frags); btl_endpoint 225 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c item != opal_list_get_end(&btl_endpoint->endpoint_frags); btl_endpoint 235 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static inline void mca_btl_tcp2_endpoint_event_init(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 238 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache = (char*)malloc(mca_btl_tcp2_component.tcp_endpoint_cache); btl_endpoint 239 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache; btl_endpoint 242 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_recv_event, btl_endpoint 243 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd, btl_endpoint 246 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint ); btl_endpoint 253 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_send_event, btl_endpoint 254 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd, btl_endpoint 257 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint); btl_endpoint 266 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int mca_btl_tcp2_endpoint_send(mca_btl_base_endpoint_t* btl_endpoint, mca_btl_tcp2_frag_t* frag) btl_endpoint 270 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_CRITICAL_SECTION_ENTER(&btl_endpoint->endpoint_send_lock); btl_endpoint 271 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 275 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_list_append(&btl_endpoint->endpoint_frags, (opal_list_item_t*)frag); btl_endpoint 277 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(btl_endpoint->endpoint_state == MCA_BTL_TCP_CLOSED) btl_endpoint 278 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c rc = mca_btl_tcp2_endpoint_start_connect(btl_endpoint); btl_endpoint 284 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if (btl_endpoint->endpoint_send_frag == NULL) { btl_endpoint 286 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_frag_send(frag, btl_endpoint->endpoint_sd)) { btl_endpoint 288 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_mutex_atomic_unlock(&btl_endpoint->endpoint_send_lock); btl_endpoint 292 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_send_frag = frag; btl_endpoint 294 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_ACTIVATE_EVENT(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 298 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_list_append(&btl_endpoint->endpoint_frags, (opal_list_item_t*)frag); btl_endpoint 302 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_CRITICAL_SECTION_LEAVE(&btl_endpoint->endpoint_send_lock); btl_endpoint 311 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static int mca_btl_tcp2_endpoint_send_blocking(mca_btl_base_endpoint_t* btl_endpoint, void* data, size_t size) btl_endpoint 316 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int retval = send(btl_endpoint->endpoint_sd, (const char *)ptr+cnt, size-cnt, 0); btl_endpoint 321 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 337 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static int mca_btl_tcp2_endpoint_send_connect_ack(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 344 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(mca_btl_tcp2_endpoint_send_blocking(btl_endpoint, &guid, sizeof(guid)) != btl_endpoint 360 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c bool mca_btl_tcp2_endpoint_accept(mca_btl_base_endpoint_t* btl_endpoint, btl_endpoint 363 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp_proc_t *endpoint_proc = btl_endpoint->endpoint_proc; btl_endpoint 367 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(NULL == btl_endpoint->endpoint_addr) { btl_endpoint 371 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 372 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 377 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if((btl_endpoint->endpoint_sd < 0) || btl_endpoint 378 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c (btl_endpoint->endpoint_state != MCA_BTL_TCP_CONNECTED && btl_endpoint 380 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 381 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd = sd; btl_endpoint 382 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(mca_btl_tcp2_endpoint_send_connect_ack(btl_endpoint) != OMPI_SUCCESS) { btl_endpoint 383 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 384 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 385 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 388 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp_endpoint_event_init(btl_endpoint); btl_endpoint 392 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_add(&btl_endpoint->endpoint_recv_event, 0); /* TODO */ btl_endpoint 393 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp_endpoint_connected(btl_endpoint); btl_endpoint 395 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_dump(btl_endpoint, "accepted"); btl_endpoint 397 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 398 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 401 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 402 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 412 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c void mca_btl_tcp2_endpoint_close(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 414 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int sd = btl_endpoint->endpoint_sd; btl_endpoint 418 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c } while ( opal_atomic_cmpset( &(btl_endpoint->endpoint_sd), sd, -1 ) ); btl_endpoint 421 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_retries++; btl_endpoint 422 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_del(&btl_endpoint->endpoint_recv_event); btl_endpoint 423 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 425 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( NULL != btl_endpoint->endpoint_cache ) btl_endpoint 426 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c free( btl_endpoint->endpoint_cache ); btl_endpoint 427 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache = NULL; btl_endpoint 428 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache_pos = NULL; btl_endpoint 429 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_cache_length = 0; btl_endpoint 439 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_connected(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 442 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTED; btl_endpoint 443 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_retries = 0; btl_endpoint 446 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_send_event, btl_endpoint 447 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd, btl_endpoint 450 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint ); btl_endpoint 452 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(opal_list_get_size(&btl_endpoint->endpoint_frags) > 0) { btl_endpoint 453 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(NULL == btl_endpoint->endpoint_send_frag) { btl_endpoint 454 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_send_frag = (mca_btl_tcp_frag_t*) btl_endpoint 455 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 457 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_add(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 466 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static int mca_btl_tcp2_endpoint_recv_blocking(mca_btl_base_endpoint_t* btl_endpoint, void* data, size_t size) btl_endpoint 471 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int retval = recv(btl_endpoint->endpoint_sd, (char *)ptr+cnt, size-cnt, 0); btl_endpoint 475 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 483 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd, strerror(opal_socket_errno), opal_socket_errno)); btl_endpoint 484 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 500 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static int mca_btl_tcp2_endpoint_recv_connect_ack(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 503 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_proc_t* btl_proc = btl_endpoint->endpoint_proc; btl_endpoint 505 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if((mca_btl_tcp2_endpoint_recv_blocking(btl_endpoint, &guid, sizeof(orte_process_name_t))) != sizeof(orte_process_name_t)) { btl_endpoint 515 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 558 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static int mca_btl_tcp2_endpoint_start_connect(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 567 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if (AF_INET6 == btl_endpoint->endpoint_addr->addr_family) { btl_endpoint 573 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd = socket(af_family, SOCK_STREAM, 0); btl_endpoint 574 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if (btl_endpoint->endpoint_sd < 0) { btl_endpoint 575 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_retries++; btl_endpoint 580 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_set_socket_options(btl_endpoint->endpoint_sd); btl_endpoint 583 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_event_init(btl_endpoint); btl_endpoint 586 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if((flags = fcntl(btl_endpoint->endpoint_sd, F_GETFL, 0)) < 0) { btl_endpoint 591 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(fcntl(btl_endpoint->endpoint_sd, F_SETFL, flags) < 0) btl_endpoint 597 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_proc_tosocks(btl_endpoint->endpoint_addr, &endpoint_addr); btl_endpoint 602 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_addr->addr_port); btl_endpoint 604 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(connect(btl_endpoint->endpoint_sd, (struct sockaddr*)&endpoint_addr, addrlen) < 0) { btl_endpoint 607 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTING; btl_endpoint 608 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_ACTIVATE_EVENT(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 614 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c BTL_PEER_ERROR( btl_endpoint->endpoint_proc->proc_ompi, btl_endpoint 617 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_addr->addr_port, strerror(opal_socket_errno) ) ); btl_endpoint 619 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 620 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_retries++; btl_endpoint 625 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if((rc = mca_btl_tcp2_endpoint_send_connect_ack(btl_endpoint)) == OMPI_SUCCESS) { btl_endpoint 626 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECT_ACK; btl_endpoint 627 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_ACTIVATE_EVENT(&btl_endpoint->endpoint_recv_event, 0); btl_endpoint 629 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 640 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_complete_connect(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 646 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_proc_tosocks(btl_endpoint->endpoint_addr, &endpoint_addr); btl_endpoint 649 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 652 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_ERROR, (char *)&so_error, &so_length) < 0) { btl_endpoint 656 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 660 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_add(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 667 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 671 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(mca_btl_tcp2_endpoint_send_connect_ack(btl_endpoint) == OMPI_SUCCESS) { btl_endpoint 672 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECT_ACK; btl_endpoint 673 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_add(&btl_endpoint->endpoint_recv_event, 0); btl_endpoint 675 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 687 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_base_endpoint_t* btl_endpoint = (mca_btl_base_endpoint_t *)user; btl_endpoint 692 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( sd != btl_endpoint->endpoint_sd ) btl_endpoint 695 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 696 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 700 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c rc = mca_btl_tcp2_endpoint_recv_connect_ack(btl_endpoint); btl_endpoint 703 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 704 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_connected(btl_endpoint); btl_endpoint 705 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 707 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_dump(btl_endpoint, "connected"); btl_endpoint 710 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 717 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c frag = btl_endpoint->endpoint_recv_frag; btl_endpoint 730 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 733 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_FRAG_INIT_DST(frag, btl_endpoint); btl_endpoint 737 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( mca_btl_tcp_frag_recv(frag, btl_endpoint->endpoint_sd) == false ) { btl_endpoint 738 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_recv_frag = frag; btl_endpoint 740 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_recv_frag = NULL; btl_endpoint 745 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( 0 != btl_endpoint->endpoint_cache_length ) { btl_endpoint 753 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c MCA_BTL_TCP_FRAG_INIT_DST(frag, btl_endpoint); btl_endpoint 764 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c assert( 0 == btl_endpoint->endpoint_cache_length ); btl_endpoint 766 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 778 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 779 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c BTL_ERROR(("invalid socket state(%d)", btl_endpoint->endpoint_state)); btl_endpoint 780 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 781 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 782 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 795 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp_endpoint_t* btl_endpoint = (mca_btl_tcp_endpoint_t *)user; btl_endpoint 796 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_mutex_atomic_lock(&btl_endpoint->endpoint_send_lock); btl_endpoint 797 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 799 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_endpoint_complete_connect(btl_endpoint); btl_endpoint 803 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c while (NULL != btl_endpoint->endpoint_send_frag) { btl_endpoint 804 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c mca_btl_tcp2_frag_t* frag = btl_endpoint->endpoint_send_frag; btl_endpoint 807 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(mca_btl_tcp2_frag_send(frag, btl_endpoint->endpoint_sd) == false) { btl_endpoint 811 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_send_frag = (mca_btl_tcp2_frag_t*) btl_endpoint 812 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 815 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_mutex_atomic_unlock(&btl_endpoint->endpoint_send_lock); btl_endpoint 818 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_mutex_atomic_lock(&btl_endpoint->endpoint_send_lock); btl_endpoint 822 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(NULL == btl_endpoint->endpoint_send_frag) { btl_endpoint 823 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 827 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c BTL_ERROR(("invalid connection state (%d)", btl_endpoint->endpoint_state)); btl_endpoint 828 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 831 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c opal_mutex_atomic_unlock(&btl_endpoint->endpoint_send_lock); btl_endpoint 153 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c mca_btl_base_endpoint_t* btl_endpoint = frag->endpoint; btl_endpoint 158 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c if( 0 != btl_endpoint->endpoint_cache_length ) { btl_endpoint 164 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c cnt = length = btl_endpoint->endpoint_cache_length; btl_endpoint 169 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c memcpy( frag->iov_ptr[i].iov_base, btl_endpoint->endpoint_cache_pos, length ); btl_endpoint 171 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->segments[0].seg_addr.pval = btl_endpoint->endpoint_cache_pos; btl_endpoint 172 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->iov_ptr[i].iov_base = btl_endpoint->endpoint_cache_pos; btl_endpoint 174 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c btl_endpoint->endpoint_cache_pos += length; btl_endpoint 175 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c btl_endpoint->endpoint_cache_length -= length; btl_endpoint 176 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c length = btl_endpoint->endpoint_cache_length; btl_endpoint 178 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache; btl_endpoint 187 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->iov_ptr[num_vecs].iov_base = btl_endpoint->endpoint_cache_pos; btl_endpoint 189 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c mca_btl_tcp2_component.tcp_endpoint_cache - btl_endpoint->endpoint_cache_length; btl_endpoint 199 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 211 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 217 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c mca_btl_tcp2_endpoint_close(btl_endpoint); btl_endpoint 239 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c btl_endpoint->endpoint_cache_length = cnt; btl_endpoint 244 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c if (btl_endpoint->endpoint_nbo && frag->iov_idx == 1) MCA_BTL_TCP_HDR_NTOH(frag->hdr); btl_endpoint 375 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c mca_btl_base_endpoint_t* btl_endpoint ) btl_endpoint 389 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_nbo = true; btl_endpoint 394 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_proc = btl_proc; btl_endpoint 395 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_proc->proc_endpoints[btl_proc->proc_endpoint_count++] = btl_endpoint; btl_endpoint 606 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_addr = best_addr[i][best_assignment[i]]; btl_endpoint 607 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_addr->addr_inuse++; btl_endpoint 632 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_addr = best_addr[i_max][j_max]; btl_endpoint 633 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_addr->addr_inuse++; btl_endpoint 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_endpoint 687 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(btl_proc->proc_endpoints[i] == btl_endpoint) { btl_endpoint 698 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if (NULL != btl_endpoint->endpoint_addr) { btl_endpoint 699 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c btl_endpoint->endpoint_addr->addr_inuse--; btl_endpoint 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_endpoint 733 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if( btl_endpoint->endpoint_addr->addr_family != addr->sa_family ) { btl_endpoint 739 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if( memcmp( &btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 747 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if( memcmp( &btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 758 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(mca_btl_tcp_endpoint_accept(btl_endpoint, addr, sd)) { btl_endpoint 116 ompi/mca/bml/base/bml_base_btl.c des->des_cbfunc(bml_btl->btl, bml_btl->btl_endpoint, des, OMPI_SUCCESS); btl_endpoint 136 ompi/mca/bml/base/bml_base_btl.c bml_btl->btl_endpoint, btl_endpoint 63 ompi/mca/bml/bml.h struct mca_btl_base_endpoint_t* btl_endpoint; /**< BTL addressing info */ btl_endpoint 242 ompi/mca/bml/bml.h *des = btl->btl_alloc(btl, bml_btl->btl_endpoint, order, size, flags); btl_endpoint 273 ompi/mca/bml/bml.h rc = btl->btl_send(btl, bml_btl->btl_endpoint, des, tag); btl_endpoint 289 ompi/mca/bml/bml.h return btl->btl_send(btl, bml_btl->btl_endpoint, des, tag); btl_endpoint 303 ompi/mca/bml/bml.h return btl->btl_sendi(btl, bml_btl->btl_endpoint, btl_endpoint 315 ompi/mca/bml/bml.h return btl->btl_put( btl, bml_btl->btl_endpoint, local_address, remote_address, local_handle, btl_endpoint 326 ompi/mca/bml/bml.h return btl->btl_get( btl, bml_btl->btl_endpoint, local_address, remote_address, local_handle, btl_endpoint 341 ompi/mca/bml/bml.h *des = btl->btl_prepare_src( btl, bml_btl->btl_endpoint, conv, btl_endpoint 354 ompi/mca/bml/bml.h *handle = btl->btl_register_mem (btl, bml_btl->btl_endpoint, base, size, flags); btl_endpoint 198 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *btl_endpoint) btl_endpoint 247 ompi/mca/bml/r2/bml_r2.c bml_btl->btl_endpoint = btl_endpoint; btl_endpoint 278 ompi/mca/bml/r2/bml_r2.c bml_btl_rdma->btl_endpoint = btl_endpoint; btl_endpoint 399 ompi/mca/bml/r2/bml_r2.c struct mca_btl_base_endpoint_t *btl_endpoint = NULL; btl_endpoint 406 ompi/mca/bml/r2/bml_r2.c rc = btl->btl_add_procs (btl, 1, (opal_proc_t **) &proc, &btl_endpoint, NULL); btl_endpoint 407 ompi/mca/bml/r2/bml_r2.c if (OMPI_SUCCESS != rc || NULL == btl_endpoint) { btl_endpoint 413 ompi/mca/bml/r2/bml_r2.c rc = mca_bml_r2_endpoint_add_btl (proc, bml_endpoint, btl, btl_endpoint); btl_endpoint 415 ompi/mca/bml/r2/bml_r2.c btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &btl_endpoint); btl_endpoint 624 ompi/mca/bml/r2/bml_r2.c int rc = btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &bml_btl->btl_endpoint); btl_endpoint 644 ompi/mca/bml/r2/bml_r2.c if (bml_btl->btl_endpoint == rdma_btl->btl_endpoint) { btl_endpoint 651 ompi/mca/bml/r2/bml_r2.c int rc = btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &rdma_btl->btl_endpoint); btl_endpoint 49 ompi/mca/osc/rdma/osc_rdma_peer.c return bml_endpoint->btl_rdma.bml_btls[btl_index].btl_endpoint; btl_endpoint 652 ompi/mca/pml/ob1/pml_ob1.c bml_btl->btl->btl_dump(bml_btl->btl, bml_btl->btl_endpoint, verbose); btl_endpoint 129 ompi/mca/pml/ob1/pml_ob1_cuda.c handle = bml_btl->btl->btl_register_mem (bml_btl->btl, bml_btl->btl_endpoint, btl_endpoint 69 ompi/mca/pml/ob1/pml_ob1_rdma.c if (eager_btl->btl_endpoint == bml_btl->btl_endpoint) { btl_endpoint 89 ompi/mca/pml/ob1/pml_ob1_rdma.c reg_handle = btl->btl_register_mem (btl, bml_btl->btl_endpoint, base, btl_endpoint 129 ompi/mca/pml/ob1/pml_ob1_rdma.c if (eager_btl->btl_endpoint == bml_btl->btl_endpoint) { btl_endpoint 159 ompi/mca/pml/ob1/pml_ob1_rdma.c if (eager_btl->btl_endpoint == bml_btl->btl_endpoint) { btl_endpoint 44 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_endpoint_t *btl_endpoint = (mca_btl_ofi_endpoint_t*) endpoint; btl_endpoint 71 opal/mca/btl/ofi/btl_ofi_atomics.c btl_endpoint->peer_addr, /* remote addr */ btl_endpoint 97 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_endpoint_t *btl_endpoint = (mca_btl_ofi_endpoint_t*) endpoint; btl_endpoint 123 opal/mca/btl/ofi/btl_ofi_atomics.c btl_endpoint->peer_addr, /* remote addr */ btl_endpoint 150 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_endpoint_t *btl_endpoint = (mca_btl_ofi_endpoint_t*) endpoint; btl_endpoint 177 opal/mca/btl/ofi/btl_ofi_atomics.c btl_endpoint->peer_addr, btl_endpoint 67 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_ofi_endpoint_t *btl_endpoint = (mca_btl_ofi_endpoint_t*) endpoint; btl_endpoint 86 opal/mca/btl/ofi/btl_ofi_rdma.c btl_endpoint->peer_addr, btl_endpoint 111 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_ofi_endpoint_t *btl_endpoint = (mca_btl_ofi_endpoint_t*) endpoint; btl_endpoint 131 opal/mca/btl/ofi/btl_ofi_rdma.c btl_endpoint->peer_addr, btl_endpoint 120 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_construct(mca_btl_base_endpoint_t* btl_endpoint); btl_endpoint 121 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_destruct(mca_btl_base_endpoint_t* btl_endpoint); btl_endpoint 147 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_base_endpoint_t* btl_endpoint, btl_endpoint 165 opal/mca/btl/tcp/btl_tcp_endpoint.c getsockname(btl_endpoint->endpoint_sd, (struct sockaddr*)&inaddr, &addrlen); btl_endpoint 179 opal/mca/btl/tcp/btl_tcp_endpoint.c getpeername(btl_endpoint->endpoint_sd, (struct sockaddr*)&inaddr, &addrlen); btl_endpoint 194 opal/mca/btl/tcp/btl_tcp_endpoint.c used = snprintf(outmsg, DEBUG_LENGTH, "[%d", btl_endpoint->endpoint_sd); btl_endpoint 196 opal/mca/btl/tcp/btl_tcp_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 224 opal/mca/btl/tcp/btl_tcp_endpoint.c if((flags = fcntl(btl_endpoint->endpoint_sd, F_GETFL, 0)) < 0) { btl_endpoint 231 opal/mca/btl/tcp/btl_tcp_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_SNDBUF, (char *)&sndbuf, &obtlen) < 0) { btl_endpoint 240 opal/mca/btl/tcp/btl_tcp_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_RCVBUF, (char *)&rcvbuf, &obtlen) < 0) { btl_endpoint 249 opal/mca/btl/tcp/btl_tcp_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, IPPROTO_TCP, TCP_NODELAY, (char *)&nodelay, &obtlen) < 0) { btl_endpoint 261 opal/mca/btl/tcp/btl_tcp_endpoint.c (void*)btl_endpoint->endpoint_cache, btl_endpoint->endpoint_cache_pos - btl_endpoint->endpoint_cache, btl_endpoint 262 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache_length); btl_endpoint 266 opal/mca/btl/tcp/btl_tcp_endpoint.c (btl_endpoint->endpoint_nbo ? "NBO" : ""), (int)btl_endpoint->endpoint_retries); btl_endpoint 272 opal/mca/btl/tcp/btl_tcp_endpoint.c if( NULL != btl_endpoint->endpoint_recv_frag ) btl_endpoint 273 opal/mca/btl/tcp/btl_tcp_endpoint.c used += mca_btl_tcp_frag_dump(btl_endpoint->endpoint_recv_frag, "active recv", btl_endpoint 277 opal/mca/btl/tcp/btl_tcp_endpoint.c if( NULL != btl_endpoint->endpoint_send_frag ) btl_endpoint 278 opal/mca/btl/tcp/btl_tcp_endpoint.c used += mca_btl_tcp_frag_dump(btl_endpoint->endpoint_send_frag, "active send (inaccurate iov)", btl_endpoint 281 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_LIST_FOREACH(item, &btl_endpoint->endpoint_frags, mca_btl_tcp_frag_t) { btl_endpoint 291 opal/mca/btl/tcp/btl_tcp_endpoint.c (NULL != btl_endpoint->endpoint_proc ? OPAL_NAME_PRINT(btl_endpoint->endpoint_proc->proc_opal->proc_name) : "unknown remote"), btl_endpoint 300 opal/mca/btl/tcp/btl_tcp_endpoint.c static inline void mca_btl_tcp_endpoint_event_init(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 303 opal/mca/btl/tcp/btl_tcp_endpoint.c assert(NULL == btl_endpoint->endpoint_cache); btl_endpoint 304 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache = (char*)malloc(mca_btl_tcp_component.tcp_endpoint_cache); btl_endpoint 305 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache; btl_endpoint 308 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_recv_event, btl_endpoint 309 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd, btl_endpoint 312 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint ); btl_endpoint 318 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_send_event, btl_endpoint 319 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd, btl_endpoint 322 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint); btl_endpoint 331 opal/mca/btl/tcp/btl_tcp_endpoint.c int mca_btl_tcp_endpoint_send(mca_btl_base_endpoint_t* btl_endpoint, mca_btl_tcp_frag_t* frag) btl_endpoint 335 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 336 opal/mca/btl/tcp/btl_tcp_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 340 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_list_append(&btl_endpoint->endpoint_frags, (opal_list_item_t*)frag); btl_endpoint 342 opal/mca/btl/tcp/btl_tcp_endpoint.c if(btl_endpoint->endpoint_state == MCA_BTL_TCP_CLOSED) btl_endpoint 343 opal/mca/btl/tcp/btl_tcp_endpoint.c rc = mca_btl_tcp_endpoint_start_connect(btl_endpoint); btl_endpoint 349 opal/mca/btl/tcp/btl_tcp_endpoint.c if (NULL == btl_endpoint->endpoint_send_frag) { btl_endpoint 351 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_frag_send(frag, btl_endpoint->endpoint_sd)) { btl_endpoint 354 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 361 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(50, btl_endpoint, true, "complete send fragment [endpoint_send]"); btl_endpoint 364 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_send_frag = frag; btl_endpoint 365 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "event_add(send) [endpoint_send]"); btl_endpoint 367 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ACTIVATE_EVENT(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 370 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "send fragment enqueued [endpoint_send]"); btl_endpoint 372 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_list_append(&btl_endpoint->endpoint_frags, (opal_list_item_t*)frag); btl_endpoint 376 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 386 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_send_blocking(mca_btl_base_endpoint_t* btl_endpoint, btl_endpoint 389 opal/mca/btl/tcp/btl_tcp_endpoint.c int ret = mca_btl_tcp_send_blocking(btl_endpoint->endpoint_sd, data, size); btl_endpoint 391 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 401 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_send_connect_ack(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 412 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_send_blocking(btl_endpoint, btl_endpoint 425 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_base_endpoint_t* btl_endpoint = (mca_btl_base_endpoint_t*)context; btl_endpoint 429 opal/mca/btl/tcp/btl_tcp_endpoint.c if( OPAL_THREAD_TRYLOCK(&btl_endpoint->endpoint_recv_lock) ) { btl_endpoint 430 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_accept_event, &now); btl_endpoint 433 opal/mca/btl/tcp/btl_tcp_endpoint.c if( OPAL_THREAD_TRYLOCK(&btl_endpoint->endpoint_send_lock) ) { btl_endpoint 434 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 435 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_accept_event, &now); btl_endpoint 439 opal/mca/btl/tcp/btl_tcp_endpoint.c if(NULL == btl_endpoint->endpoint_addr) { btl_endpoint 440 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(btl_endpoint->endpoint_sd_next); /* No further use of this socket. Close it */ btl_endpoint 441 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd_next = -1; btl_endpoint 442 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 443 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 444 opal/mca/btl/tcp/btl_tcp_endpoint.c if( NULL != btl_endpoint->endpoint_btl->tcp_error_cb ) { btl_endpoint 445 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_btl->tcp_error_cb( btl_endpoint 446 opal/mca/btl/tcp/btl_tcp_endpoint.c &btl_endpoint->endpoint_btl->super, MCA_BTL_ERROR_FLAGS_NONFATAL, btl_endpoint 447 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_proc->proc_opal, btl_endpoint 453 opal/mca/btl/tcp/btl_tcp_endpoint.c cmpval = opal_compare_proc(btl_endpoint->endpoint_proc->proc_opal->proc_name, btl_endpoint 455 opal/mca/btl/tcp/btl_tcp_endpoint.c if((btl_endpoint->endpoint_sd < 0) || btl_endpoint 456 opal/mca/btl/tcp/btl_tcp_endpoint.c (btl_endpoint->endpoint_state != MCA_BTL_TCP_CONNECTED && btl_endpoint 458 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 459 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd = btl_endpoint->endpoint_sd_next; btl_endpoint 460 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd_next = -1; btl_endpoint 461 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_endpoint_send_connect_ack(btl_endpoint) != OPAL_SUCCESS) { btl_endpoint 462 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, true, " [endpoint_accept]"); btl_endpoint 463 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 464 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 467 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_event_init(btl_endpoint); btl_endpoint 468 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "event_add(recv) [endpoint_accept]"); btl_endpoint 469 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_recv_event, 0); btl_endpoint 474 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_connected(btl_endpoint); btl_endpoint 476 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "accepted"); btl_endpoint 479 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(btl_endpoint->endpoint_sd_next); /* No further use of this socket. Close it */ btl_endpoint 480 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd_next = -1; btl_endpoint 482 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 483 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 496 opal/mca/btl/tcp/btl_tcp_endpoint.c void mca_btl_tcp_endpoint_accept(mca_btl_base_endpoint_t* btl_endpoint, btl_endpoint 501 opal/mca/btl/tcp/btl_tcp_endpoint.c assert(btl_endpoint->endpoint_sd_next == -1); btl_endpoint 502 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd_next = sd; btl_endpoint 504 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_evtimer_set(mca_btl_tcp_event_base, &btl_endpoint->endpoint_accept_event, btl_endpoint 505 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_complete_accept, btl_endpoint); btl_endpoint 506 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_accept_event, &now); btl_endpoint 515 opal/mca/btl/tcp/btl_tcp_endpoint.c void mca_btl_tcp_endpoint_close(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 517 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, false, "[close]"); btl_endpoint 518 opal/mca/btl/tcp/btl_tcp_endpoint.c if(btl_endpoint->endpoint_sd < 0) btl_endpoint 520 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_retries++; btl_endpoint 521 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, false, "event_del(recv) [close]"); btl_endpoint 522 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_del(&btl_endpoint->endpoint_recv_event); btl_endpoint 527 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, false, "event_del(send) [close]"); btl_endpoint 528 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 531 opal/mca/btl/tcp/btl_tcp_endpoint.c free( btl_endpoint->endpoint_cache ); btl_endpoint 532 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache = NULL; btl_endpoint 533 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache_pos = NULL; btl_endpoint 534 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_cache_length = 0; btl_endpoint 537 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(btl_endpoint->endpoint_sd); btl_endpoint 538 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd = -1; btl_endpoint 544 opal/mca/btl/tcp/btl_tcp_endpoint.c if( MCA_BTL_TCP_FAILED == btl_endpoint->endpoint_state ) { btl_endpoint 545 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_frag_t* frag = btl_endpoint->endpoint_send_frag; btl_endpoint 547 opal/mca/btl/tcp/btl_tcp_endpoint.c frag = (mca_btl_tcp_frag_t*)opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 551 opal/mca/btl/tcp/btl_tcp_endpoint.c frag = (mca_btl_tcp_frag_t*)opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 554 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CLOSED; btl_endpoint 563 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_connected(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 566 opal/mca/btl/tcp/btl_tcp_endpoint.c assert( MCA_BTL_TCP_CONNECTED != btl_endpoint->endpoint_state ); btl_endpoint 567 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTED; btl_endpoint 568 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_retries = 0; btl_endpoint 569 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, true, "READY [endpoint_connected]"); btl_endpoint 571 opal/mca/btl/tcp/btl_tcp_endpoint.c if(opal_list_get_size(&btl_endpoint->endpoint_frags) > 0) { btl_endpoint 572 opal/mca/btl/tcp/btl_tcp_endpoint.c if(NULL == btl_endpoint->endpoint_send_frag) btl_endpoint 573 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_send_frag = (mca_btl_tcp_frag_t*) btl_endpoint 574 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 575 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "event_add(send) [endpoint_connected]"); btl_endpoint 576 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 590 opal/mca/btl/tcp/btl_tcp_endpoint.c static int mca_btl_tcp_endpoint_recv_connect_ack(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 593 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_proc_t* btl_proc = btl_endpoint->endpoint_proc; btl_endpoint 597 opal/mca/btl/tcp/btl_tcp_endpoint.c retval = mca_btl_tcp_recv_blocking(btl_endpoint->endpoint_sd, &hs_msg, sizeof(hs_msg)); btl_endpoint 600 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 631 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 674 opal/mca/btl/tcp/btl_tcp_endpoint.c static int mca_btl_tcp_endpoint_start_connect(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 683 opal/mca/btl/tcp/btl_tcp_endpoint.c if (AF_INET6 == btl_endpoint->endpoint_addr->addr_family) { btl_endpoint 688 opal/mca/btl/tcp/btl_tcp_endpoint.c assert( btl_endpoint->endpoint_sd < 0 ); btl_endpoint 689 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd = socket(af_family, SOCK_STREAM, 0); btl_endpoint 690 opal/mca/btl/tcp/btl_tcp_endpoint.c if (btl_endpoint->endpoint_sd < 0) { btl_endpoint 691 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_retries++; btl_endpoint 696 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_set_socket_options(btl_endpoint->endpoint_sd); btl_endpoint 699 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_event_init(btl_endpoint); btl_endpoint 702 opal/mca/btl/tcp/btl_tcp_endpoint.c if((flags = fcntl(btl_endpoint->endpoint_sd, F_GETFL, 0)) < 0) { btl_endpoint 711 opal/mca/btl/tcp/btl_tcp_endpoint.c if(fcntl(btl_endpoint->endpoint_sd, F_SETFL, flags) < 0) { btl_endpoint 723 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_proc_tosocks(btl_endpoint->endpoint_addr, &endpoint_addr); btl_endpoint 731 opal/mca/btl/tcp/btl_tcp_endpoint.c assert(NULL != &btl_endpoint->endpoint_btl->tcp_ifaddr); btl_endpoint 732 opal/mca/btl/tcp/btl_tcp_endpoint.c if (bind(btl_endpoint->endpoint_sd, (struct sockaddr*) &btl_endpoint->endpoint_btl->tcp_ifaddr, btl_endpoint 735 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_net_get_hostname((struct sockaddr*) &btl_endpoint->endpoint_btl->tcp_ifaddr), btl_endpoint 736 opal/mca/btl/tcp/btl_tcp_endpoint.c htons(((struct sockaddr_in*)&btl_endpoint->endpoint_btl->tcp_ifaddr)->sin_port), btl_endpoint 739 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(btl_endpoint->endpoint_sd); btl_endpoint 745 opal/mca/btl/tcp/btl_tcp_endpoint.c assert(NULL != &btl_endpoint->endpoint_btl->tcp_ifaddr); btl_endpoint 746 opal/mca/btl/tcp/btl_tcp_endpoint.c if (bind(btl_endpoint->endpoint_sd, (struct sockaddr*) &btl_endpoint->endpoint_btl->tcp_ifaddr, btl_endpoint 749 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_net_get_hostname((struct sockaddr*) &btl_endpoint->endpoint_btl->tcp_ifaddr), btl_endpoint 750 opal/mca/btl/tcp/btl_tcp_endpoint.c htons(((struct sockaddr_in6*)&btl_endpoint->endpoint_btl->tcp_ifaddr)->sin6_port), btl_endpoint 753 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(btl_endpoint->endpoint_sd); btl_endpoint 760 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_NAME_PRINT(btl_endpoint->endpoint_proc->proc_opal->proc_name), btl_endpoint 762 opal/mca/btl/tcp/btl_tcp_endpoint.c ntohs(btl_endpoint->endpoint_addr->addr_port)); btl_endpoint 764 opal/mca/btl/tcp/btl_tcp_endpoint.c if(0 == connect(btl_endpoint->endpoint_sd, (struct sockaddr*)&endpoint_addr, addrlen)) { btl_endpoint 770 opal/mca/btl/tcp/btl_tcp_endpoint.c if((rc = mca_btl_tcp_endpoint_send_connect_ack(btl_endpoint)) == OPAL_SUCCESS) { btl_endpoint 771 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECT_ACK; btl_endpoint 772 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "event_add(recv) [start_connect]"); btl_endpoint 773 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_recv_event, 0); btl_endpoint 781 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, true, "dropped connection [start_connect]"); btl_endpoint 785 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTING; btl_endpoint 786 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "event_add(send) [start_connect]"); btl_endpoint 787 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ACTIVATE_EVENT(&btl_endpoint->endpoint_send_event, 0); btl_endpoint 797 opal/mca/btl/tcp/btl_tcp_endpoint.c BTL_PEER_ERROR( btl_endpoint->endpoint_proc->proc_opal, btl_endpoint 800 opal/mca/btl/tcp/btl_tcp_endpoint.c ntohs(btl_endpoint->endpoint_addr->addr_port), strerror(opal_socket_errno) ) ); btl_endpoint 802 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 803 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 813 opal/mca/btl/tcp/btl_tcp_endpoint.c static int mca_btl_tcp_endpoint_complete_connect(mca_btl_base_endpoint_t* btl_endpoint) btl_endpoint 823 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 825 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_proc_tosocks(btl_endpoint->endpoint_addr, &endpoint_addr); btl_endpoint 828 opal/mca/btl/tcp/btl_tcp_endpoint.c if(getsockopt(btl_endpoint->endpoint_sd, SOL_SOCKET, SO_ERROR, (char *)&so_error, &so_length) < 0) { btl_endpoint 837 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 853 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 862 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_endpoint_send_connect_ack(btl_endpoint) == OPAL_SUCCESS) { btl_endpoint 863 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECT_ACK; btl_endpoint 864 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_add(&btl_endpoint->endpoint_recv_event, 0); btl_endpoint 869 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, false, "event_add(recv) [complete_connect]"); btl_endpoint 872 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, false, " [complete_connect]"); btl_endpoint 873 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 874 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 886 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_base_endpoint_t* btl_endpoint = (mca_btl_base_endpoint_t *)user; btl_endpoint 891 opal/mca/btl/tcp/btl_tcp_endpoint.c if( sd != btl_endpoint->endpoint_sd ) btl_endpoint 910 opal/mca/btl/tcp/btl_tcp_endpoint.c if( OPAL_THREAD_TRYLOCK(&btl_endpoint->endpoint_recv_lock) ) btl_endpoint 913 opal/mca/btl/tcp/btl_tcp_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 916 opal/mca/btl/tcp/btl_tcp_endpoint.c int rc = mca_btl_tcp_endpoint_recv_connect_ack(btl_endpoint); btl_endpoint 919 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_LOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 920 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_connected(btl_endpoint); btl_endpoint 921 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 922 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, true, "connected"); btl_endpoint 935 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_module_t *m = btl_endpoint->endpoint_btl; btl_endpoint 940 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_proc->proc_opal, btl_endpoint 944 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 951 opal/mca/btl/tcp/btl_tcp_endpoint.c frag = btl_endpoint->endpoint_recv_frag; btl_endpoint 961 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 964 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_FRAG_INIT_DST(frag, btl_endpoint); btl_endpoint 968 opal/mca/btl/tcp/btl_tcp_endpoint.c assert( 0 == btl_endpoint->endpoint_cache_length ); btl_endpoint 972 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_frag_recv(frag, btl_endpoint->endpoint_sd) == false) { btl_endpoint 973 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_recv_frag = frag; btl_endpoint 975 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_recv_frag = NULL; btl_endpoint 982 opal/mca/btl/tcp/btl_tcp_endpoint.c if( 0 != btl_endpoint->endpoint_cache_length ) { btl_endpoint 986 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_FRAG_INIT_DST(frag, btl_endpoint); btl_endpoint 993 opal/mca/btl/tcp/btl_tcp_endpoint.c assert( 0 == btl_endpoint->endpoint_cache_length ); btl_endpoint 995 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 1005 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 1008 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_recv_lock); btl_endpoint 1009 opal/mca/btl/tcp/btl_tcp_endpoint.c BTL_ERROR(("invalid socket state(%d)", btl_endpoint->endpoint_state)); btl_endpoint 1010 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 1011 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 1024 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_t* btl_endpoint = (mca_btl_tcp_endpoint_t *)user; btl_endpoint 1027 opal/mca/btl/tcp/btl_tcp_endpoint.c if( OPAL_THREAD_TRYLOCK(&btl_endpoint->endpoint_send_lock) ) btl_endpoint 1030 opal/mca/btl/tcp/btl_tcp_endpoint.c switch(btl_endpoint->endpoint_state) { btl_endpoint 1032 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_endpoint_complete_connect(btl_endpoint); btl_endpoint 1036 opal/mca/btl/tcp/btl_tcp_endpoint.c while (NULL != btl_endpoint->endpoint_send_frag) { btl_endpoint 1037 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_tcp_frag_t* frag = btl_endpoint->endpoint_send_frag; btl_endpoint 1040 opal/mca/btl/tcp/btl_tcp_endpoint.c if(mca_btl_tcp_frag_send(frag, btl_endpoint->endpoint_sd) == false) { btl_endpoint 1044 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_send_frag = (mca_btl_tcp_frag_t*) btl_endpoint 1045 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_list_remove_first(&btl_endpoint->endpoint_frags); btl_endpoint 1048 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 1058 opal/mca/btl/tcp/btl_tcp_endpoint.c if( OPAL_THREAD_TRYLOCK(&btl_endpoint->endpoint_send_lock) ) btl_endpoint 1063 opal/mca/btl/tcp/btl_tcp_endpoint.c if(NULL == btl_endpoint->endpoint_send_frag) { btl_endpoint 1064 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(10, btl_endpoint, false, "event_del(send) [endpoint_send_handler]"); btl_endpoint 1065 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 1069 opal/mca/btl/tcp/btl_tcp_endpoint.c BTL_ERROR(("invalid connection state (%d)", btl_endpoint->endpoint_state)); btl_endpoint 1070 opal/mca/btl/tcp/btl_tcp_endpoint.c MCA_BTL_TCP_ENDPOINT_DUMP(1, btl_endpoint, true, "event_del(send) [endpoint_send_handler:error]"); btl_endpoint 1071 opal/mca/btl/tcp/btl_tcp_endpoint.c opal_event_del(&btl_endpoint->endpoint_send_event); btl_endpoint 1074 opal/mca/btl/tcp/btl_tcp_endpoint.c OPAL_THREAD_UNLOCK(&btl_endpoint->endpoint_send_lock); btl_endpoint 101 opal/mca/btl/tcp/btl_tcp_endpoint.h mca_btl_base_endpoint_t* btl_endpoint, bool full_info, const char* msg); btl_endpoint 168 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_base_endpoint_t* btl_endpoint = frag->endpoint; btl_endpoint 175 opal/mca/btl/tcp/btl_tcp_frag.c if( 0 != btl_endpoint->endpoint_cache_length ) { btl_endpoint 181 opal/mca/btl/tcp/btl_tcp_frag.c cnt = length = btl_endpoint->endpoint_cache_length; btl_endpoint 186 opal/mca/btl/tcp/btl_tcp_frag.c memcpy( frag->iov_ptr[i].iov_base, btl_endpoint->endpoint_cache_pos, length ); btl_endpoint 188 opal/mca/btl/tcp/btl_tcp_frag.c frag->segments[0].seg_addr.pval = btl_endpoint->endpoint_cache_pos; btl_endpoint 189 opal/mca/btl/tcp/btl_tcp_frag.c frag->iov_ptr[i].iov_base = btl_endpoint->endpoint_cache_pos; btl_endpoint 191 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_cache_pos += length; btl_endpoint 192 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_cache_length -= length; btl_endpoint 193 opal/mca/btl/tcp/btl_tcp_frag.c length = btl_endpoint->endpoint_cache_length; btl_endpoint 195 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache; btl_endpoint 204 opal/mca/btl/tcp/btl_tcp_frag.c frag->iov_ptr[num_vecs].iov_base = btl_endpoint->endpoint_cache_pos; btl_endpoint 206 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_component.tcp_endpoint_cache - btl_endpoint->endpoint_cache_length; btl_endpoint 215 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 216 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 228 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 229 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 236 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_proc->proc_opal->proc_hostname); btl_endpoint 237 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 238 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 245 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; btl_endpoint 246 opal/mca/btl/tcp/btl_tcp_frag.c mca_btl_tcp_endpoint_close(btl_endpoint); btl_endpoint 268 opal/mca/btl/tcp/btl_tcp_frag.c btl_endpoint->endpoint_cache_length = cnt; btl_endpoint 273 opal/mca/btl/tcp/btl_tcp_frag.c if (btl_endpoint->endpoint_nbo && frag->iov_idx == 1) MCA_BTL_TCP_HDR_NTOH(frag->hdr); btl_endpoint 293 opal/mca/btl/tcp/btl_tcp_frag.c if (btl_endpoint->endpoint_nbo) MCA_BTL_BASE_SEGMENT_NTOH(frag->segments[i]); btl_endpoint 440 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_base_endpoint_t* btl_endpoint ) btl_endpoint 469 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_nbo = true; btl_endpoint 474 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_proc = btl_proc; btl_endpoint 475 opal/mca/btl/tcp/btl_tcp_proc.c btl_proc->proc_endpoints[btl_proc->proc_endpoint_count++] = btl_endpoint; btl_endpoint 697 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_addr = proc_data->best_addr[i][best]; btl_endpoint 698 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_addr->addr_inuse = true; btl_endpoint 723 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_addr = proc_data->best_addr[i_max][j_max]; btl_endpoint 724 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_addr->addr_inuse = true; btl_endpoint 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_endpoint 789 opal/mca/btl/tcp/btl_tcp_proc.c if(btl_proc->proc_endpoints[i] == btl_endpoint) { btl_endpoint 800 opal/mca/btl/tcp/btl_tcp_proc.c if (NULL != btl_endpoint->endpoint_addr) { btl_endpoint 801 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_addr->addr_inuse = false; btl_endpoint 861 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_base_endpoint_t* btl_endpoint = btl_proc->proc_endpoints[i]; btl_endpoint 865 opal/mca/btl/tcp/btl_tcp_proc.c if( btl_endpoint->endpoint_addr->addr_family != addr->sa_family) { btl_endpoint 870 opal/mca/btl/tcp/btl_tcp_proc.c if( memcmp( &btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 879 opal/mca/btl/tcp/btl_tcp_proc.c inet_ntop(AF_INET, (void*)(struct in_addr*)&btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 883 opal/mca/btl/tcp/btl_tcp_proc.c } else if (btl_endpoint->endpoint_state != MCA_BTL_TCP_CLOSED) { btl_endpoint 885 opal/mca/btl/tcp/btl_tcp_proc.c match_btl_endpoint = btl_endpoint; btl_endpoint 891 opal/mca/btl/tcp/btl_tcp_proc.c if( memcmp( &btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 900 opal/mca/btl/tcp/btl_tcp_proc.c inet_ntop(AF_INET6, (void*)(struct in6_addr*)&btl_endpoint->endpoint_addr->addr_inet, btl_endpoint 904 opal/mca/btl/tcp/btl_tcp_proc.c } else if (btl_endpoint->endpoint_state != MCA_BTL_TCP_CLOSED) { btl_endpoint 906 opal/mca/btl/tcp/btl_tcp_proc.c match_btl_endpoint = btl_endpoint; btl_endpoint 916 opal/mca/btl/tcp/btl_tcp_proc.c btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTING; btl_endpoint 917 opal/mca/btl/tcp/btl_tcp_proc.c (void)mca_btl_tcp_endpoint_accept(btl_endpoint, addr, sd); btl_endpoint 937 opal/mca/btl/tcp/btl_tcp_proc.c mca_btl_base_endpoint_t* btl_endpoint = btl_proc->proc_endpoints[i]; btl_endpoint 938 opal/mca/btl/tcp/btl_tcp_proc.c if (btl_endpoint->endpoint_addr->addr_family != addr->sa_family) { btl_endpoint 941 opal/mca/btl/tcp/btl_tcp_proc.c inet_ntop(btl_endpoint->endpoint_addr->addr_family, btl_endpoint 942 opal/mca/btl/tcp/btl_tcp_proc.c (void*) &(btl_endpoint->endpoint_addr->addr_inet),