Examples of ttlSeconds()

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

866
867
868
869
870
871
872
873
874
875
876
    // verify that data signature is still the same
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));

    // try to overwrite with wrong protection keys 2 and data signature (expected to fail)
    data = new Data("dataB").setProtectedEntry();
    data.ttlSeconds(ttl).basedOn(bKey).sign(keyPair1, factory);
    // put using wrong content protection keys 2 to sign message
    futureTryOverwrite = p1.put(lKey).setDomainKey(dKey).setData(cKey, data).setVersionKey(vKey)
        .keyPair(keyPair2).start();
    futureTryOverwrite.awaitUninterruptibly();
    Assert.assertFalse(futureTryOverwrite.isSuccess());
View Full Code Here

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

883
884
885
886
887
888
889
890
891
892
893
    // verify that data signature is still the same
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));

    // try to overwrite without content protection and without data signature (expected to fail)
    data = new Data("dataC");
    data.ttlSeconds(ttl).basedOn(bKey).sign(keyPair1, factory);
    // put using wrong content protection keys 2 to sign message
    futureTryOverwrite = p1.put(lKey).setDomainKey(dKey).setData(cKey, data).setVersionKey(vKey).start();
    futureTryOverwrite.awaitUninterruptibly();
    Assert.assertFalse(futureTryOverwrite.isSuccess());
View Full Code Here

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

60
61
62
63
64
65
66
67
68
69
70
    int ttl = 4;

    String testData = "data";
    Data data = new Data(testData).setProtectedEntry();
    data.ttlSeconds(ttl).basedOn(bKey);

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

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

83
84
85
86
87
88
89
90
91
92
93
    FutureDigest futureDigest = p1.digest(lKey).setDomainKey(dKey).setContentKey(cKey)
        .setVersionKey(vKey).returnMetaValues().start();
    futureDigest.awaitUninterruptibly();
    Assert.assertTrue(futureDigest.isSuccess());
    Data dataMeta = futureDigest.getDigest().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()

751
752
753
754
755
756
757
758
759
760
761
        data.signature(newData.signature());
        changed = true;
      }
      if (data!=null) {
        data.validFromMillis(newData.validFromMillis());
        data.ttlSeconds(newData.ttlSeconds());
        changed = true;
      }
      if (changed) {
        long expiration = data.expirationMillis();
        // handle timeout
View Full Code Here

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

785
786
787
788
789
790
791
792
793
794
795
      if (data != null) {
        // remove prepare flag
        data.prepareFlag(false);

        data.validFromMillis(newData.validFromMillis());
        data.ttlSeconds(newData.ttlSeconds());

        long expiration = data.expirationMillis();
        // handle timeout
        backend.addTimeout(key, expiration);
        found = backend.put(key, data);
View Full Code Here

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

73
74
75
76
77
78
79
80
81
82
83
    try {
      PeerDHT[] peers = UtilsDHT2.createNodes(10, rnd, 4001);
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      final Data data1 = new Data(new byte[1]);
      data1.ttlSeconds(3);
      FuturePut futurePut = master.put(Number160.createHash("test")).data(data1).start();
      futurePut.awaitUninterruptibly();
      Assert.assertEquals(true, futurePut.isSuccess());
      FutureGet futureGet = peers[1].get(Number160.createHash("test")).start();
      futureGet.awaitUninterruptibly();
View Full Code Here

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

99
100
101
102
103
104
105
106
107
108
109
    try {
      PeerDHT[] peers = UtilsDHT2.createNodes(10, rnd, 4001);
      master = peers[0];
      UtilsDHT2.perfectRouting(peers);
      final Data data1 = new Data(new byte[1]);
      data1.ttlSeconds(3);
      FuturePut futurePut = master.put(Number160.createHash("test")).versionKey(Number160.MAX_VALUE)
              .data(data1).start();
      futurePut.awaitUninterruptibly();
      Assert.assertEquals(true, futurePut.isSuccess());
      //
View Full Code Here

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

227
228
229
230
231
232
233
234
235
236
237
    PeerDHT master = null;
    try {
      Peer pmaster = new PeerBuilder(new Number160(rnd)).ports(4001).start();
      master = new PeerBuilderDHT(pmaster).storage(new StorageMemory(1)).start();
      Data data = new Data("hallo");
      data.ttlSeconds(1);
      FuturePut fdht = master.put(Number160.ONE).data(data).start();
      fdht.awaitUninterruptibly();
      fdht.futureRequests().awaitUninterruptibly();
      Assert.assertEquals(true, fdht.isSuccess());
      Thread.sleep(3000);
View Full Code Here

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

1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
      final PeerDHT[] peers = UtilsDHT2.createNodes(100, rnd, 4001);
      master = peers[0];
      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() {
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.