queryjoinbehaviour.java

p2p仿真器。开发者可以工作在覆盖层中进行创造和测试逻辑算法或者创建和测试新的服务。PlanetSim还可以将仿真代码平稳转换为在Internet上的实验代码

package planet.symphony.behaviours;

import java.util.Collection;

import planet.commonapi.Node;
import planet.commonapi.NodeHandle;
import planet.commonapi.RouteMessage;
import planet.commonapi.behaviours.Behaviour;
import planet.results.LinkStateResults;
import planet.symphony.SymphonyNode;
import planet.symphony.messages.*;

/**
 * This behaviour accepts QUERY_JOIN requests. The node which receives the
 * QUERY_JOIN request is the immediate successor of the newbie's Id. Hence,
 * it handles incoming JOIN requests. It sends a SET_INFO message to newbie
 * with its neighbour's Set. 
 * 
 * @author Marc Sanchez <[e-mail]>
 * @author Helio Tejedor <[e-mail]>
 */
public class QueryJoinBehaviour implements Behaviour { 
    /* internal attributes */
    private SymphonyNode symphony = null;
    private JoinMessage joinMsg = null;
    private NodeHandle nodeHandle = null;
    private NodeHandle newNode    = null;
    private Collection neighbourSet = null;
    private NeighbourMessage newNeighbours = null;
    private RouteMessage newNeighbour = null;
    
	/**
	 *  Given a RouteMessage and a Node as input, onMessage's method do execution 
	 * steps for the behaviour. Node should be casted to Node's class in order to
	 * manage data structures and protocol of designed overlay.
	 * @param msg RouteMessage taken as input.
	 * @param node Node taken as input.
	 */
	public void onMessage(RouteMessage msg, Node node) {
		symphony = (SymphonyNode) node;
		
		joinMsg = (JoinMessage) msg.getMessage();
		
		//LinkStateResults.updateHopsByTypeOf(msg);
		
		// NODEHANDLE
		nodeHandle = symphony.getLocalHandle();
		newNode    = joinMsg.getNewNode();
		
		neighbourSet = symphony.getNeighbourSet();
		newNeighbours = NeighbourMessagePool.getMessage(neighbourSet);
		newNeighbour = symphony.buildMessage(nodeHandle, newNode, newNode, SymphonyNode.SET_INFO,
		           SymphonyNode.REFRESH, newNeighbours);
		symphony.addToNeighbourSet(newNode);
		
		//LinkStateResults.newMessage(newNeighbour);
		//LinkStateResults.updateOutcoming(symphony.getId());
        symphony.sendMessage(newNeighbour);
	}
	/**
	 * @return Returns the name of behaviour. 
	 */
	public String getName() {
		return "QueryJoinBehaviour";
	}
	/**
	 * @return Returns a string representation of the behaviour. In general, the toString
	 * method returns a string that "textually represents" this behaviour. The result should 
	 * be a concise but informative representation that is easy for a person to read. 
	 */ 
	public String toString() {
		return getName();
	}

}