peerinfobundle.java

服务器模块主要负责分配计算任务

package primecruncher;
import net.jxta.protocol.*;
import net.jxta.peer.*;
import net.jxta.pipe.*;
import net.jxta.id.*;

class PeerInfoBundle{
    //private PeerAdvertisement peerAdvertisement = null;
    private ModuleSpecAdvertisement moduleSpecAdvertisement=null;
    private PeerMetrics peerMetrics=null;

    /*****************************************************************/
    PeerInfoBundle(ModuleSpecAdvertisement mAdv){
        //this.peerAdvertisement=adv;
        this.moduleSpecAdvertisement=mAdv;
        peerMetrics=new PeerMetrics();

    }
    /*
    protected PeerAdvertisement getPeerAdvertisement() {
        return peerAdvertisement;
    }
    */
   /*****************************************************************/
    protected ModuleSpecAdvertisement getModuleSpecAdvertisement(){
        return moduleSpecAdvertisement;
    }
    /*****************************************************************/
    protected PeerMetrics getPeerMetrics(){
        return peerMetrics;
    }
    /*****************************************************************/
    public boolean equals(Object o){   //将给定的公告信息的pipeID和自身的作比较
        if(o instanceof PeerInfoBundle){
            PeerInfoBundle b=(PeerInfoBundle)o;
            ID bPipd=b.moduleSpecAdvertisement.getPipeAdvertisement().getPipeID();
            ID ourID=moduleSpecAdvertisement.getPipeAdvertisement().getPipeID();
            return ourID.getUniqueValue().equals(bPipd.getUniqueValue());
        }
        return false;
    }
    /*****************************************************************/
    public int hashCode(){
        return moduleSpecAdvertisement.getPipeAdvertisement().getPipeID().getUniqueValue().hashCode();
    }
    /*****************************************************************/
    class PeerMetrics{
    }
}