Browse Source

update stress test jni92

JNI-92
heck 5 years ago
parent
commit
c6d2732870
  1. 30
      test/java/foundation/pEp/jniadapter/test/jni92/TestMain.java

30
test/java/foundation/pEp/jniadapter/test/jni92/TestMain.java

@ -29,7 +29,6 @@ class TestThread extends Thread {
class TestMain { class TestMain {
public static Engine createNewEngine() throws pEpException { public static Engine createNewEngine() throws pEpException {
Engine e; Engine e;
TestUtils.logH2("Creating new Engine"); TestUtils.logH2("Creating new Engine");
@ -53,50 +52,43 @@ class TestMain {
}); });
} }
public static void TestMainRun(int nrEngines) { public static void TestMainRun(int nrEngines) {
Vector<Engine> engineVector = TestMain.createEngines(nrEngines); Vector<Engine> engineVector = TestMain.createEngines(nrEngines);
// TestUtils.sleep(200);
Consumer<Engine> c = (e) -> { Consumer<Engine> c = (e) -> {
// Vector<Identity> v = e.own_identities_retrieve(); Vector<Identity> v = e.own_identities_retrieve();
//
// TestUtils.log("own idents: " + v.size()); TestUtils.log("own idents: " + v.size());
// v.forEach( i -> { v.forEach( i -> {
// TestUtils.log(TestUtils.identityToString(i)); TestUtils.log(TestUtils.identityToString(i));
// }); });
e.getVersion(); e.getVersion();
// e.OpenPGP_list_keyinfo(""); e.OpenPGP_list_keyinfo("");
}; };
// TestMain.engineConsumer(engineVector, c); TestMain.engineConsumer(engineVector, c);
} }
public static void main(String[] args) { public static void main(String[] args) {
TestUtils.logH1("JNI-92 Starting"); TestUtils.logH1("JNI-92 Starting");
int nrTestruns = 1000; int nrTestruns = 100;
boolean multiThreaded = true; boolean multiThreaded = true;
int nrThreads = 20; int nrThreads = 200;
int nrEnginesPerThread = 1000; int nrEnginesPerThread = 100;
for (int run = 0; run < nrTestruns; run++ ) { for (int run = 0; run < nrTestruns; run++ ) {
TestUtils.logH1("Testrun Nr: " + run); TestUtils.logH1("Testrun Nr: " + run);
if (!multiThreaded) { if (!multiThreaded) {
// Single Threaded // Single Threaded
// for (int i = 0; i < nrEnginesPerThread; i++) {
// Engine eni = new Engine();
// }
TestMainRun(nrEnginesPerThread); TestMainRun(nrEnginesPerThread);
} else { } else {
// Mutli Threaded // Mutli Threaded
Vector<TestThread> tts = new Vector<TestThread>(); Vector<TestThread> tts = new Vector<TestThread>();
for (int i = 0; i < nrThreads; i++) { for (int i = 0; i < nrThreads; i++) {
tts.add(new TestThread("TestThread-" + i, nrEnginesPerThread)); tts.add(new TestThread("TestThread-" + i, nrEnginesPerThread));
// TestUtils.sleep(200);
} }
tts.forEach(t -> { tts.forEach(t -> {
t.start(); t.start();
// TestUtils.sleep(2000);
}); });
tts.forEach(t -> { tts.forEach(t -> {

Loading…
Cancel
Save