Package net.tomp2p.futures

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

462
463
464
465
466
467
468
469
470
471
472
    // put version 1 with content protection keys
    Data data1 = new Data("data1").setProtectedEntry();
    Number160 vKey1 = Number160.createHash("version1");
    FuturePut futurePut1 = p1.put(lKey).setDomainKey(dKey).setData(cKey, data1).setVersionKey(vKey1)
        .keyPair(key).start();
    futurePut1.awaitUninterruptibly();
    assertTrue(futurePut1.isSuccess());

    // put version 2 basing on version 1 with content protection keys
    Data data2 = new Data("data2").basedOn(vKey1).setProtectedEntry();
    Number160 vKey2 = Number160.createHash("version2");
View Full Code Here
470
471
472
473
474
475
476
477
478
479
480
    // put version 2 basing on version 1 with content protection keys
    Data data2 = new Data("data2").basedOn(vKey1).setProtectedEntry();
    Number160 vKey2 = Number160.createHash("version2");
    FuturePut futurePut2 = p1.put(lKey).setDomainKey(dKey).setData(cKey, data2).setVersionKey(vKey2)
        .keyPair(key).start();
    futurePut2.awaitUninterruptibly();
    assertTrue(futurePut2.isSuccess());

    // remove with correct content protection keys using from/to
    FutureRemove futureRemove = p1.remove(lKey).from(new Number640(lKey, dKey, cKey, Number160.ZERO))
        .to(new Number640(lKey, dKey, cKey, Number160.MAX_VALUE)).keyPair(key).start();
View Full Code Here
524
525
526
527
528
529
530
531
532
533
534
    Number160 cKey = Number160.createHash("content");

    // initial put with protection keys 1
    Data data1 = new Data("data1").setProtectedEntry();
    FuturePut futurePut1 = p1.put(lKey).setData(cKey, data1).setDomainKey(dKey).keyPair(keyPair1).start();
    futurePut1.awaitUninterruptibly();
    assertTrue(futurePut1.isSuccess());

    // 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
View Full Code Here
532
533
534
535
536
537
538
539
540
541
542
    // 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).putMeta().setData(cKey, data3)
        .keyPair(keyPair1).start();
    futurePut3.awaitUninterruptibly();
    assertTrue(futurePut3.isSuccess());

    // verify that nothing changed
    FutureGet futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).start()
        .awaitUninterruptibly();
View Full Code Here
545
546
547
548
549
550
551
552
553
554
555
    assertEquals(keyPair2.getPublic(), futureGet.getData().publicKey());

    // overwrite with protection keys 2
    Data data4 = new Data("data4").setProtectedEntry();
    FuturePut futurePut4 = p1.put(lKey).setData(cKey, data4).setDomainKey(dKey).keyPair(keyPair2).start();
    futurePut4.awaitUninterruptibly();
    assertTrue(futurePut4.isSuccess());

    // verify overwrite
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).start()
        .awaitUninterruptibly();
View Full Code Here
557
558
559
560
561
562
563
564
565
566
567
    assertEquals(keyPair2.getPublic(), futureGet.getData().publicKey());

    // try to overwrite without protection keys (expected to fail)
    Data data5A = new Data("data5A");
    FuturePut futurePut5A = p1.put(lKey).setData(cKey, data5A).setDomainKey(dKey).start();
    futurePut5A.awaitUninterruptibly();
    assertFalse(futurePut5A.isSuccess());

    // verify that nothing changed
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).start()
        .awaitUninterruptibly();
View Full Code Here
570
571
572
573
574
575
576
577
578
579
580
    // try to overwrite with wrong protection keys 1 (expected to fail)
    Data data5B = new Data("data5B").setProtectedEntry();
    FuturePut futurePut5B = p1.put(lKey).setData(cKey, data5B).setDomainKey(dKey).keyPair(keyPair1)
        .start();
    futurePut5B.awaitUninterruptibly();
    assertFalse(futurePut5B.isSuccess());

    // verify that nothing changed
    futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).start()
        .awaitUninterruptibly();
View Full Code Here
611
612
613
614
615
616
617
618
619
620
621
    // initial put with protection keys 1
    Data data1 = new Data("data1").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut1 = p1.put(lKey).setData(cKey, data1).setDomainKey(dKey).setVersionKey(vKey)
        .keyPair(keyPair1).start();
    futurePut1.awaitUninterruptibly();
    assertTrue(futurePut1.isSuccess());

    // overwrite with protection keys 1
    Data data2 = new Data("data2").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut2 = p1.put(lKey).setData(cKey, data2).setDomainKey(dKey).setVersionKey(vKey)
View Full Code Here
618
619
620
621
622
623
624
625
626
627
628
    // overwrite with protection keys 1
    Data data2 = new Data("data2").basedOn(bKey).setProtectedEntry();
    FuturePut futurePut2 = p1.put(lKey).setData(cKey, data2).setDomainKey(dKey).setVersionKey(vKey)
        .keyPair(keyPair1).start();
    futurePut2.awaitUninterruptibly();
    assertTrue(futurePut2.isSuccess());

    // verify overwrite
    FutureGet futureGet = p2.get(lKey).setContentKey(cKey).setDomainKey(dKey).setVersionKey(vKey).start()
        .awaitUninterruptibly();
View Full Code Here
631
632
633
634
635
636
637
638
639
640
641
    // try to overwrite without protection keys (expected to fail)
    Data data2A = new Data("data2A").basedOn(bKey);
    FuturePut futurePut2A = p1.put(lKey).setData(cKey, data2A).setDomainKey(dKey).setVersionKey(vKey)
        .start();
    futurePut2A.awaitUninterruptibly();
    assertFalse(futurePut2A.isSuccess());

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