X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=hacks%2Fanalog.py;h=355dabe495e5f6f906e9da9851c9b9ce22f1d6bf;hb=5f8250c029d342ebb670deff6007fb044dd4a38d;hp=760f58ea0c2189607a4025dd5766d75c6214662a;hpb=c55877926307d7018942beb5fd65a39f278e05de;p=dcpomatic.git

diff --git a/hacks/analog.py b/hacks/analog.py
index 760f58ea0..355dabe49 100644
--- a/hacks/analog.py
+++ b/hacks/analog.py
@@ -11,13 +11,15 @@ import matplotlib.pyplot as plt
 parser = argparse.ArgumentParser()
 parser.add_argument('log_file')
 parser.add_argument('-q', '--queue', help='plot queue size', action='store_true')
-parser.add_argument('-e', '--encoder-threads', help='plot encoder thread activity', action='store_true')
+parser.add_argument('--encoder-threads', help='plot encoder thread activity', action='store_true')
 parser.add_argument('-f', '--plot-first-encoder', help='plot more detailed activity of the first encoder thread', action='store_true')
 parser.add_argument('-s', '--fps-stats', help='frames-per-second stats', action='store_true')
 parser.add_argument('--encoder-stats', help='encoder thread activity stats', action='store_true')
-parser.add_argument('--dump-first-encoder', help='dump activity of the first encoder thread', action='store_true')
+parser.add_argument('--encoder-dump', help='dump activity of the specified encoder', action='store_true')
+parser.add_argument('-e', '--encoder', help='encoder index (from 0)')
 parser.add_argument('--from', help='time in seconds to start at', type=int, dest='from_time')
 parser.add_argument('--to', help='time in seconds to stop at', type=int, dest='to_time')
+parser.add_argument('--max-encoder-threads', help='maximum number of encoder threads to plot with --encoder-threads', type=int, default=None)
 args = parser.parse_args()
 
 def find_nth(haystack, needle, n):
@@ -112,7 +114,16 @@ while True:
         try:
             T = Time(time.mktime(time.strptime(l[:s])))
         except:
-            T = Time(time.mktime(time.strptime(l[:s], "%d.%m.%Y %H:%M:%S")))
+            try:
+                T = Time(time.mktime(time.strptime(l[:s], "%d.%m.%Y %H:%M:%S")))
+            except:
+                try:
+                    T = Time(time.mktime(time.strptime(l[:s], "%d/%m/%Y %H:%M:%S")))
+                except:
+                    x = l[:s]
+                    if not x.endswith('M'):
+                        x += 'M'
+                    T = Time(time.mktime(time.strptime(x, "%d/%m/%Y %H:%M:%S %p")))
         message = l[s+2:]
 
     # T is elapsed time since the first log message
@@ -153,6 +164,11 @@ elif args.encoder_threads:
     # y=0 thread is sleeping
     # y=1 thread is awake
     # y=2 thread is encoding
+    # y=3 thread is awaiting a remote encode
+
+    if args.max_encoder_threads is not None:
+        encoder_threads = encoder_threads[0:min(args.max_encoder_threads, len(encoder_threads))]
+    
     plt.figure()
     N = len(encoder_threads)
     n = 1
@@ -167,6 +183,8 @@ elif args.encoder_threads:
                 continue
             if args.to_time is not None and e[0].float_seconds() >= args.to_time:
                 continue
+            if e[1] == 'start-remote-send' or e[1] == 'finish-remote-send' or e[1] == 'start-remote-receive' or e[1] == 'finish-remote-receive':
+                continue
             x.append(e[0].float_seconds())
             x.append(e[0].float_seconds())
             y.append(previous)
@@ -178,6 +196,10 @@ elif args.encoder_threads:
                 y.append(2)
             elif e[1] == 'finish-local-encode':
                 y.append(1)
+            elif e[1] == 'start-remote-encode':
+                y.append(3)
+            elif e[1] == 'finish-remote-encode':
+                y.append(1)
             else:
                 print>>sys.stderr,'unknown event %s' % e[1]
                 sys.exit(1)
@@ -197,7 +219,7 @@ elif args.plot_first_encoder:
 
     N = 6
     n = 1
-    for t in ['sleep', 'wake', 'begin_encode', 'end_encode']:
+    for t in ['encoder-sleep', 'encoder-wake', 'start-local-encode', 'finish-local-encode']:
         plt.subplot(N, 1, n)
         x = []
         y = []
@@ -220,12 +242,12 @@ elif args.plot_first_encoder:
 
     plt.show()
 
-elif args.dump_first_encoder:
-    events = encoder_thread_events.itervalues().next()
-    last = 0
-    for e in events:
-        print e[0].float_seconds(), (e[0].float_seconds() - last), e[1]
-        last = e[0].float_seconds()
+elif args.encoder_dump:
+    for t in encoder_threads[int(args.encoder)]:
+        last = 0
+        for e in t.events:
+            print (e[0].float_seconds() - last), e[1]
+            last = e[0].float_seconds()
 
 elif args.fps_stats:
     local = 0
@@ -288,11 +310,11 @@ elif args.encoder_stats:
         if total == 0:
             continue
 
-        print '\t%s: %2.f%%' % ('Asleep'.ljust(16), asleep.float_seconds() * 100 / total)
+        print '\t%s: %2.f%% %fs' % ('Asleep'.ljust(16), asleep.float_seconds() * 100 / total, asleep.float_seconds())
 
         def print_with_fps(v, name, total, frames):
             if v.float_seconds() > 1:
-                print '\t%s: %2.f%% %.2ffps' % (name.ljust(16), v.float_seconds() * 100 / total, frames / v.float_seconds())
+                print '\t%s: %2.f%% %f %.2ffps' % (name.ljust(16), v.float_seconds() * 100 / total, v.float_seconds(), frames / v.float_seconds())
 
         print_with_fps(local_encoding, 'Local encoding', total, wakes)
         if sending.float_seconds() > 0: