/dports/benchmarks/imb/IMB_3.0/src/ |
H A D | IMB_init_file.c | 158 MPI_Type_size(c_info->etype,&c_info->e_size); in IMB_init_file() 159 c_info->filetype = c_info->etype; in IMB_init_file() 180 if( c_info->rank > c_info->all_io_procs-1 || c_info->rank < 0 ) in IMB_init_file() 202 sprintf(c_info->filename,"%s_g%d_%d",FILENAME,c_info->group_no,c_info->w_rank); in IMB_init_file() 222 c_info->File_comm = c_info->communicator; in IMB_init_file() 224 c_info->File_rank = c_info->rank; in IMB_init_file() 266 c_info->amode, c_info->info, &c_info->fh); in IMB_init_file() 270 c_info->etype,c_info->etype,c_info->datarep,c_info->info); in IMB_init_file() 410 c_info->amode, c_info->info, &c_info->fh); in IMB_open_file() 413 ierr = MPI_File_set_view(c_info->fh, c_info->disp, c_info->etype, in IMB_open_file() [all …]
|
H A D | IMB_init.c | 274 if(ierr<3 || c_info->px*c_info->py < c_info->w_num_procs) in IMB_basic_input() 556 fprintf(dbgf,"px py = %d %d\n",c_info->px,c_info->py); in IMB_basic_input() 678 c_info->pair1 = c_info ->num_procs-1; in IMB_init_communicator() 691 c_info->g_sizes[0] = c_info->w_num_procs; in IMB_init_communicator() 721 c_info->g_sizes[c_info->n_groups-1] = c_info->num_procs; in IMB_init_communicator() 750 &c_info->g_sizes[c_info->n_groups-1]); in IMB_init_communicator() 751 aux_ptr += c_info->g_sizes[c_info->n_groups-1]; in IMB_init_communicator() 814 if( c_info->px>1 && c_info->py>1 ) in IMB_set_communicator() 819 if(i+j*c_info->px<c_info->w_num_procs) in IMB_set_communicator() 840 if(map[c_info->w_rank] < c_info->NP) color=0; in IMB_set_communicator() [all …]
|
H A D | IMB_mem_manager.c | 225 c_info->s_data = (assign_type*)c_info->s_buffer; in IMB_alloc_buf() 243 c_info->r_data = (assign_type*)c_info->r_buffer; in IMB_alloc_buf() 489 c_info -> s_buffer = c_info -> r_buffer = NULL; in IMB_init_pointers() 490 c_info -> s_data = c_info -> r_data = NULL; in IMB_init_pointers() 491 c_info -> s_alloc = c_info -> r_alloc = 0; in IMB_init_pointers() 499 IMB_i_alloc(&c_info->sndcnt,c_info->w_num_procs,"Init_Pointers 3"); in IMB_init_pointers() 500 IMB_i_alloc(&c_info->sdispl,c_info->w_num_procs,"Init_Pointers 4"); in IMB_init_pointers() 502 IMB_i_alloc(&c_info->reccnt,c_info->w_num_procs,"Init_Pointers 5"); in IMB_init_pointers() 503 IMB_i_alloc(&c_info->rdispl,c_info->w_num_procs,"Init_Pointers 6"); in IMB_init_pointers() 506 c_info->filename = c_info->datarep = (char*)NULL; in IMB_init_pointers() [all …]
|
H A D | IMB_read.c | 411 (c_info->fh, Offset, c_info->r_buffer,Locsize,c_info->etype,&stat); in IMB_read_ij() 431 (c_info->fh,c_info->r_buffer,Locsize,c_info->etype,&stat); in IMB_read_ij() 514 (c_info->fh,c_info->r_buffer,Locsize,c_info->etype); in IMB_iread_ij() 521 (c_info->fh,c_info->r_buffer,&stat); in IMB_iread_ij() 541 (c_info->fh,Offset,c_info->r_buffer,Locsize,c_info->etype); in IMB_iread_ij() 549 (c_info->fh,c_info->r_buffer,&stat); in IMB_iread_ij() 567 (c_info->fh,c_info->r_buffer,Locsize,c_info->etype); in IMB_iread_ij() 575 (c_info->fh,c_info->r_buffer,&stat); in IMB_iread_ij() 627 (c_info->fh,c_info->r_buffer,Locsize,c_info->etype,&REQUESTS[j]); in IMB_iread_ij() 653 (c_info->fh,Offset,c_info->r_buffer,Locsize,c_info->etype,&REQUESTS[j]); in IMB_iread_ij() [all …]
|
H A D | IMB_ones_unidir.c | 140 if (c_info->rank == c_info->pair0) in IMB_unidir_put() 145 else if (c_info->rank == c_info->pair1) in IMB_unidir_put() 223 if (c_info->rank == c_info->pair0) in IMB_unidir_get() 228 else if (c_info->rank == c_info->pair1) in IMB_unidir_get() 347 ierr = MPI_Get(c_info->r_buffer, r_num, c_info->r_data_type, in IMB_ones_get() 353 DIAGNOSTICS("MPI_Get: ",c_info,c_info->r_buffer,r_num,r_num,i,0); in IMB_ones_get() 355 CHK_DIFF("MPI_Get",c_info, c_info->r_buffer, i*r_num, in IMB_ones_get() 461 CHK_DIFF("MPI_Get",c_info, c_info->r_buffer, 0, in IMB_ones_mget() 557 ierr = MPI_Put(c_info->s_buffer, s_num, c_info->s_data_type, in IMB_ones_put() 575 DIAGNOSTICS("MPI_Put: ",c_info,c_info->r_buffer,r_num,r_num,i,0); in IMB_ones_put() [all …]
|
H A D | IMB_write.c | 342 ierr=GEN_File_write(c_info->fh,c_info->s_buffer,Locsize,c_info->etype,&stat); in IMB_write_ij() 356 (c_info->fh, Offset, c_info->s_buffer,Locsize,c_info->etype,&stat); in IMB_write_ij() 368 (c_info->fh,c_info->s_buffer,Locsize,c_info->etype,&stat); in IMB_write_ij() 455 (c_info->fh,c_info->s_buffer,Locsize,c_info->etype); in IMB_iwrite_ij() 463 (c_info->fh,c_info->s_buffer,&stat); in IMB_iwrite_ij() 476 (c_info->fh,Offset,c_info->s_buffer,Locsize,c_info->etype); in IMB_iwrite_ij() 485 (c_info->fh,c_info->s_buffer,&stat); in IMB_iwrite_ij() 497 (c_info->fh,c_info->s_buffer,Locsize,c_info->etype); in IMB_iwrite_ij() 506 (c_info->fh,c_info->s_buffer,&stat); in IMB_iwrite_ij() 566 (c_info->fh,Offset,c_info->s_buffer,Locsize,c_info->etype,&REQUESTS[j]); in IMB_iwrite_ij() [all …]
|
H A D | IMB_init_transfer.c | 128 IMB_get_rank_portion(c_info->File_rank, c_info->all_io_procs, size, asize, in IMB_init_transfer() 143 IMB_set_buf(c_info, c_info->File_rank, 0, baslen-1, 1, 0); in IMB_init_transfer() 145 IMB_set_buf(c_info, c_info->File_rank, 1, 0, 0, baslen-1); in IMB_init_transfer() 175 c_info->filetype = c_info->view; in IMB_init_transfer() 179 else c_info->filetype = c_info->etype; in IMB_init_transfer() 185 IMB_set_buf(c_info, c_info->File_rank, 0, baslen-1, 1, 0 ); in IMB_init_transfer() 188 IMB_set_buf(c_info, c_info->File_rank, 1, 0, 0, baslen-1 ); in IMB_init_transfer() 227 ierr = MPI_Win_create(c_info->r_buffer,sz,r_size,c_info->info, in IMB_init_transfer() 228 c_info->communicator, &c_info->WIN); in IMB_init_transfer() 235 ierr = MPI_Win_create(c_info->s_buffer,sz,s_size,c_info->info, in IMB_init_transfer() [all …]
|
H A D | IMB_exchange.c | 143 if(c_info->rank < c_info->num_procs-1) right = c_info->rank+1; in IMB_exchange() 144 if(c_info->rank > 0) left = c_info->rank-1; in IMB_exchange() 146 if(c_info->rank == c_info->num_procs-1) right = 0; in IMB_exchange() 147 if(c_info->rank == 0) left = c_info->num_procs-1 ; in IMB_exchange() 149 if((c_info->rank >= 0) && (c_info->rank <= c_info->num_procs-1)) in IMB_exchange() 156 ierr= MPI_Isend(c_info->s_buffer,s_num,c_info->s_data_type, in IMB_exchange() 159 ierr= MPI_Isend(c_info->s_buffer,s_num,c_info->s_data_type, in IMB_exchange() 163 ierr= MPI_Recv( c_info->r_buffer,r_num,c_info->r_data_type, in IMB_exchange() 167 CHK_DIFF("Exchange",c_info, c_info->r_buffer, 0, in IMB_exchange() 172 ierr= MPI_Recv( c_info->r_buffer,r_num,c_info->r_data_type, in IMB_exchange() [all …]
|
H A D | IMB_prototypes.h | 200 void IMB_set_default(struct comm_info* c_info); 231 void IMB_free_file(struct comm_info * c_info); 233 void IMB_del_file(struct comm_info* c_info); 235 int IMB_open_file(struct comm_info* c_info); 264 void IMB_end_msg(struct comm_info* c_info ); 279 void IMB_show_procids(struct comm_info* c_info); 319 void IMB_del_s_buf(struct comm_info* c_info ); 321 void IMB_del_r_buf(struct comm_info* c_info ); 343 void IMB_init_errhand(struct comm_info* c_info); 345 void IMB_set_errhand(struct comm_info* c_info); [all …]
|
H A D | IMB_pingpong.c | 143 if (c_info->rank == c_info->pair0) in IMB_pingpong() 146 dest = c_info->pair1; in IMB_pingpong() 154 ierr = MPI_Send(c_info->s_buffer,s_num,c_info->s_data_type,dest, in IMB_pingpong() 157 ierr = MPI_Recv(c_info->r_buffer,r_num,c_info->r_data_type,source, in IMB_pingpong() 161 CHK_DIFF("PingPong",c_info, c_info->r_buffer, 0, in IMB_pingpong() 170 else if (c_info->rank == c_info->pair1) in IMB_pingpong() 172 dest =c_info->pair0 ; in IMB_pingpong() 180 ierr= MPI_Recv(c_info->r_buffer,r_num,c_info->r_data_type,source, in IMB_pingpong() 183 ierr= MPI_Send(c_info->s_buffer,s_num,c_info->s_data_type,dest, in IMB_pingpong() 184 s_tag,c_info->communicator); in IMB_pingpong() [all …]
|
H A D | IMB_alltoallv.c | 127 MPI_Type_size(c_info->s_data_type,&s_size); in IMB_alltoallv() 137 for (i=0;i<c_info->num_procs ;i++) in IMB_alltoallv() 139 c_info->sdispl[i] = s_num*i; in IMB_alltoallv() 140 c_info->sndcnt[i] = s_num; in IMB_alltoallv() 141 c_info->rdispl[i] = r_num*i; in IMB_alltoallv() 142 c_info->reccnt[i] = r_num; in IMB_alltoallv() 147 if(c_info->rank!=-1) in IMB_alltoallv() 154 ierr = MPI_Alltoallv(c_info->s_buffer,c_info->sndcnt,c_info->sdispl, in IMB_alltoallv() 156 c_info->r_buffer,c_info->reccnt,c_info->rdispl, in IMB_alltoallv() 158 c_info->communicator); in IMB_alltoallv() [all …]
|
H A D | IMB_ones_accu.c | 139 root = (c_info-> rank == 0); in IMB_accumulate() 142 if( c_info-> rank < 0 ) in IMB_accumulate() 156 (c_info->s_buffer, s_num, c_info->red_data_type, in IMB_accumulate() 157 0, i*s_num, s_num, c_info->red_data_type, c_info->op_type, in IMB_accumulate() 158 c_info->WIN ); in IMB_accumulate() 166 CHK_DIFF("Accumulate",c_info, (void*)(c_info->r_data+i*s_num), 0, in IMB_accumulate() 172 MPI_Barrier(c_info->communicator); in IMB_accumulate() 191 ((void*)(c_info->s_data+i*s_num), s_num, c_info->red_data_type, in IMB_accumulate() 192 0, i*s_num, s_num, c_info->red_data_type, c_info->op_type, in IMB_accumulate() 193 c_info->WIN ); in IMB_accumulate() [all …]
|
H A D | IMB_ones_bidir.c | 135 if (c_info->rank == c_info->pair0) in IMB_bidir_get() 137 dest = c_info->pair1; in IMB_bidir_get() 139 else if (c_info->rank == c_info->pair1) in IMB_bidir_get() 141 dest =c_info->pair0 ; in IMB_bidir_get() 147 IMB_ones_get( c_info, in IMB_bidir_get() 153 IMB_ones_mget( c_info, in IMB_bidir_get() 217 if (c_info->rank == c_info->pair0) in IMB_bidir_put() 219 dest = c_info->pair1; in IMB_bidir_put() 221 else if (c_info->rank == c_info->pair1) in IMB_bidir_put() 223 dest =c_info->pair0 ; in IMB_bidir_put() [all …]
|
H A D | IMB_allgatherv.c | 127 MPI_Type_size(c_info->s_data_type,&s_size); in hyperfine_raw_command() 128 MPI_Type_size(c_info->r_data_type,&r_size); in hyperfine_raw_command() 137 for (i=0;i<c_info->num_procs ;i++) in hyperfine_raw_command() 139 c_info->rdispl[i] = r_num*i; in hyperfine_raw_command() 140 c_info->reccnt[i] = r_num; in hyperfine_raw_command() 145 if(c_info->rank!=-1) in hyperfine_raw_command() 152 ierr = MPI_Allgatherv(c_info->s_buffer,s_num,c_info->s_data_type, in hyperfine_raw_command() 153 c_info->r_buffer,c_info->reccnt,c_info->rdispl, in hyperfine_raw_command() 155 c_info->communicator); in hyperfine_raw_command() 157 CHK_DIFF("Allgatherv",c_info, c_info->r_buffer, 0, in hyperfine_raw_command() [all …]
|
H A D | IMB_pingping.c | 132 MPI_Type_size(c_info->s_data_type,&s_size); in IMB_pingping() 144 if (c_info->rank == c_info->pair0) in IMB_pingping() 145 dest = c_info->pair1; in IMB_pingping() 146 else if (c_info->rank == c_info->pair1) in IMB_pingping() 147 dest = c_info->pair0; in IMB_pingping() 158 ierr= MPI_Isend(c_info->s_buffer,s_num, in IMB_pingping() 159 c_info->s_data_type,dest,s_tag, in IMB_pingping() 160 c_info->communicator,&request); in IMB_pingping() 162 ierr = MPI_Recv(c_info->r_buffer,r_num,c_info->r_data_type,source, in IMB_pingping() 163 r_tag,c_info->communicator,&stat); in IMB_pingping() [all …]
|
H A D | IMB_err_handler.c | 269 void IMB_set_errhand(struct comm_info* c_info) in IMB_set_errhand() argument 291 if( c_info->communicator != MPI_COMM_NULL ) in IMB_set_errhand() 292 MPI_Errhandler_set(c_info->communicator, c_info->ERR); in IMB_set_errhand() 295 if( c_info->WIN != MPI_WIN_NULL ) in IMB_set_errhand() 296 MPI_Win_set_errhandler(c_info->WIN, c_info->ERRW); in IMB_set_errhand() 300 if( c_info->fh != MPI_FILE_NULL ) in IMB_set_errhand() 301 MPI_File_set_errhandler(c_info->fh, c_info->ERRF); in IMB_set_errhand() 310 void IMB_del_errhand(struct comm_info* c_info) in IMB_del_errhand() argument 331 MPI_Errhandler_free(&c_info->ERR); in IMB_del_errhand() 334 MPI_Errhandler_free(&c_info->ERRW); in IMB_del_errhand() [all …]
|
H A D | IMB_reduce_scatter.c | 131 MPI_Type_size(c_info->red_data_type,&s_size); in IMB_reduce_scatter() 133 for (i=0;i<c_info->num_procs ;i++) in IMB_reduce_scatter() 135 IMB_get_rank_portion(i, c_info->num_procs, size, s_size, in IMB_reduce_scatter() 137 c_info->reccnt[i] = (pos2-pos1+1)/s_size; in IMB_reduce_scatter() 139 if( i==c_info->rank ) {pos=pos1; Locsize= s_size*c_info->reccnt[i];} in IMB_reduce_scatter() 143 if(c_info->rank!=-1) in IMB_reduce_scatter() 151 (c_info->s_buffer,c_info->r_buffer, in IMB_reduce_scatter() 152 c_info->reccnt, in IMB_reduce_scatter() 153 c_info->red_data_type,c_info->op_type, in IMB_reduce_scatter() 154 c_info->communicator); in IMB_reduce_scatter() [all …]
|
H A D | IMB_sendrecv.c | 130 MPI_Type_size(c_info->s_data_type,&s_size); in IMB_sendrecv() 131 MPI_Type_size(c_info->r_data_type,&r_size); in IMB_sendrecv() 140 if(c_info->rank!=-1) in IMB_sendrecv() 143 dest = (c_info->rank + 1) % (c_info->num_procs); in IMB_sendrecv() 144 source = (c_info->rank + c_info->num_procs-1) % (c_info->num_procs); in IMB_sendrecv() 146 for(i=0; i<N_BARR; i++) MPI_Barrier(c_info->communicator); in IMB_sendrecv() 151 ierr= MPI_Sendrecv(c_info->s_buffer,s_num,c_info->s_data_type, in IMB_sendrecv() 152 dest,s_tag,c_info->r_buffer,r_num, in IMB_sendrecv() 153 c_info->r_data_type,source,r_tag, in IMB_sendrecv() 154 c_info->communicator,&stat); in IMB_sendrecv() [all …]
|
H A D | IMB_output.c | 378 for( i=0; i<c_info->n_groups; i++ ) ip += c_info->g_sizes[i]; in IMB_display_times() 500 if(c_info->w_rank == 0 ) in IMB_show_selections() 565 if( c_info->w_rank == 0 ) in IMB_show_procids() 569 if( c_info->px>1 && c_info->py>1 ) in IMB_show_procids() 574 for( i=0; i<c_info->px && ip<c_info->NP; i++) in IMB_show_procids() 576 py = c_info->w_num_procs/c_info->px; in IMB_show_procids() 577 if( i<c_info->w_num_procs%c_info->px ) py++; in IMB_show_procids() 587 idle = c_info->w_num_procs-c_info->num_procs; in IMB_show_procids() 592 c_info->n_groups,c_info->num_procs); in IMB_show_procids() 594 IMB_print_array(c_info->g_ranks,c_info->n_groups,0, in IMB_show_procids() [all …]
|
H A D | IMB_chk_diff.c | 504 c_info->amode, c_info->info, &restore); 536 (restore,c_info->r_buffer,Totalsize,c_info->etype,&stat); 596 IMB_del_r_buf(c_info); 631 MPI_Gather(&pos,1,MPI_INT,c_info->rdispl,1,MPI_INT,0,c_info->File_comm); 646 MPI_Gather(&pos,1,MPI_INT,c_info->rdispl,1,MPI_INT,0,c_info->File_comm); 647 MPI_Gather(&Locsize,1,MPI_INT,c_info->reccnt,1,MPI_INT,0,c_info->File_comm); 651 IMB_chk_contiguous(c_info, c_info->rdispl, c_info->reccnt, &defloc ); 811 NP = c_info->num_procs; 982 NP = c_info->num_procs; 1077 NP = c_info->num_procs; [all …]
|
H A D | IMB_alltoall.c | 81 void IMB_alltoall(struct comm_info* c_info, int size, int n_sample, in IMB_allgatherv() argument 128 MPI_Type_size(c_info->s_data_type,&s_size); in IMB_allgatherv() 129 MPI_Type_size(c_info->r_data_type,&r_size); in IMB_allgatherv() 136 if(c_info->rank!=-1) in IMB_allgatherv() 138 for(i=0; i<N_BARR; i++) MPI_Barrier(c_info->communicator); in IMB_allgatherv() 143 ierr = MPI_Alltoall(c_info->s_buffer,s_num,c_info->s_data_type, in IMB_allgatherv() 144 c_info->r_buffer,r_num,c_info->r_data_type, in IMB_allgatherv() 145 c_info->communicator); in IMB_allgatherv() 148 CHK_DIFF("Alltoall",c_info, c_info->r_buffer, c_info->rank*size, in IMB_allgatherv() 149 0, c_info->num_procs*size, 1, in IMB_allgatherv()
|
H A D | IMB_window.c | 83 void IMB_window(struct comm_info* c_info, int size, int n_sample, in IMB_window() argument 124 if(c_info->rank!=-1) in IMB_window() 126 for(i=0; i<N_BARR; i++) MPI_Barrier(c_info->communicator); in IMB_window() 131 ierr = MPI_Win_create(c_info->r_buffer,size,1,MPI_INFO_NULL, in IMB_window() 132 c_info->communicator, &c_info->WIN); in IMB_window() 134 ierr = MPI_Win_fence(0, c_info->WIN); in IMB_window() 139 ierr = MPI_Put(c_info->s_buffer, 1, c_info->s_data_type, in IMB_window() 140 c_info->rank, 0, 1, c_info->r_data_type, c_info->WIN); in IMB_window() 143 ierr = MPI_Win_free(&c_info->WIN); in IMB_window()
|
H A D | IMB_allgather.c | 77 void IMB_allgather(struct comm_info* c_info, int size, int n_sample, in IMB_allgather() argument 123 MPI_Type_size(c_info->s_data_type,&s_size); in IMB_allgather() 124 MPI_Type_size(c_info->r_data_type,&r_size); in IMB_allgather() 131 if(c_info->rank!=-1) in IMB_allgather() 133 for(i=0; i<N_BARR; i++) MPI_Barrier(c_info->communicator); in IMB_allgather() 138 ierr = MPI_Allgather(c_info->s_buffer,s_num,c_info->s_data_type, in IMB_allgather() 139 c_info->r_buffer,r_num,c_info->r_data_type, in IMB_allgather() 140 c_info->communicator); in IMB_allgather() 143 CHK_DIFF("Allgather",c_info, c_info->r_buffer, 0, in IMB_allgather() 144 0, c_info->num_procs*size, 1, in IMB_allgather()
|
H A D | IMB_reduce.c | 81 void IMB_reduce(struct comm_info* c_info, int size, int n_sample, in IMB_reduce() argument 128 MPI_Type_size(c_info->red_data_type,&s_size); in IMB_reduce() 131 if(c_info->rank!=-1) in IMB_reduce() 135 for(i=0; i<N_BARR; i++) MPI_Barrier(c_info->communicator); in IMB_reduce() 140 ierr = MPI_Reduce(c_info->s_buffer,c_info->r_buffer,s_num, in IMB_reduce() 141 c_info->red_data_type,c_info->op_type, in IMB_reduce() 142 i1,c_info->communicator); in IMB_reduce() 146 if( c_info->rank == i1 ) in IMB_reduce() 148 CHK_DIFF("Reduce",c_info, c_info->r_buffer, 0, in IMB_reduce() 155 i1=(++i1)%c_info->num_procs; in IMB_reduce()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/python/pyarrow/ |
H A D | config.pxi | 36 const CBuildInfo* c_info 38 c_info = &GetBuildInfo() 40 return BuildInfo(version=frombytes(c_info.version_string), 41 version_info=VersionInfo(c_info.version_major, 44 so_version=frombytes(c_info.so_version), 46 compiler_id=frombytes(c_info.compiler_id), 49 git_id=frombytes(c_info.git_id), 51 package_kind=frombytes(c_info.package_kind)) 68 CRuntimeInfo c_info 70 c_info = GetRuntimeInfo() [all …]
|