Examples of net.tomp2p.futures.FutureBootstrap

net.tomp2p.futures.FutureBootstrap
Used for bootstrapping. One important information in bootstrapping is to get the nodes that we bootstrapped to. We may not know this in advance as we might bootstrap via broadcast. @author Thomas Bocek

            // do testing
            List<FutureBootstrap> tmp = new ArrayList<FutureBootstrap>();
            // we start from 1, because a broadcast to ourself will not get
            // replied.
            for (int i = 1; i < peers.length; i++) {
                FutureBootstrap res = peers[i].bootstrap().ports(4001).broadcast().start();
                tmp.add(res);
            }
        } finally {
            if (master != null) {
                master.shutdown().await();

View Full Code Here

        final Random rnd = new Random(42);
        Peer peer = null;
        try {
            peer = new PeerBuilder(new Number160(rnd)).ports(4000).start();
            PeerAddress pa = new PeerAddress(new Number160(rnd), "192.168.77.77", 4000, 4000);
            FutureBootstrap tmp = peer.bootstrap().peerAddress(pa).start();
            tmp.awaitUninterruptibly();
            Assert.assertEquals(false, tmp.isSuccess());
        } finally {
            if (peer != null) {
                peer.shutdown().await();
            }
        }

View Full Code Here

    public void testBootstrap6() throws Exception {
        final Random rnd = new Random(42);
        Peer peer = null;
        try {
            peer = new PeerBuilder(new Number160(rnd)).ports(4000).start();
            FutureBootstrap tmp = peer.bootstrap().peerAddress(peer.peerAddress()).start();
            tmp.awaitUninterruptibly();
            Assert.assertEquals(true, tmp.isSuccess());
        } finally {
            if (peer != null) {
                peer.shutdown().await();
            }
        }

View Full Code Here


            Collection<PeerAddress> bootstrapTo = new ArrayList<PeerAddress>(2);
            PeerAddress pa = new PeerAddress(new Number160(rnd), "192.168.77.77", 4000, 4000);
            bootstrapTo.add(peer.peerAddress());
            bootstrapTo.add(pa);
            FutureBootstrap tmp = peer.bootstrap().bootstrapTo(bootstrapTo).start();
            tmp.awaitUninterruptibly();
            Assert.assertEquals(false, tmp.isSuccess());
        } finally {
            if (peer != null) {
                peer.shutdown().await();
            }
        }

View Full Code Here

    } else {
      System.out.println("*** FAILED " + fd.failedReason());
    }


    bootStrapServer = fd.reporter();
    FutureBootstrap bootstrap = peer.peer().bootstrap().peerAddress(bootStrapServer).start();
    bootstrap.awaitUninterruptibly();
    if (!bootstrap.isSuccess()) {
      System.out.println("*** COULD NOT BOOTSTRAP!");
    } else {
      System.out.println("*** SUCCESSFUL BOOTSTRAP");
    }

View Full Code Here

        } catch (Exception e) {
            e.printStackTrace();
            Assert.fail();
            return null;
        }
        final FutureBootstrap fb = peer.bootstrap().broadcast().ports(seed.peerAddress().udpPort()).start();
        fb.awaitUninterruptibly();
        peer.discover().peerAddress(fb.bootstrapTo().iterator().next()).start();
        fb.addListener(new BaseFutureListener<BaseFuture>() {
            @Override
            public void operationComplete(BaseFuture future) throws Exception {
                Collection<PeerAddress> addresses = fb.bootstrapTo();
                if (addresses != null && !addresses.isEmpty()) {
                    peer.discover().peerAddress(addresses.iterator().next()).start().awaitUninterruptibly();
                } else {
                    Assert.assertTrue("Unable to boostrap to peers in the network", false);
                }

View Full Code Here

    try {
      // setup (step 1)
      Bindings b = new Bindings().addInterface("lo");
      p1 = new PeerBuilder(new Number160(rnd)).ports(4001).bindings(b).start();
      p2 = new PeerBuilder(new Number160(rnd)).ports(4002).bindings(b).start();
      FutureBootstrap fb = p2.bootstrap().peerAddress(p1.peerAddress()).start();
      fb.awaitUninterruptibly();
      Assert.assertEquals(true, fb.isSuccess());
    } finally {
      if (p1 != null) {
        p1.shutdown().await();
      }
      if (p2 != null) {

View Full Code Here

    PeerAddress upa = peer.peerBean().serverPeerAddress();
    upa = upa.changeFirewalledTCP(true).changeFirewalledUDP(true).changeSlow(relayType.isSlow());
    peer.peerBean().serverPeerAddress(upa);
    // find neighbors


    FutureBootstrap futureBootstrap = bootstrapBuilder.start();
    futureBootstrapNAT.futureBootstrap0(futureBootstrap);


    futureBootstrap.addListener(new BaseFutureAdapter<FutureBootstrap>() {
      @Override
      public void operationComplete(FutureBootstrap future) throws Exception {
        if (future.isSuccess()) {
          // setup relay
          LOG.debug("bootstrap completed");
          final FutureRelay futureRelay = new FutureRelay();
          final DistributedRelay distributedRelay = startSetupRelay(futureRelay);
          futureBootstrapNAT.futureRelay(futureRelay);
          futureRelay.addListener(new BaseFutureAdapter<FutureRelay>() {


            @Override
            public void operationComplete(FutureRelay future) throws Exception {
              // find neighbors again
              if (future.isSuccess()) {
                FutureBootstrap futureBootstrap = bootstrapBuilder.start();
                futureBootstrapNAT.futureBootstrap1(futureBootstrap);
                futureBootstrap.addListener(new BaseFutureAdapter<FutureBootstrap>() {
                  @Override
                  public void operationComplete(FutureBootstrap future) throws Exception {
                    if (future.isSuccess()) {
                      Shutdown shutdown = startRelayMaintenance(futureRelay, bootstrapBuilder, distributedRelay);
                      futureBootstrapNAT.done(shutdown);

View Full Code Here

0 1 2

TOP

Related Classes of net.tomp2p.futures.FutureBootstrap

lupos.distributed.p2p.network.impl.TomP2P

net.tomp2p.dht.TestAddUpdateTTL

net.tomp2p.dht.TestDHT

net.tomp2p.dht.TestRealNetwork

net.tomp2p.dht.UtilsDHT2

net.tomp2p.examples.ExampleBootstrap

net.tomp2p.examples.ExampleDiscover

net.tomp2p.examples.ExampleDNS

net.tomp2p.examples.ExampleNATChat

net.tomp2p.examples.TomP2PTests

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.