In-line run of subs_in_out so that it gets the environment more easily.
[libdcp.git] / src / stereo_picture_asset_writer.cc
1 /*
2     Copyright (C) 2012-2021 Carl Hetherington <cth@carlh.net>
3
4     This file is part of libdcp.
5
6     libdcp 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     libdcp 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 libdcp.  If not, see <http://www.gnu.org/licenses/>.
18
19     In addition, as a special exception, the copyright holders give
20     permission to link the code of portions of this program with the
21     OpenSSL library under certain conditions as described in each
22     individual source file, and distribute linked combinations
23     including the two.
24
25     You must obey the GNU General Public License in all respects
26     for all of the code used other than OpenSSL.  If you modify
27     file(s) with this exception, you may extend this exception to your
28     version of the file(s), but you are not obligated to do so.  If you
29     do not wish to do so, delete this exception statement from your
30     version.  If you delete this exception statement from all source
31     files in the program, then also delete it here.
32 */
33
34
35 /** @file  src/stereo_picture_asset_writer.cc
36  *  @brief StereoPictureAssetWriter class
37  */
38
39
40 #include "stereo_picture_asset_writer.h"
41 #include "exceptions.h"
42 #include "dcp_assert.h"
43 #include "picture_asset.h"
44 #include "crypto_context.h"
45 #include <asdcp/AS_DCP.h>
46 #include <asdcp/KM_fileio.h>
47
48
49 #include "picture_asset_writer_common.cc"
50
51
52 using std::string;
53 using std::shared_ptr;
54 using namespace dcp;
55
56
57 struct StereoPictureAssetWriter::ASDCPState : public ASDCPStateBase
58 {
59         ASDCP::JP2K::MXFSWriter mxf_writer;
60 };
61
62
63 StereoPictureAssetWriter::StereoPictureAssetWriter (PictureAsset* mxf, boost::filesystem::path file, bool overwrite)
64         : PictureAssetWriter (mxf, file, overwrite)
65         , _state (new StereoPictureAssetWriter::ASDCPState)
66 {
67
68 }
69
70
71 StereoPictureAssetWriter::~StereoPictureAssetWriter()
72 {
73         try {
74                 /* Last-resort finalization to close the file, at least */
75                 if (!_finalized) {
76                         _state->mxf_writer.Finalize();
77                 }
78         } catch (...) {}
79 }
80
81
82 void
83 StereoPictureAssetWriter::start (uint8_t const * data, int size)
84 {
85         dcp::start (this, _state, _picture_asset, data, size);
86         _picture_asset->set_frame_rate (Fraction (_picture_asset->edit_rate().numerator * 2, _picture_asset->edit_rate().denominator));
87 }
88
89
90 FrameInfo
91 StereoPictureAssetWriter::write (uint8_t const * data, int size)
92 {
93         DCP_ASSERT (!_finalized);
94
95         if (!_started) {
96                 start (data, size);
97         }
98
99         if (ASDCP_FAILURE (_state->j2k_parser.OpenReadFrame (data, size, _state->frame_buffer))) {
100                 boost::throw_exception (MiscError ("could not parse J2K frame"));
101         }
102
103         _state->frame_buffer.PlaintextOffset(0);
104
105         uint64_t const before_offset = _state->mxf_writer.Tell ();
106
107         string hash;
108         auto r = _state->mxf_writer.WriteFrame (
109                 _state->frame_buffer,
110                 _next_eye == Eye::LEFT ? ASDCP::JP2K::SP_LEFT : ASDCP::JP2K::SP_RIGHT,
111                 _crypto_context->context(),
112                 _crypto_context->hmac(),
113                 &hash
114                 );
115
116         if (ASDCP_FAILURE (r)) {
117                 boost::throw_exception (MXFFileError ("error in writing video MXF", _file.string(), r));
118         }
119
120         _next_eye = _next_eye == Eye::LEFT ? Eye::RIGHT : Eye::LEFT;
121
122         if (_next_eye == Eye::LEFT) {
123                 ++_frames_written;
124         }
125
126         return FrameInfo (before_offset, _state->mxf_writer.Tell() - before_offset, hash);
127 }
128
129
130 void
131 StereoPictureAssetWriter::fake_write (int size)
132 {
133         DCP_ASSERT (_started);
134         DCP_ASSERT (!_finalized);
135
136         auto r = _state->mxf_writer.FakeWriteFrame (size, _next_eye == Eye::LEFT ? ASDCP::JP2K::SP_LEFT : ASDCP::JP2K::SP_RIGHT);
137         if (ASDCP_FAILURE(r)) {
138                 boost::throw_exception (MXFFileError("error in writing video MXF", _file.string(), r));
139         }
140
141         _next_eye = _next_eye == Eye::LEFT ? Eye::RIGHT : Eye::LEFT;
142         if (_next_eye == Eye::LEFT) {
143                 ++_frames_written;
144         }
145 }
146
147
148 bool
149 StereoPictureAssetWriter::finalize ()
150 {
151         if (_started) {
152                 auto r = _state->mxf_writer.Finalize();
153                 if (ASDCP_FAILURE(r)) {
154                         boost::throw_exception (MXFFileError("error in finalizing video MXF", _file.string(), r));
155                 }
156         }
157
158         _picture_asset->_intrinsic_duration = _frames_written;
159         return PictureAssetWriter::finalize ();
160 }