zervo/seb-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

no sync in ping and event

Browse source
This commit is contained in:
anhefti 2023-06-01 14:43:54 +02:00
parent 45e01dc0dd
commit 5dc85f9e73
2 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/SEBClientEventBatchService.java
View file

@ -161,10 +161,10 @@ public class SEBClientEventBatchService {
}
ClientConnectionDataInternal clientConnection = null;
synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
clientConnection = this.examSessionCacheService
.getClientConnection(eventData.connectionToken);
}
//synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
clientConnection = this.examSessionCacheService
.getClientConnection(eventData.connectionToken);
//}
if (clientConnection == null) {
log.error("Failed to get ClientConnectionDataInternal for: {}", eventData.connectionToken);
@ -208,10 +208,10 @@ public class SEBClientEventBatchService {
try {
ClientConnectionDataInternal clientConnection = null;
synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
clientConnection = this.examSessionCacheService
.getClientConnection(eventData.connectionToken);
}
//synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
clientConnection = this.examSessionCacheService
.getClientConnection(eventData.connectionToken);
//}
if (clientConnection == null) {
log.warn("Failed to retrieve ClientConnection for token {}. Skip this event",

8
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/SEBClientPingBatchService.java
View file

@ -92,10 +92,10 @@ public class SEBClientPingBatchService {
}
ClientConnectionDataInternal activeClientConnection = null;
synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
activeClientConnection = this.examSessionCacheService
.getClientConnection(connectionToken);
}
//synchronized (ExamSessionCacheService.CLIENT_CONNECTION_CREATION_LOCK) {
activeClientConnection = this.examSessionCacheService
.getClientConnection(connectionToken);
//}
if (activeClientConnection != null) {
activeClientConnection.notifyPing(timestamp);