|
1 | 1 | ### This file contains functions to load balance of data X.spmd.
|
2 | 2 |
|
3 |
| -balance.info <- function(X.spmd, comm = .SPMD.CT$comm, |
| 3 | +balance.info <- function(X.spmd, comm = .pbd_env$SPMD.CT$comm, |
4 | 4 | spmd.major = 1, method = c("block.cyclic", "block0")){
|
5 | 5 | COMM.SIZE <- spmd.comm.size(comm)
|
6 | 6 | COMM.RANK <- spmd.comm.rank(comm)
|
@@ -64,7 +64,7 @@ balance.info <- function(X.spmd, comm = .SPMD.CT$comm,
|
64 | 64 | } # End of balance.info()
|
65 | 65 |
|
66 | 66 |
|
67 |
| -load.balance <- function(X.spmd, bal.info = NULL, comm = .SPMD.CT$comm, |
| 67 | +load.balance <- function(X.spmd, bal.info = NULL, comm = .pbd_env$SPMD.CT$comm, |
68 | 68 | spmd.major = 1){
|
69 | 69 | COMM.RANK <- spmd.comm.rank(comm)
|
70 | 70 | if(is.null(bal.info)){
|
@@ -149,7 +149,7 @@ load.balance <- function(X.spmd, bal.info = NULL, comm = .SPMD.CT$comm,
|
149 | 149 | } # End of load.balance().
|
150 | 150 |
|
151 | 151 |
|
152 |
| -unload.balance <- function(new.X.spmd, bal.info, comm = .SPMD.CT$comm){ |
| 152 | +unload.balance <- function(new.X.spmd, bal.info, comm = .pbd_env$SPMD.CT$comm){ |
153 | 153 | rev.bal.info <- list(send = data.frame(org = bal.info$recv$belong,
|
154 | 154 | belong = bal.info$recv$org),
|
155 | 155 | recv = data.frame(org = bal.info$send$belong,
|
|
0 commit comments