Package net.tomp2p.dht

Examples of net.tomp2p.dht.PeerDHT.shutdown()

21
22
23
24
25
26
27
28
29
30
31
      exampleSendOne(peers[14]);
      Thread.sleep(60000);
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      master.shutdown();
    }
  }

  private static void exampleSendOne(PeerDHT peer) {
    RequestP2PConfiguration requestP2PConfiguration = new RequestP2PConfiguration(1, 10, 0);
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
                MyData<String> myData = (MyData<String>) data.object();
        System.out.println("key: " + myData.key() + ", domain: " + myData.domain() + ", content: "
                + myData.content() + ", data: " + myData.data());
      }
    } finally {
      master.shutdown();
    }
  }

  private static class MyPeer {
    final private PeerDHT peer;
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
            exampleUnQL(peers);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally {
            master.shutdown();
        }
    }

    private static void exampleUnQL(PeerDHT[] peers) throws IOException, ClassNotFoundException {
        execute(peers[22], new Query(QUERY_1));
View Full Code Here
665
666
667
668
669
670
671
672
673
674
675
    } finally {
      if (master != null) {
        master.shutdown().await();
      }
      if (unreachablePeer != null) {
        unreachablePeer.shutdown().await();
      }
    }
  }

  @Test
View Full Code Here
730
731
732
733
734
735
736
737
738
739
740
    } finally {
      if(master != null) {
        master.shutdown().await();
      }
      if(unreachablePeer != null) {
        unreachablePeer.shutdown().await();
      }
    }
  }

  @Test
View Full Code Here
812
813
814
815
816
817
818
819
820
821
822
      }
      if(unreachablePeer1 != null) {
        unreachablePeer1.shutdown().await();
      }
      if(unreachablePeer2 != null) {
        unreachablePeer2.shutdown().await();
      }
    }
  }

  @Test
View Full Code Here
250
251
252
253
254
255
256
257
258
259
260
    } finally {
      if (sender != null) {
        sender.shutdown().await();
      }
      if (receiver != null) {
        receiver.shutdown().await();
      }
    }
  }

  @Test
View Full Code Here
312
313
314
315
316
317
318
319
320
321
322
    } finally {
      if (sender != null) {
        sender.shutdown().await();
      }
      if (receiver != null) {
        receiver.shutdown().await();
      }
    }
  }

  @Test
View Full Code Here
897
898
899
900
901
902
903
904
905
906
907
       }
       if(unreachablePeer1 != null) {
         unreachablePeer1.shutdown().await();
       }
       if(unreachablePeer2 != null) {
         unreachablePeer2.shutdown().await();
       }
         }
    }
 
  @Test
View Full Code Here
383
384
385
386
387
388
389
390
391
392
393
    } finally {
      if (sender != null) {
        sender.shutdown().await();
      }
      if (receiver != null) {
        receiver.shutdown().await();
      }
    }
  }

  @Test
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.