mirror of
https://github.com/sfilippone/psblas3.git
synced 2026-10-18 11:52:11 +00:00
psblas3-integer8:
base/comm/psb_cscatter.F90 base/comm/psb_cspgather.F90 base/comm/psb_dscatter.F90 base/comm/psb_dspgather.F90 base/comm/psb_iscatter.F90 base/comm/psb_sscatter.F90 base/comm/psb_sspgather.F90 base/comm/psb_zscatter.F90 base/comm/psb_zspgather.F90 base/internals/psb_indx_map_fnd_owner.F90 base/internals/psi_desc_index.F90 base/internals/psi_extrct_dl.F90 base/internals/psi_iswapdata.F90 base/internals/psi_iswaptran.F90 base/modules/psb_const_mod.F90 base/modules/psi_bcast_mod.F90 base/modules/psi_comm_buffers_mod.F90 base/modules/psi_p2p_mod.F90 base/modules/psi_penv_mod.F90 base/modules/psi_reduce_mod.F90 base/tools/psb_ccdbldext.F90 base/tools/psb_csphalo.F90 base/tools/psb_dcdbldext.F90 base/tools/psb_dsphalo.F90 base/tools/psb_scdbldext.F90 base/tools/psb_ssphalo.F90 base/tools/psb_zcdbldext.F90 base/tools/psb_zsphalo.F90 New names for variables holding mpi datatypes; hopefully clear enough.
This commit is contained in:
@@ -134,8 +134,8 @@ subroutine psb_indx_map_fnd_owner(idx,iprc,idxmap,info)
|
||||
t3 = psb_wtime()
|
||||
end if
|
||||
|
||||
call mpi_allgatherv(idx,hsz(me+1),psb_mpi_integer,&
|
||||
& hproc,hsz,hidx,psb_mpi_integer,&
|
||||
call mpi_allgatherv(idx,hsz(me+1),psb_mpi_ipk_integer,&
|
||||
& hproc,hsz,hidx,psb_mpi_ipk_integer,&
|
||||
& icomm,info)
|
||||
if (gettime) then
|
||||
tamx = psb_wtime() - t3
|
||||
@@ -178,7 +178,7 @@ subroutine psb_indx_map_fnd_owner(idx,iprc,idxmap,info)
|
||||
end if
|
||||
|
||||
! Collect all the answers with alltoallv (need sizes)
|
||||
call mpi_alltoall(sdsz,1,psb_mpi_integer,rvsz,1,mpi_integer,icomm,info)
|
||||
call mpi_alltoall(sdsz,1,psb_mpi_ipk_integer,rvsz,1,psb_mpi_def_integer,icomm,info)
|
||||
|
||||
isz = sum(rvsz)
|
||||
|
||||
@@ -192,8 +192,8 @@ subroutine psb_indx_map_fnd_owner(idx,iprc,idxmap,info)
|
||||
rvidx(ip) = j
|
||||
j = j + rvsz(ip)
|
||||
end do
|
||||
call mpi_alltoallv(hproc,sdsz,sdidx,psb_mpi_integer,&
|
||||
& answers(:,1),rvsz,rvidx,psb_mpi_integer,&
|
||||
call mpi_alltoallv(hproc,sdsz,sdidx,psb_mpi_ipk_integer,&
|
||||
& answers(:,1),rvsz,rvidx,psb_mpi_ipk_integer,&
|
||||
& icomm,info)
|
||||
if (gettime) then
|
||||
tamx = psb_wtime() - t3 + tamx
|
||||
|
||||
@@ -186,7 +186,7 @@ subroutine psi_desc_index(desc,index_in,dep_list,&
|
||||
i = i + nerv + 1
|
||||
end do
|
||||
ihinsz=i
|
||||
call mpi_alltoall(sdsz,1,mpi_integer,rvsz,1,mpi_integer,icomm,minfo)
|
||||
call mpi_alltoall(sdsz,1,psb_mpi_def_integer,rvsz,1,psb_mpi_def_integer,icomm,minfo)
|
||||
if (minfo /= psb_success_) then
|
||||
call psb_errpush(psb_err_from_subroutine_,name,a_err='mpi_alltoall')
|
||||
goto 9999
|
||||
@@ -292,8 +292,8 @@ subroutine psi_desc_index(desc,index_in,dep_list,&
|
||||
idxr = idxr + rvsz(proc+1)
|
||||
end do
|
||||
|
||||
call mpi_alltoallv(sndbuf,sdsz,bsdindx,psb_mpi_integer,&
|
||||
& rcvbuf,rvsz,brvindx,psb_mpi_integer,icomm,minfo)
|
||||
call mpi_alltoallv(sndbuf,sdsz,bsdindx,psb_mpi_ipk_integer,&
|
||||
& rcvbuf,rvsz,brvindx,psb_mpi_ipk_integer,icomm,minfo)
|
||||
if (minfo /= psb_success_) then
|
||||
call psb_errpush(psb_err_from_subroutine_,name,a_err='mpi_alltoallv')
|
||||
goto 9999
|
||||
|
||||
@@ -271,8 +271,8 @@ subroutine psi_extract_dep_list(ictxt,is_bld,is_upd,desc_str,dep_list,&
|
||||
goto 9999
|
||||
endif
|
||||
itmp(1:dl_lda) = dep_list(1:dl_lda,me)
|
||||
call mpi_allgather(itmp,dl_lda,psb_mpi_integer,&
|
||||
& dep_list,dl_lda,psb_mpi_integer,icomm,info)
|
||||
call mpi_allgather(itmp,dl_lda,psb_mpi_ipk_integer,&
|
||||
& dep_list,dl_lda,psb_mpi_ipk_integer,icomm,info)
|
||||
deallocate(itmp,stat=info)
|
||||
if (info /= psb_success_) then
|
||||
info=psb_err_alloc_dealloc_
|
||||
|
||||
@@ -302,8 +302,8 @@ subroutine psi_iswapidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
|
||||
! swap elements using mpi_alltoallv
|
||||
call mpi_alltoallv(sndbuf,sdsz,bsdidx,&
|
||||
& psb_mpi_integer,rcvbuf,rvsz,&
|
||||
& brvidx,psb_mpi_integer,icomm,iret)
|
||||
& psb_mpi_ipk_integer,rcvbuf,rvsz,&
|
||||
& brvidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
if(iret /= mpi_success) then
|
||||
ierr(1) = iret
|
||||
info=psb_err_mpi_error_
|
||||
@@ -363,7 +363,7 @@ subroutine psi_iswapidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
if ((nerv>0).and.(proc_to_comm /= me)) then
|
||||
p2ptag = psb_int_swap_tag
|
||||
call mpi_irecv(rcvbuf(rcv_pt),n*nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag, icomm,rvhd(i),iret)
|
||||
end if
|
||||
rcv_pt = rcv_pt + n*nerv
|
||||
@@ -388,11 +388,11 @@ subroutine psi_iswapidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
if (usersend) then
|
||||
call mpi_rsend(sndbuf(snd_pt),n*nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
else
|
||||
call mpi_send(sndbuf(snd_pt),n*nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
end if
|
||||
|
||||
@@ -801,8 +801,8 @@ subroutine psi_iswapidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
|
||||
! swap elements using mpi_alltoallv
|
||||
call mpi_alltoallv(sndbuf,sdsz,bsdidx,&
|
||||
& psb_mpi_integer,rcvbuf,rvsz,&
|
||||
& brvidx,psb_mpi_integer,icomm,iret)
|
||||
& psb_mpi_ipk_integer,rcvbuf,rvsz,&
|
||||
& brvidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
if(iret /= mpi_success) then
|
||||
ierr(1) = iret
|
||||
info=psb_err_mpi_error_
|
||||
@@ -859,7 +859,7 @@ subroutine psi_iswapidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
if ((nerv>0).and.(proc_to_comm /= me)) then
|
||||
p2ptag = psb_int_swap_tag
|
||||
call mpi_irecv(rcvbuf(rcv_pt),nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag, icomm,rvhd(i),iret)
|
||||
end if
|
||||
rcv_pt = rcv_pt + nerv
|
||||
@@ -884,11 +884,11 @@ subroutine psi_iswapidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
if (usersend) then
|
||||
call mpi_rsend(sndbuf(snd_pt),nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
else
|
||||
call mpi_send(sndbuf(snd_pt),nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
end if
|
||||
|
||||
@@ -1238,8 +1238,8 @@ end subroutine psi_iswapidxv
|
||||
!!$
|
||||
!!$ ! swap elements using mpi_alltoallv
|
||||
!!$ call mpi_alltoallv(sndbuf,sdsz,bsdidx,&
|
||||
!!$ & psb_mpi_integer,rcvbuf,rvsz,&
|
||||
!!$ & brvidx,psb_mpi_integer,icomm,iret)
|
||||
!!$ & psb_mpi_ipk_integer,rcvbuf,rvsz,&
|
||||
!!$ & brvidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
!!$ if(iret /= mpi_success) then
|
||||
!!$ ierr(1) = iret
|
||||
!!$ info=psb_err_mpi_error_
|
||||
@@ -1296,7 +1296,7 @@ end subroutine psi_iswapidxv
|
||||
!!$ if ((nerv>0).and.(proc_to_comm /= me)) then
|
||||
!!$ p2ptag = psb_int_swap_tag
|
||||
!!$ call mpi_irecv(rcvbuf(rcv_pt),nerv,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag, icomm,rvhd(i),iret)
|
||||
!!$ end if
|
||||
!!$ rcv_pt = rcv_pt + nerv
|
||||
@@ -1321,11 +1321,11 @@ end subroutine psi_iswapidxv
|
||||
!!$ if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
!!$ if (usersend) then
|
||||
!!$ call mpi_rsend(sndbuf(snd_pt),nesd,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag,icomm,iret)
|
||||
!!$ else
|
||||
!!$ call mpi_send(sndbuf(snd_pt),nesd,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag,icomm,iret)
|
||||
!!$ end if
|
||||
!!$
|
||||
|
||||
@@ -320,8 +320,8 @@ subroutine psi_itranidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
|
||||
! swap elements using mpi_alltoallv
|
||||
call mpi_alltoallv(rcvbuf,rvsz,brvidx,&
|
||||
& psb_mpi_integer,&
|
||||
& sndbuf,sdsz,bsdidx,psb_mpi_integer,icomm,iret)
|
||||
& psb_mpi_ipk_integer,&
|
||||
& sndbuf,sdsz,bsdidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
if(iret /= mpi_success) then
|
||||
ierr(1) = iret
|
||||
info=psb_err_mpi_error_
|
||||
@@ -378,7 +378,7 @@ subroutine psi_itranidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
p2ptag = psb_int_swap_tag
|
||||
call mpi_irecv(sndbuf(snd_pt),n*nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,rvhd(i),iret)
|
||||
end if
|
||||
rcv_pt = rcv_pt + n*nerv
|
||||
@@ -402,11 +402,11 @@ subroutine psi_itranidxm(iictxt,iicomm,flag,n,beta,y,idx,totxch,totsnd,totrcv,wo
|
||||
p2ptag = psb_int_swap_tag
|
||||
if (usersend) then
|
||||
call mpi_rsend(rcvbuf(rcv_pt),n*nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
else
|
||||
call mpi_send(rcvbuf(rcv_pt),n*nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,iret)
|
||||
end if
|
||||
|
||||
@@ -824,8 +824,8 @@ subroutine psi_itranidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
|
||||
! swap elements using mpi_alltoallv
|
||||
call mpi_alltoallv(rcvbuf,rvsz,brvidx,&
|
||||
& psb_mpi_integer,&
|
||||
& sndbuf,sdsz,bsdidx,psb_mpi_integer,icomm,iret)
|
||||
& psb_mpi_ipk_integer,&
|
||||
& sndbuf,sdsz,bsdidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
if(iret /= mpi_success) then
|
||||
ierr(1) = iret
|
||||
info=psb_err_mpi_error_
|
||||
@@ -882,7 +882,7 @@ subroutine psi_itranidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
p2ptag = psb_int_swap_tag
|
||||
call mpi_irecv(sndbuf(snd_pt),nesd,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag,icomm,rvhd(i),iret)
|
||||
end if
|
||||
rcv_pt = rcv_pt + nerv
|
||||
@@ -906,11 +906,11 @@ subroutine psi_itranidxv(iictxt,iicomm,flag,beta,y,idx,totxch,totsnd,totrcv,work
|
||||
p2ptag = psb_int_swap_tag
|
||||
if (usersend) then
|
||||
call mpi_rsend(rcvbuf(rcv_pt),nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag, icomm,iret)
|
||||
else
|
||||
call mpi_send(rcvbuf(rcv_pt),nerv,&
|
||||
& psb_mpi_integer,prcid(i),&
|
||||
& psb_mpi_ipk_integer,prcid(i),&
|
||||
& p2ptag, icomm,iret)
|
||||
end if
|
||||
|
||||
@@ -1273,8 +1273,8 @@ end subroutine psi_itranidxv
|
||||
!!$
|
||||
!!$ ! swap elements using mpi_alltoallv
|
||||
!!$ call mpi_alltoallv(rcvbuf,rvsz,brvidx,&
|
||||
!!$ & psb_mpi_integer,&
|
||||
!!$ & sndbuf,sdsz,bsdidx,psb_mpi_integer,icomm,iret)
|
||||
!!$ & psb_mpi_ipk_integer,&
|
||||
!!$ & sndbuf,sdsz,bsdidx,psb_mpi_ipk_integer,icomm,iret)
|
||||
!!$ if(iret /= mpi_success) then
|
||||
!!$ ierr(1) = iret
|
||||
!!$ info=psb_err_mpi_error_
|
||||
@@ -1331,7 +1331,7 @@ end subroutine psi_itranidxv
|
||||
!!$ if ((nesd>0).and.(proc_to_comm /= me)) then
|
||||
!!$ p2ptag = psb_int_swap_tag
|
||||
!!$ call mpi_irecv(sndbuf(snd_pt),nesd,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag,icomm,rvhd(i),iret)
|
||||
!!$ end if
|
||||
!!$ rcv_pt = rcv_pt + nerv
|
||||
@@ -1355,11 +1355,11 @@ end subroutine psi_itranidxv
|
||||
!!$ p2ptag = psb_int_swap_tag
|
||||
!!$ if (usersend) then
|
||||
!!$ call mpi_rsend(rcvbuf(rcv_pt),nerv,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag, icomm,iret)
|
||||
!!$ else
|
||||
!!$ call mpi_send(rcvbuf(rcv_pt),nerv,&
|
||||
!!$ & psb_mpi_integer,prcid(i),&
|
||||
!!$ & psb_mpi_ipk_integer,prcid(i),&
|
||||
!!$ & p2ptag, icomm,iret)
|
||||
!!$ end if
|
||||
!!$
|
||||
|
||||
Reference in New Issue
Block a user