Enable injection timing reporting in ConcurrentProviders

Netflix · Apr 14, 2015 · 5296cd5 · 5296cd5
1 parent 6d8a66e
commit 5296cd5
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/...nator-core/src/main/java/com/netflix/governator/guice/concurrent/ConcurrentProviders.java b/...nator-core/src/main/java/com/netflix/governator/guice/concurrent/ConcurrentProviders.java
@@ -106,9 +106,9 @@ private T create() {
                 InjectionPoint injectionPoint = InjectionPoint.forConstructorOf(type);
                 final long startTime = System.nanoTime();
 
-//                for (LifecycleListener listener : listeners) {
-//                    listener.objectInjecting(TypeLiteral.get(type));
-//                }
+                for (LifecycleListener listener : listeners) {
+                    listener.objectInjecting(TypeLiteral.get(type));
+                }
                 if (injectionPoint != null) {
                     List<Dependency<?>> deps = injectionPoint.getDependencies();
                     if (deps.size() > 0) {
@@ -163,9 +163,9 @@ public Object get() {
                             try {
                                 T obj = (T)constructor.newInstance(params.toArray());
                                 long duration = System.nanoTime() - startTime;
-//                                for (LifecycleListener listener : listeners) {
-//                                    listener.objectInjected((TypeLiteral<T>)TypeLiteral.get(type), obj, duration, TimeUnit.NANOSECONDS);
-//                                }
+                                for (LifecycleListener listener : listeners) {
+                                    listener.objectInjected((TypeLiteral<T>)TypeLiteral.get(type), obj, duration, TimeUnit.NANOSECONDS);
+                                }
                                 return obj;
                             } catch (Exception e) {
                                 throw new RuntimeException(e);
@@ -180,9 +180,9 @@ public Object get() {
                 try {
                     T obj = type.newInstance();
                     long duration = System.nanoTime() - startTime;
-//                    for (LifecycleListener listener : listeners) {
-//                        listener.objectInjected((TypeLiteral<T>)TypeLiteral.get(type), obj, duration, TimeUnit.NANOSECONDS);
-//                    }
+                    for (LifecycleListener listener : listeners) {
+                        listener.objectInjected((TypeLiteral<T>)TypeLiteral.get(type), obj, duration, TimeUnit.NANOSECONDS);
+                    }
                     return obj;
                 } catch (Exception e) {
                     e.printStackTrace();
@@ -228,14 +228,14 @@ public <S> Supplier<S> getCreator(final Key<S> key) {
                     @Override
                     public S get() {
                         final long startTime = System.nanoTime();
-//                        for (LifecycleListener listener : listeners) {
-//                            listener.objectInjecting(key.getTypeLiteral());
-//                        }
+                        for (LifecycleListener listener : listeners) {
+                            listener.objectInjecting(key.getTypeLiteral());
+                        }
                         S obj = injector.getInstance(key);
                         final long duration = System.nanoTime() - startTime;
-//                        for (LifecycleListener listener : listeners) {
-//                            listener.objectInjected(key.getTypeLiteral(), obj, System.nanoTime() - startTime, TimeUnit.NANOSECONDS);
-//                        }
+                        for (LifecycleListener listener : listeners) {
+                            listener.objectInjected(key.getTypeLiteral(), obj, duration, TimeUnit.NANOSECONDS);
+                        }
                         return obj;
                     }
                 };