diff --git a/examples/oshmem_circular_shift.java b/examples/oshmem_circular_shift.java index 2f848213ba..776d166d27 100644 --- a/examples/oshmem_circular_shift.java +++ b/examples/oshmem_circular_shift.java @@ -16,7 +16,7 @@ public class oshmem_circular_shift System.out.println("Process "+ myPE +" gets message from "+ peer +" ("+ numPEs +" processes in ring)"); - bbb.getInt(aaa, 1, peer); + bbb.getInt(aaa, peer); ShMem.barrierAll(); bbb.free(); System.out.println("Process "+ myPE +" exiting"); diff --git a/examples/oshmem_max_reduction.java b/examples/oshmem_max_reduction.java index ea9e0ad73c..499427d656 100644 --- a/examples/oshmem_max_reduction.java +++ b/examples/oshmem_max_reduction.java @@ -12,17 +12,13 @@ public class oshmem_max_reduction int numPEs = ShMem.getNumPEs(), myPE = ShMem.getMyPE(); - Addr src = new Addr(8 * N), // long is 8 bytes. - dst = new Addr(8 * N), - pWrk = new Addr(8 * ShMem.REDUCE_SYNC_SIZE), - pSync = new Addr(8 * ShMem.BCAST_SYNC_SIZE); + Addr src = new Addr(8 * N), // long is 8 bytes. + dst = new Addr(8 * N), + pWrk = new Addr(8 * ShMem.REDUCE_SYNC_SIZE); + PSync pSync = new PSync(ShMem.BCAST_SYNC_SIZE); - LongBuffer srcBuf = src.asLongBuffer(), - dstBuf = dst.asLongBuffer(), - pSyncBuf = pSync.asLongBuffer(); - - for(int i = 0; i < ShMem.BCAST_SYNC_SIZE; i++) - pSyncBuf.put(i, ShMem.SYNC_VALUE); + LongBuffer srcBuf = src.asLongBuffer(), + dstBuf = dst.asLongBuffer(); for(int i = 0; i < N; i++) srcBuf.put(i, myPE + i); diff --git a/examples/oshmem_symmetric_data.java b/examples/oshmem_symmetric_data.java index 53361d7d32..d21ef48955 100644 --- a/examples/oshmem_symmetric_data.java +++ b/examples/oshmem_symmetric_data.java @@ -25,7 +25,7 @@ public class oshmem_symmetric_data // static makes it symmetric // put "size" words into target on each PE for(int i = 1; i < numPE; i++) - target.putInt(source, SIZE, i); + target.putInt(source, i); } ShMem.barrierAll(); // sync sender and receiver