List of potentialHits() Examples

Examples of potentialHits()

net.tomp2p.futures.FutureRouting.potentialHits()
The potential hits set contains those peers that are in the direct hit and that did report to *not* have the key (Number160) we were looking for. We already check for the content during routing, since we send the information what we are looking for anyway, so a reply if the content exists or not is not very expensive. However, a peer may lie about this. @see #directHits() @see #directHitsDigest() @return The potential hits, the peers in the direct set and those peersthat reports to *not* have the key (Number160) we were looking for.

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

                                RequestP2PConfiguration p2pConfiguration2 = adjustConfiguration(builder.requestP2PConfiguration, 
                                    futureRouting.potentialHits().size());


                                parallelRequests(p2pConfiguration2, 
                                    builder.isFastGet() ? futureRouting.directHits(): EMPTY_NAVIGABLE_SET,
                                        futureRouting.potentialHits(),
                                    futureDHT, false, future.channelCreator(),
                                        new OperationMapper<FutureRemove>() {
                                            Map<PeerAddress, Map<Number640, Data>> rawDataResult = new HashMap<PeerAddress, Map<Number640, Data>>();


                                            Map<PeerAddress, Map<Number640, Byte>> rawDataNoResult = new HashMap<PeerAddress, Map<Number640, Byte>>();

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()


            // new RoutingBuilder(peers[6].getPeerID(), null, null, 0, 0, 0, 100, 2, false), Type.REQUEST_2, cc);
            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            Assert.assertEquals(peers[5].peerAddress(), ns.first());
        } finally {
            if (cc != null) {
                cc.shutdown().awaitListenersUninterruptibly();
            }

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

            FutureRouting fr = peers[0].distributedRouting().route(routingBuilder, request, cc);


            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            // node5 cannot be reached, so it should not be part of the result
            Assert.assertEquals(false, peers[5].peerAddress().equals(ns.first()));
            Assert.assertEquals(true, peers[4].peerAddress().equals(ns.first()));
            LOG.error("done!");
        } finally {

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

            FutureRouting fr = peers[0].distributedRouting().route(routingBuilder, request, cc);


            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            Assert.assertEquals(peers[5].peerAddress(), ns.first());
            Assert.assertEquals(false, ns.contains(peers[3].peerAddress()));
            Assert.assertEquals(false, ns.contains(peers[4].peerAddress()));
        } finally {
            if (cc != null) {

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

            FutureRouting fr = peers[0].distributedRouting().route(routingBuilder, request, cc);


            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            Assert.assertEquals(peers[5].peerAddress(), ns.first());
            Assert.assertEquals(true, ns.contains(peers[0].peerAddress()));
            Assert.assertEquals(true, ns.contains(peers[1].peerAddress()));
            Assert.assertEquals(true, ns.contains(peers[2].peerAddress()));
            Assert.assertEquals(false, ns.contains(peers[3].peerAddress()));

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

            FutureRouting fr = peers[0].distributedRouting().route(routingBuilder, request, cc);


            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            Assert.assertEquals(peers[5].peerAddress(), ns.first());
            Assert.assertEquals(true, ns.contains(peers[3].peerAddress()));
            Assert.assertEquals(true, ns.contains(peers[4].peerAddress()));
            Assert.assertEquals(6, ns.size());
        } finally {

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

            FutureRouting fr = peers[500].distributedRouting().route(routingBuilder, request, cc);


            fr.awaitUninterruptibly();
            // do verification
            Assert.assertEquals(true, fr.isSuccess());
            SortedSet<PeerAddress> ns = fr.potentialHits();
            Assert.assertEquals(peers[20].peerAddress(), ns.first());
        } finally {
            if (cc != null) {
                cc.shutdown().awaitListenersUninterruptibly();
            }

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()


                FutureRouting frr = peers[50].distributedRouting().route(routingBuilder, Type.REQUEST_1,
                        cc);


                frr.awaitUninterruptibly();
                SortedSet<PeerAddress> ss2 = frr.potentialHits();
                // test the first 5 peers, because we set noNewInformation to 5,
                // which means we find at least 5 entries.
                for (int i = 0; i < 5; i++) {
                    PeerAddress pa = ss.first();
                    PeerAddress pa2 = ss2.first();

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()


          futureRouting.addListener(new BaseFutureAdapter<FutureRouting>() {
            @Override
            public void operationComplete(FutureRouting future) throws Exception {
              if (futureRouting.isSuccess()) {
                LOG.debug("found potential hits for tracker add: {}", futureRouting.potentialHits());
                loop(builder.locationKey(), builder.domainKey(), futureRouting.potentialHits(),
                        builder.trackerConfiguration(), futureTracker, false,
                        builder.knownPeers(), new Operation() {
                          @Override
                          public FutureResponse create(PeerAddress remotePeer, boolean primary) {

View Full Code Here

Examples of net.tomp2p.futures.FutureRouting.potentialHits()

          futureRouting.addListener(new BaseFutureAdapter<FutureRouting>() {
            @Override
            public void operationComplete(FutureRouting future) throws Exception {
              if (futureRouting.isSuccess()) {
                LOG.debug("found potential hits for tracker add: {}", futureRouting.potentialHits());
                loop(builder.locationKey(), builder.domainKey(), futureRouting.potentialHits(),
                        builder.trackerConfiguration(), futureTracker, false,
                        builder.knownPeers(), new Operation() {
                          @Override
                          public FutureResponse create(PeerAddress remotePeer, boolean primary) {
                            LOG.debug("tracker add (me={}): {} location={}",

View Full Code Here

0 1

TOP

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.