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

log an ping notification improvements

Browse source
This commit is contained in:
anhefti 2022-03-31 08:11:55 +02:00
parent 16582d0ce8
commit 23c63783d7
2 changed files with 3 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/indicator/AbstractClientIndicator.java
View file

@ -84,8 +84,8 @@ public abstract class AbstractClientIndicator implements ClientIndicator {
this.connectionId, this.connectionId,
getType()); getType());
if (this.ditributedIndicatorValueRecordId == null) { if (this.ditributedIndicatorValueRecordId == null && log.isDebugEnabled()) {
log.warn("Failed to recover from missing indicator value cache record: {} type: {}", log.debug("Failed to recover from missing indicator value cache record: {} type: {}",
this.connectionId, this.connectionId,
getType()); getType());
} }

10
src/main/java/ch/ethz/seb/sebserver/webservice/servicelayer/session/impl/indicator/AbstractPingIndicator.java
View file

@ -30,15 +30,7 @@ public abstract class AbstractPingIndicator extends AbstractClientIndicator {
public final void notifyPing(final long timestamp, final int pingNumber) { public final void notifyPing(final long timestamp, final int pingNumber) {
super.currentValue = timestamp; super.currentValue = timestamp;
if (!this.cachingEnabled) { if (!this.cachingEnabled && super.ditributedIndicatorValueRecordId != null) {
if (super.ditributedIndicatorValueRecordId == null) {
tryRecoverIndicatorRecord();
if (this.ditributedIndicatorValueRecordId == null) {
return;
}
}
this.distributedIndicatorValueService.updatePingAsync(this.ditributedIndicatorValueRecordId); this.distributedIndicatorValueService.updatePingAsync(this.ditributedIndicatorValueRecordId);
} }
} }