blob 119 opal/mca/pmix/base/pmix_base_frame.c p->blob = NULL; blob 124 opal/mca/pmix/base/pmix_base_frame.c if (NULL != p->blob) { blob 125 opal/mca/pmix/base/pmix_base_frame.c free(p->blob); blob 426 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/copy.c (*dest)->blob = NULL; blob 428 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/copy.c if (NULL != src->blob) { blob 429 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/copy.c (*dest)->blob = (uint8_t*)malloc(src->size * sizeof(uint8_t)); blob 430 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/copy.c if (NULL == (*dest)->blob) { blob 433 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/copy.c memcpy((*dest)->blob, src->blob, src->size * sizeof(uint8_t)); blob 54 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/internal.h uint8_t *blob; blob 77 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/internal.h if (NULL != (m)->blob) { \ blob 78 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/internal.h free((m)->blob); \ blob 79 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/internal.h (m)->blob = NULL; \ blob 854 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/pack.c if (PMIX_SUCCESS != (ret = pmix12_bfrop_pack_byte(regtypes, buffer, ptr[i].blob, ptr[i].size, PMIX_UINT8))) { blob 1073 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/unpack.c ptr[i].blob = (uint8_t*)malloc(ptr[i].size * sizeof(uint8_t)); blob 1075 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v12/unpack.c if (PMIX_SUCCESS != (ret = pmix12_bfrop_unpack_byte(regtypes, buffer, ptr[i].blob, &m, PMIX_UINT8))) { blob 733 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL != sm[n].blob && 0 < sm[n].size) { blob 734 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pm[n].blob = (uint8_t*)malloc(sm[n].size); blob 735 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL == pm[n].blob) { blob 738 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c memcpy(pm[n].blob, sm[n].blob, sm[n].size); blob 741 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pm[n].blob = NULL; blob 958 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c (*dest)->blob = NULL; blob 960 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL != src->blob) { blob 961 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c (*dest)->blob = (uint8_t*)malloc(src->size * sizeof(uint8_t)); blob 962 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL == (*dest)->blob) { blob 965 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c memcpy((*dest)->blob, src->blob, src->size * sizeof(uint8_t)); blob 1344 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL != sm[n].blob && 0 < sm[n].size) { blob 1345 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pm[n].blob = (uint8_t*)malloc(sm[n].size); blob 1346 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c if (NULL == pm[n].blob) { blob 1351 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c memcpy(pm[n].blob, sm[n].blob, sm[n].size); blob 1354 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pm[n].blob = NULL; blob 55 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/internal.h uint8_t *blob; blob 78 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/internal.h if (NULL != (m)->blob) { \ blob 79 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/internal.h free((m)->blob); \ blob 80 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/internal.h (m)->blob = NULL; \ blob 882 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/pack.c if (PMIX_SUCCESS != (ret = pmix20_bfrop_pack_byte(regtypes, buffer, ptr[i].blob, ptr[i].size, PMIX_UINT8))) { blob 1113 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/unpack.c ptr[i].blob = (uint8_t*)malloc(ptr[i].size * sizeof(uint8_t)); blob 1115 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/unpack.c if (PMIX_SUCCESS != (ret = pmix20_bfrop_unpack_byte(regtypes, buffer, ptr[i].blob, &m, PMIX_UINT8))) { blob 76 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c uint8_t *blob; blob 529 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c if (PMIX_SUCCESS != (ret = pmix_bfrops_base_pack_byte(regtypes, buffer, ptr[i].blob, ptr[i].size, PMIX_UINT8))) { blob 598 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c ptr[i].blob = (uint8_t*)malloc(ptr[i].size * sizeof(uint8_t)); blob 600 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c if (PMIX_SUCCESS != (ret = pmix_bfrops_base_unpack_byte(regtypes, buffer, ptr[i].blob, &m, PMIX_UINT8))) { blob 633 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c (*dest)->blob = NULL; blob 635 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c if (NULL != src->blob) { blob 636 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c (*dest)->blob = (uint8_t*)malloc(src->size * sizeof(uint8_t)); blob 637 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c if (NULL == (*dest)->blob) { blob 640 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v21/bfrop_pmix21.c memcpy((*dest)->blob, src->blob, src->size * sizeof(uint8_t)); blob 76 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c uint8_t *blob; blob 545 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c if (PMIX_SUCCESS != (ret = pmix_bfrops_base_pack_byte(regtypes, buffer, ptr[i].blob, ptr[i].size, PMIX_UINT8))) { blob 613 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c ptr[i].blob = (uint8_t*)malloc(ptr[i].size * sizeof(uint8_t)); blob 615 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c if (PMIX_SUCCESS != (ret = pmix_bfrops_base_unpack_byte(regtypes, buffer, ptr[i].blob, &m, PMIX_UINT8))) { blob 649 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c (*dest)->blob = NULL; blob 651 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c if (NULL != src->blob) { blob 652 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c (*dest)->blob = (uint8_t*)malloc(src->size * sizeof(uint8_t)); blob 653 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c if (NULL == (*dest)->blob) { blob 656 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v3/bfrop_pmix3.c memcpy((*dest)->blob, src->blob, src->size * sizeof(uint8_t)); blob 597 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_value_t *val, blob; blob 669 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c kv.value = &blob; blob 670 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c blob.type = PMIX_BYTE_OBJECT; blob 671 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c PMIX_UNLOAD_BUFFER(&buf, blob.data.bo.bytes, blob.data.bo.size); blob 673 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c PMIX_VALUE_DESTRUCT(&blob); blob 536 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rank_blob_t *blob; blob 696 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c blob = PMIX_NEW(rank_blob_t); blob 697 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c blob->buf = pbkt; blob 698 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&rank_blobs, &blob->super); blob 730 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(blob, &rank_blobs, rank_blob_t) { blob 732 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_UNLOAD_BUFFER(blob->buf, bo.bytes, bo.size); blob 646 opal/mca/pmix/pmix_types.h uint8_t *blob; blob 142 orte/mca/rml/base/rml_base_frame.c orte_rml_recv_cb_t *blob = (orte_rml_recv_cb_t*)cbdata; blob 144 orte/mca/rml/base/rml_base_frame.c ORTE_ACQUIRE_OBJECT(blob); blob 146 orte/mca/rml/base/rml_base_frame.c blob->name.jobid = sender->jobid; blob 147 orte/mca/rml/base/rml_base_frame.c blob->name.vpid = sender->vpid; blob 149 orte/mca/rml/base/rml_base_frame.c opal_dss.copy_payload(&blob->data, buffer); blob 151 orte/mca/rml/base/rml_base_frame.c ORTE_POST_OBJECT(blob); blob 152 orte/mca/rml/base/rml_base_frame.c blob->active = false; blob 3116 orte/orted/orted_submit.c opal_buffer_t *blob; blob 3125 orte/orted/orted_submit.c while (OPAL_SUCCESS == opal_dss.unpack(buffer, &blob, &cnt, OPAL_BUFFER)) { blob 3128 orte/orted/orted_submit.c if (OPAL_SUCCESS != opal_dss.unpack(blob, &name, &cnt, ORTE_NAME) || blob 3129 orte/orted/orted_submit.c OPAL_SUCCESS != opal_dss.unpack(blob, &hostname, &cnt, OPAL_STRING) || blob 3130 orte/orted/orted_submit.c OPAL_SUCCESS != opal_dss.unpack(blob, &pid, &cnt, OPAL_PID)) { blob 3131 orte/orted/orted_submit.c OBJ_RELEASE(blob); blob 3138 orte/orted/orted_submit.c while (OPAL_SUCCESS == opal_dss.unpack(blob, &st, &cnt, OPAL_STRING)) { blob 3144 orte/orted/orted_submit.c OBJ_RELEASE(blob); blob 46 orte/test/system/ofi_big_msg.c orte_rml_recv_cb_t blob; blob 86 orte/test/system/ofi_big_msg.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 87 orte/test/system/ofi_big_msg.c blob.active = true; blob 90 orte/test/system/ofi_big_msg.c orte_rml_recv_callback, &blob); blob 91 orte/test/system/ofi_big_msg.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 92 orte/test/system/ofi_big_msg.c OBJ_DESTRUCT(&blob); blob 97 orte/test/system/ofi_big_msg.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 98 orte/test/system/ofi_big_msg.c blob.active = true; blob 101 orte/test/system/ofi_big_msg.c orte_rml_recv_callback, &blob); blob 102 orte/test/system/ofi_big_msg.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 104 orte/test/system/ofi_big_msg.c opal_output(0, "%s received message %d from %s", ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), j, ORTE_NAME_PRINT(&blob.name)); blob 108 orte/test/system/ofi_big_msg.c opal_dss.copy_payload(buf, &blob.data); blob 109 orte/test/system/ofi_big_msg.c OBJ_DESTRUCT(&blob); blob 48 orte/test/system/ofi_conduit_stress.c orte_rml_recv_cb_t blob; blob 108 orte/test/system/ofi_conduit_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 109 orte/test/system/ofi_conduit_stress.c blob.active = true; blob 112 orte/test/system/ofi_conduit_stress.c orte_rml_recv_callback, &blob); blob 113 orte/test/system/ofi_conduit_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 114 orte/test/system/ofi_conduit_stress.c OBJ_DESTRUCT(&blob); blob 119 orte/test/system/ofi_conduit_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 120 orte/test/system/ofi_conduit_stress.c blob.active = true; blob 123 orte/test/system/ofi_conduit_stress.c orte_rml_recv_callback, &blob); blob 124 orte/test/system/ofi_conduit_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 126 orte/test/system/ofi_conduit_stress.c opal_output(0, "%s received message %d from %s", ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), j, ORTE_NAME_PRINT(&blob.name)); blob 130 orte/test/system/ofi_conduit_stress.c opal_dss.copy_payload(buf, &blob.data); blob 131 orte/test/system/ofi_conduit_stress.c OBJ_DESTRUCT(&blob); blob 107 orte/test/system/ofi_query_test.c orte_rml_recv_cb_t blob; blob 47 orte/test/system/ofi_stress.c orte_rml_recv_cb_t blob; blob 86 orte/test/system/ofi_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 87 orte/test/system/ofi_stress.c blob.active = true; blob 90 orte/test/system/ofi_stress.c orte_rml_recv_callback, &blob); blob 91 orte/test/system/ofi_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 92 orte/test/system/ofi_stress.c OBJ_DESTRUCT(&blob); blob 97 orte/test/system/ofi_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 98 orte/test/system/ofi_stress.c blob.active = true; blob 101 orte/test/system/ofi_stress.c orte_rml_recv_callback, &blob); blob 102 orte/test/system/ofi_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 104 orte/test/system/ofi_stress.c opal_output(0, "%s received message %d from %s", ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), j, ORTE_NAME_PRINT(&blob.name)); blob 108 orte/test/system/ofi_stress.c opal_dss.copy_payload(buf, &blob.data); blob 109 orte/test/system/ofi_stress.c OBJ_DESTRUCT(&blob); blob 47 orte/test/system/oob_stress.c orte_rml_recv_cb_t blob; blob 85 orte/test/system/oob_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 86 orte/test/system/oob_stress.c blob.active = true; blob 89 orte/test/system/oob_stress.c orte_rml_recv_callback, &blob); blob 90 orte/test/system/oob_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 91 orte/test/system/oob_stress.c OBJ_DESTRUCT(&blob); blob 96 orte/test/system/oob_stress.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 97 orte/test/system/oob_stress.c blob.active = true; blob 100 orte/test/system/oob_stress.c orte_rml_recv_callback, &blob); blob 101 orte/test/system/oob_stress.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 105 orte/test/system/oob_stress.c opal_dss.copy_payload(buf, &blob.data); blob 106 orte/test/system/oob_stress.c OBJ_DESTRUCT(&blob); blob 111 orte/test/system/oob_stress_channel.c orte_rml_recv_cb_t blob; blob 187 orte/test/system/oob_stress_channel.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 188 orte/test/system/oob_stress_channel.c blob.active = true; blob 191 orte/test/system/oob_stress_channel.c orte_rml_recv_callback, &blob); blob 192 orte/test/system/oob_stress_channel.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 193 orte/test/system/oob_stress_channel.c OBJ_DESTRUCT(&blob); blob 204 orte/test/system/oob_stress_channel.c OBJ_CONSTRUCT(&blob, orte_rml_recv_cb_t); blob 205 orte/test/system/oob_stress_channel.c blob.active = true; blob 208 orte/test/system/oob_stress_channel.c orte_rml_recv_callback, &blob); blob 209 orte/test/system/oob_stress_channel.c ORTE_WAIT_FOR_COMPLETION(blob.active); blob 211 orte/test/system/oob_stress_channel.c ORTE_NAME_PRINT(&blob.name)); blob 214 orte/test/system/oob_stress_channel.c opal_dss.copy_payload(buf, &blob.data); blob 215 orte/test/system/oob_stress_channel.c OBJ_DESTRUCT(&blob);