Examples of ttlSeconds()

Examples of net.tomp2p.storage.Data.ttlSeconds()

1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
      UtilsDHT2.perfectRouting(peers);
      final Number160 key = Number160.createHash("test");
      final Data data1 = new Data("test1");
      data1.ttlSeconds(3);
      final Data data2 = new Data("test2");
      data2.ttlSeconds(3);

      // add every second a two values
      Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

66
67
68
69
70
71
72
73
74
75
76
      Number160 bKey = Number160.createHash(basedOnKey);

      H2HTestData testData = new H2HTestData(s1);

      Data data = new Data(testData);
      data.ttlSeconds(10000);
      data.addBasedOn(bKey);
      data.protectEntryNow(keyPair, factory);
      FuturePut futurePut1 = p1.put(lKey).data(cKey, data).domainKey(dKey).versionKey(vKey)
              .keyPair(keyPair).start();
      futurePut1.awaitUninterruptibly();
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

118
119
120
121
122
123
124
125
126
127
128
        return new PeerBuilderDHT(peer).start();
    }

    private void add(PeerDHT peer, byte[] key, byte[] value) throws InterruptedException {
        Data data = new Data(value);
        data.ttlSeconds(3);
        peer.add(new Number160(key)).data(data).routingConfiguration(new RoutingConfiguration(1, 0, 10, 1))
                .requestP2PConfiguration(new RequestP2PConfiguration(3, 5, 0)).start()
                .addListener(new BaseFutureAdapter<FuturePut>() {
                    @Override
                    public void operationComplete(final FuturePut future) throws Exception {
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
    int ttl = 4;

    String testData = "data";
    Data data = new Data(testData).protectEntry(keyPair1);
    data.ttlSeconds(ttl).addBasedOn(bKey);

    // initial put
    FuturePut futurePut = p1.put(lKey).domainKey(dKey).data(cKey, data).versionKey(vKey).keyPair(keyPair1)
            .start();
    futurePut.awaitUninterruptibly();
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
    FutureDigest futureDigest = p1.digest(lKey).domainKey(dKey).contentKey(cKey).versionKey(vKey)
            .returnMetaValues().start();
    futureDigest.awaitUninterruptibly();
    Assert.assertTrue(futureDigest.isSuccess());
    Data dataMeta = futureDigest.digest().dataMap().values().iterator().next();
    Assert.assertTrue(ttl > dataMeta.ttlSeconds());

    // wait again a moment, till data gets expired
    Thread.sleep(2000);

    // check if data has been removed
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
    int ttl = 10;

    String testData = "data";
    Data data = new Data(testData).protectEntryNow(keyPairOld, factory);
    data.ttlSeconds(ttl).addBasedOn(bKey);

    // initial put of some test data
    FuturePut futurePut = p1.put(lKey).domainKey(dKey).data(cKey, data).versionKey(vKey)
            .keyPair(keyPairOld).start();
    futurePut.awaitUninterruptibly();
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

261
262
263
264
265
266
267
268
269
270
271
        storageM.close();
    }

    private void testTTL1(StorageLayer storage) throws Exception {
        Data data = new Data("string");
        data.ttlSeconds(0);
        storage.put(key1, data, null, false, false);
        Thread.sleep(2000);
        Data tmp = storage.get(key1);
        Assert.assertEquals(true, tmp != null);
    }
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

277
278
279
280
281
282
283
284
285
286
287
        storageM.close();
    }

    private void testTTL2(StorageLayer storage) throws Exception {
        Data data = new Data("string");
        data.ttlSeconds(1);
        storage.put(key1, data, null, false, false);
        Thread.sleep(2000);
        storage.checkTimeout();
        Data tmp = storage.get(key1);
        Assert.assertEquals(true, tmp == null);
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

295
296
297
298
299
300
301
302
303
304
305
        storageM.close();
    }
   
    private void testTTLLeak(StorageLayer storage) throws Exception {
        Data data = new Data("string");
        data.ttlSeconds(1);
        storage.put(key1, data, null, false, false);
        Thread.sleep(2000);
        storage.checkTimeout();
        Data tmp = storage.get(key1);
        Assert.assertEquals(true, tmp == null);
View Full Code Here

Examples of net.tomp2p.storage.Data.ttlSeconds()

689
690
691
692
693
694
695
696
697
698
699
      p2.peer().bootstrap().peerAddress(p1.peerAddress()).start().awaitUninterruptibly();
      p1.peer().bootstrap().peerAddress(p2.peerAddress()).start().awaitUninterruptibly();

      Data data = new Data("test1");
      data.ttlSeconds(1);
      FuturePut fp1 = p1.put(Number160.createHash("key1")).data(data).start().awaitUninterruptibly();
      Assert.assertTrue(fp1.isSuccess());

      Thread.sleep(2000);
      Data retData = p2.get(Number160.createHash("key1")).start().awaitUninterruptibly().data();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.