Examples of net.tomp2p.p2p.PeerBuilder

net.tomp2p.p2p.PeerBuilder
The maker / builder of a {@link Peer} class. @author Thomas Bocek

  @Test
    public void testTracker2() throws Exception {
        final Random rnd = new Random(42L);
        PeerTracker master = null;
        try {
            master = new PeerBuilderTracker(new PeerBuilder(new Number160(rnd)).p2pId(1).ports(4001).start()).verifyPeersOnTracker(false).start();
            PeerTracker[] nodes = createNodes(master, 500, rnd);
            // perfect routing
            for (int i = 0; i < nodes.length; i++) {
                for (int j = 0; j < nodes.length; j++)
                    nodes[i].peer().peerBean().peerMap().peerFound(nodes[j].peerAddress(), null, null);

View Full Code Here

  @Test
    public void testTracker2_5() throws Exception {
        final Random rnd = new Random(42L);
        PeerTracker master = null;
        try {
            master = new PeerBuilderTracker(new PeerBuilder(new Number160(rnd)).p2pId(1).ports(4001).start()).verifyPeersOnTracker(false).start();
            PeerTracker[] nodes = createNodes(master, 500, rnd);
            // perfect routing
            for (int i = 0; i < nodes.length; i++) {
                for (int j = 0; j < nodes.length; j++)
                    nodes[i].peer().peerBean().peerMap().peerFound(nodes[j].peerAddress(), null, null);

View Full Code Here

  @Test
    public void testTracker3() throws Exception {
        final Random rnd = new Random(42L);
        PeerTracker master = null;
        try {
            master = new PeerBuilderTracker(new PeerBuilder(new Number160(rnd)).p2pId(1).ports(4001).start()).verifyPeersOnTracker(false).start();
            PeerTracker[] nodes = createNodes(master, 500, rnd);
            // perfect routing
            for (int i = 0; i < nodes.length; i++) {
                for (int j = 0; j < nodes.length; j++)
                    nodes[i].peer().peerBean().peerMap().peerFound(nodes[j].peerAddress(), null, null);

View Full Code Here

  @Test
    public void testTracker4() throws Exception {
        final Random rnd = new Random(42L);
        PeerTracker master = null;
        try {
            master = new PeerBuilderTracker(new PeerBuilder(new Number160(rnd)).p2pId(1).ports(4001).start()).verifyPeersOnTracker(false).start();
            PeerTracker[] nodes = createNodes(master, 1000, rnd);
            // perfect routing
            for (int i = 0; i < nodes.length; i++) {
                // nodes[i].getPeerBean().getTrackerStorage()
                // .setTrackerStoreSize(nodes[i].getPeerBean().getTrackerStorage().getTrackerSize());

View Full Code Here

        Bindings bindings = new Bindings().addInterface("lo");
        Peer[] peers = new Peer[nrOfPeers];
        if (automaticFuture != null) {
          Number160 peerId = new Number160(rnd);
          PeerMap peerMap = new PeerMap(new PeerMapConfiguration(peerId));
            peers[0] = new PeerBuilder(peerId)
                    .ports(port).enableMaintenance(maintenance)
                    .bindings(bindings).peerMap(peerMap).start().addAutomaticFuture(automaticFuture);
        } else {
          Number160 peerId = new Number160(rnd);
          PeerMap peerMap = new PeerMap(new PeerMapConfiguration(peerId));
            peers[0] = new PeerBuilder(peerId).enableMaintenance(maintenance).bindings(bindings)
                   .peerMap(peerMap).ports(port).start();
        }


        for (int i = 1; i < nrOfPeers; i++) {
            if (automaticFuture != null) {
              Number160 peerId = new Number160(rnd);
              PeerMap peerMap = new PeerMap(new PeerMapConfiguration(peerId));
                peers[i] = new PeerBuilder(peerId)
                        .masterPeer(peers[0])
                        .enableMaintenance(maintenance).enableMaintenance(maintenance).peerMap(peerMap).bindings(bindings).start().addAutomaticFuture(automaticFuture);
            } else {
              Number160 peerId = new Number160(rnd);
              PeerMap peerMap = new PeerMap(new PeerMapConfiguration(peerId).peerNoVerification());
                peers[i] = new PeerBuilder(peerId).enableMaintenance(maintenance)
                        .bindings(bindings).peerMap(peerMap).masterPeer(peers[0])
                        .start();
            }
        }
        System.err.println("peers created.");

View Full Code Here


    private PeerTracker[] createNodes(PeerTracker master, int nr, Random rnd) throws Exception {


      PeerTracker[] nodes = new PeerTracker[nr+1];
        for (int i = 0; i < nr; i++) {
            nodes[i+1] = new PeerBuilderTracker(new PeerBuilder(new Number160(rnd)).p2pId(1).masterPeer(master.peer()).start()).verifyPeersOnTracker(false).start();
        }
        nodes[0] = master;
        return nodes;
    }

View Full Code Here

        if (nrOfPeers < 1) {
            throw new IllegalArgumentException("Cannot create less than 1 peer");
        }
        Peer[] peers = new Peer[nrOfPeers];
        for (int i = 0; i < nrOfPeers; i++) {
            peers[i] = new PeerBuilder(new Number160(rnd))
                    .ports(startPort + i).start().addAutomaticFuture(automaticFuture);
        }
        System.err.println("real peers created.");
        return peers;
    }

View Full Code Here

    public static Peer[] createNonMaintenanceNodes(int nrOfPeers, Random rnd, int port) throws IOException {
        if (nrOfPeers < 1) {
            throw new IllegalArgumentException("Cannot create less than 1 peer");
        }
        Peer[] peers = new Peer[nrOfPeers];
        peers[0] = new PeerBuilder(new Number160(rnd)).enableMaintenance(false).ports(port).start();
        for (int i = 1; i < nrOfPeers; i++) {
            peers[i] = new PeerBuilder(new Number160(rnd)).enableMaintenance(false).masterPeer(peers[0])
                    .start();
        }
        System.err.println("non-maintenance peers created.");
        return peers;
    }

View Full Code Here


    public static Peer[] createAndAttachNodes(int nr, int port, Random rnd) throws Exception {
        Peer[] peers = new Peer[nr];
        for (int i = 0; i < nr; i++) {
            if (i == 0) {
                peers[0] = new PeerBuilder(new Number160(rnd)).ports(port).start();
            } else {
                peers[i] = new PeerBuilder(new Number160(rnd)).masterPeer(peers[0]).start();
            }
        }
        return peers;
    }

View Full Code Here

    public void sendPingTCP() throws IOException, InterruptedException {
        Peer sender = null;
        ChannelCreator cc = null;
        try {
            PeerAddress pa = new PeerAddress(Number160.ZERO, Inet4Address.getByName(IP), PORT, PORT);
            sender = new PeerBuilder(new Number160("0x9876")).ports(PORT).enableMaintenance(false)
                    .start();
            PingRPC handshake = new PingRPC(sender.peerBean(), sender.connectionBean());
            FutureChannelCreator fcc = sender.connectionBean().reservation().create(0, 1);
            fcc.awaitUninterruptibly();
            cc = fcc.channelCreator();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of net.tomp2p.p2p.PeerBuilder

net.tomp2p.connection.Bindings

net.tomp2p.connection.ChannelClientConfiguration

net.tomp2p.connection.ChannelServerConfiguration

net.tomp2p.connection.ConnectionBean

net.tomp2p.connection.DefaultSendBehavior

net.tomp2p.connection.DSASignatureFactory

net.tomp2p.connection.PeerBean

net.tomp2p.connection.PeerCreator

net.tomp2p.connection.PingBuilderFactory

net.tomp2p.connection.Ports

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.