Examples of addPeerAddress()

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

145
146
147
148
149
150
151
152
153
154
155
   * @throws NoPeerConnectionException
   */
  @Test
  public void allOtherClientsAreDead() throws NoSessionException, NoPeerConnectionException {
    Locations fakedLocations = new Locations(userId);
    fakedLocations.addPeerAddress(network.get(0).getConnection().getPeer().getPeerAddress());
    // not responding nodes
    fakedLocations.addPeerAddress(network.get(4).getConnection().getPeer().getPeerAddress());
    fakedLocations.addPeerAddress(network.get(5).getConnection().getPeer().getPeerAddress());

    Locations result = runProcessStep(fakedLocations, true);
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

147
148
149
150
151
152
153
154
155
156
157
  @Test
  public void allOtherClientsAreDead() throws NoSessionException, NoPeerConnectionException {
    Locations fakedLocations = new Locations(userId);
    fakedLocations.addPeerAddress(network.get(0).getConnection().getPeer().getPeerAddress());
    // not responding nodes
    fakedLocations.addPeerAddress(network.get(4).getConnection().getPeer().getPeerAddress());
    fakedLocations.addPeerAddress(network.get(5).getConnection().getPeer().getPeerAddress());

    Locations result = runProcessStep(fakedLocations, true);

    assertEquals(1, result.getPeerAddresses().size());
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

148
149
150
151
152
153
154
155
156
157
158
  public void allOtherClientsAreDead() throws NoSessionException, NoPeerConnectionException {
    Locations fakedLocations = new Locations(userId);
    fakedLocations.addPeerAddress(network.get(0).getConnection().getPeer().getPeerAddress());
    // not responding nodes
    fakedLocations.addPeerAddress(network.get(4).getConnection().getPeer().getPeerAddress());
    fakedLocations.addPeerAddress(network.get(5).getConnection().getPeer().getPeerAddress());

    Locations result = runProcessStep(fakedLocations, true);

    assertEquals(1, result.getPeerAddresses().size());
    assertEquals(network.get(0).getConnection().getPeer().getPeerAddress(), result.getPeerAddresses().iterator().next());
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

181
182
183
184
185
186
187
188
189
190
191
   * @throws NoPeerConnectionException
   */
  @Test
  public void notCompleteLocations() throws NoSessionException, NoPeerConnectionException {
    Locations fakedLocations = new Locations(userId);
    fakedLocations.addPeerAddress(network.get(1).getConnection().getPeer().getPeerAddress());

    Locations result = runProcessStep(fakedLocations,
        isInitialClient(fakedLocations, network.get(0).getConnection().getPeer().getPeerAddress()));

    assertEquals(2, result.getPeerAddresses().size());
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

64
65
66
67
68
69
70
71
72
73
74
    proxy.getConnection().getPeer().getPeerBean().storage(new H2HStorageMemory());

    // create the needed objects
    String userId = proxy.getNodeId();
    Locations newLocations = new Locations(userId);
    newLocations.addPeerAddress(putter.getConnection().getPeer().getPeerAddress());
    KeyPair protectionKeys = EncryptionUtil.generateRSAKeyPair();

    // initialize the process and the one and only step to test
    PutLocationContext context = new PutLocationContext(newLocations, protectionKeys);
    PutUserLocationsStep step = new PutUserLocationsStep(context, context, putter.getDataManager());
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

97
98
99
100
101
102
103
104
105
106
107
    proxy.getConnection().getPeer().getPeerBean().storage(new DenyingPutTestStorage());

    // create the needed objects
    String userId = proxy.getNodeId();
    Locations newLocations = new Locations(userId);
    newLocations.addPeerAddress(putter.getConnection().getPeer().getPeerAddress());
    KeyPair protectionKeys = EncryptionUtil.generateRSAKeyPair();

    // initialize the process and the one and only step to test
    PutLocationContext context = new PutLocationContext(newLocations, protectionKeys);
    PutUserLocationsStep step = new PutUserLocationsStep(context, context, putter.getDataManager());
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

116
117
118
119
120
121
122
123
124
125
126
    updatedLocations.setVersionKey(context.consumeLocations().getVersionKey());

    // add addresses that responded and self
    for (PeerAddress address : responses.keySet()) {
      if (responses.get(address)) {
        updatedLocations.addPeerAddress(address);
      }
    }
    updatedLocations.addPeerAddress(networkManager.getConnection().getPeer().getPeerAddress());
    context.provideLocations(updatedLocations);
View Full Code Here

Examples of org.hive2hive.core.model.Locations.addPeerAddress()

119
120
121
122
123
124
125
126
127
128
129
    for (PeerAddress address : responses.keySet()) {
      if (responses.get(address)) {
        updatedLocations.addPeerAddress(address);
      }
    }
    updatedLocations.addPeerAddress(networkManager.getConnection().getPeer().getPeerAddress());
    context.provideLocations(updatedLocations);

    // evaluate if initial
    List<PeerAddress> clientAddresses = new ArrayList<PeerAddress>(updatedLocations.getPeerAddresses());
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.