Index: src/test/org/apache/hama/bsp/TestBSPPeer.java =================================================================== --- src/test/org/apache/hama/bsp/TestBSPPeer.java (리비전 1028159) +++ src/test/org/apache/hama/bsp/TestBSPPeer.java (작업 사본) @@ -82,8 +82,10 @@ public class BSPPeerThread extends Thread { private BSPPeer peer; private int MAXIMUM_DURATION = 5; - + private int lastTwoDigitsOfPort; + public BSPPeerThread(Configuration conf) throws IOException { + lastTwoDigitsOfPort = conf.getInt(Constants.PEER_PORT, 0) - 30000; this.peer = new BSPPeer(conf); Set peerNames = new HashSet(NUM_PEER); for (int i = 0; i < NUM_PEER; i++) { @@ -128,16 +130,21 @@ e.printStackTrace(); } - assertEquals(peer.getNumCurrentMessages(), 1); verifyPayload(); } - - assertEquals(peer.getNumCurrentMessages(), NUM_PEER * ROUND); } private void verifyPayload() { - System.out.println("[" + getName() + "] verifying " - + peer.localQueue.size() + " messages"); + int numMessages = peer.getNumCurrentMessages(); + System.out.println("[" + peer.getPeerName() + "] verifying " + + numMessages + " messages"); + + if (lastTwoDigitsOfPort < 10) { + assertEquals(20, numMessages); + } else { + assertEquals(0, numMessages); + } + BSPMessage msg = null; try {