Package net.tomp2p.futures

Examples of net.tomp2p.futures.FuturePut.awaitUninterruptibly()

644
645
646
647
648
649
650
651
652
653
654
    // try to overwrite with wrong protection keys 2 (expected to fail)
    Data data2B = new Data("data2B").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut2B = p1.put(lKey).setData(cKey, data2B).setDomainKey(dKey).setVersionKey(vKey)
        .keyPair(keyPair2).start();
    futurePut2B.awaitUninterruptibly();
    assertFalse(futurePut2B.isSuccess());

    // verify that nothing changed
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
658
659
660
661
662
663
664
665
666
667
668
    // change protection keys to protection keys 2, create meta data
    Data data3 = new Data().setProtectedEntry().publicKey(keyPair2.getPublic()).duplicateMeta();
    // use the old protection key 1 to sign the message
    FuturePut futurePut3 = p1.put(lKey).setDomainKey(dKey).setVersionKey(vKey).putMeta()
        .setData(cKey, data3).keyPair(keyPair1).start();
    futurePut3.awaitUninterruptibly();
    assertTrue(futurePut3.isSuccess());

    // verify change
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
673
674
675
676
677
678
679
680
681
682
683
    // overwrite with protection keys 2
    Data data4 = new Data("data4").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut4 = p1.put(lKey).setData(cKey, data4).setDomainKey(dKey).setVersionKey(vKey)
        .keyPair(keyPair2).start();
    futurePut4.awaitUninterruptibly();
    assertTrue(futurePut4.isSuccess());

    // verify overwrite
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
686
687
688
689
690
691
692
693
694
695
696
    // try to overwrite without protection keys (expected to fail)
    Data data5A = new Data("data5A").basedOn(bKey);
    FuturePut futurePut5A = p1.put(lKey).setData(cKey, data5A).setDomainKey(dKey).setVersionKey(vKey)
        .start();
    futurePut5A.awaitUninterruptibly();
    assertFalse(futurePut5A.isSuccess());

    // verify that nothing changed
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
699
700
701
702
703
704
705
706
707
708
709
   
    // try to overwrite with wrong protection keys 1 (expected to fail)
    Data data5B = new Data("data5B").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut5B = p1.put(lKey).setData(cKey, data5B).setDomainKey(dKey).setVersionKey(vKey)
        .keyPair(keyPair1).start();
    futurePut5B.awaitUninterruptibly();
    assertFalse(futurePut5B.isSuccess());

    // verify that nothing changed
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
754
755
756
757
758
759
760
761
762
763
764
    // initial put with keys 1 and data signature
    Data data = new Data("data").sign(keyPair1, factory);
    data.ttlSeconds(ttl).basedOn(bKey);
    FuturePut futurePut = p1.put(lKey).setDomainKey(dKey).setData(cKey, data).setVersionKey(vKey).start();
    futurePut.awaitUninterruptibly();
    Assert.assertTrue(futurePut.isSuccess());

    // create signature with keys 1 having the data object
    byte[] signature1 = factory.sign(keyPair1.getPrivate(), data.buffer()).encode();
View Full Code Here
780
781
782
783
784
785
786
787
788
789
790
    data = new Data().ttlSeconds(ttl).signature(codec.decode(signatureNew));
    // don't forget to set signed flag, create meta data
    data.signed(true).duplicateMeta();
    FuturePut futurePutMeta = p1.put(lKey).setDomainKey(dKey).putMeta().setData(cKey, data)
        .setVersionKey(vKey).start();
    futurePutMeta.awaitUninterruptibly();
    Assert.assertTrue(futurePutMeta.isSuccess());

    // verify new data signature
    Data retData = p1.get(lKey).setDomainKey(dKey).setContentKey(cKey).setVersionKey(vKey).start()
        .awaitUninterruptibly().getData();
View Full Code Here
836
837
838
839
840
841
842
843
844
845
846
    Data intialData = new Data("data").setProtectedEntry();
    intialData.ttlSeconds(ttl).basedOn(bKey).sign(keyPair1, factory);
    // put using content protection key 1 to sign message
    FuturePut futureIntialPut = p1.put(lKey).setDomainKey(dKey).setData(cKey, intialData)
        .setVersionKey(vKey).keyPair(keyPair1).start();
    futureIntialPut.awaitUninterruptibly();
    Assert.assertTrue(futureIntialPut.isSuccess());

    // verify put
    Data retData = p1.get(lKey).setDomainKey(dKey).setContentKey(cKey).setVersionKey(vKey).start()
        .awaitUninterruptibly().getData();
View Full Code Here
853
854
855
856
857
858
859
860
861
862
863
    Data data = new Data("dataA");
    data.ttlSeconds(ttl).basedOn(bKey).sign(keyPair1, factory);
    // put using content protection key 1 to sign message
    FuturePut futureTryOverwrite = p1.put(lKey).setDomainKey(dKey).setData(cKey, data)
        .setVersionKey(vKey).start();
    futureTryOverwrite.awaitUninterruptibly();
    Assert.assertFalse(futureTryOverwrite.isSuccess());

    // verify that nothing changed
    retData = p1.get(lKey).setDomainKey(dKey).setContentKey(cKey).setVersionKey(vKey).start()
        .awaitUninterruptibly().getData();
View Full Code Here
870
871
872
873
874
875
876
877
878
879
880
    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());

    // verify that nothing changed
    retData = p1.get(lKey).setDomainKey(dKey).setContentKey(cKey).setVersionKey(vKey).start()
        .awaitUninterruptibly().getData();
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.