caspervk/AndroidAPS
1
0
Fork 0
Code Releases Activity

Log summary after 10s, then every 60s.

Browse source
This commit is contained in:
Johannes Mockenhaupt 2017-10-14 18:07:12 +02:00
parent 785a8f21de
commit 82dd8c2c5e
No known key found for this signature in database
GPG key ID: 9E1EA6AF7BBBB0D1
1 changed files with 31 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
app/src/main/java/com/squareup/otto/LoggingBus.java
View file

@ -5,12 +5,24 @@ import org.slf4j.LoggerFactory;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import info.nightscout.androidaps.events.Event; import info.nightscout.androidaps.events.Event;
/** Logs events has they're being posted to and dispatched from the event bus.
*
* A summary of references between sender and event and event and receiver is printed
* after 10s (after startup) and then again every 60s.
* */
public class LoggingBus extends Bus { public class LoggingBus extends Bus {
private static Logger log = LoggerFactory.getLogger(LoggingBus.class); private static Logger log = LoggerFactory.getLogger(LoggingBus.class);
private static long everyMinute = System.currentTimeMillis() + 10 * 1000;
private Map<String, Set<String>> event2Receiver = new HashMap<>();
public LoggingBus(ThreadEnforcer enforcer) { public LoggingBus(ThreadEnforcer enforcer) {
super(enforcer); super(enforcer);
} }
@ -48,10 +60,28 @@ public class LoggingBus extends Bus {
Method targcetMethod = (Method) methodField.get(wrapper); Method targcetMethod = (Method) methodField.get(wrapper);
String className = targcetMethod.getDeclaringClass().getSimpleName(); String className = targcetMethod.getDeclaringClass().getSimpleName();
String methodName = targcetMethod.getName(); String methodName = targcetMethod.getName();
log.debug(" receiver: " + className + "." + methodName); String receiverMethod = className + "." + methodName;
log.debug(" receiver: " + receiverMethod);
String key = event.getClass().getSimpleName();
if (!event2Receiver.containsKey(key)) event2Receiver.put(key, new HashSet<String>());
event2Receiver.get(key).add(receiverMethod);
} catch (ReflectiveOperationException e) { } catch (ReflectiveOperationException e) {
log.debug(" receiver: <unknown>"); log.debug(" receiver: <unknown>");
} }
if (everyMinute < System.currentTimeMillis()) {
log.debug("***************** The story so far ****************");
for (Map.Entry<String, Set<String>> stringSetEntry : event2Receiver.entrySet()) {
log.debug(" " + stringSetEntry.getKey());
for (String s : stringSetEntry.getValue()) {
log.debug(" -> " + s);
}
}
log.debug("***************************************************");
everyMinute = System.currentTimeMillis() + 60 * 1000;
}
super.dispatch(event, wrapper); super.dispatch(event, wrapper);
} }
} }