hdr 382 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 383 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 384 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.size = 0; hdr 386 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.size += frag->segments[i].seg_len; hdr 391 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.base.tag = tag; hdr 392 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_SEND; hdr 393 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.count = 0; hdr 394 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 419 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.size = 0; hdr 422 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 423 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 427 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.size += frag->segments[i].seg_len; hdr 432 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.base.tag = MCA_BTL_TAG_BTL; hdr 433 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_PUT; hdr 434 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.count = frag->base.des_dst_cnt; hdr 435 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 462 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.size = 0; hdr 465 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 466 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 469 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.base.tag = MCA_BTL_TAG_BTL; hdr 470 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_GET; hdr 471 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->hdr.count = frag->base.des_src_cnt; hdr 472 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 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); hdr 245 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c switch(frag->hdr.type) { hdr 247 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c if(frag->iov_idx == 1 && frag->hdr.size) { hdr 249 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->segments[0].seg_len = frag->hdr.size; hdr 251 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->iov[1].iov_len = frag->hdr.size; hdr 266 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->iov[1].iov_len = frag->hdr.count * sizeof(mca_btl_base_segment_t); hdr 270 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c for( i = 0; i < frag->hdr.count; i++ ) { hdr 274 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c frag->iov_cnt += frag->hdr.count; hdr 60 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h mca_btl_tcp2_hdr_t hdr; hdr 151 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h frag->iov[0].iov_len = sizeof(frag->hdr); \ hdr 152 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; \ hdr 46 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h #define MCA_BTL_TCP_HDR_HTON(hdr) \ hdr 48 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h hdr.count = htons(hdr.count); \ hdr 49 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h hdr.size = htonl(hdr.size); \ hdr 52 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h #define MCA_BTL_TCP_HDR_NTOH(hdr) \ hdr 54 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h hdr.count = ntohs(hdr.count); \ hdr 55 contrib/build-mca-comps-outside-of-tree/btl_tcp2_hdr.h hdr.size = ntohl(hdr.size); \ hdr 289 ompi/debuggers/ompi_common_dll.c ompi_field_offset(i_info->mca_pml_ob1_recv_frag_t.offset.hdr, hdr 290 ompi/debuggers/ompi_common_dll.c qh_type, mca_pml_ob1_recv_frag_t, hdr); hdr 148 ompi/debuggers/ompi_common_dll_defs.h int hdr; hdr 299 ompi/mca/osc/pt2pt/osc_pt2pt_header.h osc_pt2pt_ntoh(ompi_osc_pt2pt_header_t *hdr) hdr 301 ompi/mca/osc/pt2pt/osc_pt2pt_header.h if(!(hdr->base.flags & OMPI_OSC_PT2PT_HDR_FLAG_NBO)) hdr 304 ompi/mca/osc/pt2pt/osc_pt2pt_header.h switch(hdr->base.type) { hdr 307 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_PUT_HDR_NTOH(hdr->put); hdr 313 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_ACC_HDR_NTOH(hdr->acc); hdr 316 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_GET_HDR_NTOH(hdr->get); hdr 320 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_CSWAP_HDR_NTOH(hdr->cswap); hdr 323 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_COMPLETE_HDR_NTOH(hdr->complete); hdr 326 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_POST_HDR_NTOH(hdr->post); hdr 329 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_LOCK_HDR_NTOH(hdr->lock); hdr 332 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_LOCK_ACK_HDR_NTOH(hdr->lock_ack); hdr 335 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_UNLOCK_HDR_NTOH(hdr->unlock); hdr 338 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_UNLOCK_ACK_HDR_NTOH(hdr->unlock_ack); hdr 341 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FLUSH_HDR_NTOH(hdr->flush); hdr 344 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FLUSH_ACK_HDR_NTOH(hdr->flush_ack); hdr 347 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FRAG_HDR_NTOH(hdr->frag); hdr 363 ompi/mca/osc/pt2pt/osc_pt2pt_header.h osc_pt2pt_hton_intr(ompi_osc_pt2pt_header_t *hdr, const ompi_proc_t *proc) hdr 366 ompi/mca/osc/pt2pt/osc_pt2pt_header.h hdr->base.flags |= OMPI_OSC_PT2PT_HDR_FLAG_NBO; hdr 371 ompi/mca/osc/pt2pt/osc_pt2pt_header.h hdr->base.flags |= OMPI_OSC_PT2PT_HDR_FLAG_NBO; hdr 372 ompi/mca/osc/pt2pt/osc_pt2pt_header.h switch(hdr->base.type) { hdr 375 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_PUT_HDR_HTON(hdr->put); hdr 381 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_ACC_HDR_HTON(hdr->acc); hdr 384 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_GET_HDR_HTON(hdr->get); hdr 388 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_CSWAP_HDR_HTON(hdr->cswap); hdr 391 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_COMPLETE_HDR_HTON(hdr->complete); hdr 394 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_POST_HDR_HTON(hdr->post); hdr 397 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_LOCK_HDR_HTON(hdr->lock); hdr 400 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_LOCK_ACK_HDR_HTON(hdr->lock_ack); hdr 403 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_UNLOCK_HDR_HTON(hdr->unlock); hdr 406 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_UNLOCK_ACK_HDR_HTON(hdr->unlock_ack); hdr 409 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FLUSH_HDR_HTON(hdr->flush); hdr 412 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FLUSH_ACK_HDR_HTON(hdr->flush_ack); hdr 415 ompi/mca/osc/pt2pt/osc_pt2pt_header.h MCA_OSC_PT2PT_FRAG_HDR_HTON(hdr->frag); hdr 569 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h printf("%x %x %x\n", elem->value[j], req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 570 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 571 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 572 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 573 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 411 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if((req->hdr.hdr_match.hdr_src == peer || peer == OMPI_ANY_SOURCE) && (req->hdr.hdr_match.hdr_tag == tag || tag == OMPI_ANY_TAG)) hdr 414 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("Found list: %x tag: %x peer: %x\n", list, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 469 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("custom_match_umq_append list: %x key: %x payload: %x tag: %d src: %d\n", list, key, payload, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 574 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("%x %x %x\n", elem->value[j], req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 575 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 576 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 577 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 578 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 402 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if((req->hdr.hdr_match.hdr_src == peer || peer == OMPI_ANY_SOURCE) && (req->hdr.hdr_match.hdr_tag == tag || tag == OMPI_ANY_TAG)) hdr 405 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("Found list: %x tag: %x peer: %x\n", list, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 460 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("custom_match_umq_append list: %x key: %x payload: %x tag: %d src: %d\n", list, key, payload, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 569 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("%x %x %x\n", elem->value[j], req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 570 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 571 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 572 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 573 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 420 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if((req->hdr.hdr_match.hdr_src == peer || peer == OMPI_ANY_SOURCE) && (req->hdr.hdr_match.hdr_tag == tag || tag == OMPI_ANY_TAG)) hdr 423 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("Found list: %x tag: %x peer: %x\n", list, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 478 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("custom_match_umq_append list: %x key: %x payload: %x tag: %d src: %d\n", list, key, payload, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 587 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("%lx %x %x\n", (uintptr_t) elem->value[j], req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 588 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 589 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 590 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 591 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 507 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h printf("%x %x %x\n", elem->value, req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 508 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 509 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 510 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 511 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 484 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h req->hdr.hdr_match.hdr_tag, req->hdr.hdr_match.hdr_src); hdr 578 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if( OMPI_ANY_SOURCE == req->hdr.hdr_match.hdr_src ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); hdr 579 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h else snprintf(cpeer, 64, "%d", req->hdr.hdr_match.hdr_src); hdr 580 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if( OMPI_ANY_TAG == req->hdr.hdr_match.hdr_tag ) snprintf(ctag, 64, "%s", "ANY_TAG"); hdr 581 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h else snprintf(ctag, 64, "%d", req->hdr.hdr_match.hdr_tag); hdr 199 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_match_hdr_t* hdr; hdr 219 ompi/mca/pml/ob1/pml_ob1.c hdr = &frag->hdr.hdr_match; hdr 222 ompi/mca/pml/ob1/pml_ob1.c if( frag->hdr.hdr_match.hdr_ctx != comm->c_contextid ) hdr 238 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 246 ompi/mca/pml/ob1/pml_ob1.c pml_proc = mca_pml_ob1_peer_lookup(comm, hdr->hdr_src); hdr 252 ompi/mca/pml/ob1/pml_ob1.c custom_match_umq_append(pml_comm->umq, hdr->hdr_tag, hdr->hdr_src, frag); hdr 255 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 259 ompi/mca/pml/ob1/pml_ob1.c if (((uint16_t)hdr->hdr_seq) == ((uint16_t)pml_proc->expected_sequence) ) { hdr 267 ompi/mca/pml/ob1/pml_ob1.c custom_match_umq_append(pml_comm->umq, hdr->hdr_tag, hdr->hdr_src, frag); hdr 270 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 280 ompi/mca/pml/ob1/pml_ob1.c hdr = &frag->hdr.hdr_match; hdr 479 ompi/mca/pml/ob1/pml_ob1.c static void mca_pml_ob1_dump_hdr(mca_pml_ob1_hdr_t* hdr) hdr 483 ompi/mca/pml/ob1/pml_ob1.c switch(hdr->hdr_common.hdr_type) { hdr 487 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_match.hdr_ctx, hdr->hdr_match.hdr_src, hdr 488 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_match.hdr_tag, hdr->hdr_match.hdr_seq); hdr 493 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_match.hdr_ctx, hdr->hdr_rndv.hdr_match.hdr_src, hdr 494 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_match.hdr_tag, hdr->hdr_rndv.hdr_match.hdr_seq, hdr 495 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_msg_length); hdr 501 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_match.hdr_ctx, hdr->hdr_rndv.hdr_match.hdr_src, hdr 502 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_match.hdr_tag, hdr->hdr_rndv.hdr_match.hdr_seq, hdr 503 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rndv.hdr_msg_length, hdr->hdr_rget.hdr_frag.lval, hdr 504 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rget.hdr_src_ptr); hdr 509 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_ack.hdr_src_req.pval, hdr->hdr_ack.hdr_dst_req.pval, hdr 510 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_ack.hdr_send_offset, hdr->hdr_ack.hdr_send_size); hdr 515 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_frag.hdr_frag_offset, hdr 516 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_frag.hdr_src_req.pval, hdr->hdr_frag.hdr_dst_req.pval); hdr 522 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rdma.hdr_req.pval, hdr->hdr_rdma.hdr_frag.pval, hdr 523 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rdma.hdr_recv_req.pval, hdr->hdr_rdma.hdr_rdma_offset, hdr 524 ompi/mca/pml/ob1/pml_ob1.c hdr->hdr_rdma.hdr_dst_ptr, hdr->hdr_rdma.hdr_dst_size); hdr 536 ompi/mca/pml/ob1/pml_ob1.c (hdr->hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_NBO ? "nbo" : " "), hdr 569 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_dump_hdr( &frag->hdr ); hdr 580 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_dump_hdr( &item->hdr ); hdr 584 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_dump_hdr( &frag->hdr ); hdr 745 ompi/mca/pml/ob1/pml_ob1.c switch(pckt->hdr.hdr_common.hdr_type) { hdr 749 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_ack.hdr_src_req.lval, hdr 750 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_ack.hdr_dst_req.pval, hdr 751 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_ack.hdr_send_offset, hdr 752 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_ack.hdr_send_size, hdr 753 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_NORDMA); hdr 764 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_fin.hdr_frag, hdr 765 ompi/mca/pml/ob1/pml_ob1.c pckt->hdr.hdr_fin.hdr_size, hdr 225 ompi/mca/pml/ob1/pml_ob1.h mca_pml_ob1_hdr_t hdr; hdr 251 ompi/mca/pml/ob1/pml_ob1.h mca_pml_ob1_fin_hdr_prepare (&_pckt->hdr.hdr_fin, 0, \ hdr 67 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_common_hdr_prepare (mca_pml_ob1_common_hdr_t *hdr, uint8_t hdr_type, hdr 70 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_type = hdr_type; hdr 71 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_flags = hdr_flags; hdr 99 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_match_hdr_prepare (mca_pml_ob1_match_hdr_t *hdr, uint8_t hdr_type, uint8_t hdr_flags, hdr 102 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_common_hdr_prepare (&hdr->hdr_common, hdr_type, hdr_flags); hdr 103 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_ctx = hdr_ctx; hdr 104 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_src = hdr_src; hdr 105 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_tag = hdr_tag; hdr 106 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_seq = hdr_seq; hdr 108 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 109 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 143 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_rendezvous_hdr_prepare (mca_pml_ob1_rendezvous_hdr_t *hdr, uint8_t hdr_type, uint8_t hdr_flags, hdr 147 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_match_hdr_prepare (&hdr->hdr_match, hdr_type, hdr_flags, hdr_ctx, hdr_src, hdr_tag, hdr_seq); hdr 148 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_msg_length = hdr_msg_length; hdr 149 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_src_req.pval = hdr_src_req; hdr 181 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_rget_hdr_prepare (mca_pml_ob1_rget_hdr_t *hdr, uint8_t hdr_flags, hdr 186 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_rendezvous_hdr_prepare (&hdr->hdr_rndv, MCA_PML_OB1_HDR_TYPE_RGET, hdr_flags, hdr 189 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 190 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 191 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[2] = 0; hdr 192 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[3] = 0; hdr 194 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_frag.pval = hdr_frag; hdr 195 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_src_ptr = (uint64_t)(intptr_t) hdr_src_ptr; hdr 198 ompi/mca/pml/ob1/pml_ob1_hdr.h memcpy (hdr + 1, local_handle, local_handle_size); hdr 227 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_frag_hdr_prepare (mca_pml_ob1_frag_hdr_t *hdr, uint8_t hdr_flags, hdr 231 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_common_hdr_prepare (&hdr->hdr_common, MCA_PML_OB1_HDR_TYPE_FRAG, hdr_flags); hdr 233 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 234 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 235 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[2] = 0; hdr 236 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[3] = 0; hdr 237 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[4] = 0; hdr 238 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[5] = 0; hdr 240 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_frag_offset = hdr_frag_offset; hdr 241 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_src_req.pval = hdr_src_req; hdr 242 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_dst_req.lval = hdr_dst_req; hdr 273 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_ack_hdr_prepare (mca_pml_ob1_ack_hdr_t *hdr, uint8_t hdr_flags, hdr 277 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_common_hdr_prepare (&hdr->hdr_common, MCA_PML_OB1_HDR_TYPE_ACK, hdr_flags); hdr 279 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 280 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 281 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[2] = 0; hdr 282 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[3] = 0; hdr 283 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[4] = 0; hdr 284 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[5] = 0; hdr 286 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_src_req.lval = hdr_src_req; hdr 287 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_dst_req.pval = hdr_dst_req; hdr 288 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_send_offset = hdr_send_offset; hdr 289 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_send_size = hdr_send_size; hdr 330 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_rdma_hdr_prepare (mca_pml_ob1_rdma_hdr_t *hdr, uint8_t hdr_flags, hdr 336 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_common_hdr_prepare (&hdr->hdr_common, MCA_PML_OB1_HDR_TYPE_PUT, hdr_flags); hdr 338 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 339 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 341 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_req.lval = hdr_req; hdr 342 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_frag.pval = hdr_frag; hdr 343 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_recv_req.pval = hdr_recv_req; hdr 344 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_rdma_offset = hdr_rdma_offset; hdr 345 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_dst_ptr = (uint64_t)(intptr_t) hdr_dst_ptr; hdr 346 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_dst_size = hdr_dst_size; hdr 349 ompi/mca/pml/ob1/pml_ob1_hdr.h memcpy (hdr + 1, local_handle, local_handle_size); hdr 382 ompi/mca/pml/ob1/pml_ob1_hdr.h static inline void mca_pml_ob1_fin_hdr_prepare (mca_pml_ob1_fin_hdr_t *hdr, uint8_t hdr_flags, hdr 385 ompi/mca/pml/ob1/pml_ob1_hdr.h mca_pml_ob1_common_hdr_prepare (&hdr->hdr_common, MCA_PML_OB1_HDR_TYPE_FIN, hdr_flags); hdr 387 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[0] = 0; hdr 388 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_padding[1] = 0; hdr 390 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_frag.lval = hdr_frag; hdr 391 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_size = hdr_size; hdr 423 ompi/mca/pml/ob1/pml_ob1_hdr.h ob1_hdr_ntoh(mca_pml_ob1_hdr_t *hdr, const uint8_t hdr_type) hdr 425 ompi/mca/pml/ob1/pml_ob1_hdr.h if(!(hdr->hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_NBO)) hdr 430 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_MATCH_HDR_NTOH(hdr->hdr_match); hdr 433 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RNDV_HDR_NTOH(hdr->hdr_rndv); hdr 436 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RGET_HDR_NTOH(hdr->hdr_rget); hdr 439 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_ACK_HDR_NTOH(hdr->hdr_ack); hdr 442 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_FRAG_HDR_NTOH(hdr->hdr_frag); hdr 445 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RDMA_HDR_NTOH(hdr->hdr_rdma); hdr 448 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_FIN_HDR_NTOH(hdr->hdr_fin); hdr 463 ompi/mca/pml/ob1/pml_ob1_hdr.h ob1_hdr_hton_intr(mca_pml_ob1_hdr_t *hdr, const uint8_t hdr_type, hdr 467 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_common.hdr_flags |= MCA_PML_OB1_HDR_FLAGS_NBO; hdr 473 ompi/mca/pml/ob1/pml_ob1_hdr.h hdr->hdr_common.hdr_flags |= MCA_PML_OB1_HDR_FLAGS_NBO; hdr 476 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_MATCH_HDR_HTON(hdr->hdr_match); hdr 479 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RNDV_HDR_HTON(hdr->hdr_rndv); hdr 482 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RGET_HDR_HTON(hdr->hdr_rget); hdr 485 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_ACK_HDR_HTON(hdr->hdr_ack); hdr 488 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_FRAG_HDR_HTON(hdr->hdr_frag); hdr 491 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_RDMA_HDR_HTON(hdr->hdr_rdma); hdr 494 ompi/mca/pml/ob1/pml_ob1_hdr.h MCA_PML_OB1_FIN_HDR_HTON(hdr->hdr_fin); hdr 184 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_hdr_t *hdr; hdr 241 ompi/mca/pml/ob1/pml_ob1_irecv.c hdr = (mca_pml_ob1_hdr_t*)frag->segments->seg_addr.pval; hdr 242 ompi/mca/pml/ob1/pml_ob1_irecv.c switch(hdr->hdr_common.hdr_type) { hdr 277 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_hdr_t *hdr; hdr 333 ompi/mca/pml/ob1/pml_ob1_irecv.c hdr = (mca_pml_ob1_hdr_t*)frag->segments->seg_addr.pval; hdr 334 ompi/mca/pml/ob1/pml_ob1_irecv.c switch(hdr->hdr_common.hdr_type) { hdr 79 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_btl_base_segment_t* segments, hdr 84 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); hdr 93 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_btl_base_segment_t* segments, hdr 98 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); hdr 100 ompi/mca/pml/ob1/pml_ob1_recvfrag.c custom_match_umq_append(queue, hdr->hdr_tag, hdr->hdr_src, frag); hdr 123 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr; hdr 128 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr = &frag->hdr.hdr_match; hdr 136 ompi/mca/pml/ob1/pml_ob1_recvfrag.c assert(hdr->hdr_seq != prior->hdr.hdr_match.hdr_seq); hdr 141 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( hdr->hdr_seq < prior->hdr.hdr_match.hdr_seq ) { hdr 142 ompi/mca/pml/ob1/pml_ob1_recvfrag.c uint16_t d1, d2 = prior->hdr.hdr_match.hdr_seq - hdr->hdr_seq; hdr 146 ompi/mca/pml/ob1/pml_ob1_recvfrag.c d2 = prior->hdr.hdr_match.hdr_seq - hdr->hdr_seq; hdr 147 ompi/mca/pml/ob1/pml_ob1_recvfrag.c } while( (hdr->hdr_seq < prior->hdr.hdr_match.hdr_seq) && hdr 150 ompi/mca/pml/ob1/pml_ob1_recvfrag.c uint16_t prior_seq = prior->hdr.hdr_match.hdr_seq, hdr 151 ompi/mca/pml/ob1/pml_ob1_recvfrag.c next_seq = ((mca_pml_ob1_recv_frag_t*)(prior->super.super.opal_list_next))->hdr.hdr_match.hdr_seq; hdr 153 ompi/mca/pml/ob1/pml_ob1_recvfrag.c while( (hdr->hdr_seq > prior_seq) && (hdr->hdr_seq > next_seq) && (prior_seq < next_seq) ) { hdr 156 ompi/mca/pml/ob1/pml_ob1_recvfrag.c next_seq = ((mca_pml_ob1_recv_frag_t*)(prior->super.super.opal_list_next))->hdr.hdr_match.hdr_seq; hdr 165 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( (parent->hdr.hdr_match.hdr_seq + 1) == hdr->hdr_seq ) { hdr 173 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( (largest->hdr.hdr_match.hdr_seq + 1) == hdr->hdr_seq ) { hdr 191 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( parent->hdr.hdr_match.hdr_seq >= seq ) hdr 192 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( abs(parent->hdr.hdr_match.hdr_seq - seq) < abs((*queue)->hdr.hdr_match.hdr_seq - seq)) hdr 198 ompi/mca/pml/ob1/pml_ob1_recvfrag.c uint16_t upper = parent->hdr.hdr_match.hdr_seq; hdr 200 ompi/mca/pml/ob1/pml_ob1_recvfrag.c upper = ((mca_pml_ob1_recv_frag_t*)parent->range->super.super.opal_list_prev)->hdr.hdr_match.hdr_seq; hdr 202 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( (upper + 1) == next->hdr.hdr_match.hdr_seq ) { hdr 297 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, hdr 319 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, hdr 327 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_btl_base_segment_t* segments, hdr 337 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( (NULL != frag) && (frag->hdr.hdr_match.hdr_seq == proc->expected_sequence) ) { hdr 349 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t* hdr = (mca_pml_ob1_match_hdr_t*)segments->seg_addr.pval; hdr 362 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(((mca_pml_ob1_hdr_t*) hdr), MCA_PML_OB1_HDR_TYPE_MATCH); hdr 365 ompi/mca/pml/ob1/pml_ob1_recvfrag.c comm_ptr = ompi_comm_lookup(hdr->hdr_ctx); hdr 375 ompi/mca/pml/ob1/pml_ob1_recvfrag.c btl, hdr, segments, num_segments, NULL ); hdr 381 ompi/mca/pml/ob1/pml_ob1_recvfrag.c proc = mca_pml_ob1_peer_lookup (comm_ptr, hdr->hdr_src); hdr 390 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 406 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if(OPAL_UNLIKELY(((uint16_t) hdr->hdr_seq) != ((uint16_t) proc->expected_sequence))) { hdr 409 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); hdr 425 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 427 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_one(btl, hdr, segments, num_segments, comm_ptr, proc, NULL); hdr 434 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 448 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_REQUEST_MATCHED(match, hdr); hdr 510 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &frag->hdr.hdr_match, hdr 512 ompi/mca/pml/ob1/pml_ob1_recvfrag.c frag->hdr.hdr_match.hdr_common.hdr_type, frag); hdr 528 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 533 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(hdr, MCA_PML_OB1_HDR_TYPE_RNDV); hdr 534 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match(btl, &hdr->hdr_match, segments, hdr 545 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 550 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(hdr, MCA_PML_OB1_HDR_TYPE_RGET); hdr 551 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match(btl, &hdr->hdr_match, segments, hdr 564 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 572 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(hdr, MCA_PML_OB1_HDR_TYPE_ACK); hdr 573 ompi/mca/pml/ob1/pml_ob1_recvfrag.c sendreq = (mca_pml_ob1_send_request_t*)hdr->hdr_ack.hdr_src_req.pval; hdr 574 ompi/mca/pml/ob1/pml_ob1_recvfrag.c sendreq->req_recv = hdr->hdr_ack.hdr_dst_req; hdr 578 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if(hdr->hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_NORDMA) { hdr 587 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if (hdr->hdr_ack.hdr_send_size) { hdr 588 ompi/mca/pml/ob1/pml_ob1_recvfrag.c size = hdr->hdr_ack.hdr_send_size; hdr 590 ompi/mca/pml/ob1/pml_ob1_recvfrag.c size = sendreq->req_send.req_bytes_packed - hdr->hdr_ack.hdr_send_offset; hdr 593 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_send_request_copy_in_out(sendreq, hdr->hdr_ack.hdr_send_offset, size); hdr 630 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 637 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(hdr, MCA_PML_OB1_HDR_TYPE_FRAG); hdr 638 ompi/mca/pml/ob1/pml_ob1_recvfrag.c recvreq = (mca_pml_ob1_recv_request_t*)hdr->hdr_frag.hdr_dst_req.pval; hdr 667 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 674 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh(hdr, MCA_PML_OB1_HDR_TYPE_PUT); hdr 675 ompi/mca/pml/ob1/pml_ob1_recvfrag.c sendreq = (mca_pml_ob1_send_request_t*)hdr->hdr_rdma.hdr_req.pval; hdr 676 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_send_request_put(sendreq,btl,&hdr->hdr_rdma); hdr 687 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_fin_hdr_t* hdr = (mca_pml_ob1_fin_hdr_t *) segments->seg_addr.pval; hdr 694 ompi/mca/pml/ob1/pml_ob1_recvfrag.c ob1_hdr_ntoh((union mca_pml_ob1_hdr_t *)hdr, MCA_PML_OB1_HDR_TYPE_FIN); hdr 695 ompi/mca/pml/ob1/pml_ob1_recvfrag.c frag = (mca_pml_ob1_rdma_frag_t *) hdr->hdr_frag.pval; hdr 696 ompi/mca/pml/ob1/pml_ob1_recvfrag.c frag->cbfunc (frag, hdr->hdr_size); hdr 724 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_pml_ob1_comm_t *comm, hdr 730 ompi/mca/pml/ob1/pml_ob1_recvfrag.c int tag = hdr->hdr_tag; hdr 771 ompi/mca/pml/ob1/pml_ob1_recvfrag.c return custom_match_prq_find_dequeue_verify(comm->prq, hdr->hdr_tag, hdr->hdr_src); hdr 777 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_pml_ob1_comm_t *comm, hdr 781 ompi/mca/pml/ob1/pml_ob1_recvfrag.c int tag = hdr->hdr_tag; hdr 800 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, mca_btl_base_segment_t* segments, hdr 815 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_incomming(hdr, comm, proc); hdr 818 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_incomming(hdr, comm, proc); hdr 820 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_incomming_no_any_source (hdr, comm, proc); hdr 841 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(tmp, hdr, segments, num_segments, btl); hdr 863 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_umq(comm->umq, btl, hdr, segments, hdr 866 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_list(&proc->unexpected_frags, btl, hdr, segments, hdr 873 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 910 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, hdr 923 ompi/mca/pml/ob1/pml_ob1_recvfrag.c comm_ptr = ompi_comm_lookup(hdr->hdr_ctx); hdr 933 ompi/mca/pml/ob1/pml_ob1_recvfrag.c btl, hdr, segments, num_segments, NULL ); hdr 939 ompi/mca/pml/ob1/pml_ob1_recvfrag.c proc = mca_pml_ob1_peer_lookup (comm_ptr, hdr->hdr_src); hdr 948 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 959 ompi/mca/pml/ob1/pml_ob1_recvfrag.c frag_msg_seq = hdr->hdr_seq; hdr 967 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); hdr 980 ompi/mca/pml/ob1/pml_ob1_recvfrag.c return mca_pml_ob1_recv_frag_match_proc(btl, comm_ptr, proc, hdr, hdr 996 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_match_hdr_t *hdr, hdr 1023 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 1025 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_one(btl, hdr, segments, num_segments, comm_ptr, proc, frag); hdr 1032 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr->hdr_src, hdr->hdr_tag, PERUSE_RECV); hdr 1062 ompi/mca/pml/ob1/pml_ob1_recvfrag.c hdr = &frag->hdr.hdr_match; hdr 1066 ompi/mca/pml/ob1/pml_ob1_recvfrag.c type = hdr->hdr_common.hdr_type; hdr 43 ompi/mca/pml/ob1/pml_ob1_recvfrag.h mca_pml_ob1_hdr_t hdr; hdr 63 ompi/mca/pml/ob1/pml_ob1_recvfrag.h #define MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segs, cnt, btl ) \ hdr 71 ompi/mca/pml/ob1/pml_ob1_recvfrag.h ob1_hdr_copy( (mca_pml_ob1_hdr_t*)hdr, &frag->hdr ); \ hdr 264 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_rendezvous_hdr_t* hdr, hdr 274 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(hdr->hdr_msg_length > bytes_received) { hdr 282 ompi/mca/pml/ob1/pml_ob1_recvreq.c hdr->hdr_match.hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_CONTIG && hdr 287 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(hdr->hdr_match.hdr_common.hdr_flags & MCA_PML_OB1_HDR_FLAGS_PIN) hdr 296 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_send_offset = hdr->hdr_msg_length; hdr 298 ompi/mca/pml/ob1/pml_ob1_recvreq.c } else if(bml_endpoint->btl_send_limit < hdr->hdr_msg_length) { hdr 300 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_send_offset = hdr->hdr_msg_length - hdr 318 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(recvreq->req_send_offset == hdr->hdr_msg_length) hdr 329 ompi/mca/pml/ob1/pml_ob1_recvreq.c return mca_pml_ob1_recv_request_ack_send(proc, hdr->hdr_src_req.lval, hdr 419 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_rdma_hdr_t *hdr; hdr 441 ompi/mca/pml/ob1/pml_ob1_recvreq.c hdr = (mca_pml_ob1_rdma_hdr_t *) ctl->des_segments->seg_addr.pval; hdr 442 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_rdma_hdr_prepare (hdr, (!recvreq->req_ack_sent) ? MCA_PML_OB1_HDR_TYPE_ACK : 0, hdr 446 ompi/mca/pml/ob1/pml_ob1_recvreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_PUT, proc); hdr 525 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 529 ompi/mca/pml/ob1/pml_ob1_recvreq.c data_offset = hdr->hdr_frag.hdr_frag_offset; hdr 586 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 592 ompi/mca/pml/ob1/pml_ob1_recvreq.c data_offset = hdr->hdr_frag.hdr_frag_offset; hdr 658 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_rget_hdr_t* hdr = (mca_pml_ob1_rget_hdr_t*)segments->seg_addr.pval; hdr 666 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_bytes_packed = hdr->hdr_rndv.hdr_msg_length; hdr 670 ompi/mca/pml/ob1/pml_ob1_recvreq.c MCA_PML_OB1_RECV_REQUEST_MATCHED(recvreq, &hdr->hdr_rndv.hdr_match); hdr 681 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_ack(recvreq, &hdr->hdr_rndv, 0); hdr 701 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_ack(recvreq, &hdr->hdr_rndv, 0); hdr 712 ompi/mca/pml/ob1/pml_ob1_recvreq.c bytes_remaining = hdr->hdr_rndv.hdr_msg_length; hdr 715 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->remote_req_send = hdr->hdr_rndv.hdr_src_req; hdr 763 ompi/mca/pml/ob1/pml_ob1_recvreq.c memcpy (frag->remote_handle, hdr + 1, btl->btl_registration_handle_size); hdr 766 ompi/mca/pml/ob1/pml_ob1_recvreq.c frag->remote_address = hdr->hdr_src_ptr + offset; hdr 776 ompi/mca/pml/ob1/pml_ob1_recvreq.c frag->rdma_hdr.hdr_rget = *hdr; hdr 815 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 820 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_bytes_packed = hdr->hdr_rndv.hdr_msg_length; hdr 821 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->remote_req_send = hdr->hdr_rndv.hdr_src_req; hdr 823 ompi/mca/pml/ob1/pml_ob1_recvreq.c MCA_PML_OB1_RECV_REQUEST_MATCHED(recvreq, &hdr->hdr_match); hdr 824 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_ack(recvreq, &hdr->hdr_rndv, bytes_received); hdr 884 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 891 ompi/mca/pml/ob1/pml_ob1_recvreq.c MCA_PML_OB1_RECV_REQUEST_MATCHED(recvreq, &hdr->hdr_match); hdr 939 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr = (mca_pml_ob1_hdr_t*)segments->seg_addr.pval; hdr 941 ompi/mca/pml/ob1/pml_ob1_recvreq.c switch(hdr->hdr_common.hdr_type) { hdr 949 ompi/mca/pml/ob1/pml_ob1_recvreq.c bytes_packed = hdr->hdr_rndv.hdr_msg_length; hdr 954 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_match.hdr_tag; hdr 955 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_match.hdr_src; hdr 1134 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( frag->hdr.hdr_match.hdr_tag >= 0 ) hdr 1139 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( frag->hdr.hdr_match.hdr_tag == tag ) hdr 1179 ompi/mca/pml/ob1/pml_ob1_recvreq.c *p = procp[frag->hdr.hdr_match.hdr_src]; hdr 1180 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[frag->hdr.hdr_match.hdr_src]->ompi_proc; hdr 1234 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_hdr_t* hdr; hdr 1319 ompi/mca/pml/ob1/pml_ob1_recvreq.c hdr = (mca_pml_ob1_hdr_t*)frag->segments->seg_addr.pval; hdr 1322 ompi/mca/pml/ob1/pml_ob1_recvreq.c hdr->hdr_match.hdr_src, hdr 1323 ompi/mca/pml/ob1/pml_ob1_recvreq.c hdr->hdr_match.hdr_tag, hdr 1338 ompi/mca/pml/ob1/pml_ob1_recvreq.c switch(hdr->hdr_common.hdr_type) { hdr 238 ompi/mca/pml/ob1/pml_ob1_recvreq.h #define MCA_PML_OB1_RECV_REQUEST_MATCHED(request, hdr) \ hdr 239 ompi/mca/pml/ob1/pml_ob1_recvreq.h recv_req_matched(request, hdr) hdr 242 ompi/mca/pml/ob1/pml_ob1_recvreq.h mca_pml_ob1_match_hdr_t *hdr) hdr 244 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_src; hdr 245 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_tag; hdr 413 ompi/mca/pml/ob1/pml_ob1_recvreq.h _pckt->hdr.hdr_common.hdr_type = MCA_PML_OB1_HDR_TYPE_ACK; \ hdr 414 ompi/mca/pml/ob1/pml_ob1_recvreq.h _pckt->hdr.hdr_ack.hdr_src_req.lval = (S); \ hdr 415 ompi/mca/pml/ob1/pml_ob1_recvreq.h _pckt->hdr.hdr_ack.hdr_dst_req.pval = (D); \ hdr 416 ompi/mca/pml/ob1/pml_ob1_recvreq.h _pckt->hdr.hdr_ack.hdr_send_offset = (O); \ hdr 417 ompi/mca/pml/ob1/pml_ob1_recvreq.h _pckt->hdr.hdr_ack.hdr_send_size = (Sz); \ hdr 383 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_hdr_t* hdr; hdr 416 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_hdr_t*)segment->seg_addr.pval; hdr 417 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rendezvous_hdr_prepare (&hdr->hdr_rndv, MCA_PML_OB1_HDR_TYPE_RNDV, 0, hdr 424 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RNDV, sendreq->req_send.req_base.req_proc); hdr 489 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_hdr_t* hdr; hdr 568 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_hdr_t*)segment->seg_addr.pval; hdr 569 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_match_hdr_prepare (&hdr->hdr_match, MCA_PML_OB1_HDR_TYPE_MATCH, 0, hdr 575 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_MATCH, sendreq->req_send.req_base.req_proc); hdr 616 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_hdr_t* hdr; hdr 633 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_hdr_t*)segment->seg_addr.pval; hdr 634 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_match_hdr_prepare (&hdr->hdr_match, MCA_PML_OB1_HDR_TYPE_MATCH, 0, hdr 640 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_MATCH, sendreq->req_send.req_base.req_proc); hdr 679 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rget_hdr_t *hdr; hdr 715 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_alloc(bml_btl, &des, MCA_BTL_NO_ORDER, sizeof (*hdr) + reg_size, hdr 728 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_rget_hdr_t *) des->des_segments->seg_addr.pval; hdr 730 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rget_hdr_prepare (hdr, MCA_PML_OB1_HDR_FLAGS_CONTIG | MCA_PML_OB1_HDR_FLAGS_PIN, hdr 738 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RGET, sendreq->req_send.req_base.req_proc); hdr 776 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_hdr_t* hdr; hdr 815 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_hdr_t*)segment->seg_addr.pval; hdr 816 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rendezvous_hdr_prepare (&hdr->hdr_rndv, MCA_PML_OB1_HDR_TYPE_RNDV, flags | hdr 824 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RNDV, sendreq->req_send.req_base.req_proc); hdr 944 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_frag_hdr_t* hdr; hdr 1039 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr = (mca_pml_ob1_frag_hdr_t*)des->des_segments->seg_addr.pval; hdr 1040 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_frag_hdr_prepare (hdr, 0, range->range_send_offset, sendreq, hdr 1043 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_FRAG, hdr 1222 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rdma_hdr_t* hdr ) hdr 1227 ompi/mca/pml/ob1/pml_ob1_sendreq.c if(hdr->hdr_common.hdr_flags & MCA_PML_OB1_HDR_TYPE_ACK) { hdr 1231 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_recv.pval = hdr->hdr_recv_req.pval; hdr 1249 ompi/mca/pml/ob1/pml_ob1_sendreq.c memcpy (frag->remote_handle, hdr + 1, btl->btl_registration_handle_size); hdr 1252 ompi/mca/pml/ob1/pml_ob1_sendreq.c frag->rdma_hdr.hdr_rdma = *hdr; hdr 1254 ompi/mca/pml/ob1/pml_ob1_sendreq.c frag->rdma_length = hdr->hdr_dst_size; hdr 1256 ompi/mca/pml/ob1/pml_ob1_sendreq.c frag->remote_address = hdr->hdr_dst_ptr; hdr 1262 ompi/mca/pml/ob1/pml_ob1_sendreq.c hdr->hdr_rdma_offset, &frag->local_address); hdr 506 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_pml_ob1_rdma_hdr_t* hdr ); hdr 524 opal/mca/btl/btl.h #define MCA_BTL_BASE_HEADER_HTON(hdr) hdr 525 opal/mca/btl/btl.h #define MCA_BTL_BASE_HEADER_NTOH(hdr) hdr 199 opal/mca/btl/ofi/btl_ofi.h mca_btl_ofi_header_t hdr; hdr 83 opal/mca/btl/ofi/btl_ofi_frag.c frag->hdr.len = size; hdr 111 opal/mca/btl/ofi/btl_ofi_frag.c frag->hdr.tag = tag; hdr 121 opal/mca/btl/ofi/btl_ofi_frag.c &frag->hdr, hdr 122 opal/mca/btl/ofi/btl_ofi_frag.c sizeof(mca_btl_ofi_header_t) + frag->hdr.len, hdr 146 opal/mca/btl/ofi/btl_ofi_frag.c frag->segments[0].seg_len = frag->hdr.len; hdr 150 opal/mca/btl/ofi/btl_ofi_frag.c reg = mca_btl_base_active_message_trigger + frag->hdr.tag; hdr 151 opal/mca/btl/ofi/btl_ofi_frag.c reg->cbfunc (&ofi_btl->super, frag->hdr.tag, &frag->base, reg->cbdata); hdr 194 opal/mca/btl/ofi/btl_ofi_frag.c frag->hdr.len += length; hdr 352 opal/mca/btl/ofi/btl_ofi_module.c rc = fi_recv (context->rx_ctx, &frag->hdr, MCA_BTL_OFI_RECV_SIZE, hdr 45 opal/mca/btl/portals4/btl_portals4_frag.h mca_btl_base_header_t hdr; hdr 78 opal/mca/btl/portals4/btl_portals4_rdma.c frag->hdr.tag = MCA_BTL_TAG_MAX; hdr 42 opal/mca/btl/portals4/btl_portals4_send.c frag->hdr.tag = tag; hdr 944 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->len = length; hdr 947 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->tag = tag; hdr 981 opal/mca/btl/smcuda/btl_smcuda.c endpoint->peer_smp_rank, (void *) VIRTUAL2RELATIVE(frag->hdr), false, true, rc); hdr 1017 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->len = frag->segment.seg_len; hdr 1019 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->tag = tag; hdr 1031 opal/mca/btl/smcuda/btl_smcuda.c endpoint->peer_smp_rank, (void *) VIRTUAL2RELATIVE(frag->hdr), false, true, rc); hdr 1230 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->tag = MCA_BTL_TAG_SMCUDA; hdr 1252 opal/mca/btl/smcuda/btl_smcuda.c endpoint->peer_smp_rank, (void *) VIRTUAL2RELATIVE(frag->hdr), false, true, rc); hdr 1274 opal/mca/btl/smcuda/btl_smcuda.c (void*) frag, frag->size, (void*) frag->hdr->frag, hdr 1275 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->len, frag->hdr->my_smp_rank, hdr 1276 opal/mca/btl/smcuda/btl_smcuda.c frag->hdr->tag); hdr 652 opal/mca/btl/smcuda/btl_smcuda_component.c frag->hdr->tag = MCA_BTL_TAG_SMCUDA; hdr 666 opal/mca/btl/smcuda/btl_smcuda_component.c endpoint->peer_smp_rank, (void *) VIRTUAL2RELATIVE(frag->hdr), false, true, rc); hdr 695 opal/mca/btl/smcuda/btl_smcuda_component.c endpoint = mca_btl_smcuda_component.sm_peers[frag->hdr->my_smp_rank]; hdr 767 opal/mca/btl/smcuda/btl_smcuda_component.c assert(endpoint->peer_smp_rank == frag->hdr->my_smp_rank); hdr 1004 opal/mca/btl/smcuda/btl_smcuda_component.c mca_btl_smcuda_hdr_t *hdr; hdr 1033 opal/mca/btl/smcuda/btl_smcuda_component.c hdr = (mca_btl_smcuda_hdr_t *)sm_fifo_read(fifo); hdr 1040 opal/mca/btl/smcuda/btl_smcuda_component.c if(SM_FIFO_FREE == hdr) { hdr 1046 opal/mca/btl/smcuda/btl_smcuda_component.c switch(((uintptr_t)hdr) & MCA_BTL_SMCUDA_FRAG_TYPE_MASK) { hdr 1052 opal/mca/btl/smcuda/btl_smcuda_component.c hdr = (mca_btl_smcuda_hdr_t *) RELATIVE2VIRTUAL(hdr); hdr 1053 opal/mca/btl/smcuda/btl_smcuda_component.c peer_smp_rank = hdr->my_smp_rank; hdr 1062 opal/mca/btl/smcuda/btl_smcuda_component.c reg = mca_btl_base_active_message_trigger + hdr->tag; hdr 1063 opal/mca/btl/smcuda/btl_smcuda_component.c seg.seg_addr.pval = ((char *)hdr) + sizeof(mca_btl_smcuda_hdr_t); hdr 1064 opal/mca/btl/smcuda/btl_smcuda_component.c seg.seg_len = hdr->len; hdr 1068 opal/mca/btl/smcuda/btl_smcuda_component.c Frag.hdr = hdr; /* needed for peer rank in control messages */ hdr 1070 opal/mca/btl/smcuda/btl_smcuda_component.c reg->cbfunc(&mca_btl_smcuda.super, hdr->tag, &(Frag.base), hdr 1075 opal/mca/btl/smcuda/btl_smcuda_component.c my_smp_rank, peer_smp_rank, hdr->frag, false, true, rc); hdr 1080 opal/mca/btl/smcuda/btl_smcuda_component.c int status = (uintptr_t)hdr & MCA_BTL_SMCUDA_FRAG_STATUS_MASK; hdr 1084 opal/mca/btl/smcuda/btl_smcuda_component.c frag = (mca_btl_smcuda_frag_t *)((char*)((uintptr_t)hdr & hdr 1117 opal/mca/btl/smcuda/btl_smcuda_component.c hdr = (mca_btl_smcuda_hdr_t *) RELATIVE2VIRTUAL(hdr); hdr 1118 opal/mca/btl/smcuda/btl_smcuda_component.c peer_smp_rank = hdr->my_smp_rank; hdr 1119 opal/mca/btl/smcuda/btl_smcuda_component.c hdr = (mca_btl_smcuda_hdr_t*)((uintptr_t)hdr->frag | hdr 1123 opal/mca/btl/smcuda/btl_smcuda_component.c my_smp_rank, peer_smp_rank, hdr, false, true, rc); hdr 87 opal/mca/btl/smcuda/btl_smcuda_fifo.h peer_smp_rank, hdr, resend, retry_pending_sends, rc) \ hdr 99 opal/mca/btl/smcuda/btl_smcuda_fifo.h if(sm_fifo_write(hdr, fifo) != OPAL_SUCCESS) { \ hdr 100 opal/mca/btl/smcuda/btl_smcuda_fifo.h add_pending(endpoint_peer, hdr, resend); \ hdr 29 opal/mca/btl/smcuda/btl_smcuda_frag.c frag->hdr = (mca_btl_smcuda_hdr_t*)frag->base.super.ptr; hdr 30 opal/mca/btl/smcuda/btl_smcuda_frag.c if(frag->hdr != NULL) { hdr 31 opal/mca/btl/smcuda/btl_smcuda_frag.c frag->hdr->frag = (mca_btl_smcuda_frag_t*)((uintptr_t)frag | hdr 33 opal/mca/btl/smcuda/btl_smcuda_frag.c frag->segment.seg_addr.pval = ((char*)frag->hdr) + hdr 35 opal/mca/btl/smcuda/btl_smcuda_frag.c frag->hdr->my_smp_rank = mca_btl_smcuda_component.my_smp_rank; hdr 86 opal/mca/btl/smcuda/btl_smcuda_frag.h mca_btl_smcuda_hdr_t *hdr; hdr 323 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 324 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 325 opal/mca/btl/tcp/btl_tcp.c frag->hdr.size = 0; hdr 327 opal/mca/btl/tcp/btl_tcp.c frag->hdr.size += frag->segments[i].seg_len; hdr 332 opal/mca/btl/tcp/btl_tcp.c frag->hdr.base.tag = tag; hdr 333 opal/mca/btl/tcp/btl_tcp.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_SEND; hdr 334 opal/mca/btl/tcp/btl_tcp.c frag->hdr.count = 0; hdr 335 opal/mca/btl/tcp/btl_tcp.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 393 opal/mca/btl/tcp/btl_tcp.c frag->hdr.size = 0; hdr 396 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 397 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 401 opal/mca/btl/tcp/btl_tcp.c frag->hdr.size += frag->segments[i].seg_len; hdr 406 opal/mca/btl/tcp/btl_tcp.c frag->hdr.base.tag = MCA_BTL_TAG_BTL; hdr 407 opal/mca/btl/tcp/btl_tcp.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_PUT; hdr 408 opal/mca/btl/tcp/btl_tcp.c frag->hdr.count = 1; hdr 409 opal/mca/btl/tcp/btl_tcp.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 460 opal/mca/btl/tcp/btl_tcp.c frag->hdr.size = 0; hdr 463 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; hdr 464 opal/mca/btl/tcp/btl_tcp.c frag->iov[0].iov_len = sizeof(frag->hdr); hdr 467 opal/mca/btl/tcp/btl_tcp.c frag->hdr.base.tag = MCA_BTL_TAG_BTL; hdr 468 opal/mca/btl/tcp/btl_tcp.c frag->hdr.type = MCA_BTL_TCP_HDR_TYPE_GET; hdr 469 opal/mca/btl/tcp/btl_tcp.c frag->hdr.count = 1; hdr 470 opal/mca/btl/tcp/btl_tcp.c if (endpoint->endpoint_nbo) MCA_BTL_TCP_HDR_HTON(frag->hdr); hdr 71 opal/mca/btl/tcp/btl_tcp.h if( MCA_BTL_TCP_HDR_TYPE_SEND == frag->hdr.type ) { \ hdr 73 opal/mca/btl/tcp/btl_tcp.h reg = mca_btl_base_active_message_trigger + frag->hdr.base.tag; \ hdr 74 opal/mca/btl/tcp/btl_tcp.h reg->cbfunc(&frag->endpoint->endpoint_btl->super, frag->hdr.base.tag, &frag->base, reg->cbdata); \ hdr 976 opal/mca/btl/tcp/btl_tcp_endpoint.c if( MCA_BTL_TCP_HDR_TYPE_SEND == frag->hdr.type ) { hdr 978 opal/mca/btl/tcp/btl_tcp_endpoint.c reg = mca_btl_base_active_message_trigger + frag->hdr.base.tag; hdr 979 opal/mca/btl/tcp/btl_tcp_endpoint.c reg->cbfunc(&frag->btl->super, frag->hdr.base.tag, &frag->base, reg->cbdata); hdr 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); hdr 274 opal/mca/btl/tcp/btl_tcp_frag.c switch(frag->hdr.type) { hdr 276 opal/mca/btl/tcp/btl_tcp_frag.c if(frag->iov_idx == 1 && frag->hdr.size) { hdr 278 opal/mca/btl/tcp/btl_tcp_frag.c frag->segments[0].seg_len = frag->hdr.size; hdr 280 opal/mca/btl/tcp/btl_tcp_frag.c frag->iov[1].iov_len = frag->hdr.size; hdr 288 opal/mca/btl/tcp/btl_tcp_frag.c frag->iov[1].iov_len = frag->hdr.count * sizeof(mca_btl_base_segment_t); hdr 292 opal/mca/btl/tcp/btl_tcp_frag.c for( i = 0; i < frag->hdr.count; i++ ) { hdr 297 opal/mca/btl/tcp/btl_tcp_frag.c frag->iov_cnt += frag->hdr.count; hdr 53 opal/mca/btl/tcp/btl_tcp_frag.h mca_btl_tcp_hdr_t hdr; hdr 118 opal/mca/btl/tcp/btl_tcp_frag.h frag->iov[0].iov_len = sizeof(frag->hdr); \ hdr 119 opal/mca/btl/tcp/btl_tcp_frag.h frag->iov[0].iov_base = (IOVBASE_TYPE*)&frag->hdr; \ hdr 45 opal/mca/btl/tcp/btl_tcp_hdr.h #define MCA_BTL_TCP_HDR_HTON(hdr) \ hdr 47 opal/mca/btl/tcp/btl_tcp_hdr.h hdr.count = htons(hdr.count); \ hdr 48 opal/mca/btl/tcp/btl_tcp_hdr.h hdr.size = htonl(hdr.size); \ hdr 51 opal/mca/btl/tcp/btl_tcp_hdr.h #define MCA_BTL_TCP_HDR_NTOH(hdr) \ hdr 53 opal/mca/btl/tcp/btl_tcp_hdr.h hdr.count = ntohs(hdr.count); \ hdr 54 opal/mca/btl/tcp/btl_tcp_hdr.h hdr.size = ntohl(hdr.size); \ hdr 39 opal/mca/btl/template/btl_template_frag.h mca_btl_base_header_t *hdr; hdr 57 opal/mca/btl/ugni/btl_ugni_device.h void *hdr; hdr 70 opal/mca/btl/ugni/btl_ugni_device.h grc = GNI_SmsgSendWTag (args->ep_handle, args->hdr, args->hdr_len, args->payload, hdr 459 opal/mca/btl/ugni/btl_ugni_device.h static inline int mca_btl_ugni_endpoint_smsg_send_wtag (mca_btl_base_endpoint_t *endpoint, void *hdr, size_t hdr_len, hdr 463 opal/mca/btl/ugni/btl_ugni_device.h .hdr = hdr, .hdr_len = hdr_len, .payload = payload, hdr 75 opal/mca/btl/ugni/btl_ugni_frag.h mca_btl_ugni_frag_hdr_t hdr; hdr 54 opal/mca/btl/ugni/btl_ugni_get.c memset (&frag->hdr, 0, sizeof (frag->hdr)); hdr 67 opal/mca/btl/ugni/btl_ugni_get.c (void) mca_btl_ugni_start_eager_get (frag->endpoint, pending_frag->hdr.eager_ex, frag); hdr 83 opal/mca/btl/ugni/btl_ugni_get.c uint32_t len = frag->hdr.eager.send.lag & 0x00ffffff; hdr 84 opal/mca/btl/ugni/btl_ugni_get.c uint8_t tag = frag->hdr.eager.send.lag >> 24; hdr 85 opal/mca/btl/ugni/btl_ugni_get.c size_t payload_len = frag->hdr.eager.size; hdr 92 opal/mca/btl/ugni/btl_ugni_get.c BTL_VERBOSE(("eager get for rem_ctx %p complete", frag->hdr.eager.ctx)) hdr 98 opal/mca/btl/ugni/btl_ugni_get.c segs[0].seg_addr.pval = frag->hdr.eager_ex.pml_header; hdr 113 opal/mca/btl/ugni/btl_ugni_get.c frag->hdr.rdma.ctx = frag->hdr.eager.ctx; hdr 123 opal/mca/btl/ugni/btl_ugni_get.c rc = opal_mca_btl_ugni_smsg_send (frag, &frag->hdr.rdma, sizeof (frag->hdr.rdma), hdr 132 opal/mca/btl/ugni/btl_ugni_get.c mca_btl_ugni_eager_ex_frag_hdr_t hdr, hdr 139 opal/mca/btl/ugni/btl_ugni_get.c BTL_VERBOSE(("starting eager get for remote ctx: %p", hdr.eager.ctx)); hdr 151 opal/mca/btl/ugni/btl_ugni_get.c frag->hdr.eager_ex = hdr; hdr 158 opal/mca/btl/ugni/btl_ugni_get.c frag->hdr.eager_ex = hdr; hdr 161 opal/mca/btl/ugni/btl_ugni_get.c size = (hdr.eager.size + 3) & ~3; hdr 167 opal/mca/btl/ugni/btl_ugni_get.c rc = mca_btl_ugni_post (endpoint, true, size, frag->base.super.ptr, hdr.eager.address, hdr 168 opal/mca/btl/ugni/btl_ugni_get.c &frag->memory_handle, &hdr.eager.memory_handle, hdr 262 opal/mca/btl/ugni/btl_ugni_module.c frag->hdr_size = sizeof (frag->hdr.eager); hdr 267 opal/mca/btl/ugni/btl_ugni_module.c frag->hdr.eager.memory_handle = registration->handle; hdr 269 opal/mca/btl/ugni/btl_ugni_module.c frag->hdr_size = sizeof (frag->hdr.send); hdr 36 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr_size = reserve + sizeof (frag->hdr.send); hdr 38 opal/mca/btl/ugni/btl_ugni_prepare.h frag->segments[0].seg_addr.pval = frag->hdr.send_ex.pml_header; hdr 88 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr.eager.memory_handle = registration->handle;; hdr 90 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr_size = reserve + sizeof (frag->hdr.eager); hdr 91 opal/mca/btl/ugni/btl_ugni_prepare.h frag->segments[0].seg_addr.pval = frag->hdr.eager_ex.pml_header; hdr 93 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr_size = reserve + sizeof (frag->hdr.send); hdr 94 opal/mca/btl/ugni/btl_ugni_prepare.h frag->segments[0].seg_addr.pval = frag->hdr.send_ex.pml_header; hdr 134 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr.eager.memory_handle = registration->handle; hdr 135 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr_size = reserve + sizeof (frag->hdr.eager); hdr 136 opal/mca/btl/ugni/btl_ugni_prepare.h frag->segments[0].seg_addr.pval = frag->hdr.eager_ex.pml_header; hdr 143 opal/mca/btl/ugni/btl_ugni_prepare.h frag->hdr_size = reserve + sizeof (frag->hdr.send); hdr 144 opal/mca/btl/ugni/btl_ugni_prepare.h frag->segments[0].seg_addr.pval = frag->hdr.send_ex.pml_header; hdr 21 opal/mca/btl/ugni/btl_ugni_rdma.h mca_btl_ugni_eager_ex_frag_hdr_t hdr, hdr 56 opal/mca/btl/ugni/btl_ugni_send.c frag->hdr.send.lag = (tag << 24) | size; hdr 149 opal/mca/btl/ugni/btl_ugni_send.c frag->hdr.send.lag = (tag << 24) | total_size; hdr 182 opal/mca/btl/ugni/btl_ugni_send.c rc = opal_mca_btl_ugni_smsg_send (frag, &frag->hdr.rdma, sizeof (frag->hdr.rdma), hdr 98 opal/mca/btl/ugni/btl_ugni_smsg.c frag.hdr.send = ((mca_btl_ugni_send_frag_hdr_t *) data_ptr)[0]; hdr 100 opal/mca/btl/ugni/btl_ugni_smsg.c tag = frag.hdr.send.lag >> 24; hdr 101 opal/mca/btl/ugni/btl_ugni_smsg.c len = frag.hdr.send.lag & 0x00ffffff; hdr 118 opal/mca/btl/ugni/btl_ugni_smsg.c frag.hdr.eager_ex = ((mca_btl_ugni_eager_ex_frag_hdr_t *) data_ptr)[0]; hdr 120 opal/mca/btl/ugni/btl_ugni_smsg.c mca_btl_ugni_start_eager_get (ep, frag.hdr.eager_ex, NULL); hdr 123 opal/mca/btl/ugni/btl_ugni_smsg.c frag.hdr.rdma = ((mca_btl_ugni_rdma_frag_hdr_t *) data_ptr)[0]; hdr 125 opal/mca/btl/ugni/btl_ugni_smsg.c if (((mca_btl_ugni_base_frag_t *)frag.hdr.rdma.ctx)->flags & MCA_BTL_UGNI_FRAG_SMSG_COMPLETE) { hdr 126 opal/mca/btl/ugni/btl_ugni_smsg.c mca_btl_ugni_frag_complete (frag.hdr.rdma.ctx, OPAL_SUCCESS); hdr 129 opal/mca/btl/ugni/btl_ugni_smsg.c ((mca_btl_ugni_base_frag_t *)frag.hdr.rdma.ctx)->flags &= ~MCA_BTL_UGNI_FRAG_IGNORE; hdr 75 opal/mca/btl/ugni/btl_ugni_smsg.h void *hdr, size_t hdr_len, hdr 83 opal/mca/btl/ugni/btl_ugni_smsg.h grc = mca_btl_ugni_endpoint_smsg_send_wtag (endpoint, hdr, hdr_len, payload, payload_len, hdr 114 opal/mca/btl/ugni/btl_ugni_smsg.h return opal_mca_btl_ugni_smsg_send (frag, &frag->hdr.send, frag->hdr_size, hdr 120 opal/mca/btl/ugni/btl_ugni_smsg.h frag->hdr.eager.size = frag->segments[1].seg_len; hdr 121 opal/mca/btl/ugni/btl_ugni_smsg.h frag->hdr.eager.address = frag->segments[1].seg_addr.lval; hdr 122 opal/mca/btl/ugni/btl_ugni_smsg.h frag->hdr.eager.ctx = (void *) frag; hdr 124 opal/mca/btl/ugni/btl_ugni_smsg.h return opal_mca_btl_ugni_smsg_send (frag, &frag->hdr.eager, frag->hdr_size, hdr 57 opal/mca/btl/usnic/btl_usnic_recv.c opal_btl_usnic_btl_header_t *hdr; hdr 108 opal/mca/btl/usnic/btl_usnic_recv.c hdr = seg->rs_base.us_btl_header; hdr 112 opal/mca/btl/usnic/btl_usnic_recv.c (void*) endpoint, hdr->pkt_seq, hdr->payload_len); hdr 124 opal/mca/btl/usnic/btl_usnic_recv.c if (hdr->put_addr != NULL) { hdr 137 opal/mca/btl/usnic/btl_usnic_recv.c if (hdr->put_addr == NULL) { hdr 138 opal/mca/btl/usnic/btl_usnic_recv.c reg = mca_btl_base_active_message_trigger + hdr->tag; hdr 139 opal/mca/btl/usnic/btl_usnic_recv.c seg->rs_segment.seg_len = hdr->payload_len; hdr 145 opal/mca/btl/usnic/btl_usnic_recv.c reg->cbfunc(&module->super, hdr->tag, &seg->rs_desc, reg->cbdata); hdr 57 opal/mca/btl/vader/btl_vader_atomic.c mca_btl_vader_sc_emu_hdr_t *hdr; hdr 63 opal/mca/btl/vader/btl_vader_atomic.c hdr = (mca_btl_vader_sc_emu_hdr_t *) frag->segments[0].seg_addr.pval; hdr 65 opal/mca/btl/vader/btl_vader_atomic.c *((int64_t *) frag->rdma.local_address) = hdr->operand[0]; hdr 608 opal/mca/btl/vader/btl_vader_component.c void mca_btl_vader_poll_handle_frag (mca_btl_vader_hdr_t *hdr, struct mca_btl_base_endpoint_t *endpoint) hdr 614 opal/mca/btl/vader/btl_vader_component.c if (hdr->flags & MCA_BTL_VADER_FLAG_COMPLETE) { hdr 615 opal/mca/btl/vader/btl_vader_component.c mca_btl_vader_frag_complete (hdr->frag); hdr 619 opal/mca/btl/vader/btl_vader_component.c reg = mca_btl_base_active_message_trigger + hdr->tag; hdr 620 opal/mca/btl/vader/btl_vader_component.c segments[0].seg_addr.pval = (void *) (hdr + 1); hdr 621 opal/mca/btl/vader/btl_vader_component.c segments[0].seg_len = hdr->len; hdr 623 opal/mca/btl/vader/btl_vader_component.c if (hdr->flags & MCA_BTL_VADER_FLAG_SINGLE_COPY) { hdr 626 opal/mca/btl/vader/btl_vader_component.c xpmem_reg = vader_get_registation (endpoint, hdr->sc_iov.iov_base, hdr 627 opal/mca/btl/vader/btl_vader_component.c hdr->sc_iov.iov_len, 0, hdr 631 opal/mca/btl/vader/btl_vader_component.c segments[1].seg_len = hdr->sc_iov.iov_len; hdr 635 opal/mca/btl/vader/btl_vader_component.c reg->cbfunc(&mca_btl_vader.super, hdr->tag, &frag, reg->cbdata); hdr 638 opal/mca/btl/vader/btl_vader_component.c reg->cbfunc(&mca_btl_vader.super, hdr->tag, &frag, reg->cbdata); hdr 641 opal/mca/btl/vader/btl_vader_component.c if (OPAL_UNLIKELY(MCA_BTL_VADER_FLAG_SETUP_FBOX & hdr->flags)) { hdr 642 opal/mca/btl/vader/btl_vader_component.c mca_btl_vader_endpoint_setup_fbox_recv (endpoint, relative2virtual(hdr->fbox_base)); hdr 646 opal/mca/btl/vader/btl_vader_component.c hdr->flags = MCA_BTL_VADER_FLAG_COMPLETE; hdr 647 opal/mca/btl/vader/btl_vader_component.c vader_fifo_write_back (hdr, endpoint); hdr 653 opal/mca/btl/vader/btl_vader_component.c mca_btl_vader_hdr_t *hdr; hdr 657 opal/mca/btl/vader/btl_vader_component.c hdr = vader_fifo_read (mca_btl_vader_component.my_fifo, &endpoint); hdr 658 opal/mca/btl/vader/btl_vader_component.c if (NULL == hdr) { hdr 662 opal/mca/btl/vader/btl_vader_component.c mca_btl_vader_poll_handle_frag (hdr, endpoint); hdr 687 opal/mca/btl/vader/btl_vader_component.c ret = vader_fifo_write_ep (frag->hdr, ep); hdr 54 opal/mca/btl/vader/btl_vader_fbox.h void mca_btl_vader_poll_handle_frag (mca_btl_vader_hdr_t *hdr, mca_btl_base_endpoint_t *ep); hdr 56 opal/mca/btl/vader/btl_vader_fbox.h static inline void mca_btl_vader_fbox_set_header (mca_btl_vader_fbox_hdr_t *hdr, uint16_t tag, hdr 61 opal/mca/btl/vader/btl_vader_fbox.h hdr->data_i32.value1 = 0; hdr 63 opal/mca/btl/vader/btl_vader_fbox.h hdr->data_i32.value0 = size; hdr 65 opal/mca/btl/vader/btl_vader_fbox.h hdr->data_i32.value1 = tmp.data_i32.value1; hdr 68 opal/mca/btl/vader/btl_vader_fbox.h static inline mca_btl_vader_fbox_hdr_t mca_btl_vader_fbox_read_header (mca_btl_vader_fbox_hdr_t *hdr) hdr 70 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_fbox_hdr_t tmp = {.data_i32 = {.value1 = hdr->data_i32.value1}};; hdr 72 opal/mca/btl/vader/btl_vader_fbox.h tmp.data_i32.value0 = hdr->data_i32.value0; hdr 195 opal/mca/btl/vader/btl_vader_fbox.h const mca_btl_vader_fbox_hdr_t hdr = mca_btl_vader_fbox_read_header (MCA_BTL_VADER_FBOX_HDR(ep->fbox_in.buffer + start)); hdr 198 opal/mca/btl/vader/btl_vader_fbox.h if (0 == hdr.data.tag || hdr.data.seq != ep->fbox_in.seq) { hdr 208 opal/mca/btl/vader/btl_vader_fbox.h ep->peer_smp_rank, hdr.data.tag, hdr.data.size, hdr.data.seq, start)); hdr 211 opal/mca/btl/vader/btl_vader_fbox.h if (OPAL_LIKELY((0xfe & hdr.data.tag) != 0xfe)) { hdr 215 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_base_active_message_trigger + hdr.data.tag; hdr 222 opal/mca/btl/vader/btl_vader_fbox.h segment.seg_len = hdr.data.size; hdr 223 opal/mca/btl/vader/btl_vader_fbox.h segment.seg_addr.pval = (void *) (ep->fbox_in.buffer + start + sizeof (hdr)); hdr 226 opal/mca/btl/vader/btl_vader_fbox.h reg->cbfunc(&mca_btl_vader.super, hdr.data.tag, &desc, reg->cbdata); hdr 227 opal/mca/btl/vader/btl_vader_fbox.h } else if (OPAL_LIKELY(0xfe == hdr.data.tag)) { hdr 229 opal/mca/btl/vader/btl_vader_fbox.h fifo_value_t *value = (fifo_value_t *)(ep->fbox_in.buffer + start + sizeof (hdr)); hdr 230 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_hdr_t *hdr = relative2virtual(*value); hdr 231 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_poll_handle_frag (hdr, ep); hdr 234 opal/mca/btl/vader/btl_vader_fbox.h start = (start + hdr.data.size + sizeof (hdr) + MCA_BTL_VADER_FBOX_ALIGNMENT_MASK) & ~MCA_BTL_VADER_FBOX_ALIGNMENT_MASK; hdr 258 opal/mca/btl/vader/btl_vader_fbox.h static inline void mca_btl_vader_try_fbox_setup (mca_btl_base_endpoint_t *ep, mca_btl_vader_hdr_t *hdr) hdr 273 opal/mca/btl/vader/btl_vader_fbox.h hdr->flags |= MCA_BTL_VADER_FLAG_SETUP_FBOX; hdr 274 opal/mca/btl/vader/btl_vader_fbox.h hdr->fbox_base = virtual2relative((char *) ep->fbox_out.buffer); hdr 119 opal/mca/btl/vader/btl_vader_fifo.h mca_btl_vader_hdr_t *hdr; hdr 131 opal/mca/btl/vader/btl_vader_fifo.h hdr = (mca_btl_vader_hdr_t *) relative2virtual (value); hdr 135 opal/mca/btl/vader/btl_vader_fifo.h assert (hdr->next != value); hdr 137 opal/mca/btl/vader/btl_vader_fifo.h if (OPAL_UNLIKELY(VADER_FIFO_FREE == hdr->next)) { hdr 141 opal/mca/btl/vader/btl_vader_fifo.h while (VADER_FIFO_FREE == hdr->next) { hdr 145 opal/mca/btl/vader/btl_vader_fifo.h fifo->fifo_head = hdr->next; hdr 148 opal/mca/btl/vader/btl_vader_fifo.h fifo->fifo_head = hdr->next; hdr 152 opal/mca/btl/vader/btl_vader_fifo.h return hdr; hdr 177 opal/mca/btl/vader/btl_vader_fifo.h mca_btl_vader_hdr_t *hdr = (mca_btl_vader_hdr_t *) relative2virtual (prev); hdr 178 opal/mca/btl/vader/btl_vader_fifo.h hdr->next = value; hdr 197 opal/mca/btl/vader/btl_vader_fifo.h static inline bool vader_fifo_write_ep (mca_btl_vader_hdr_t *hdr, struct mca_btl_base_endpoint_t *ep) hdr 199 opal/mca/btl/vader/btl_vader_fifo.h fifo_value_t rhdr = virtual2relative ((char *) hdr); hdr 206 opal/mca/btl/vader/btl_vader_fifo.h mca_btl_vader_try_fbox_setup (ep, hdr); hdr 207 opal/mca/btl/vader/btl_vader_fifo.h hdr->next = VADER_FIFO_FREE; hdr 224 opal/mca/btl/vader/btl_vader_fifo.h static inline void vader_fifo_write_back (mca_btl_vader_hdr_t *hdr, struct mca_btl_base_endpoint_t *ep) hdr 226 opal/mca/btl/vader/btl_vader_fifo.h hdr->next = VADER_FIFO_FREE; hdr 227 opal/mca/btl/vader/btl_vader_fifo.h vader_fifo_write(ep->fifo, virtual2relativepeer (ep, (char *) hdr)); hdr 32 opal/mca/btl/vader/btl_vader_frag.c frag->hdr = (mca_btl_vader_hdr_t*)frag->base.super.ptr; hdr 33 opal/mca/btl/vader/btl_vader_frag.c if(frag->hdr != NULL) { hdr 34 opal/mca/btl/vader/btl_vader_frag.c frag->hdr->frag = frag; hdr 35 opal/mca/btl/vader/btl_vader_frag.c frag->hdr->flags = 0; hdr 36 opal/mca/btl/vader/btl_vader_frag.c frag->segments[0].seg_addr.pval = (char *)(frag->hdr + 1); hdr 88 opal/mca/btl/vader/btl_vader_frag.h mca_btl_vader_hdr_t *hdr; hdr 114 opal/mca/btl/vader/btl_vader_frag.h if (frag->hdr) { hdr 115 opal/mca/btl/vader/btl_vader_frag.h frag->hdr->flags = 0; hdr 118 opal/mca/btl/vader/btl_vader_frag.h frag->segments[0].seg_addr.pval = (char *)(frag->hdr + 1); hdr 161 opal/mca/btl/vader/btl_vader_frag.h mca_btl_vader_sc_emu_hdr_t *hdr; hdr 162 opal/mca/btl/vader/btl_vader_frag.h size_t total_size = size + sizeof (*hdr); hdr 177 opal/mca/btl/vader/btl_vader_frag.h hdr = (mca_btl_vader_sc_emu_hdr_t *) frag->segments[0].seg_addr.pval; hdr 179 opal/mca/btl/vader/btl_vader_frag.h hdr->type = type; hdr 180 opal/mca/btl/vader/btl_vader_frag.h hdr->addr = remote_address; hdr 181 opal/mca/btl/vader/btl_vader_frag.h hdr->op = op; hdr 182 opal/mca/btl/vader/btl_vader_frag.h hdr->flags = flags; hdr 183 opal/mca/btl/vader/btl_vader_frag.h hdr->operand[0] = operand1; hdr 184 opal/mca/btl/vader/btl_vader_frag.h hdr->operand[1] = operand2; hdr 163 opal/mca/btl/vader/btl_vader_get.c mca_btl_vader_sc_emu_hdr_t *hdr; hdr 165 opal/mca/btl/vader/btl_vader_get.c size_t len = frag->segments[0].seg_len - sizeof (*hdr); hdr 171 opal/mca/btl/vader/btl_vader_get.c hdr = (mca_btl_vader_sc_emu_hdr_t *) frag->segments[0].seg_addr.pval; hdr 172 opal/mca/btl/vader/btl_vader_get.c data = (void *) (hdr + 1); hdr 511 opal/mca/btl/vader/btl_vader_module.c frag->hdr->flags = MCA_BTL_VADER_FLAG_SINGLE_COPY; hdr 514 opal/mca/btl/vader/btl_vader_module.c frag->hdr->sc_iov.iov_base = data_ptr; hdr 515 opal/mca/btl/vader/btl_vader_module.c frag->hdr->sc_iov.iov_len = *size; hdr 161 opal/mca/btl/vader/btl_vader_put.c mca_btl_vader_sc_emu_hdr_t *hdr; hdr 175 opal/mca/btl/vader/btl_vader_put.c hdr = (mca_btl_vader_sc_emu_hdr_t *) frag->segments[0].seg_addr.pval; hdr 177 opal/mca/btl/vader/btl_vader_put.c memcpy ((void *) (hdr + 1), local_address, size); hdr 95 opal/mca/btl/vader/btl_vader_sc_emu.c mca_btl_vader_sc_emu_hdr_t *hdr = (mca_btl_vader_sc_emu_hdr_t *) desc->des_segments[0].seg_addr.pval; hdr 96 opal/mca/btl/vader/btl_vader_sc_emu.c size_t size = desc->des_segments[0].seg_len - sizeof (*hdr); hdr 97 opal/mca/btl/vader/btl_vader_sc_emu.c void *data = (void *)(hdr + 1); hdr 99 opal/mca/btl/vader/btl_vader_sc_emu.c switch (hdr->type) { hdr 101 opal/mca/btl/vader/btl_vader_sc_emu.c memcpy ((void *) hdr->addr, data, size); hdr 104 opal/mca/btl/vader/btl_vader_sc_emu.c memcpy (data, (void *) hdr->addr, size); hdr 108 opal/mca/btl/vader/btl_vader_sc_emu.c if (!(hdr->flags & MCA_BTL_ATOMIC_FLAG_32BIT)) { hdr 109 opal/mca/btl/vader/btl_vader_sc_emu.c mca_btl_vader_sc_emu_atomic_64 (hdr->operand, (void *) hdr->addr, hdr->op); hdr 112 opal/mca/btl/vader/btl_vader_sc_emu.c int32_t tmp = (int32_t) hdr->operand[0]; hdr 113 opal/mca/btl/vader/btl_vader_sc_emu.c mca_btl_vader_sc_emu_atomic_32 (&tmp, (void *) hdr->addr, hdr->op); hdr 114 opal/mca/btl/vader/btl_vader_sc_emu.c hdr->operand[0] = tmp; hdr 125 opal/mca/btl/vader/btl_vader_sc_emu.c if (!(hdr->flags & MCA_BTL_ATOMIC_FLAG_32BIT)) { hdr 126 opal/mca/btl/vader/btl_vader_sc_emu.c opal_atomic_compare_exchange_strong_64 ((opal_atomic_int64_t *) hdr->addr, &hdr->operand[0], hdr->operand[1]); hdr 129 opal/mca/btl/vader/btl_vader_sc_emu.c opal_atomic_compare_exchange_strong_32 ((opal_atomic_int32_t *) hdr->addr, (int32_t *) &hdr->operand[0], hdr 130 opal/mca/btl/vader/btl_vader_sc_emu.c (int32_t) hdr->operand[1]); hdr 50 opal/mca/btl/vader/btl_vader_send.c frag->hdr->len = total_size; hdr 52 opal/mca/btl/vader/btl_vader_send.c frag->hdr->tag = tag; hdr 55 opal/mca/btl/vader/btl_vader_send.c if (opal_list_get_size (&endpoint->pending_frags) || !vader_fifo_write_ep (frag->hdr, endpoint)) { hdr 72 opal/mca/btl/vader/btl_vader_send.c if ((frag->hdr->flags & MCA_BTL_VADER_FLAG_SINGLE_COPY) || hdr 84 opal/mca/btl/vader/btl_vader_sendi.c frag->hdr->len = length; hdr 85 opal/mca/btl/vader/btl_vader_sendi.c frag->hdr->tag = tag; hdr 107 opal/mca/btl/vader/btl_vader_sendi.c if (!vader_fifo_write_ep (frag->hdr, endpoint)) { hdr 87 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_hdr_t *hdr, hdr 200 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_hdr_t *hdr, hdr 212 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_hdr_t *hdr, hdr 377 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_hdr_t *hdr, hdr 736 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_ptl_hdr_t *hdr, hdr 62 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_ptl_hdr_t *hdr, hdr 342 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_ptl_hdr_t *hdr, hdr 63 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c pmix_ptl_hdr_t *hdr, hdr 251 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_ptl_hdr_t *hdr, hdr 69 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_ptl_hdr_t *hdr, hdr 285 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_ptl_hdr_t *hdr, hdr 110 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_ptl_hdr_t *hdr, hdr 940 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_ptl_hdr_t *hdr, hdr 59 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_ptl_hdr_t *hdr, hdr 63 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_ptl_hdr_t *hdr, hdr 510 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_ptl_hdr_t *hdr, hdr 560 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_ptl_hdr_t *hdr, hdr 61 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_ptl_hdr_t *hdr, hdr 276 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_ptl_hdr_t *hdr, hdr 710 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c pmix_ptl_hdr_t *hdr, hdr 50 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_ptl_hdr_t *hdr, hdr 46 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_ptl_hdr_t *hdr, hdr 203 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_ptl_hdr_t *hdr, hdr 812 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_ptl_hdr_t *hdr, hdr 45 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c pmix_ptl_hdr_t *hdr, hdr 51 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_ptl_hdr_t *hdr, hdr 38 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c pmix_ptl_hdr_t *hdr, hdr 234 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c pmix_ptl_hdr_t *hdr, hdr 93 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c static void notify_event_cbfunc(struct pmix_peer_t *pr, pmix_ptl_hdr_t *hdr, hdr 83 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c static void regevents_cbfunc(struct pmix_peer_t *peer, pmix_ptl_hdr_t *hdr, hdr 337 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_ptl_hdr_t hdr; hdr 347 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_ptl_hdr_t *hdr, hdr 39 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.h pmix_ptl_hdr_t *hdr, hdr 132 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c memset(&p->hdr, 0, sizeof(pmix_ptl_hdr_t)); hdr 133 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c p->hdr.tag = UINT32_MAX; hdr 134 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c p->hdr.nbytes = 0; hdr 153 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c memset(&p->hdr, 0, sizeof(pmix_ptl_hdr_t)); hdr 154 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c p->hdr.tag = UINT32_MAX; hdr 155 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c p->hdr.nbytes = 0; hdr 70 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_hdr_t hdr; hdr 241 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c hdr.nbytes = 0; // initialize the hdr to something safe hdr 245 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c hdr.tag = rcv->tag; hdr 246 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rcv->cbfunc(pmix_globals.mypeer, &hdr, &buf, rcv->cbdata); hdr 267 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c iov[1].iov_len = ntohl(msg->hdr.nbytes); hdr 268 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c remain += ntohl(msg->hdr.nbytes); hdr 324 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->sdbytes = ntohl(msg->hdr.nbytes) - rc; hdr 399 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (NULL == msg) ? UINT_MAX : ntohl(msg->hdr.tag), hdr 406 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c ntohl(msg->hdr.tag)); hdr 469 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_hdr_t hdr; hdr 497 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr; hdr 507 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c ptr = (char*)&hdr; hdr 512 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.pindex = ntohl(hdr.pindex); hdr 513 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.tag = ntohl(hdr.tag); hdr 514 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.nbytes = ntohl(hdr.nbytes); hdr 517 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (int)peer->recv_msg->hdr.tag, hdr 518 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (int)peer->recv_msg->hdr.nbytes); hdr 520 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (0 == peer->recv_msg->hdr.nbytes) { hdr 524 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.tag); hdr 536 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (unsigned long)peer->recv_msg->hdr.nbytes); hdr 538 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (pmix_ptl_globals.max_msg_size < peer->recv_msg->hdr.nbytes) { hdr 540 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (unsigned long)peer->recv_msg->hdr.nbytes, hdr 544 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes); hdr 545 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c memset(peer->recv_msg->data, 0, peer->recv_msg->hdr.nbytes); hdr 548 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes; hdr 576 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (int)peer->recv_msg->hdr.nbytes, hdr 577 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.tag, peer->sd); hdr 657 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.pindex = htonl(pmix_globals.pindex); hdr 658 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.tag = htonl(queue->tag); hdr 659 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.nbytes = htonl((queue->buf)->bytes_used); hdr 662 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdptr = (char*)&snd->hdr; hdr 734 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.pindex = htonl(pmix_globals.pindex); hdr 735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.tag = htonl(tag); hdr 736 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->hdr.nbytes = htonl(ms->bfr->bytes_used); hdr 739 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c snd->sdptr = (char*)&snd->hdr; hdr 772 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (int)msg->hdr.nbytes, msg->hdr.tag, msg->sd); hdr 778 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->hdr.tag, rcv->tag); hdr 780 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (msg->hdr.tag == rcv->tag || UINT_MAX == rcv->tag) { hdr 785 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LOAD_BUFFER(msg->peer, &buf, msg->data, msg->hdr.nbytes); hdr 795 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->hdr.tag); hdr 796 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rcv->cbfunc(msg->peer, &msg->hdr, &buf, rcv->cbdata); hdr 814 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_PTL_TAG_DYNAMIC <= msg->hdr.tag) { hdr 816 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->hdr.tag, msg->peer->info->pname.nspace, hdr 140 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c if (msg->hdr.tag == req->tag || UINT_MAX == req->tag) { hdr 146 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c buf.bytes_allocated = buf.bytes_used = msg->hdr.nbytes; hdr 151 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c req->cbfunc(msg->peer, &msg->hdr, &buf, req->cbdata); hdr 118 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_ptl_hdr_t *hdr, hdr 133 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_ptl_hdr_t hdr; hdr 147 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_ptl_hdr_t hdr; hdr 252 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (void)memcpy(&(c)->hdr, &(h), sizeof(pmix_ptl_hdr_t)); \ hdr 276 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.pindex = htonl(pmix_globals.pindex); \ hdr 277 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.tag = htonl(t); \ hdr 279 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->hdr.nbytes = htonl(nbytes); \ hdr 282 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h snd->sdptr = (char*)&snd->hdr; \ hdr 961 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_ptl_hdr_t hdr; hdr 984 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c memset(&hdr, 0, sizeof(pmix_ptl_hdr_t)); hdr 985 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c hdr.pindex = -1; hdr 986 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c hdr.tag = UINT32_MAX; hdr 1087 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c hdr.nbytes = sdsize + strlen(PMIX_VERSION) + 1 + strlen(sec) + 1 \ hdr 1093 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c sdsize = (sizeof(hdr) + hdr.nbytes); hdr 1104 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c memcpy(msg, &hdr, sizeof(pmix_ptl_hdr_t)); hdr 957 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_hdr_t hdr; hdr 987 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c memset(&hdr, 0, sizeof(pmix_ptl_hdr_t)); hdr 990 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_ptl_hdr_t)))) { hdr 999 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_MAX_CRED_SIZE < hdr.nbytes) { hdr 1004 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (NULL == (msg = (char*)malloc(hdr.nbytes))) { hdr 1009 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes))) { hdr 1020 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c cnt = hdr.nbytes; hdr 279 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_usock_hdr_t hdr; hdr 290 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c memset(&hdr, 0, sizeof(pmix_usock_hdr_t)); hdr 291 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c hdr.pindex = -1; hdr 292 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c hdr.tag = UINT32_MAX; hdr 319 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c hdr.nbytes = sdsize + (strlen(PMIX_VERSION) + 1) + \ hdr 326 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c sdsize = (sizeof(hdr) + hdr.nbytes); hdr 335 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c memcpy(msg, &hdr, sizeof(pmix_usock_hdr_t)); hdr 566 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (NULL == msg) ? UINT_MAX : msg->hdr.tag, hdr 573 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.pindex = ntohl(msg->hdr.pindex); hdr 574 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.tag = ntohl(msg->hdr.tag); hdr 575 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c nbytes = msg->hdr.nbytes; hdr 576 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.nbytes = ntohl(nbytes); hdr 580 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.pindex, msg->hdr.tag, (unsigned long)msg->hdr.nbytes); hdr 595 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->sdbytes = msg->hdr.nbytes; hdr 605 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.pindex = htonl(msg->hdr.pindex); hdr 606 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.tag = htonl(msg->hdr.tag); hdr 607 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c nbytes = msg->hdr.nbytes; hdr 608 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->hdr.nbytes = htonl(nbytes); hdr 718 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr; hdr 732 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (int)peer->recv_msg->hdr.tag, hdr 733 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (int)peer->recv_msg->hdr.nbytes); hdr 735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (0 == peer->recv_msg->hdr.nbytes) { hdr 739 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->hdr.tag); hdr 751 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (unsigned long)peer->recv_msg->hdr.nbytes); hdr 753 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes); hdr 754 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c memset(peer->recv_msg->data, 0, peer->recv_msg->hdr.nbytes); hdr 757 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes; hdr 783 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c (int)peer->recv_msg->hdr.nbytes, hdr 784 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->hdr.tag, peer->sd); hdr 872 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.pindex = pmix_globals.pindex; hdr 873 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.tag = tag; hdr 874 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.nbytes = ms->bfr->bytes_used; hdr 877 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdptr = (char*)&snd->hdr; hdr 923 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.pindex = htonl(pmix_globals.pindex); hdr 924 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.tag = htonl(queue->tag); hdr 925 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->hdr.nbytes = htonl((queue->buf)->bytes_used); hdr 928 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c snd->sdptr = (char*)&snd->hdr; hdr 344 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_usock_hdr_t hdr; hdr 365 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c memset(&hdr, 0, sizeof(pmix_usock_hdr_t)); hdr 368 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_usock_hdr_t)))) { hdr 377 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_MAX_CRED_SIZE < hdr.nbytes) { hdr 382 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (NULL == (msg = (char*)malloc(hdr.nbytes))) { hdr 387 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes)) { hdr 396 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c len = hdr.nbytes; hdr 2083 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_PTL_SEND_ONEWAY(rc, cd->peer, reply, cd->hdr.tag); hdr 2132 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_PTL_SEND_ONEWAY(rc, cd->peer, reply, cd->hdr.tag); hdr 2204 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->cd->peer, cd->cd->hdr.tag, reply); hdr 2267 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2379 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2485 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2641 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2719 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2776 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2803 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2850 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2911 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 2970 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 3029 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 3099 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 3150 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, cd->peer, cd->hdr.tag, reply); hdr 3195 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, scd->peer, scd->hdr.tag, reply); hdr 3549 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_ptl_hdr_t *hdr, hdr 3561 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c ret = server_switchyard(peer, hdr->tag, buf); hdr 3576 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_SERVER_QUEUE_REPLY(rc, peer, hdr->tag, reply); hdr 3691 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_SERVER_QUEUE_REPLY(ret, cd->peer, cd->hdr.tag, reply); hdr 3819 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_SERVER_QUEUE_REPLY(ret, cd->peer, cd->hdr.tag, reply); hdr 214 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h (c)->hdr.tag = (t); \ hdr 358 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_ptl_hdr_t *hdr, hdr 83 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_ptl_hdr_t *hdr, hdr 185 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_ptl_hdr_t *hdr, hdr 229 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_ptl_hdr_t *hdr, hdr 1107 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_ptl_hdr_t *hdr, hdr 254 orte/mca/oob/tcp/oob_tcp.c mca_oob_tcp_hdr_t hdr; hdr 264 orte/mca/oob/tcp/oob_tcp.c if (ORTE_SUCCESS != mca_oob_tcp_peer_recv_connect_ack(NULL, sd, &hdr)) { hdr 269 orte/mca/oob/tcp/oob_tcp.c if (MCA_OOB_TCP_IDENT == hdr.type) { hdr 270 orte/mca/oob/tcp/oob_tcp.c if (NULL == (peer = mca_oob_tcp_peer_lookup(&hdr.origin))) { hdr 294 orte/mca/oob/tcp/oob_tcp.c ORTE_NAME_PRINT(&(hdr.origin)), hdr 1150 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst), hdr 1159 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&(mop->snd->hdr.dst), sizeof(uint64_t)); hdr 1165 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst)); hdr 1175 orte/mca/oob/tcp/oob_tcp_component.c MCA_OOB_TCP_HDR_NTOH(&mop->snd->hdr); hdr 1178 orte/mca/oob/tcp/oob_tcp_component.c snd->dst = mop->snd->hdr.dst; hdr 1179 orte/mca/oob/tcp/oob_tcp_component.c snd->origin = mop->snd->hdr.origin; hdr 1180 orte/mca/oob/tcp/oob_tcp_component.c snd->tag = mop->snd->hdr.tag; hdr 1181 orte/mca/oob/tcp/oob_tcp_component.c snd->seq_num = mop->snd->hdr.seq_num; hdr 1183 orte/mca/oob/tcp/oob_tcp_component.c snd->count = mop->snd->hdr.nbytes; hdr 404 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_hdr_t hdr; hdr 412 orte/mca/oob/tcp/oob_tcp_connection.c hdr.origin = *ORTE_PROC_MY_NAME; hdr 413 orte/mca/oob/tcp/oob_tcp_connection.c hdr.dst = peer->name; hdr 414 orte/mca/oob/tcp/oob_tcp_connection.c hdr.type = MCA_OOB_TCP_IDENT; hdr 415 orte/mca/oob/tcp/oob_tcp_connection.c hdr.tag = 0; hdr 416 orte/mca/oob/tcp/oob_tcp_connection.c hdr.seq_num = 0; hdr 417 orte/mca/oob/tcp/oob_tcp_connection.c memset(hdr.routed, 0, ORTE_MAX_RTD_SIZE+1); hdr 421 orte/mca/oob/tcp/oob_tcp_connection.c hdr.nbytes = sdsize; hdr 422 orte/mca/oob/tcp/oob_tcp_connection.c MCA_OOB_TCP_HDR_HTON(&hdr); hdr 425 orte/mca/oob/tcp/oob_tcp_connection.c sdsize += sizeof(hdr); hdr 432 orte/mca/oob/tcp/oob_tcp_connection.c memcpy(msg + offset, &hdr, sizeof(hdr)); hdr 433 orte/mca/oob/tcp/oob_tcp_connection.c offset += sizeof(hdr); hdr 458 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_hdr_t hdr; hdr 467 orte/mca/oob/tcp/oob_tcp_connection.c hdr.origin = *ORTE_PROC_MY_NAME; hdr 468 orte/mca/oob/tcp/oob_tcp_connection.c hdr.dst = name; hdr 469 orte/mca/oob/tcp/oob_tcp_connection.c hdr.type = MCA_OOB_TCP_IDENT; hdr 470 orte/mca/oob/tcp/oob_tcp_connection.c hdr.tag = 0; hdr 471 orte/mca/oob/tcp/oob_tcp_connection.c hdr.seq_num = 0; hdr 472 orte/mca/oob/tcp/oob_tcp_connection.c memset(hdr.routed, 0, ORTE_MAX_RTD_SIZE+1); hdr 476 orte/mca/oob/tcp/oob_tcp_connection.c hdr.nbytes = sdsize; hdr 477 orte/mca/oob/tcp/oob_tcp_connection.c MCA_OOB_TCP_HDR_HTON(&hdr); hdr 480 orte/mca/oob/tcp/oob_tcp_connection.c sdsize += sizeof(hdr); hdr 487 orte/mca/oob/tcp/oob_tcp_connection.c memcpy(msg + offset, &hdr, sizeof(hdr)); hdr 488 orte/mca/oob/tcp/oob_tcp_connection.c offset += sizeof(hdr); hdr 726 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_hdr_t hdr; hdr 739 orte/mca/oob/tcp/oob_tcp_connection.c if (tcp_peer_recv_blocking(peer, sd, &hdr, sizeof(mca_oob_tcp_hdr_t))) { hdr 768 orte/mca/oob/tcp/oob_tcp_connection.c MCA_OOB_TCP_HDR_NTOH(&hdr); hdr 771 orte/mca/oob/tcp/oob_tcp_connection.c *dhdr = hdr; hdr 774 orte/mca/oob/tcp/oob_tcp_connection.c if (MCA_OOB_TCP_PROBE == hdr.type) { hdr 776 orte/mca/oob/tcp/oob_tcp_connection.c hdr.type = MCA_OOB_TCP_PROBE; hdr 777 orte/mca/oob/tcp/oob_tcp_connection.c hdr.dst = hdr.origin; hdr 778 orte/mca/oob/tcp/oob_tcp_connection.c hdr.origin = *ORTE_PROC_MY_NAME; hdr 779 orte/mca/oob/tcp/oob_tcp_connection.c MCA_OOB_TCP_HDR_HTON(&hdr); hdr 780 orte/mca/oob/tcp/oob_tcp_connection.c tcp_peer_send_blocking(sd, &hdr, sizeof(mca_oob_tcp_hdr_t)); hdr 785 orte/mca/oob/tcp/oob_tcp_connection.c if (hdr.type != MCA_OOB_TCP_IDENT) { hdr 787 orte/mca/oob/tcp/oob_tcp_connection.c hdr.type); hdr 799 orte/mca/oob/tcp/oob_tcp_connection.c peer = mca_oob_tcp_peer_lookup(&hdr.origin); hdr 805 orte/mca/oob/tcp/oob_tcp_connection.c peer->name = hdr.origin; hdr 817 orte/mca/oob/tcp/oob_tcp_connection.c if (OPAL_EQUAL != orte_util_compare_name_fields(ORTE_NS_CMP_ALL, &peer->name, &hdr.origin)) { hdr 821 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&(hdr.origin)), hdr 835 orte/mca/oob/tcp/oob_tcp_connection.c if (NULL == (msg = (char*)malloc(hdr.nbytes))) { hdr 840 orte/mca/oob/tcp/oob_tcp_connection.c if (!tcp_peer_recv_blocking(peer, sd, msg, hdr.nbytes)) { hdr 132 orte/mca/oob/tcp/oob_tcp_sendrecv.c iov[1].iov_len = ntohl(msg->hdr.nbytes); hdr 133 orte/mca/oob/tcp/oob_tcp_sendrecv.c remain += ntohl(msg->hdr.nbytes); hdr 191 orte/mca/oob/tcp/oob_tcp_sendrecv.c msg->sdbytes = ntohl(msg->hdr.nbytes) - rc; hdr 247 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); hdr 256 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); hdr 270 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); hdr 291 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); hdr 499 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->rdptr = (char*)&peer->recv_msg->hdr; hdr 511 orte/mca/oob/tcp/oob_tcp_sendrecv.c MCA_OOB_TCP_HDR_NTOH(&peer->recv_msg->hdr); hdr 513 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (0 == peer->recv_msg->hdr.nbytes) { hdr 517 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(&peer->name), peer->recv_msg->hdr.tag); hdr 522 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), (unsigned long)peer->recv_msg->hdr.nbytes); hdr 524 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->data = (char*)malloc(peer->recv_msg->hdr.nbytes); hdr 527 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->rdbytes = peer->recv_msg->hdr.nbytes; hdr 555 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(&peer->recv_msg->hdr.origin), hdr 556 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)peer->recv_msg->hdr.nbytes, hdr 557 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst), hdr 558 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.tag); hdr 561 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (peer->recv_msg->hdr.dst.jobid == ORTE_PROC_MY_NAME->jobid && hdr 562 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.dst.vpid == ORTE_PROC_MY_NAME->vpid) { hdr 567 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.tag, hdr 568 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.seq_num); hdr 569 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_RML_POST_MESSAGE(&peer->recv_msg->hdr.origin, hdr 570 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.tag, hdr 571 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.seq_num, hdr 573 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->recv_msg->hdr.nbytes); hdr 581 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst)); hdr 583 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->dst = peer->recv_msg->hdr.dst; hdr 584 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->origin = peer->recv_msg->hdr.origin; hdr 585 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->tag = peer->recv_msg->hdr.tag; hdr 587 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->seq_num = peer->recv_msg->hdr.seq_num; hdr 588 orte/mca/oob/tcp/oob_tcp_sendrecv.c snd->count = peer->recv_msg->hdr.nbytes; hdr 628 orte/mca/oob/tcp/oob_tcp_sendrecv.c memset(&ptr->hdr, 0, sizeof(mca_oob_tcp_hdr_t)); hdr 654 orte/mca/oob/tcp/oob_tcp_sendrecv.c memset(&ptr->hdr, 0, sizeof(mca_oob_tcp_hdr_t)); hdr 45 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_hdr_t hdr; hdr 58 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_hdr_t hdr; hdr 107 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.origin = (m)->origin; \ hdr 108 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.dst = (m)->dst; \ hdr 109 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.type = MCA_OOB_TCP_USER; \ hdr 110 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.tag = (m)->tag; \ hdr 111 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.seq_num = (m)->seq_num; \ hdr 116 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = (m)->buffer->bytes_used; \ hdr 118 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = 0; \ hdr 120 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes += (m)->iov[i].iov_len; \ hdr 123 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = (m)->count; \ hdr 126 orte/mca/oob/tcp/oob_tcp_sendrecv.h MCA_OOB_TCP_HDR_HTON(&_s->hdr); \ hdr 128 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->sdptr = (char*)&_s->hdr; \ hdr 151 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.origin = (m)->origin; \ hdr 152 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.dst = (m)->dst; \ hdr 153 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.type = MCA_OOB_TCP_USER; \ hdr 154 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.tag = (m)->tag; \ hdr 155 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.seq_num = (m)->seq_num; \ hdr 160 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = (m)->buffer->bytes_used; \ hdr 162 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = 0; \ hdr 164 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes += (m)->iov[i].iov_len; \ hdr 167 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = (m)->count; \ hdr 170 orte/mca/oob/tcp/oob_tcp_sendrecv.h MCA_OOB_TCP_HDR_HTON(&_s->hdr); \ hdr 172 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->sdptr = (char*)&_s->hdr; \ hdr 194 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.origin = (m)->hdr.origin; \ hdr 195 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.dst = (m)->hdr.dst; \ hdr 196 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.type = MCA_OOB_TCP_USER; \ hdr 197 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.tag = (m)->hdr.tag; \ hdr 198 orte/mca/oob/tcp/oob_tcp_sendrecv.h (void)opal_string_copy(_s->hdr.routed, (m)->hdr.routed, \ hdr 203 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->hdr.nbytes = (m)->hdr.nbytes; \ hdr 205 orte/mca/oob/tcp/oob_tcp_sendrecv.h MCA_OOB_TCP_HDR_HTON(&_s->hdr); \ hdr 207 orte/mca/oob/tcp/oob_tcp_sendrecv.h _s->sdptr = (char*)&_s->hdr; \ hdr 264 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->hdr = proxy->hdr; \ hdr 265 orte/mca/oob/tcp/oob_tcp_sendrecv.h MCA_OOB_TCP_HDR_HTON(&snd->hdr); \ hdr 269 orte/mca/oob/tcp/oob_tcp_sendrecv.h snd->sdptr = (char*)&snd->hdr; \