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

          .start();
      futureDiscover.awaitUninterruptibly();
      logger.info(String.format("Discover of %s %s", pa,
          (futureDiscover.isSuccess()) ? "succeeded" : "failed"));
      // Future Bootstrap - slave
      FutureBootstrap futureBootstrap = peer.bootstrap()
          .setInetAddress(masterPeerAddress).setPorts(masterPeerPort)
          .start();
      futureBootstrap.awaitUninterruptibly();
      logger.info(String.format("Bootstrap of %s %s", pa,
          (futureDiscover.isSuccess()) ? "succeeded" : "failed"));
      if (futureBootstrap.getBootstrapTo() != null) {
        logger.info("Future Bootstrap to ... all known");
        peer.discover()
            .setPeerAddress(
                futureBootstrap.getBootstrapTo().iterator()
                    .next()).start().awaitUninterruptibly();
      }
    } catch (java.net.BindException
        | org.jboss.netty.channel.ChannelException e) {
      e.printStackTrace();

View Full Code Here

    try {


      if (masterPeer != null) {
        peer = new PeerMaker(new Number160(r)).setPorts(port)
            .makeAndListen();
        FutureBootstrap res = peer.bootstrap()
            .setPeerAddress(masterPeer.getPeerAddress()).start();
        res.awaitUninterruptibly();


      } else
        peer = new PeerMaker(new Number160(r)).setPorts(port)
            .makeAndListen();

View Full Code Here

      peer.shutdown();
      isConnected = false;
      return false;
    }


    FutureBootstrap futureBootstrap = peer.bootstrap().setInetAddress(bootstrapAddress).setPorts(port).start();
    futureBootstrap.awaitUninterruptibly();


    if (futureBootstrap.isSuccess()) {
      logger.debug("Bootstrapping successful. Bootstrapped to '{}'.", bootstrapAddress.getHostAddress());
      return true;
    } else {
      logger.warn("Bootstrapping failed: {}.", futureBootstrap.getFailedReason());
      peer.shutdown();
      isConnected = false;
      return false;
    }
  }

View Full Code Here

            if (futureDiscover.isSuccess()) {
                log.info("Discover with direct connection successful. Address = " + futureDiscover.peerAddress());
                //cachedPeers.put(id, peer);
                
                //bootstrap
                FutureBootstrap fb = peer.bootstrap().peerAddress(masterNodeAddress).start();
                fb.awaitUninterruptibly();
                if (fb.isSuccess()) {
                  log.info("Bootstrap with direct connection successful. Address = " + fb.bootstrapTo());
                  return peer;
                } else {
                  return null;
                }
            }

View Full Code Here


      for (int i = 0; i < peers.length; i++) {
        System.out.println("peer[" + i + "]: " + peers[i].peerAddress());
      }


      FutureBootstrap futureBootstrap1 = peers[1].bootstrap().peerAddress(peers[0].peerAddress()).start();
      futureBootstrap1.awaitUninterruptibly();
      System.out.println("peer[0] knows: " + peers[0].peerBean().peerMap().all() + " unverified: "
              + peers[0].peerBean().peerMap().allOverflow());
      System.out.println("wait for maintenace ping");
      Thread.sleep(2000);
      System.out.println("peer[0] knows: " + peers[0].peerBean().peerMap().all() + " unverified: "
              + peers[0].peerBean().peerMap().allOverflow());
      FutureBootstrap futureBootstrap2 = peers[2].bootstrap().peerAddress(peers[0].peerAddress()).start();
      futureBootstrap2.awaitUninterruptibly();
      // list all the peers C knows by now:
      System.out.println("peer[2] knows: " + peers[2].peerBean().peerMap().all());


    } finally {
      // 0 is the master

View Full Code Here

    PeerAddress pa = unreachable.peerBean().serverPeerAddress();
    pa = pa.changeFirewalledTCP(true).changeFirewalledUDP(true);
    unreachable.peerBean().serverPeerAddress(pa);
    
    // find neighbors
    FutureBootstrap futureBootstrap = unreachable.bootstrap().peerAddress(peers[0].peerAddress()).start();
    futureBootstrap.awaitUninterruptibly();
    Assert.assertTrue(futureBootstrap.isSuccess());
    
    // setup relay
    PeerNAT uNat = new PeerBuilderNAT(unreachable).start();
    FutureRelayNAT frn = uNat.startRelay(master.peerAddress());
    frn.awaitUninterruptibly();

View Full Code Here

        }
        for (FutureDiscover future : futures2) {
            future.awaitUninterruptibly();
        }
        for (int i = 1; i < peers.length; i++) {
            FutureBootstrap tmp = peers[i].bootstrap().peerAddress(peers[0].peerAddress()).start();
            futures1.add(tmp);
        }
        for (int i = 1; i < peers.length; i++) {
            FutureBootstrap tmp = peers[0].bootstrap().peerAddress(peers[i].peerAddress()).start();
            futures1.add(tmp);
        }
        for (FutureBootstrap future : futures1)
            future.awaitUninterruptibly();
    }

View Full Code Here

                    return "world!";
                }
            });
            // keep the connection for 20s alive. Setting -1 means to keep it
            // open as long as possible
            FutureBootstrap masterAnother = peer1.bootstrap().peerAddress(peer2.peerAddress()).start();
            FutureBootstrap anotherMaster = peer2.bootstrap().peerAddress(peer1.peerAddress()).start();
            masterAnother.awaitUninterruptibly();
            anotherMaster.awaitUninterruptibly();
            FuturePeerConnection fpc = peer1.createPeerConnection(peer2.peerAddress());
            // fpc.awaitUninterruptibly();
            // PeerConnection peerConnection = fpc.peerConnection();
            String sentObject = "Hello";
            FutureDirect fd = peer1.sendDirect(fpc).object(sentObject).start();

View Full Code Here

    @Ignore
    public void startClient() throws IOException {
        Random r = new Random(Utils2.THE_ANSWER2);
        Bindings b = new Bindings().addProtocol(StandardProtocolFamily.INET6);
        Peer peer = new PeerBuilder(new Number160(r)).bindings(b).ports(port).start();
        FutureBootstrap fb = peer.bootstrap().inetAddress(InetAddress.getByName(ipSuperPeer)).ports(port).start();
        fb.awaitUninterruptibly();
        System.out.println("Got it: " + fb.isSuccess());
    }

View Full Code Here

    // Future Discover
    FutureDiscover futureDiscover = client.discover().inetAddress(address).ports(masterPort).start();
    futureDiscover.awaitUninterruptibly();


    // Future Bootstrap - slave
    FutureBootstrap futureBootstrap = client.bootstrap().inetAddress(address).ports(masterPort).start();
    futureBootstrap.awaitUninterruptibly();


    Collection<PeerAddress> addressList = client.peerBean().peerMap().all();
    System.out.println(addressList.size());


    if (futureDiscover.isSuccess()) {

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.