Lines Matching refs:win
31 MPI_Win win; member
386 if (addr != NULL) PetscCallMPI(MPI_Win_attach(link->win, addr, wsize)); in PetscSFWindowAttach()
427 …ostassert, PetscMPIInt startassert, const MPI_Aint **target_disp, MPI_Request **reqs, MPI_Win *win) in PetscSFGetWindow() argument
445 *win = MPI_WIN_NULL; in PetscSFGetWindow()
473 *win = link->win; in PetscSFGetWindow()
491 … " of flavor %d for comm %" PETSC_INTPTR_T_FMT "\n", (PETSC_INTPTR_T)link->win, link->flavor, (PET… in PetscSFGetWindow()
492 *win = link->win; in PetscSFGetWindow()
512 PetscCallMPI(MPI_Win_create(rootdata, wsize, (PetscMPIInt)bytes, w->info, wcomm, &link->win)); in PetscSFGetWindow()
517 PetscCallMPI(MPI_Win_create_dynamic(w->info, wcomm, &link->win)); in PetscSFGetWindow()
521 …PetscCallMPI(MPI_Win_allocate(wsize, (PetscMPIInt)bytes, w->info, wcomm, &link->addr, &link->win)); in PetscSFGetWindow()
527 …llMPI(MPI_Win_allocate_shared(wsize, (PetscMPIInt)bytes, w->info, wcomm, &link->addr, &link->win)); in PetscSFGetWindow()
534 … " of flavor %d for comm %" PETSC_INTPTR_T_FMT "\n", (PETSC_INTPTR_T)link->win, link->flavor, (PET… in PetscSFGetWindow()
535 *win = link->win; in PetscSFGetWindow()
545 …CSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_lock(MPI_LOCK_EXCLUSIVE, rank, MPI_MODE_NOCHECK, *win)); in PetscSFGetWindow()
548 PetscCallMPI(MPI_Win_unlock(rank, *win)); in PetscSFGetWindow()
549 PetscCallMPI(MPI_Win_fence(0, *win)); in PetscSFGetWindow()
557 PetscCallMPI(MPI_Win_fence(fenceassert, *win)); in PetscSFGetWindow()
576 if (isize) PetscCallMPI(MPI_Win_post(ingroup, postassert, *win)); in PetscSFGetWindow()
577 if (osize) PetscCallMPI(MPI_Win_start(outgroup, startassert, *win)); in PetscSFGetWindow()
605 …f, MPI_Datatype unit, const void *rootdata, const void *leafdata, MPI_Win *win, MPI_Request **reqs) in PetscSFFindWindow() argument
614 *win = MPI_WIN_NULL; in PetscSFFindWindow()
618 *win = MPI_WIN_NULL; in PetscSFFindWindow()
623 … " of flavor %d for comm %" PETSC_INTPTR_T_FMT "\n", (PETSC_INTPTR_T)link->win, link->flavor, (PET… in PetscSFFindWindow()
624 *win = link->win; in PetscSFFindWindow()
650 …tscSFWindowSyncType sync, PetscBool epoch, PetscMPIInt fenceassert, PetscBool update, MPI_Win *win) in PetscSFRestoreWindow() argument
661 if (*win == MPI_WIN_NULL) PetscFunctionReturn(PETSC_SUCCESS); in PetscSFRestoreWindow()
665 if (*win == link->win) { in PetscSFRestoreWindow()
685 … " of flavor %d for comm %" PETSC_INTPTR_T_FMT "\n", (PETSC_INTPTR_T)link->win, link->flavor, (PET… in PetscSFRestoreWindow()
689 PetscCallMPI(MPI_Win_fence(fenceassert, *win)); in PetscSFRestoreWindow()
707 if (osize) PetscCallMPI(MPI_Win_complete(*win)); in PetscSFRestoreWindow()
708 if (isize) PetscCallMPI(MPI_Win_wait(*win)); in PetscSFRestoreWindow()
716 if (link->addr != NULL) PetscCallMPI(MPI_Win_detach(link->win, link->addr)); in PetscSFRestoreWindow()
721 …= PETSCSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_fence(MPI_MODE_NOPUT | MPI_MODE_NOSUCCEED, *win)); in PetscSFRestoreWindow()
733 PetscCallMPI(MPI_Win_free(&link->win)); in PetscSFRestoreWindow()
735 *win = MPI_WIN_NULL; in PetscSFRestoreWindow()
849 PetscCallMPI(MPI_Win_free(&wlink->win)); in PetscSFReset_Window()
881 PetscCallMPI(MPI_Win_create_dynamic(w->info, wcomm, &link->win)); in PetscSFRegisterPersistent_Window()
922 PetscCallMPI(MPI_Win_detach(link->win, link->addr)); in PetscSFDeregisterPersistent_Window()
927 PetscCallMPI(MPI_Win_free(&link->win)); in PetscSFDeregisterPersistent_Window()
1009 MPI_Win win; in PetscSFBcastBegin_Window() local
1015 …c, PETSC_TRUE, MPI_MODE_NOPUT | MPI_MODE_NOPRECEDE, MPI_MODE_NOPUT, 0, &target_disp, &reqs, &win)); in PetscSFBcastBegin_Window()
1020 PetscCallMPI(MPI_Win_lock(MPI_LOCK_SHARED, ranks[i], MPI_MODE_NOCHECK, win)); in PetscSFBcastBegin_Window()
1022 PetscCallMPI(MPI_Rget(leafdata, 1, mine[i], ranks[i], tdp, 1, remote[i], win, &reqs[i])); in PetscSFBcastBegin_Window()
1024 PetscCallMPI(MPI_Get(leafdata, 1, mine[i], ranks[i], tdp, 1, remote[i], win)); in PetscSFBcastBegin_Window()
1028 PetscCallMPI(MPI_Get(leafdata, 1, mine[i], ranks[i], tdp, 1, remote[i], win)); in PetscSFBcastBegin_Window()
1038 MPI_Win win; in PetscSFBcastEnd_Window() local
1042 PetscCall(PetscSFFindWindow(sf, unit, rootdata, leafdata, &win, &reqs)); in PetscSFBcastEnd_Window()
1050 for (PetscMPIInt i = 0; i < nranks; i++) PetscCallMPI(MPI_Win_unlock(ranks[i], win)); in PetscSFBcastEnd_Window()
1052 … (void *)rootdata, w->sync, PETSC_TRUE, MPI_MODE_NOSTORE | MPI_MODE_NOSUCCEED, PETSC_FALSE, &win)); in PetscSFBcastEnd_Window()
1063 MPI_Win win; in PetscSFReduceBegin_Window() local
1069 …tdata, (void *)leafdata, w->sync, PETSC_TRUE, MPI_MODE_NOPRECEDE, 0, 0, &target_disp, NULL, &win)); in PetscSFReduceBegin_Window()
1074 …CSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_lock(MPI_LOCK_SHARED, ranks[i], MPI_MODE_NOCHECK, win)); in PetscSFReduceBegin_Window()
1075 … PetscCallMPI(MPI_Accumulate((void *)leafdata, 1, mine[i], ranks[i], tdp, 1, remote[i], op, win)); in PetscSFReduceBegin_Window()
1076 if (w->sync == PETSCSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_unlock(ranks[i], win)); in PetscSFReduceBegin_Window()
1084 MPI_Win win; in PetscSFReduceEnd_Window() local
1088 PetscCall(PetscSFFindWindow(sf, unit, rootdata, leafdata, &win, &reqs)); in PetscSFReduceEnd_Window()
1090 …tscSFRestoreWindow(sf, unit, rootdata, w->sync, PETSC_TRUE, MPI_MODE_NOSUCCEED, PETSC_TRUE, &win)); in PetscSFReduceEnd_Window()
1100 MPI_Win win; in PetscSFFetchAndOpBegin_Window() local
1115 …data, (void *)leafdata, PETSCSF_WINDOW_SYNC_LOCK, PETSC_FALSE, 0, 0, 0, &target_disp, NULL, &win)); in PetscSFFetchAndOpBegin_Window()
1117 …tdata, (void *)leafdata, w->sync, PETSC_TRUE, MPI_MODE_NOPRECEDE, 0, 0, &target_disp, NULL, &win)); in PetscSFFetchAndOpBegin_Window()
1124 PetscCallMPI(MPI_Win_lock(MPI_LOCK_EXCLUSIVE, ranks[i], 0, win)); in PetscSFFetchAndOpBegin_Window()
1125 PetscCallMPI(MPI_Get(leafupdate, 1, mine[i], ranks[i], tdp, 1, remote[i], win)); in PetscSFFetchAndOpBegin_Window()
1126 … PetscCallMPI(MPI_Accumulate((void *)leafdata, 1, mine[i], ranks[i], tdp, 1, remote[i], op, win)); in PetscSFFetchAndOpBegin_Window()
1127 PetscCallMPI(MPI_Win_unlock(ranks[i], win)); in PetscSFFetchAndOpBegin_Window()
1129 …w->sync == PETSCSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_lock(MPI_LOCK_SHARED, ranks[i], 0, win)); in PetscSFFetchAndOpBegin_Window()
1130 …ulate((void *)leafdata, 1, mine[i], leafupdate, 1, mine[i], ranks[i], tdp, 1, remote[i], op, win)); in PetscSFFetchAndOpBegin_Window()
1131 if (w->sync == PETSCSF_WINDOW_SYNC_LOCK) PetscCallMPI(MPI_Win_unlock(ranks[i], win)); in PetscSFFetchAndOpBegin_Window()
1142 MPI_Win win; in PetscSFFetchAndOpEnd_Window() local
1149 PetscCall(PetscSFFindWindow(sf, unit, rootdata, leafdata, &win, &reqs)); in PetscSFFetchAndOpEnd_Window()
1152 …tscSFRestoreWindow(sf, unit, rootdata, w->sync, PETSC_TRUE, MPI_MODE_NOSUCCEED, PETSC_TRUE, &win)); in PetscSFFetchAndOpEnd_Window()
1154 …scSFRestoreWindow(sf, unit, rootdata, PETSCSF_WINDOW_SYNC_LOCK, PETSC_FALSE, 0, PETSC_TRUE, &win)); in PetscSFFetchAndOpEnd_Window()