Package org.hive2hive.core.processes.util

Examples of org.hive2hive.core.processes.util.TestProcessComponentListener

107
108
109
110
111
112
113
114
115
116
117
    SessionParameters sessionParameters = new SessionParameters();
    sessionParameters.setProfileManager(new UserProfileManager(client.getDataManager(), wrongCredentials));

    IProcessComponent loginProcess = ProcessFactory.instance().createLoginProcess(wrongCredentials, sessionParameters,
        client);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    loginProcess.attachListener(listener);
    loginProcess.start();

    UseCaseTestUtil.waitTillFailed(listener, 20);
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
        } catch (SendFailedException e) {
          throw new ProcessExecutionException("Expected behavior.", e);
        }
      }
    };
    TestProcessComponentListener listener = new TestProcessComponentListener();
    step.attachListener(listener);
    step.start();
    // wait for the process to finish
    UseCaseTestUtil.waitTillFailed(listener, 10);
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    String locationKey = holder.getNodeId();
    String contentKey = NetworkTestUtil.randomString();

    TestGetProcessStepRollBack getStepRollBack = new TestGetProcessStepRollBack(locationKey, contentKey,
        getter.getDataManager());
    TestProcessComponentListener listener = new TestProcessComponentListener();
    getStepRollBack.attachListener(listener);
    getStepRollBack.start();

    // wait for the process to finish
    UseCaseTestUtil.waitTillFailed(listener, 10);
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
  public void testDownloadWrongKeys() throws IOException, NoSessionException, GetFailedException,
      InvalidProcessStateException {
    KeyPair wrongKeys = EncryptionUtil.generateRSAKeyPair(H2HConstants.KEYLENGTH_META_FILE);

    IProcessComponent process = ProcessFactory.instance().createDownloadFileProcess(wrongKeys.getPublic(), downloader);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);
    process.start();

    UseCaseTestUtil.waitTillFailed(listener, 20);
  }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
    FileUtils.write(existing, testContent);
    long lastModifiedBefore = existing.lastModified();

    IProcessComponent process = ProcessFactory.instance().createDownloadFileProcess(fileNode.getFilePublicKey(),
        downloader);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);
    process.start();

    UseCaseTestUtil.waitTillFailed(listener, 20);
View Full Code Here
88
89
90
91
92
93
94
95
96
97
                .setData(testData)).awaitUninterruptibly();

    // initialize the process and the one and only step to test
    TestRemoveProcessStep removeStep = new TestRemoveProcessStep(locationKey, contentKey, network.get(0)
        .getDataManager());
    TestProcessComponentListener listener = new TestProcessComponentListener();
    removeStep.attachListener(listener);
    removeStep.start();
    UseCaseTestUtil.waitTillFailed(listener, 10);
  }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    String data = NetworkTestUtil.randomString();

    // initialize the process and the one and only step to test
    TestPutProcessStep putStep = new TestPutProcessStep(locationKey, contentKey, new H2HTestData(data),
        putter.getDataManager());
    TestProcessComponentListener listener = new TestProcessComponentListener();
    putStep.attachListener(listener);
    putStep.start();

    // wait for the process to finish
    UseCaseTestUtil.waitTillFailed(listener, 10);
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
    // skip the login and continue with the newfile process
    NetworkManager client = network.get(2);

    File file = FileTestUtil.createFileRandomContent(1, uploaderRoot, CHUNK_SIZE);
    IProcessComponent process = ProcessFactory.instance().createNewFileProcess(file, client);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);
    process.start();

    UseCaseTestUtil.waitTillFailed(listener, 40);
  }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    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());
    TestProcessComponentListener listener = new TestProcessComponentListener();
    step.attachListener(listener);
    step.start();

    // wait for the process to finish
    UseCaseTestUtil.waitTillFailed(listener, 10);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
    KeyPair key = EncryptionUtil.generateRSAKeyPair(H2HConstants.KEYLENGTH_USER_KEYS);
    NetworkManager node = network.get(random.nextInt(networkSize));

    TestPutUserProfileTaskStep putStep = new TestPutUserProfileTaskStep(userId, userProfileTask, key.getPublic(), node);

    TestProcessComponentListener listener = new TestProcessComponentListener();
    AsyncComponent component = new AsyncComponent(putStep);
    component.attachListener(listener);

    // start and cancel immediately
    component.start();
View Full Code Here
TOP

Related Classes of org.hive2hive.core.processes.util.TestProcessComponentListener

  • org.hive2hive.core.network.data.UserProfileManagerTest
  • org.hive2hive.core.network.userprofiletask.UserProfileTaskQueueTest
  • org.hive2hive.core.processes.framework.ProcessListenerTest
  • org.hive2hive.core.processes.framework.SequentialProcessTest
  • org.hive2hive.core.processes.implementations.common.base.BaseDirectMessageProcessStepTest
  • org.hive2hive.core.processes.implementations.common.base.BaseGetProcessStepTest
  • org.hive2hive.core.processes.implementations.common.base.BaseMessageProcessStepTest
  • org.hive2hive.core.processes.implementations.common.base.BasePutProcessStepTest
  • org.hive2hive.core.processes.implementations.common.base.BaseRemoveProcessStepTest
  • org.hive2hive.core.processes.implementations.common.PutLocationStepTest
    • Copyright © 2018 www.massapicom. 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.