Don't announce job is finished until things have been torn down; may help with #1674.
[dcpomatic.git] / hacks / check_packets.py
1 #!/usr/bin/python
2
3 import subprocess
4 import shlex
5 import sys
6
7 last_video = None
8 last_video_pts = None
9
10 def handle(frame):
11     global last_video
12     global last_video_pts
13     if frame['media_type'] == 'video':
14         if last_video_pts is not None and frame['pkt_pts_time'] <= last_video_pts:
15             print 'Out of order video frame %f (%d) is same as or behind %f (%d)' % (frame['pkt_pts_time'], frame['pkt_pts'], last_video_pts, last_video)
16         else:
17             print 'OK frame %f' % frame['pkt_pts_time']
18         last_video = frame['pkt_pts']
19         last_video_pts = frame['pkt_pts_time']
20
21 p = subprocess.Popen(shlex.split('ffprobe -show_frames %s' % sys.argv[1]), stdin=None, stdout=subprocess.PIPE)
22 frame = dict()
23 while True:
24     l = p.stdout.readline()
25     if l == '':
26         break
27
28     l = l.strip()
29
30     if l == '[/FRAME]':
31         handle(frame)
32         frame = dict()
33     elif l != '[FRAME]' and l != '[SIDE_DATA]' and l != '[/SIDE_DATA]':
34         s = l.split('=')
35         if s[0] == 'pkt_pts_time':
36             frame[s[0]] = float(s[1])
37         elif s[0] == 'pkt_pts':
38             frame[s[0]] = float(s[1]) 
39         elif len(s) > 1:
40             frame[s[0]] = s[1]