Wait for in-order input to shuffler before emitting anything, otherwise
[dcpomatic.git] / src / lib / shuffler.cc
1 /*
2     Copyright (C) 2018 Carl Hetherington <cth@carlh.net>
3
4     This file is part of DCP-o-matic.
5
6     DCP-o-matic is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     DCP-o-matic is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with DCP-o-matic.  If not, see <http://www.gnu.org/licenses/>.
18
19 */
20
21 #include "shuffler.h"
22 #include "content_video.h"
23 #include "dcpomatic_assert.h"
24 #include <boost/foreach.hpp>
25 #include <iostream>
26
27 using std::make_pair;
28 using boost::weak_ptr;
29 using boost::shared_ptr;
30 using boost::optional;
31
32 struct Comparator
33 {
34         bool operator()(Shuffler::Store const & a, Shuffler::Store const & b) {
35                 if (a.second.frame != b.second.frame) {
36                         return a.second.frame < b.second.frame;
37                 }
38                 return a.second.eyes < b.second.eyes;
39         }
40 };
41
42 void
43 Shuffler::video (weak_ptr<Piece> weak_piece, ContentVideo video)
44 {
45         /* Something has gong wrong if our store gets too big */
46         DCPOMATIC_ASSERT (_store.size() < 8);
47         /* We should only ever see 3D_LEFT / 3D_RIGHT */
48         DCPOMATIC_ASSERT (video.eyes == EYES_LEFT || video.eyes == EYES_RIGHT);
49
50         shared_ptr<Piece> piece = weak_piece.lock ();
51         DCPOMATIC_ASSERT (piece);
52
53         if (!_last && video.eyes == EYES_LEFT) {
54                 /* We haven't seen anything since the last clear() and we have some eyes-left so assume everything is OK */
55                 Video (weak_piece, video);
56                 _last = video;
57                 return;
58         }
59
60         _store.push_back (make_pair (weak_piece, video));
61         _store.sort (Comparator());
62
63         while (
64                 !_store.empty() &&
65                 _last &&
66                 (
67                         (_store.front().second.frame == _last->frame && _store.front().second.eyes == EYES_RIGHT && _last->eyes == EYES_LEFT) ||
68                         (_store.front().second.frame == (_last->frame + 1) && _store.front().second.eyes == EYES_LEFT && _last->eyes == EYES_RIGHT) ||
69                         _store.size() > 8
70                         )
71                 ) {
72
73                 Video (_store.front().first, _store.front().second);
74                 _last = _store.front().second;
75                 _store.pop_front ();
76         }
77 }
78
79 void
80 Shuffler::clear ()
81 {
82         _store.clear ();
83         _last = optional<ContentVideo>();
84 }
85
86 void
87 Shuffler::flush ()
88 {
89         BOOST_FOREACH (Store i, _store) {
90                 Video (i.first, i.second);
91         }
92 }