eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-23 06:06:11 +00:00
Code Activity

secured replication tests by MAJORITY read/write concern to avoid race conditions

Browse Source
This commit is contained in:
Axel Uhl
2024-06-11 14:29:45 +02:00
parent 4576450303
commit 0b04f1cabb
5 changed files with 40 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sse.replication.testsupport/src/com/sap/sse/replication/testsupport/AbstractServerReplicationTestSetUp.java
+4 -3
View File
@@ -47,6 +47,7 @@ import com.sap.sse.replication.Replicable;
import com.sap.sse.replication.ReplicationMasterDescriptor;
import com.sap.sse.replication.ReplicationReceiver;
import com.sap.sse.replication.ReplicationService;
import com.sap.sse.replication.ReplicationServletActions.Action;
import com.sap.sse.replication.impl.Activator;
import com.sap.sse.replication.impl.RabbitOutputStream;
import com.sap.sse.replication.impl.ReplicationInstancesManager;
@@ -367,17 +368,17 @@ public abstract class AbstractServerReplicationTestSetUp<ReplicableInterface ext
pw.println("Content-Type: text/plain");
pw.println();
pw.flush();
if (request.contains("DEREGISTER")) {
if (request.contains(Action.DEREGISTER.name())) {
// assuming that it is safe to unregister all replicas for tests
for (ReplicaDescriptor descriptor : getReplicaInfo()) {
unregisterReplica(descriptor);
}
} else if (request.contains("REGISTER")) {
} else if (request.contains(Action.REGISTER.name())) {
final String uuid = UUID.randomUUID().toString();
registerReplicaUuidForMaster(uuid, masterDescriptor);
masterReplicationService.registerReplica(replicaDescriptor);
pw.print(uuid);
} else if (request.contains("INITIAL_LOAD")) {
} else if (request.contains(Action.INITIAL_LOAD.name())) {
Channel channel = masterReplicationService.createMasterChannel();
RabbitOutputStream ros = new RabbitOutputStream(INITIAL_LOAD_PACKAGE_SIZE, channel,
/* queueName */ "initial-load-for-TestClient-"+UUID.randomUUID(), /* syncAfterTimeout */ false);