aggr_data 95 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c static int write_init (ompio_file_t *fh, int aggregator, mca_io_ompio_aggregator_data *aggr_data, int write_chunksize ); aggr_data 134 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c mca_io_ompio_aggregator_data **aggr_data=NULL; aggr_data 217 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data = (mca_io_ompio_aggregator_data **) malloc ( dynamic_gen2_num_io_procs * aggr_data 224 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i] = (mca_io_ompio_aggregator_data *) calloc ( 1, sizeof(mca_io_ompio_aggregator_data)); aggr_data 225 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->procs_per_group = fh->f_procs_per_group; aggr_data 226 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->procs_in_group = fh->f_procs_in_group; aggr_data 227 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->comm = fh->f_comm; aggr_data 228 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->buf = (char *)buf; // should not be used in the new version. aggr_data 366 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->total_bytes = broken_total_lengths[i]; aggr_data 367 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->decoded_iov = broken_decoded_iovs[i]; aggr_data 368 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->fview_count = (int *) malloc (fh->f_procs_per_group * sizeof (int)); aggr_data 369 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->fview_count) { aggr_data 375 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->fview_count[j] = result_counts[dynamic_gen2_num_io_procs*j+i]; aggr_data 385 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c total_fview_count = aggr_data[i]->fview_count[0]; aggr_data 387 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c total_fview_count += aggr_data[i]->fview_count[j]; aggr_data 388 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c displs[j] = displs[j-1] + aggr_data[i]->fview_count[j-1]; aggr_data 398 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->fview_count[j], aggr_data 406 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_iov_array = (struct iovec*) malloc (total_fview_count * aggr_data 408 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->global_iov_array){ aggr_data 422 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_iov_array, aggr_data 423 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->fview_count, aggr_data 433 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_iov_array, aggr_data 434 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->fview_count, aggr_data 459 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->sorted = (int *)malloc (total_fview_count * sizeof(int)); aggr_data 460 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->sorted) { aggr_data 465 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ompi_fcoll_base_sort_iovec (aggr_data[i]->global_iov_array, total_fview_count, aggr_data[i]->sorted); aggr_data 485 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_iov_array[aggr_data[i]->sorted[tv]].iov_base, aggr_data 486 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_iov_array[aggr_data[i]->sorted[tv]].iov_len); aggr_data 495 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->bytes_per_cycle = bytes_per_cycle; aggr_data 498 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->disp_index = (int *)malloc (fh->f_procs_per_group * sizeof (int)); aggr_data 499 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->disp_index) { aggr_data 505 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->max_disp_index = (int *)calloc (fh->f_procs_per_group, sizeof (int)); aggr_data 506 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->max_disp_index) { aggr_data 512 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->blocklen_per_process = (int **)calloc (fh->f_procs_per_group, sizeof (int*)); aggr_data 513 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->blocklen_per_process) { aggr_data 519 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->displs_per_process = (MPI_Aint **)calloc (fh->f_procs_per_group, sizeof (MPI_Aint*)); aggr_data 520 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->displs_per_process) { aggr_data 527 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->global_buf = (char *) malloc (bytes_per_cycle); aggr_data 528 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->prev_global_buf = (char *) malloc (bytes_per_cycle); aggr_data 529 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->global_buf || NULL == aggr_data[i]->prev_global_buf){ aggr_data 535 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->recvtype = (ompi_datatype_t **) malloc (fh->f_procs_per_group * aggr_data 537 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->prev_recvtype = (ompi_datatype_t **) malloc (fh->f_procs_per_group * aggr_data 539 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL == aggr_data[i]->recvtype || NULL == aggr_data[i]->prev_recvtype) { aggr_data 545 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->recvtype[l] = MPI_DATATYPE_NULL; aggr_data 546 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data[i]->prev_recvtype[l] = MPI_DATATYPE_NULL; aggr_data 576 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ret = shuffle_init ( 0, cycles, aggregators[i], fh->f_rank, aggr_data[i], aggr_data 587 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c SWAP_AGGR_POINTERS(aggr_data,dynamic_gen2_num_io_procs); aggr_data 591 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ret = shuffle_init ( index, cycles, aggregators[i], fh->f_rank, aggr_data[i], aggr_data 611 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ret = write_init (fh, aggregators[i], aggr_data[i], write_chunksize ); aggr_data 627 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c SWAP_AGGR_POINTERS(aggr_data,dynamic_gen2_num_io_procs); aggr_data 640 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ret = write_init (fh, aggregators[i], aggr_data[i], write_chunksize ); aggr_data 673 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if ( NULL != aggr_data ) { aggr_data 677 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if (NULL != aggr_data[i]->recvtype){ aggr_data 678 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c for (j =0; j< aggr_data[i]->procs_per_group; j++) { aggr_data 679 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if ( MPI_DATATYPE_NULL != aggr_data[i]->recvtype[j] ) { aggr_data 680 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ompi_datatype_destroy(&aggr_data[i]->recvtype[j]); aggr_data 682 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if ( MPI_DATATYPE_NULL != aggr_data[i]->prev_recvtype[j] ) { aggr_data 683 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c ompi_datatype_destroy(&aggr_data[i]->prev_recvtype[j]); aggr_data 687 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free(aggr_data[i]->recvtype); aggr_data 688 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free(aggr_data[i]->prev_recvtype); aggr_data 691 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->disp_index); aggr_data 692 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->max_disp_index); aggr_data 693 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->global_buf); aggr_data 694 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->prev_global_buf); aggr_data 695 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c for(l=0;l<aggr_data[i]->procs_per_group;l++){ aggr_data 696 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->blocklen_per_process[l]); aggr_data 697 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->displs_per_process[l]); aggr_data 700 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->blocklen_per_process); aggr_data 701 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->displs_per_process); aggr_data 703 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->sorted); aggr_data 704 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->global_iov_array); aggr_data 705 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->fview_count); aggr_data 706 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]->decoded_iov); aggr_data 708 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data[i]); aggr_data 710 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free (aggr_data); aggr_data 738 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c static int write_init (ompio_file_t *fh, int aggregator, mca_io_ompio_aggregator_data *aggr_data, int write_chunksize ) aggr_data 745 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c if ( aggregator == fh->f_rank && aggr_data->prev_num_io_entries) { aggr_data 746 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c while ( aggr_data->prev_bytes_to_write > 0 ) { aggr_data 747 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data->prev_bytes_to_write -= mca_fcoll_dynamic_gen2_split_iov_array (fh, aggr_data->prev_io_array, aggr_data 748 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c aggr_data->prev_num_io_entries, aggr_data 752 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free ( aggr_data->prev_io_array); aggr_data 759 ompi/mca/fcoll/dynamic_gen2/fcoll_dynamic_gen2_file_write_all.c free ( aggr_data->prev_io_array); aggr_data 94 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c static int write_init (ompio_file_t *fh, int aggregator, mca_io_ompio_aggregator_data *aggr_data, aggr_data 137 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c mca_io_ompio_aggregator_data **aggr_data=NULL; aggr_data 205 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data = (mca_io_ompio_aggregator_data **) malloc ( fh->f_num_aggrs * aggr_data 212 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i] = (mca_io_ompio_aggregator_data *) calloc ( 1, sizeof(mca_io_ompio_aggregator_data)); aggr_data 213 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->procs_per_group = fh->f_procs_per_group; aggr_data 214 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->procs_in_group = fh->f_procs_in_group; aggr_data 215 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->comm = fh->f_comm; aggr_data 216 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->buf = (char *)buf; // should not be used in the new version. aggr_data 365 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->total_bytes = broken_total_lengths[i]; aggr_data 366 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->decoded_iov = broken_decoded_iovs[i]; aggr_data 367 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->fview_count = (int *) malloc (fh->f_procs_per_group * sizeof (int)); aggr_data 368 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->fview_count) { aggr_data 374 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->fview_count[j] = result_counts[fh->f_num_aggrs*j+i]; aggr_data 384 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c total_fview_count = aggr_data[i]->fview_count[0]; aggr_data 386 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c total_fview_count += aggr_data[i]->fview_count[j]; aggr_data 387 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c displs[j] = displs[j-1] + aggr_data[i]->fview_count[j-1]; aggr_data 397 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->fview_count[j], aggr_data 405 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_iov_array = (struct iovec*) malloc (total_fview_count * aggr_data 407 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->global_iov_array){ aggr_data 421 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_iov_array, aggr_data 422 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->fview_count, aggr_data 432 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_iov_array, aggr_data 433 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->fview_count, aggr_data 458 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->sorted = (int *)malloc (total_fview_count * sizeof(int)); aggr_data 459 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->sorted) { aggr_data 464 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompi_fcoll_base_sort_iovec (aggr_data[i]->global_iov_array, total_fview_count, aggr_data[i]->sorted); aggr_data 484 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_iov_array[aggr_data[i]->sorted[tv]].iov_base, aggr_data 485 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_iov_array[aggr_data[i]->sorted[tv]].iov_len); aggr_data 494 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->bytes_per_cycle = bytes_per_cycle; aggr_data 497 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->disp_index = (int *)malloc (fh->f_procs_per_group * sizeof (int)); aggr_data 498 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->disp_index) { aggr_data 504 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->max_disp_index = (int *)calloc (fh->f_procs_per_group, sizeof (int)); aggr_data 505 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->max_disp_index) { aggr_data 511 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->blocklen_per_process = (int **)calloc (fh->f_procs_per_group, sizeof (int*)); aggr_data 512 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->blocklen_per_process) { aggr_data 518 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->displs_per_process = (MPI_Aint **)calloc (fh->f_procs_per_group, sizeof (MPI_Aint*)); aggr_data 519 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->displs_per_process) { aggr_data 526 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->global_buf = (char *) malloc (bytes_per_cycle); aggr_data 527 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->prev_global_buf = (char *) malloc (bytes_per_cycle); aggr_data 528 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->global_buf || NULL == aggr_data[i]->prev_global_buf){ aggr_data 534 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->recvtype = (ompi_datatype_t **) malloc (fh->f_procs_per_group * aggr_data 536 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->prev_recvtype = (ompi_datatype_t **) malloc (fh->f_procs_per_group * aggr_data 538 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL == aggr_data[i]->recvtype || NULL == aggr_data[i]->prev_recvtype) { aggr_data 544 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->recvtype[l] = MPI_DATATYPE_NULL; aggr_data 545 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data[i]->prev_recvtype[l] = MPI_DATATYPE_NULL; aggr_data 578 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ret = shuffle_init ( 0, cycles, fh->f_aggr_list[i], fh->f_rank, aggr_data[i], aggr_data 594 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c SWAP_AGGR_POINTERS(aggr_data, fh->f_num_aggrs); aggr_data 600 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ret = write_init (fh, fh->f_aggr_list[aggr_index], aggr_data[aggr_index], aggr_data 612 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ret = shuffle_init ( index, cycles, fh->f_aggr_list[i], fh->f_rank, aggr_data[i], aggr_data 634 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c SWAP_AGGR_POINTERS(aggr_data,fh->f_num_aggrs); aggr_data 640 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ret = write_init (fh, fh->f_aggr_list[aggr_index], aggr_data[aggr_index], aggr_data 680 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if ( NULL != aggr_data ) { aggr_data 684 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (NULL != aggr_data[i]->recvtype){ aggr_data 685 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c for (j =0; j< aggr_data[i]->procs_per_group; j++) { aggr_data 686 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if ( MPI_DATATYPE_NULL != aggr_data[i]->recvtype[j] ) { aggr_data 687 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompi_datatype_destroy(&aggr_data[i]->recvtype[j]); aggr_data 689 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if ( MPI_DATATYPE_NULL != aggr_data[i]->prev_recvtype[j] ) { aggr_data 690 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompi_datatype_destroy(&aggr_data[i]->prev_recvtype[j]); aggr_data 694 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free(aggr_data[i]->recvtype); aggr_data 695 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free(aggr_data[i]->prev_recvtype); aggr_data 698 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->disp_index); aggr_data 699 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->max_disp_index); aggr_data 700 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->global_buf); aggr_data 701 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->prev_global_buf); aggr_data 702 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c for(l=0;l<aggr_data[i]->procs_per_group;l++){ aggr_data 703 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->blocklen_per_process[l]); aggr_data 704 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->displs_per_process[l]); aggr_data 707 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->blocklen_per_process); aggr_data 708 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->displs_per_process); aggr_data 710 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->sorted); aggr_data 711 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->global_iov_array); aggr_data 712 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->fview_count); aggr_data 713 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]->decoded_iov); aggr_data 715 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data[i]); aggr_data 717 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free (aggr_data); aggr_data 742 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c mca_io_ompio_aggregator_data *aggr_data, aggr_data 755 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c if (aggr_data->prev_num_io_entries) { aggr_data 760 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c mca_fcoll_vulcan_split_iov_array (fh, aggr_data->prev_io_array, aggr_data 761 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c aggr_data->prev_num_io_entries, aggr_data 787 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c free(aggr_data->prev_io_array);