Skip to content
Snippets Groups Projects
Commit 6d069d3f authored by akwizgran's avatar akwizgran
Browse files

Add clock skew reporting.

parent dd799332
No related branches found
Tags release-0.0.1
No related merge requests found
Pipeline #14421 passed
...@@ -466,8 +466,11 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper { ...@@ -466,8 +466,11 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper {
} }
} else if (msg.startsWith("CLOCK_SKEW")) { } else if (msg.startsWith("CLOCK_SKEW")) {
Long skew = parseLongArgument(msg, "SKEW"); Long skew = parseLongArgument(msg, "SKEW");
if (skew != null && LOG.isLoggable(WARNING)) { if (skew != null) {
LOG.warning("Clock is skewed by " + skew + " seconds"); if (LOG.isLoggable(WARNING)) {
LOG.warning("Clock is skewed by " + skew + " seconds");
}
state.onClockSkewDetected(skew);
} }
} }
} }
...@@ -596,8 +599,7 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper { ...@@ -596,8 +599,7 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper {
bootstrapPercentage = percentage; bootstrapPercentage = percentage;
if (observer != null) { if (observer != null) {
// Notify the observer on the event executor // Notify the observer on the event executor
eventExecutor.execute(() -> eventExecutor.execute(() -> observer.onBootstrapPercentage(percentage));
observer.onBootstrapPercentage(percentage));
} }
updateState(); updateState();
} }
...@@ -699,8 +701,14 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper { ...@@ -699,8 +701,14 @@ abstract class AbstractTorWrapper implements EventHandler, TorWrapper {
private synchronized void onHsDescriptorUploaded(String onion) { private synchronized void onHsDescriptorUploaded(String onion) {
if (observer != null) { if (observer != null) {
// Notify the observer on the event executor // Notify the observer on the event executor
eventExecutor.execute(() -> eventExecutor.execute(() -> observer.onHsDescriptorUpload(onion));
observer.onHsDescriptorUpload(onion)); }
}
private synchronized void onClockSkewDetected(long skewSeconds) {
if (observer != null) {
// Notify the observer on the event executor
eventExecutor.execute(() -> observer.onClockSkewDetected(skewSeconds));
} }
} }
} }
......
...@@ -148,6 +148,11 @@ public interface TorWrapper { ...@@ -148,6 +148,11 @@ public interface TorWrapper {
* Called whenever a hidden service descriptor is uploaded. * Called whenever a hidden service descriptor is uploaded.
*/ */
void onHsDescriptorUpload(String onion); void onHsDescriptorUpload(String onion);
/**
* Called whenever Tor detects that the system clock is skewed.
*/
void onClockSkewDetected(long skewSeconds);
} }
class HiddenServiceProperties { class HiddenServiceProperties {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment