Hey Ashish, LocalBSPRunner will never use the serialization system. I thought it was overhead so I decided to not use it and just keep the messages in memory. Since we are just on one host this is a quite valid way ;) So you have to debug in distributed or pseudo-distributed mode and not in local mode.
Generally (not in the LocalBSPRunner) the messages from a task are put into its groom via RPC. The messages are put into the bundles and get transfered in the sync phase (so after sync was called). Please correct me if I'm not right, I'm new to it, too! In the LocalBSPRunner the data gets transfered during the sync phase, too. But the transfering is just a copy from one datastructure to another, so no network or serialization stuff is made. Hope to help you. Greetings, Thomas 2011/5/24 Ashish Agarwal <[email protected]> > Hi, > > I was looking at HAMA-380 and PiEstimator.java and have some questions - > > 1. In BSPMessageBundle.java, I tried adding breakpoints at different > positions but it does not stop the program for somehow. Is there any reason > why this is happening ? > > 2. In PiEstimator, I tried adding breakpoints at - > bspPeer.send(masterTask, estimate); and > bspPeer.sync(); > > On both occasions it stops at the public void run() function in the > LocalBSPRrunner.java. > > I see that the message is added to the queue in the sync() function in > BSPPeer.java. Does the message get sent using the sync() function or the > send() function in BSPPeer ? > > Thank you for your help. > > Sincerely, > Ashish > -- Thomas Jungblut Berlin mobile: 0170-3081070 business: [email protected] private: [email protected]
