+
+elif args.encoder_stats:
+ # Broad stats on what encoder threads spent their time doing
+ for t in encoder_threads:
+ last = None
+ asleep = Time()
+ local_encoding = Time()
+ sending = Time()
+ remote_encoding = Time()
+ receiving = Time()
+ wakes = 0
+ for e in t.events:
+ if last is not None:
+ if last[1] == 'encoder-sleep':
+ asleep += e[0] - last[0]
+ elif last[1] == 'encoder-wake':
+ wakes += 1
+ elif last[1] == 'start-local-encode':
+ local_encoding += e[0] - last[0]
+ elif last[1] == 'start-remote-send':
+ sending += e[0] - last[0]
+ elif last[1] == 'start-remote-encode':
+ remote_encoding += e[0] - last[0]
+ elif last[1] == 'start-remote-receive':
+ receiving += e[0] - last[0]
+ elif last[1] == 'start-encoder-thread':
+ find_encoder_thread(last[2]['thread']).server = last[2]['server']
+
+ last = e
+
+ print '-- Encoder thread %s (%s)' % (t.server, t.id)
+ print '\tAwoken %d times' % wakes
+
+ total = asleep.float_seconds() + local_encoding.float_seconds() + sending.float_seconds() + remote_encoding.float_seconds() + receiving.float_seconds()
+ if total == 0:
+ continue
+
+ print '\t%s: %2.f%%' % ('Asleep'.ljust(16), asleep.float_seconds() * 100 / total)
+
+ 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_with_fps(local_encoding, 'Local encoding', total, wakes)
+ if sending.float_seconds() > 0:
+ print '\t%s: %2.f%%' % ('Sending'.ljust(16), sending.float_seconds() * 100 / total)
+ print_with_fps(remote_encoding, 'Remote encoding', total, wakes)
+ if receiving.float_seconds() > 0:
+ print '\t%s: %2.f%%' % ('Receiving'.ljust(16), receiving.float_seconds() * 100 / total)
+ print ''