acc_data 63 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c static void osc_pt2pt_accumulate_data_constructor (osc_pt2pt_accumulate_data_t *acc_data) acc_data 65 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->source = NULL; acc_data 66 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->datatype = NULL; acc_data 67 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->op = NULL; acc_data 70 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c static void osc_pt2pt_accumulate_data_destructor (osc_pt2pt_accumulate_data_t *acc_data) acc_data 72 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (acc_data->source) { acc_data 74 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c free (acc_data->source); acc_data 77 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (acc_data->datatype) { acc_data 78 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OMPI_DATATYPE_RELEASE(acc_data->datatype); acc_data 623 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c osc_pt2pt_accumulate_data_t *acc_data; acc_data 625 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data = OBJ_NEW(osc_pt2pt_accumulate_data_t); acc_data 626 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (OPAL_UNLIKELY(NULL == acc_data)) { acc_data 630 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->module = module; acc_data 631 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->peer = peer; acc_data 632 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->target = target; acc_data 633 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->source = source; acc_data 634 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->source_len = source_len; acc_data 635 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->proc = proc; acc_data 636 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->count = count; acc_data 637 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->datatype = datatype; acc_data 639 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->op = op; acc_data 640 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c acc_data->request_count = request_count; acc_data 642 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c *acc_data_out = acc_data; acc_data 658 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c struct osc_pt2pt_accumulate_data_t *acc_data = (struct osc_pt2pt_accumulate_data_t *) request->req_complete_cb_data; acc_data 659 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_module_t *module = acc_data->module; acc_data 664 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c "accumulate_cb, request_count = %d", acc_data->request_count)); acc_data 667 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c rank = acc_data->peer; acc_data 670 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (0 == OPAL_THREAD_ADD_FETCH32(&acc_data->request_count, -1)) { acc_data 673 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (acc_data->source) { acc_data 677 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c assert (NULL != acc_data->target && NULL != acc_data->source); acc_data 679 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_base_get_primitive_type_info(acc_data->datatype, &primitive_datatype, &primitive_count); acc_data 680 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c primitive_count *= acc_data->count; acc_data 682 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (acc_data->op == &ompi_mpi_op_replace.op) { acc_data 683 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ret = ompi_datatype_sndrcv(acc_data->source, primitive_count, primitive_datatype, acc_data->target, acc_data->count, acc_data->datatype); acc_data 685 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ret = ompi_osc_base_process_op(acc_data->target, acc_data->source, acc_data->source_len, acc_data->datatype, acc_data->count, acc_data->op); acc_data 692 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c osc_pt2pt_gc_add_buffer (module, &acc_data->super); acc_data 829 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c struct osc_pt2pt_accumulate_data_t *acc_data; acc_data 871 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c datatype, op, 1, &acc_data); acc_data 879 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c NULL, accumulate_cb, acc_data); acc_data 881 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OBJ_RELEASE(acc_data); acc_data 913 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c struct osc_pt2pt_accumulate_data_t *acc_data; acc_data 922 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c datatype, op, 1, &acc_data); acc_data 929 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c accumulate_cb, acc_data); acc_data 931 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OBJ_RELEASE(acc_data); acc_data 961 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c struct osc_pt2pt_accumulate_data_t *acc_data; acc_data 991 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c datatype, op, 2, &acc_data); acc_data 999 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c &recv_request, accumulate_cb, acc_data); acc_data 1001 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OBJ_RELEASE(acc_data); acc_data 1007 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c accumulate_cb, acc_data); acc_data 1011 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OBJ_RELEASE(acc_data);