Package net.tomp2p.storage

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

212
213
214
215
216
217
218
219
220
221
222
      FutureGet fdht2 = master.get(Number160.ONE).start();
      fdht2.awaitUninterruptibly();
      System.err.println(fdht2.failedReason());
      Assert.assertEquals(true, fdht2.isSuccess());
      Data tmp = fdht2.data();
      Assert.assertEquals("hallo", tmp.object().toString());
    } finally {
      if (master != null) {
        master.shutdown().await();
      }
    }
View Full Code Here
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
      Assert.assertTrue(dataMap.containsKey(key7a));
      Assert.assertEquals(data7a.object(), dataMap.get(key7a).object());

      Number640 key7b = new Number640(key480, vKey7b);
      Assert.assertTrue(dataMap.containsKey(key7b));
      Assert.assertEquals(data7b.object(), dataMap.get(key7b).object());

      // get latest versions with digest
      FutureGet fgetWithDigest = peers[rnd.nextInt(10)].get(locationKey).domainKey(domainKey)
          .contentKey(contentKey).getLatest().withDigest().start();
      fgetWithDigest.awaitUninterruptibly();
View Full Code Here
1948
1949
1950
1951
1952
1953
1954
1955
1956
1957
1958
      Assert.assertTrue(dataMap.containsKey(key6b));
      Assert.assertEquals(data6b.object(), dataMap.get(key6b).object());

      Number640 key7 = new Number640(key480, vKey7);
      Assert.assertTrue(dataMap.containsKey(key7));
      Assert.assertEquals(data7.object(), dataMap.get(key7).object());

      // get latest versions with digest
      FutureGet fgetWithDigest = peers[rnd.nextInt(10)].get(locationKey).domainKey(domainKey)
          .contentKey(contentKey).getLatest().withDigest().start();
      fgetWithDigest.awaitUninterruptibly();
View Full Code Here
2035
2036
2037
2038
2039
2040
2041
2042
2043
2044
2045
      Assert.assertEquals(1, dataMap.size());
      Number480 key480 = new Number480(locationKey, domainKey, contentKey);

      Number640 key2 = new Number640(key480, vKey2);
      Assert.assertTrue(dataMap.containsKey(key2));
      Assert.assertEquals(data2.object(), dataMap.get(key2).object());

      // get latest versions with digest
      FutureGet fgetWithDigest = peers[rnd.nextInt(10)].get(locationKey).domainKey(domainKey)
          .contentKey(contentKey).getLatest().withDigest().start();
      fgetWithDigest.awaitUninterruptibly();
View Full Code Here
976
977
978
979
980
981
982
983
984
985
986
    futurePut4.awaitUninterruptibly();
    Assert.assertFalse(futurePut4.isSuccess());
    // verify if the two versions have the new protection key
    Data retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).versionKey(vKey1).start()
            .awaitUninterruptibly().data();
    Assert.assertEquals("data1v1", (String) retData.object());
    Assert.assertFalse(retData.verify(keyPair2.getPublic(), factory));
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).versionKey(vKey2).start()
            .awaitUninterruptibly().data();
    //Assert.assertEquals("data1v2", (String) retData.object());
    Assert.assertFalse(retData.verify(keyPair2.getPublic(), factory));
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
    }

    private void testGet(StorageLayer storage) throws IOException, ClassNotFoundException {
        store(storage);
        Data result1 = storage.get(key1);
        Assert.assertEquals("test1", result1.object());
        Data result2 = storage.get(key2);
        Assert.assertEquals("test2", result2.object());
        Data result3 = storage.get(key3);
        Assert.assertEquals(null, result3);
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
    private void testGet(StorageLayer storage) throws IOException, ClassNotFoundException {
        store(storage);
        Data result1 = storage.get(key1);
        Assert.assertEquals("test1", result1.object());
        Data result2 = storage.get(key2);
        Assert.assertEquals("test2", result2.object());
        Data result3 = storage.get(key3);
        Assert.assertEquals(null, result3);
    }

    @Test
View Full Code Here
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
        Assert.assertEquals(1, dataMap.size());
        Number480 key480 = new Number480(locationKey, domainKey, contentKey);

        Number640 key = new Number640(key480, vKey);
        Assert.assertTrue(dataMap.containsKey(key));
        Assert.assertEquals(data.object(), dataMap.get(key).object());

        // check digest result
        DigestResult digestResult = fget.digest();
        Assert.assertEquals(sortedMap.size(), digestResult.keyDigest().size());
        for (Number160 versionKey : sortedMap.keySet()) {
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
    }

    private void testRemove(StorageLayer storage) throws IOException, ClassNotFoundException {
        store(storage);
        Data result1 = storage.remove(key1, null, true).element0();
        Assert.assertEquals("test1", result1.object());
        SortedMap<Number640, Data> result2 = storage.get(key1, key4, -1, true);
        Assert.assertEquals(1, result2.size());
        store(storage);
        SortedMap<Number640, Data> result3 = storage.removeReturnData(key1, key4, null);
        Assert.assertEquals(2, result3.size());
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
        for (int i = 0; i < 10; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        Assert.assertEquals("test1", result1.object());   
                    } catch (Throwable t) {
                        t.printStackTrace();
                        counter.incrementAndGet();
                    }
                }
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.