Package org.hive2hive.core

Examples of org.hive2hive.core.H2HWaiter.tickASecond()

126
127
128
129
130
131
132
133
134
135
136
    process.attachListener(listener);
    process.start();

    H2HWaiter waiter = new H2HWaiter(60);
    do {
      waiter.tickASecond();
    } while (!listener.hasFailed());

    // verify if the md5 hash did not change
    UserProfile userProfile = UseCaseTestUtil.getUserProfile(downloader, userCredentials);
    FileIndex fileNode = (FileIndex) userProfile.getFileByPath(file, uploaderRoot);
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    UseCaseTestUtil.executeProcess(step);

    // wait till message gets handled
    H2HWaiter w = new H2HWaiter(10);
    do {
      w.tickASecond();
      futureGet = nodeA.getDataManager().getUnblocked(parameters);
      futureGet.awaitUninterruptibly();
    } while (futureGet.getData() == null);

    // verify that data arrived
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
    UseCaseTestUtil.executeProcess(step);

    // wait till response message gets handled
    H2HWaiter waiter = new H2HWaiter(10);
    do {
      waiter.tickASecond();
      futureGet = nodeA.getDataManager().getUnblocked(parametersA);
      futureGet.awaitUninterruptibly();
    } while (futureGet.getData() == null);

    // load and verify if same secret was shared
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    UseCaseTestUtil.executeProcess(step);

    // wait till message gets handled
    H2HWaiter w = new H2HWaiter(10);
    do {
      w.tickASecond();
      futureGet = nodeB.getDataManager().getUnblocked(parameters);
      futureGet.awaitUninterruptibly();
    } while (futureGet.getData() == null);

    // verify that data arrived
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
    UseCaseTestUtil.executeProcess(step);

    // wait till response message gets handled
    H2HWaiter waiter = new H2HWaiter(10);
    do {
      waiter.tickASecond();
      futureGet = nodeA.getDataManager().getUnblocked(parametersA);
      futureGet.awaitUninterruptibly();
    } while (futureGet.getData() == null);

    // load and verify if same secret was shared
View Full Code Here
687
688
689
690
691
692
693
694
695
696
697
   *            the file to synchronize
   */
  private static void waitTillSynchronized(File synchronizingFile) {
    H2HWaiter waiter = new H2HWaiter(40);
    do {
      waiter.tickASecond();
    } while (!synchronizingFile.exists());
  }

  private static void compareFiles(File originalFile, File synchronizedFile) throws IOException {
    Assert.assertEquals(originalFile.getName(), synchronizedFile.getName());
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
   *            the file to synchronize
   */
  private static void waitTillSynchronized(File synchronizingFile) {
    H2HWaiter waiter = new H2HWaiter(40);
    do {
      waiter.tickASecond();
    } while (!synchronizingFile.exists());
  }

  private static void compareFiles(File originalFile, File synchronizedFile) throws IOException {
    Assert.assertEquals(originalFile.getName(), synchronizedFile.getName());
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
  private static void waitTillSynchronized(File synchronizingFile, boolean appearing) {
    H2HWaiter waiter = new H2HWaiter(40);
    if (appearing) {
      do {
        waiter.tickASecond();
      } while (!synchronizingFile.exists());
    } else {
      do {
        waiter.tickASecond();
      } while (synchronizingFile.exists());
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
      do {
        waiter.tickASecond();
      } while (!synchronizingFile.exists());
    } else {
      do {
        waiter.tickASecond();
      } while (synchronizingFile.exists());
    }
  }

  @AfterClass
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
    File file = new File(downloaderRoot, relative.toString());

    // give some seconds for the file to download
    H2HWaiter waiter = new H2HWaiter(10);
    do {
      waiter.tickASecond();
    } while (!file.exists());

    Assert.assertTrue(file.exists());
    if (originalFile.isFile()) {
      Assert.assertEquals(FileUtils.readFileToString(originalFile), FileUtils.readFileToString(file));
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.