databehaviour.java

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

package planet.trivialp2p.behaviours;

import planet.commonapi.Node;
import planet.commonapi.RouteMessage;
import planet.commonapi.behaviours.Behaviour;
import planet.trivialp2p.TrivialNode;

/**
 * This behaviour is available for application level messages. It routes
 * to the successor (in a clockwise proximity) up to the destination node,
 * where the message is delivered.
 * @author <a href="mailto: [e-mail]">Jordi Pujol</a>
 * 03-jun-2005
 */
public class DataBehaviour implements Behaviour {
    /* Internal atributes. */
    private TrivialNode trivialNode = null;
    
    /**
     * Gets the behaviour name.
     * @return The behaviour name.
     * @see planet.commonapi.behaviours.Behaviour#getName()
     */
    public String getName() {
        return "DataBehaviour";
    }
    
    /**
     * Returns the behaviour name.
     * @return The behaviour name.
     * @see java.lang.Object#toString()
     */
    public String toString()
    {
        return getName();
    }
    
    /**
     * This method treat any application level message, the only available ones
     * in this TrivialP2P overlay implementation.
     * @param msg A RouteMessage that contains an application level message.
     * @param node The local node.
     * @see planet.commonapi.behaviours.Behaviour#onMessage(planet.commonapi.RouteMessage, planet.commonapi.Node)
     */
    public void onMessage(RouteMessage msg, Node node) {
        trivialNode = (TrivialNode)node;
        //it is necessary build a copy; the 'msg' is free at the end of its process
        trivialNode.dispatchDataMessage(trivialNode.buildMessage(msg),TrivialNode.REQUEST,TrivialNode.REFRESH);
    }
}