Package net.tomp2p.p2p

Examples of net.tomp2p.p2p.RequestP2PConfiguration

26
27
28
29
30
31
32
33
34
35
36
            master = peers[0];
            Utils2.perfectRouting(peers);
            // do testing
            Number160 locationKey = new Number160(rnd);
            FutureTask ft = peers[12].submit(locationKey, new Worker2())
                    .setRequestP2PConfiguration(new RequestP2PConfiguration(1, 0, 0)).start();
            ft.awaitUninterruptibly();
            Assert.assertEquals(true, ft.isSuccess());
            Assert.assertEquals(1, ft.getRawDataMap().size());
        } finally {
            System.out.println("done");
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
            master = peers[0];
            Utils2.perfectRouting(peers);
            // do testing
            Number160 locationKey = new Number160(rnd);
            FutureTask ft = peers[12].submit(locationKey, new Worker2())
                    .setRequestP2PConfiguration(new RequestP2PConfiguration(2, 0, 0)).start();
            ft.awaitUninterruptibly();
            Assert.assertEquals(true, ft.isSuccess());
            Assert.assertEquals(2, ft.getRawDataMap().size());
        } finally {
            System.out.println("done");
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
                        @Override
                        public void operationComplete(FutureRouting futureRouting) throws Exception {
                            if (futureRouting.isSuccess()) {
                                logger.debug("found direct hits for get: {}", futureRouting.directHits());
                                     
                                RequestP2PConfiguration p2pConfiguration2 = adjustConfiguration(builder.requestP2PConfiguration,
                                    futureRouting.potentialHits().size());
                                       
                                // store in direct hits
                                parallelRequests(
                                        p2pConfiguration2,
View Full Code Here
502
503
504
505
506
507
508
509
510
511
512
                            if (futureRouting.isSuccess()) {

                                logger.debug("found direct hits for remove: {}",
                                        futureRouting.directHits());

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

                                parallelRequests(p2pConfiguration2,
                                    builder.isFastGet() ? futureRouting.directHits(): EMPTY_NAVIGABLE_SET,
                                        futureRouting.potentialHits(),
View Full Code Here
730
731
732
733
734
735
736
737
738
        int requested = p2pConfiguration.minimumResults();
        if (size >= requested) {
            return p2pConfiguration;
        } else {
            return new RequestP2PConfiguration(size, p2pConfiguration.maxFailure(),
                    p2pConfiguration.parallelDiff());
        }
    }
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      // do testing
      Data data = new Data(new byte[44444]);
      RoutingConfiguration rc = new RoutingConfiguration(2, 10, 2);
      RequestP2PConfiguration pc = new RequestP2PConfiguration(3, 5, 0);

      FuturePut fp = peers[444].put(peers[30].peerID())
              .data(Number160.createHash("test"), new Number160(5), data).requestP2PConfiguration(pc)
              .routingConfiguration(rc).start();
View Full Code Here
258
259
260
261
262
263
264
265
266
267
268
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      // do testing
      Data data = new Data(new byte[44444]);
      RoutingConfiguration rc = new RoutingConfiguration(0, 0, 1);
      RequestP2PConfiguration pc = new RequestP2PConfiguration(1, 0, 0);
      FuturePut fdht = peers[444].put(peers[30].peerID()).data(new Number160(5), data)
              .domainKey(Number160.createHash("test")).routingConfiguration(rc)
              .requestP2PConfiguration(pc).start();
      fdht.awaitUninterruptibly();
      fdht.futureRequests().awaitUninterruptibly();
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
      PeerDHT[] peers = UtilsDHT2.createNodes(2000, rnd, 4001);
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      // do testing
      RoutingConfiguration rc = new RoutingConfiguration(2, 10, 2);
      RequestP2PConfiguration pc = new RequestP2PConfiguration(3, 5, 0);
      Data data = new Data(new byte[44444]);
      FuturePut fput = peers[444].put(peers[30].peerID()).data(new Number160(5), data)
              .domainKey(Number160.createHash("test")).routingConfiguration(rc)
              .requestP2PConfiguration(pc).start();
      fput.awaitUninterruptibly();
      fput.futureRequests().awaitUninterruptibly();
      Assert.assertEquals(true, fput.isSuccess());
      rc = new RoutingConfiguration(0, 0, 10, 1);
      pc = new RequestP2PConfiguration(1, 0, 0);

      FutureGet fget = peers[555].get(peers[30].peerID()).domainKey(Number160.createHash("test"))
              .contentKey(new Number160(5)).routingConfiguration(rc).requestP2PConfiguration(pc).start();
      fget.awaitUninterruptibly();
      Assert.assertEquals(true, fget.isSuccess());
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
      PeerDHT[] peers = UtilsDHT2.createNodes(2000, rnd, 4001);
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      // do testing
      RoutingConfiguration rc = new RoutingConfiguration(2, 10, 2);
      RequestP2PConfiguration pc = new RequestP2PConfiguration(3, 5, 0);
      Data data = new Data(new byte[44444]);
      Map<Number160, Data> tmp = new HashMap<Number160, Data>();
      tmp.put(new Number160(5), data);
      FuturePut fput = peers[444].put(peers[30].peerID()).dataMapContent(tmp)
              .domainKey(Number160.createHash("test")).routingConfiguration(rc)
View Full Code Here
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
      PeerDHT[] peers = UtilsDHT2.createNodes(1000, rnd, 4001);
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      // do testing
      RoutingConfiguration rc = new RoutingConfiguration(2, 10, 2);
      RequestP2PConfiguration pc = new RequestP2PConfiguration(3, 5, 0);
      Data data = new Data(new byte[44444]);

      FuturePut fput = peers[444].put(peers[30].peerID()).data(new Number160(5), data)
              .domainKey(Number160.createHash("test")).routingConfiguration(rc)
              .requestP2PConfiguration(pc).start();
      fput.awaitUninterruptibly();
      fput.futureRequests().awaitUninterruptibly();
      Assert.assertEquals(true, fput.isSuccess());
      rc = new RoutingConfiguration(4, 0, 10, 1);
      pc = new RequestP2PConfiguration(4, 0, 0);

      FutureGet fget = peers[555].get(peers[30].peerID()).domainKey(Number160.createHash("test"))
              .contentKey(new Number160(5)).routingConfiguration(rc).requestP2PConfiguration(pc).start();
      fget.awaitUninterruptibly();
      Assert.assertEquals(true, fget.isSuccess());
View Full Code Here
TOP

Related Classes of net.tomp2p.p2p.RequestP2PConfiguration

  • lupos.distributed.p2p.network.impl.TomP2P
  • net.tomp2p.dht.DHTBuilder
  • net.tomp2p.dht.DistributedHashTable
  • net.tomp2p.dht.TestAddUpdateTTL
  • net.tomp2p.dht.TestDHT
  • net.tomp2p.dht.TestSecurity
  • net.tomp2p.examples.ExampleDirectData
  • net.tomp2p.examples.ExampleSend
  • net.tomp2p.examples.relay.QueryNode
  • net.tomp2p.p2p.builder.SubmitBuilder
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.