You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

954 lines
37KB

  1. /*
  2. * MXF demuxer.
  3. * Copyright (c) 2006 SmartJog S.A., Baptiste Coudurier <baptiste dot coudurier at smartjog dot com>.
  4. *
  5. * This library is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU Lesser General Public
  7. * License as published by the Free Software Foundation; either
  8. * version 2 of the License, or (at your option) any later version.
  9. *
  10. * This library is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  13. * Lesser General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU Lesser General Public
  16. * License along with this library; if not, write to the Free Software
  17. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  18. */
  19. /*
  20. * References
  21. * SMPTE 336M KLV Data Encoding Protocol Using Key-Length-Value
  22. * SMPTE 377M MXF File Format Specifications
  23. * SMPTE 378M Operational Pattern 1a
  24. * SMPTE 379M MXF Generic Container
  25. * SMPTE 381M Mapping MPEG Streams into the MXF Generic Container
  26. * SMPTE 382M Mapping AES3 and Broadcast Wave Audio into the MXF Generic Container
  27. * SMPTE 383M Mapping DV-DIF Data to the MXF Generic Container
  28. *
  29. * Principle
  30. * Search for Track numbers which will identify essence element KLV packets.
  31. * Search for SourcePackage which define tracks which contains Track numbers.
  32. * Material Package contains tracks with reference to SourcePackage tracks.
  33. * Search for Descriptors (Picture, Sound) which contains codec info and parameters.
  34. * Assign Descriptors to correct Tracks.
  35. *
  36. * Metadata reading functions read Local Tags, get InstanceUID(0x3C0A) and then resolve Strong Reference from another object.
  37. * Returns -1 if Strong Reference could not be resolved.
  38. *
  39. * Simple demuxer, only OP1A supported and some files might not work at all.
  40. * Only tracks with associated descriptors will be decoded. "Highly Desirable" SMPTE 377M D.1
  41. * Only descriptors with EssenceSoundCompression or PictureEssenceCoding will be taken into account. "D/req" SMPTE 377M
  42. */
  43. //#define DEBUG
  44. #include "avformat.h"
  45. typedef uint8_t UID[16];
  46. enum MXFPackageType {
  47. MaterialPackage,
  48. SourcePackage,
  49. };
  50. enum MXFStructuralComponentType {
  51. Timecode,
  52. SourceClip,
  53. };
  54. typedef struct MXFStructuralComponent {
  55. UID uid;
  56. UID source_package_uid;
  57. UID data_definition_ul;
  58. int64_t duration;
  59. int64_t start_position;
  60. int source_track_id;
  61. enum MXFStructuralComponentType type;
  62. } MXFStructuralComponent;
  63. typedef struct MXFSequence {
  64. UID uid;
  65. UID data_definition_ul;
  66. MXFStructuralComponent **structural_components;
  67. UID *structural_components_refs;
  68. int structural_components_count;
  69. int64_t duration;
  70. } MXFSequence;
  71. typedef struct MXFTrack {
  72. UID uid;
  73. MXFSequence *sequence; /* mandatory, and only one */
  74. UID sequence_ref;
  75. int track_id;
  76. uint8_t track_number[4];
  77. AVRational edit_rate;
  78. } MXFTrack;
  79. typedef struct MXFDescriptor {
  80. UID uid;
  81. UID essence_container_ul;
  82. UID essence_codec_ul;
  83. AVRational sample_rate;
  84. AVRational aspect_ratio;
  85. int width;
  86. int height;
  87. int channels;
  88. int bits_per_sample;
  89. struct MXFDescriptor **sub_descriptors;
  90. UID *sub_descriptors_refs;
  91. int sub_descriptors_count;
  92. int linked_track_id;
  93. } MXFDescriptor;
  94. typedef struct MXFPackage {
  95. UID uid;
  96. UID package_uid;
  97. MXFTrack **tracks;
  98. UID *tracks_refs;
  99. int tracks_count;
  100. MXFDescriptor *descriptor; /* only one */
  101. UID descriptor_ref;
  102. enum MXFPackageType type;
  103. } MXFPackage;
  104. typedef struct MXFEssenceContainerData {
  105. UID uid;
  106. UID linked_package_uid;
  107. } MXFEssenceContainerData;
  108. typedef struct MXFContext {
  109. MXFPackage **packages;
  110. UID *packages_refs;
  111. int packages_count;
  112. MXFEssenceContainerData **essence_container_data_sets;
  113. UID *essence_container_data_sets_refs;
  114. int essence_container_data_sets_count;
  115. UID *essence_containers_uls; /* Universal Labels SMPTE RP224 */
  116. int essence_containers_uls_count;
  117. UID operational_pattern_ul;
  118. UID content_storage_uid;
  119. AVFormatContext *fc;
  120. } MXFContext;
  121. typedef struct KLVPacket {
  122. UID key;
  123. offset_t offset;
  124. uint64_t length;
  125. } KLVPacket;
  126. typedef struct MXFCodecUL {
  127. UID uid;
  128. enum CodecID id;
  129. } MXFCodecUL;
  130. static const UID mxf_metadata_preface_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x2F,0x00 };
  131. static const UID mxf_metadata_content_storage_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x18,0x00 };
  132. static const UID mxf_metadata_source_package_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x37,0x00 };
  133. static const UID mxf_metadata_material_package_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x36,0x00 };
  134. static const UID mxf_metadata_sequence_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x0F,0x00 };
  135. static const UID mxf_metadata_source_clip_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x11,0x00 };
  136. static const UID mxf_metadata_multiple_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x44,0x00 };
  137. static const UID mxf_metadata_generic_sound_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x42,0x00 };
  138. static const UID mxf_metadata_cdci_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x28,0x00 };
  139. static const UID mxf_metadata_rgba_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x29,0x00 };
  140. static const UID mxf_metadata_mpegvideo_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x51,0x00 };
  141. static const UID mxf_metadata_wave_descriptor_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x48,0x00 };
  142. static const UID mxf_metadata_static_track_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x3A,0x00 };
  143. static const UID mxf_metadata_track_key = { 0x06,0x0e,0x2b,0x34,0x02,0x53,0x01,0x01,0x0d,0x01,0x01,0x01,0x01,0x01,0x3b,0x00 };
  144. /* partial keys to match */
  145. static const uint8_t mxf_header_partition_pack_key[] = { 0x06,0x0e,0x2b,0x34,0x02,0x05,0x01,0x01,0x0d,0x01,0x02,0x01,0x01,0x02 };
  146. static const uint8_t mxf_essence_element_key[] = { 0x06,0x0e,0x2b,0x34,0x01,0x02,0x01,0x01,0x0d,0x01,0x03,0x01 };
  147. #define IS_KLV_KEY(x, y) (!memcmp(x, y, sizeof(y)))
  148. #define PRINT_KEY(x) dprintf("%02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X %02X\n", \
  149. x[0], x[1], x[2], x[3], x[4], x[5], x[6], x[7], x[8], x[9], x[10], x[11], x[12], x[13], x[14], x[15])
  150. static int64_t klv_decode_ber_length(ByteIOContext *pb)
  151. {
  152. int64_t size = 0;
  153. uint8_t length = get_byte(pb);
  154. int type = length >> 7;
  155. if (type) { /* long form */
  156. int bytes_num = length & 0x7f;
  157. /* SMPTE 379M 5.3.4 guarantee that bytes_num must not exceed 8 bytes */
  158. if (bytes_num > 8)
  159. return -1;
  160. while (bytes_num--)
  161. size = size << 8 | get_byte(pb);
  162. } else {
  163. size = length & 0x7f;
  164. }
  165. return size;
  166. }
  167. static int klv_read_packet(KLVPacket *klv, ByteIOContext *pb)
  168. {
  169. klv->offset = url_ftell(pb);
  170. get_buffer(pb, klv->key, 16);
  171. klv->length = klv_decode_ber_length(pb);
  172. return klv->length == -1 ? -1 : 0;
  173. }
  174. static int mxf_get_stream_index(AVFormatContext *s, KLVPacket *klv)
  175. {
  176. int i;
  177. for (i = 0; i < s->nb_streams; i++) {
  178. MXFTrack *track = s->streams[i]->priv_data;
  179. /* SMPTE 379M 7.3 */
  180. if (!memcmp(klv->key + sizeof(mxf_essence_element_key), track->track_number, sizeof(track->track_number)))
  181. return i;
  182. }
  183. return -1;
  184. }
  185. static int mxf_read_packet(AVFormatContext *s, AVPacket *pkt)
  186. {
  187. KLVPacket klv;
  188. while (!url_feof(&s->pb)) {
  189. if (klv_read_packet(&klv, &s->pb) < 0) {
  190. av_log(s, AV_LOG_ERROR, "error reading KLV packet\n");
  191. return -1;
  192. }
  193. #ifdef DEBUG
  194. PRINT_KEY(klv.key);
  195. #endif
  196. if (IS_KLV_KEY(klv.key, mxf_essence_element_key)) {
  197. av_get_packet(&s->pb, pkt, klv.length);
  198. pkt->stream_index = mxf_get_stream_index(s, &klv);
  199. return pkt->stream_index == -1 ? -1 : 0;
  200. } else
  201. url_fskip(&s->pb, klv.length);
  202. }
  203. return AVERROR_IO;
  204. }
  205. static int mxf_read_metadata_preface(MXFContext *mxf, KLVPacket *klv)
  206. {
  207. ByteIOContext *pb = &mxf->fc->pb;
  208. int bytes_read = 0;
  209. while (bytes_read < klv->length) {
  210. int tag = get_be16(pb);
  211. int size = get_be16(pb); /* SMPTE 336M Table 8 KLV specified length, 0x53 */
  212. switch (tag) {
  213. case 0x3B03:
  214. get_buffer(pb, mxf->content_storage_uid, 16);
  215. break;
  216. case 0x3B09:
  217. get_buffer(pb, mxf->operational_pattern_ul, 16);
  218. break;
  219. case 0x3B0A:
  220. mxf->essence_containers_uls_count = get_be32(pb);
  221. if (mxf->essence_containers_uls_count >= UINT_MAX / sizeof(UID))
  222. return -1;
  223. mxf->essence_containers_uls = av_malloc(mxf->essence_containers_uls_count * sizeof(UID));
  224. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  225. get_buffer(pb, mxf->essence_containers_uls, mxf->essence_containers_uls_count * sizeof(UID));
  226. break;
  227. default:
  228. url_fskip(pb, size);
  229. }
  230. bytes_read += size + 4;
  231. }
  232. return 0;
  233. }
  234. static int mxf_read_metadata_content_storage(MXFContext *mxf, KLVPacket *klv)
  235. {
  236. ByteIOContext *pb = &mxf->fc->pb;
  237. int bytes_read = 0;
  238. while (bytes_read < klv->length) {
  239. int tag = get_be16(pb);
  240. int size = get_be16(pb); /* SMPTE 336M Table 8 KLV specified length, 0x53 */
  241. dprintf("tag 0x%04X, size %d\n", tag, size);
  242. switch (tag) {
  243. case 0x1901:
  244. mxf->packages_count = get_be32(pb);
  245. if (mxf->packages_count >= UINT_MAX / sizeof(UID) ||
  246. mxf->packages_count >= UINT_MAX / sizeof(*mxf->packages))
  247. return -1;
  248. mxf->packages_refs = av_malloc(mxf->packages_count * sizeof(UID));
  249. mxf->packages = av_mallocz(mxf->packages_count * sizeof(*mxf->packages));
  250. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  251. get_buffer(pb, mxf->packages_refs, mxf->packages_count * sizeof(UID));
  252. break;
  253. case 0x1902:
  254. mxf->essence_container_data_sets_count = get_be32(pb);
  255. if (mxf->essence_container_data_sets_count >= UINT_MAX / sizeof(UID) ||
  256. mxf->essence_container_data_sets_count >= UINT_MAX / sizeof(*mxf->essence_container_data_sets))
  257. return -1;
  258. mxf->essence_container_data_sets_refs = av_malloc(mxf->essence_container_data_sets_count * sizeof(UID));
  259. mxf->essence_container_data_sets = av_mallocz(mxf->essence_container_data_sets_count * sizeof(*mxf->essence_container_data_sets));
  260. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  261. get_buffer(pb, mxf->essence_container_data_sets_refs, mxf->essence_container_data_sets_count * sizeof(UID));
  262. break;
  263. default:
  264. url_fskip(pb, size);
  265. }
  266. bytes_read += size + 4;
  267. }
  268. return 0;
  269. }
  270. static int mxf_read_metadata_source_clip(MXFContext *mxf, KLVPacket *klv)
  271. {
  272. ByteIOContext *pb = &mxf->fc->pb;
  273. MXFStructuralComponent *source_clip = av_mallocz(sizeof(*source_clip));
  274. int bytes_read = 0;
  275. int i, j, k;
  276. source_clip->type = SourceClip;
  277. while (bytes_read < klv->length) {
  278. int tag = get_be16(pb);
  279. int size = get_be16(pb); /* SMPTE 336M Table 8 KLV specified length, 0x53 */
  280. dprintf("tag 0x%04X, size %d\n", tag, size);
  281. switch (tag) {
  282. case 0x3C0A:
  283. get_buffer(pb, source_clip->uid, 16);
  284. break;
  285. case 0x0202:
  286. source_clip->duration = get_be64(pb);
  287. break;
  288. case 0x1201:
  289. source_clip->start_position = get_be64(pb);
  290. break;
  291. case 0x1101:
  292. /* UMID, only get last 16 bytes */
  293. url_fskip(pb, 16);
  294. get_buffer(pb, source_clip->source_package_uid, 16);
  295. break;
  296. case 0x1102:
  297. source_clip->source_track_id = get_be32(pb);
  298. break;
  299. default:
  300. url_fskip(pb, size);
  301. }
  302. bytes_read += size + 4;
  303. }
  304. for (i = 0; i < mxf->packages_count; i++) {
  305. if (mxf->packages[i]) {
  306. for (j = 0; j < mxf->packages[i]->tracks_count; j++) {
  307. if (mxf->packages[i]->tracks[j] && mxf->packages[i]->tracks[j]->sequence) {
  308. for (k = 0; k < mxf->packages[i]->tracks[j]->sequence->structural_components_count; k++) {
  309. if (!memcmp(mxf->packages[i]->tracks[j]->sequence->structural_components_refs[k], source_clip->uid, 16)) {
  310. mxf->packages[i]->tracks[j]->sequence->structural_components[k] = source_clip;
  311. return 0;
  312. }
  313. }
  314. }
  315. }
  316. }
  317. }
  318. return -1;
  319. }
  320. static int mxf_read_metadata_material_package(MXFContext *mxf, KLVPacket *klv)
  321. {
  322. ByteIOContext *pb = &mxf->fc->pb;
  323. MXFPackage *package = av_mallocz(sizeof(*package));
  324. int bytes_read = 0;
  325. int i;
  326. package->type = MaterialPackage;
  327. while (bytes_read < klv->length) {
  328. int tag = get_be16(pb);
  329. int size = get_be16(pb); /* KLV specified by 0x53 */
  330. switch (tag) {
  331. case 0x3C0A:
  332. get_buffer(pb, package->uid, 16);
  333. break;
  334. case 0x4403:
  335. package->tracks_count = get_be32(pb);
  336. if (package->tracks_count >= UINT_MAX / sizeof(UID) ||
  337. package->tracks_count >= UINT_MAX / sizeof(*package->tracks))
  338. return -1;
  339. package->tracks_refs = av_malloc(package->tracks_count * sizeof(UID));
  340. package->tracks = av_mallocz(package->tracks_count * sizeof(*package->tracks));
  341. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  342. get_buffer(pb, package->tracks_refs, package->tracks_count * sizeof(UID));
  343. break;
  344. default:
  345. url_fskip(pb, size);
  346. }
  347. bytes_read += size + 4;
  348. }
  349. for (i = 0; i < mxf->packages_count; i++) {
  350. if (!memcmp(mxf->packages_refs[i], package->uid, 16)) {
  351. mxf->packages[i] = package;
  352. return 0;
  353. }
  354. }
  355. return -1;
  356. }
  357. static int mxf_read_metadata_track(MXFContext *mxf, KLVPacket *klv)
  358. {
  359. ByteIOContext *pb = &mxf->fc->pb;
  360. MXFTrack *track = av_mallocz(sizeof(*track));
  361. int bytes_read = 0;
  362. int i, j;
  363. while (bytes_read < klv->length) {
  364. int tag = get_be16(pb);
  365. int size = get_be16(pb); /* KLV specified by 0x53 */
  366. dprintf("tag 0x%04X, size %d\n", tag, size);
  367. switch (tag) {
  368. case 0x3C0A:
  369. get_buffer(pb, track->uid, 16);
  370. break;
  371. case 0x4801:
  372. track->track_id = get_be32(pb);
  373. break;
  374. case 0x4804:
  375. get_buffer(pb, track->track_number, 4);
  376. break;
  377. case 0x4B01:
  378. track->edit_rate.den = get_be32(pb);
  379. track->edit_rate.num = get_be32(pb);
  380. break;
  381. case 0x4803:
  382. get_buffer(pb, track->sequence_ref, 16);
  383. break;
  384. default:
  385. url_fskip(pb, size);
  386. }
  387. bytes_read += size + 4;
  388. }
  389. for (i = 0; i < mxf->packages_count; i++) {
  390. if (mxf->packages[i]) {
  391. for (j = 0; j < mxf->packages[i]->tracks_count; j++) {
  392. if (!memcmp(mxf->packages[i]->tracks_refs[j], track->uid, 16)) {
  393. mxf->packages[i]->tracks[j] = track;
  394. return 0;
  395. }
  396. }
  397. }
  398. }
  399. return -1;
  400. }
  401. static int mxf_read_metadata_sequence(MXFContext *mxf, KLVPacket *klv)
  402. {
  403. ByteIOContext *pb = &mxf->fc->pb;
  404. MXFSequence *sequence = av_mallocz(sizeof(*sequence));
  405. int bytes_read = 0;
  406. int i, j;
  407. while (bytes_read < klv->length) {
  408. int tag = get_be16(pb);
  409. int size = get_be16(pb); /* KLV specified by 0x53 */
  410. dprintf("tag 0x%04X, size %d\n", tag, size);
  411. switch (tag) {
  412. case 0x3C0A:
  413. get_buffer(pb, sequence->uid, 16);
  414. break;
  415. case 0x0202:
  416. sequence->duration = get_be64(pb);
  417. break;
  418. case 0x0201:
  419. get_buffer(pb, sequence->data_definition_ul, 16);
  420. break;
  421. case 0x1001:
  422. sequence->structural_components_count = get_be32(pb);
  423. if (sequence->structural_components_count >= UINT_MAX / sizeof(UID) ||
  424. sequence->structural_components_count >= UINT_MAX / sizeof(*sequence->structural_components))
  425. return -1;
  426. sequence->structural_components_refs = av_malloc(sequence->structural_components_count * sizeof(UID));
  427. sequence->structural_components = av_mallocz(sequence->structural_components_count * sizeof(*sequence->structural_components));
  428. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  429. get_buffer(pb, sequence->structural_components_refs, sequence->structural_components_count * sizeof(UID));
  430. break;
  431. default:
  432. url_fskip(pb, size);
  433. }
  434. bytes_read += size + 4;
  435. }
  436. for (i = 0; i < mxf->packages_count; i++) {
  437. if (mxf->packages[i]) {
  438. for (j = 0; j < mxf->packages[i]->tracks_count; j++) {
  439. if (mxf->packages[i]->tracks[j]) {
  440. if (!memcmp(mxf->packages[i]->tracks[j]->sequence_ref, sequence->uid, 16)) {
  441. mxf->packages[i]->tracks[j]->sequence = sequence;
  442. return 0;
  443. }
  444. }
  445. }
  446. }
  447. }
  448. return -1;
  449. }
  450. static int mxf_read_metadata_source_package(MXFContext *mxf, KLVPacket *klv)
  451. {
  452. ByteIOContext *pb = &mxf->fc->pb;
  453. MXFPackage *package = av_mallocz(sizeof(*package));
  454. int bytes_read = 0;
  455. int i;
  456. package->type = SourcePackage;
  457. while (bytes_read < klv->length) {
  458. int tag = get_be16(pb);
  459. int size = get_be16(pb); /* KLV specified by 0x53 */
  460. dprintf("tag 0x%04X, size %d\n", tag, size);
  461. switch (tag) {
  462. case 0x3C0A:
  463. get_buffer(pb, package->uid, 16);
  464. break;
  465. case 0x4403:
  466. package->tracks_count = get_be32(pb);
  467. if (package->tracks_count >= UINT_MAX / sizeof(UID) ||
  468. package->tracks_count >= UINT_MAX / sizeof(*package->tracks))
  469. return -1;
  470. package->tracks_refs = av_malloc(package->tracks_count * sizeof(UID));
  471. package->tracks = av_mallocz(package->tracks_count * sizeof(*package->tracks));
  472. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  473. get_buffer(pb, package->tracks_refs, package->tracks_count * sizeof(UID));
  474. break;
  475. case 0x4401:
  476. /* UMID, only get last 16 bytes */
  477. url_fskip(pb, 16);
  478. get_buffer(pb, package->package_uid, 16);
  479. break;
  480. case 0x4701:
  481. get_buffer(pb, package->descriptor_ref, 16);
  482. break;
  483. default:
  484. url_fskip(pb, size);
  485. }
  486. bytes_read += size + 4;
  487. }
  488. for (i = 0; i < mxf->packages_count; i++) {
  489. if (!memcmp(mxf->packages_refs[i], package->uid, 16)) {
  490. mxf->packages[i] = package;
  491. return 0;
  492. }
  493. }
  494. return -1;
  495. }
  496. static int mxf_read_metadata_multiple_descriptor(MXFContext *mxf, KLVPacket *klv)
  497. {
  498. ByteIOContext *pb = &mxf->fc->pb;
  499. MXFDescriptor *descriptor = av_mallocz(sizeof(*descriptor));
  500. int bytes_read = 0;
  501. int i;
  502. while (bytes_read < klv->length) {
  503. int tag = get_be16(pb);
  504. int size = get_be16(pb); /* KLV specified by 0x53 */
  505. dprintf("tag 0x%04X, size %d\n", tag, size);
  506. switch (tag) {
  507. case 0x3C0A:
  508. get_buffer(pb, descriptor->uid, 16);
  509. break;
  510. case 0x3F01:
  511. descriptor->sub_descriptors_count = get_be32(pb);
  512. if (descriptor->sub_descriptors_count >= UINT_MAX / sizeof(UID) ||
  513. descriptor->sub_descriptors_count >= UINT_MAX / sizeof(*descriptor->sub_descriptors))
  514. return -1;
  515. descriptor->sub_descriptors_refs = av_malloc(descriptor->sub_descriptors_count * sizeof(UID));
  516. descriptor->sub_descriptors = av_mallocz(descriptor->sub_descriptors_count * sizeof(*descriptor->sub_descriptors));
  517. url_fskip(pb, 4); /* useless size of objects, always 16 according to specs */
  518. get_buffer(pb, descriptor->sub_descriptors_refs, descriptor->sub_descriptors_count * sizeof(UID));
  519. break;
  520. default:
  521. url_fskip(pb, size);
  522. }
  523. bytes_read += size + 4;
  524. }
  525. for (i = 0; i < mxf->packages_count; i++) {
  526. if (mxf->packages[i]) {
  527. if (!memcmp(mxf->packages[i]->descriptor_ref, descriptor->uid, 16)) {
  528. mxf->packages[i]->descriptor = descriptor;
  529. return 0;
  530. }
  531. }
  532. }
  533. return -1;
  534. }
  535. static void mxf_read_metadata_pixel_layout(ByteIOContext *pb, MXFDescriptor *descriptor)
  536. {
  537. int code;
  538. do {
  539. code = get_byte(pb);
  540. dprintf("pixel layout: code 0x%x\n", code);
  541. switch (code) {
  542. case 0x52: /* R */
  543. descriptor->bits_per_sample += get_byte(pb);
  544. break;
  545. case 0x47: /* G */
  546. descriptor->bits_per_sample += get_byte(pb);
  547. break;
  548. case 0x42: /* B */
  549. descriptor->bits_per_sample += get_byte(pb);
  550. break;
  551. default:
  552. get_byte(pb);
  553. }
  554. } while (code != 0); /* SMPTE 377M E.2.46 */
  555. }
  556. static int mxf_read_metadata_generic_descriptor(MXFContext *mxf, KLVPacket *klv)
  557. {
  558. ByteIOContext *pb = &mxf->fc->pb;
  559. MXFDescriptor *descriptor = av_mallocz(sizeof(*descriptor));
  560. int bytes_read = 0;
  561. int i, j;
  562. while (bytes_read < klv->length) {
  563. int tag = get_be16(pb);
  564. int size = get_be16(pb); /* KLV specified by 0x53 */
  565. dprintf("tag 0x%04X, size %d\n", tag, size);
  566. switch (tag) {
  567. case 0x3C0A:
  568. get_buffer(pb, descriptor->uid, 16);
  569. break;
  570. case 0x3004:
  571. get_buffer(pb, descriptor->essence_container_ul, 16);
  572. break;
  573. case 0x3006:
  574. descriptor->linked_track_id = get_be32(pb);
  575. break;
  576. case 0x3201: /* PictureEssenceCoding */
  577. get_buffer(pb, descriptor->essence_codec_ul, 16);
  578. break;
  579. case 0x3203:
  580. descriptor->width = get_be32(pb);
  581. break;
  582. case 0x3202:
  583. descriptor->height = get_be32(pb);
  584. break;
  585. case 0x320E:
  586. descriptor->aspect_ratio.num = get_be32(pb);
  587. descriptor->aspect_ratio.den = get_be32(pb);
  588. break;
  589. case 0x3D03:
  590. descriptor->sample_rate.num = get_be32(pb);
  591. descriptor->sample_rate.den = get_be32(pb);
  592. break;
  593. case 0x3D06: /* SoundEssenceCompression */
  594. get_buffer(pb, descriptor->essence_codec_ul, 16);
  595. break;
  596. case 0x3D07:
  597. descriptor->channels = get_be32(pb);
  598. break;
  599. case 0x3D01:
  600. descriptor->bits_per_sample = get_be32(pb);
  601. break;
  602. case 0x3401:
  603. mxf_read_metadata_pixel_layout(pb, descriptor);
  604. break;
  605. default:
  606. url_fskip(pb, size);
  607. }
  608. bytes_read += size + 4;
  609. }
  610. for (i = 0; i < mxf->packages_count; i++) {
  611. if (mxf->packages[i]) {
  612. if (!memcmp(mxf->packages[i]->descriptor_ref, descriptor->uid, 16)) {
  613. mxf->packages[i]->descriptor = descriptor;
  614. return 0;
  615. } else if (mxf->packages[i]->descriptor) { /* MultipleDescriptor */
  616. for (j = 0; j < mxf->packages[i]->descriptor->sub_descriptors_count; j++) {
  617. if (!memcmp(mxf->packages[i]->descriptor->sub_descriptors_refs[j], descriptor->uid, 16)) {
  618. mxf->packages[i]->descriptor->sub_descriptors[j] = descriptor;
  619. return 0;
  620. }
  621. }
  622. }
  623. }
  624. }
  625. return -1;
  626. }
  627. /* SMPTE RP224 http://www.smpte-ra.org/mdd/index.html */
  628. static const UID picture_essence_track_ul = { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x01,0x03,0x02,0x02,0x01,0x00,0x00,0x00 };
  629. static const UID sound_essence_track_ul = { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x01,0x03,0x02,0x02,0x02,0x00,0x00,0x00 };
  630. static const MXFCodecUL mxf_codec_uls[] = {
  631. /* PictureEssenceCoding */
  632. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x03,0x04,0x01,0x02,0x02,0x01,0x02,0x02,0x00 }, CODEC_ID_MPEG2VIDEO }, /* 422P@ML I-Frame */
  633. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x03,0x04,0x01,0x02,0x02,0x01,0x04,0x03,0x00 }, CODEC_ID_MPEG2VIDEO }, /* 422P@HL Long GoP */
  634. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x03,0x04,0x01,0x02,0x02,0x01,0x01,0x11,0x00 }, CODEC_ID_MPEG2VIDEO }, /* MP@ML Long GoP */
  635. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x03,0x04,0x01,0x02,0x02,0x01,0x02,0x03,0x00 }, CODEC_ID_MPEG2VIDEO }, /* 422P@ML Long GoP */
  636. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x03,0x04,0x01,0x02,0x02,0x01,0x03,0x03,0x00 }, CODEC_ID_MPEG2VIDEO }, /* MP@HL Long GoP */
  637. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x01,0x02,0x01,0x05 }, CODEC_ID_MPEG2VIDEO }, /* D-10 30Mbps PAL */
  638. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x01,0x02,0x01,0x01 }, CODEC_ID_MPEG2VIDEO }, /* D-10 50Mbps PAL */
  639. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x02,0x02,0x04,0x00 }, CODEC_ID_DVVIDEO }, /* DVCPRO50 PAL */
  640. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x02,0x02,0x02,0x00 }, CODEC_ID_DVVIDEO }, /* DVCPRO25 PAL */
  641. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x02,0x01,0x02,0x00 }, CODEC_ID_DVVIDEO }, /* DV25 IEC PAL */
  642. //{ { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x02,0x03,0x01,0x01,0x00 }, CODEC_ID_JPEG2K }, /* JPEG2000 Codestream */
  643. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x01,0x02,0x01,0x7F,0x00,0x00,0x00 }, CODEC_ID_RAWVIDEO }, /* Uncompressed */
  644. /* SoundEssenceCompression */
  645. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x02,0x02,0x01,0x7F,0x00,0x00,0x00 }, CODEC_ID_PCM_S16LE },
  646. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x07,0x04,0x02,0x02,0x01,0x7E,0x00,0x00,0x00 }, CODEC_ID_PCM_S16BE }, /* From Omneon MXF file */
  647. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x02,0x02,0x02,0x03,0x01,0x01,0x00 }, CODEC_ID_PCM_ALAW },
  648. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x02,0x02,0x02,0x03,0x02,0x01,0x00 }, CODEC_ID_AC3 },
  649. { { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x02,0x02,0x02,0x03,0x02,0x05,0x00 }, CODEC_ID_MP2 }, /* MP2 or MP3 */
  650. //{ { 0x06,0x0E,0x2B,0x34,0x04,0x01,0x01,0x01,0x04,0x02,0x02,0x02,0x03,0x02,0x1C,0x00 }, CODEC_ID_DOLBY_E }, /* Dolby-E */
  651. };
  652. static enum CodecID mxf_get_codec_id(const MXFCodecUL *uls, UID *uid)
  653. {
  654. while (uls->id != CODEC_ID_NONE) {
  655. if(!memcmp(uls->uid, *uid, 16))
  656. return uls->id;
  657. uls++;
  658. }
  659. return CODEC_ID_NONE;
  660. }
  661. static int mxf_parse_structural_metadata(MXFContext *mxf)
  662. {
  663. MXFPackage *material_package = NULL;
  664. MXFPackage *source_package = NULL;
  665. int i, j, k;
  666. /* TODO: handle multiple material packages (OP3x) */
  667. for (i = 0; i < mxf->packages_count; i++) {
  668. if (mxf->packages[i]->type == MaterialPackage) {
  669. material_package = mxf->packages[i];
  670. break;
  671. }
  672. }
  673. if (!material_package) {
  674. av_log(mxf->fc, AV_LOG_ERROR, "no material package found\n");
  675. return -1;
  676. }
  677. for (i = 0; i < material_package->tracks_count; i++) {
  678. MXFTrack *material_track = material_package->tracks[i];
  679. MXFTrack *source_track = NULL;
  680. MXFDescriptor *descriptor = NULL;
  681. MXFStructuralComponent *component = NULL;
  682. AVStream *st;
  683. /* TODO: handle multiple source clips */
  684. for (j = 0; j < material_track->sequence->structural_components_count; j++) {
  685. component = material_track->sequence->structural_components[j];
  686. /* TODO: handle timecode component */
  687. if (!component || component->type != SourceClip)
  688. continue;
  689. for (k = 0; k < mxf->packages_count; k++) {
  690. if (!memcmp(mxf->packages[k]->package_uid, component->source_package_uid, 16)) {
  691. source_package = mxf->packages[k];
  692. break;
  693. }
  694. }
  695. if (!source_package) {
  696. av_log(mxf->fc, AV_LOG_ERROR, "material track %d: no corresponding source package found\n", material_track->track_id);
  697. break;
  698. }
  699. for (k = 0; k < source_package->tracks_count; k++) {
  700. if (source_package->tracks[k]->track_id == component->source_track_id) {
  701. source_track = source_package->tracks[k];
  702. break;
  703. }
  704. }
  705. if (!source_track) {
  706. av_log(mxf->fc, AV_LOG_ERROR, "material track %d: no corresponding source track found\n", material_track->track_id);
  707. break;
  708. }
  709. }
  710. if (!source_track)
  711. continue;
  712. st = av_new_stream(mxf->fc, source_track->track_id);
  713. st->priv_data = source_track;
  714. st->duration = component->duration;
  715. if (st->duration == -1)
  716. st->duration = AV_NOPTS_VALUE;
  717. st->start_time = component->start_position;
  718. av_set_pts_info(st, 64, material_track->edit_rate.num, material_track->edit_rate.den);
  719. #ifdef DEBUG
  720. PRINT_KEY(source_track->sequence->data_definition_ul);
  721. #endif
  722. if (!memcmp(source_track->sequence->data_definition_ul, picture_essence_track_ul, 16))
  723. st->codec->codec_type = CODEC_TYPE_VIDEO;
  724. else if (!memcmp(source_track->sequence->data_definition_ul, sound_essence_track_ul, 16))
  725. st->codec->codec_type = CODEC_TYPE_AUDIO;
  726. else
  727. st->codec->codec_type = CODEC_TYPE_DATA;
  728. if (source_package->descriptor) {
  729. if (source_package->descriptor->sub_descriptors_count > 0) { /* SourcePackage has MultipleDescriptor */
  730. for (j = 0; j < source_package->descriptor->sub_descriptors_count; j++) {
  731. if (source_package->descriptor->sub_descriptors[j]) {
  732. if (source_package->descriptor->sub_descriptors[j]->linked_track_id == source_track->track_id) {
  733. descriptor = source_package->descriptor->sub_descriptors[j];
  734. break;
  735. }
  736. }
  737. }
  738. } else {
  739. descriptor = source_package->descriptor;
  740. }
  741. }
  742. if (!descriptor) {
  743. av_log(mxf->fc, AV_LOG_INFO, "source track %d: stream %d, no descriptor found\n", source_track->track_id, st->index);
  744. continue;
  745. }
  746. #ifdef DEBUG
  747. PRINT_KEY(descriptor->essence_codec_ul);
  748. #endif
  749. st->codec->codec_id = mxf_get_codec_id(mxf_codec_uls, &descriptor->essence_codec_ul);
  750. if (st->codec->codec_type == CODEC_TYPE_VIDEO) {
  751. st->codec->width = descriptor->width;
  752. st->codec->height = descriptor->height;
  753. st->codec->bits_per_sample = descriptor->bits_per_sample; /* Uncompressed */
  754. } else if (st->codec->codec_type == CODEC_TYPE_AUDIO) {
  755. st->codec->channels = descriptor->channels;
  756. st->codec->bits_per_sample = descriptor->bits_per_sample;
  757. st->codec->sample_rate = descriptor->sample_rate.num / descriptor->sample_rate.den;
  758. /* TODO: implement CODEC_ID_RAWAUDIO */
  759. if (st->codec->codec_id == CODEC_ID_PCM_S16LE) {
  760. if (descriptor->bits_per_sample == 24)
  761. st->codec->codec_id = CODEC_ID_PCM_S24LE;
  762. else if (descriptor->bits_per_sample == 32)
  763. st->codec->codec_id = CODEC_ID_PCM_S32LE;
  764. } else if (st->codec->codec_id == CODEC_ID_PCM_S16BE) {
  765. if (descriptor->bits_per_sample == 24)
  766. st->codec->codec_id = CODEC_ID_PCM_S24BE;
  767. else if (descriptor->bits_per_sample == 32)
  768. st->codec->codec_id = CODEC_ID_PCM_S32BE;
  769. }
  770. }
  771. }
  772. return 0;
  773. }
  774. static int mxf_read_header(AVFormatContext *s, AVFormatParameters *ap)
  775. {
  776. MXFContext *mxf = s->priv_data;
  777. KLVPacket klv;
  778. int ret = 0;
  779. mxf->fc = s;
  780. while (!url_feof(&s->pb)) {
  781. if (klv_read_packet(&klv, &s->pb) < 0) {
  782. av_log(s, AV_LOG_ERROR, "error reading KLV packet\n");
  783. return -1;
  784. }
  785. #ifdef DEBUG
  786. PRINT_KEY(klv.key);
  787. #endif
  788. if (IS_KLV_KEY(klv.key, mxf_metadata_track_key))
  789. ret = mxf_read_metadata_track(mxf, &klv);
  790. else if (IS_KLV_KEY(klv.key, mxf_metadata_static_track_key))
  791. ret = mxf_read_metadata_track(mxf, &klv);
  792. else if (IS_KLV_KEY(klv.key, mxf_metadata_source_package_key))
  793. ret = mxf_read_metadata_source_package(mxf, &klv);
  794. else if (IS_KLV_KEY(klv.key, mxf_metadata_sequence_key))
  795. ret = mxf_read_metadata_sequence(mxf, &klv);
  796. else if (IS_KLV_KEY(klv.key, mxf_metadata_material_package_key))
  797. ret = mxf_read_metadata_material_package(mxf, &klv);
  798. else if (IS_KLV_KEY(klv.key, mxf_metadata_source_clip_key))
  799. ret = mxf_read_metadata_source_clip(mxf, &klv);
  800. else if (IS_KLV_KEY(klv.key, mxf_metadata_multiple_descriptor_key))
  801. ret = mxf_read_metadata_multiple_descriptor(mxf, &klv);
  802. else if (IS_KLV_KEY(klv.key, mxf_metadata_wave_descriptor_key))
  803. ret = mxf_read_metadata_generic_descriptor(mxf, &klv);
  804. else if (IS_KLV_KEY(klv.key, mxf_metadata_mpegvideo_descriptor_key))
  805. ret = mxf_read_metadata_generic_descriptor(mxf, &klv);
  806. else if (IS_KLV_KEY(klv.key, mxf_metadata_cdci_descriptor_key))
  807. ret = mxf_read_metadata_generic_descriptor(mxf, &klv);
  808. else if (IS_KLV_KEY(klv.key, mxf_metadata_rgba_descriptor_key))
  809. ret = mxf_read_metadata_generic_descriptor(mxf, &klv);
  810. else if (IS_KLV_KEY(klv.key, mxf_metadata_generic_sound_descriptor_key))
  811. ret = mxf_read_metadata_generic_descriptor(mxf, &klv);
  812. else if (IS_KLV_KEY(klv.key, mxf_metadata_preface_key))
  813. ret = mxf_read_metadata_preface(mxf, &klv);
  814. else if (IS_KLV_KEY(klv.key, mxf_metadata_content_storage_key))
  815. ret = mxf_read_metadata_content_storage(mxf, &klv);
  816. else if (IS_KLV_KEY(klv.key, mxf_essence_element_key)) {
  817. /* FIXME avoid seek */
  818. url_fseek(&s->pb, klv.offset, SEEK_SET);
  819. break;
  820. } else
  821. url_fskip(&s->pb, klv.length);
  822. if (ret < 0) {
  823. av_log(s, AV_LOG_ERROR, "error reading header metadata\n");
  824. return ret;
  825. }
  826. }
  827. return mxf_parse_structural_metadata(mxf);
  828. }
  829. static int mxf_read_close(AVFormatContext *s)
  830. {
  831. MXFContext *mxf = s->priv_data;
  832. int i, j, k;
  833. for (i = 0; i < mxf->packages_count; i++) {
  834. for (j = 0; j < mxf->packages[i]->tracks_count; j++) {
  835. for (k = 0; k < mxf->packages[i]->tracks[j]->sequence->structural_components_count; k++)
  836. av_freep(&mxf->packages[i]->tracks[j]->sequence->structural_components[k]);
  837. av_freep(&mxf->packages[i]->tracks[j]->sequence->structural_components_refs);
  838. av_freep(&mxf->packages[i]->tracks[j]->sequence->structural_components);
  839. av_freep(&mxf->packages[i]->tracks[j]->sequence);
  840. av_freep(&mxf->packages[i]->tracks[j]);
  841. }
  842. av_freep(&mxf->packages[i]->tracks_refs);
  843. av_freep(&mxf->packages[i]->tracks);
  844. if (mxf->packages[i]->descriptor) {
  845. for (k = 0; k < mxf->packages[i]->descriptor->sub_descriptors_count; k++)
  846. av_freep(&mxf->packages[i]->descriptor->sub_descriptors[k]);
  847. av_freep(&mxf->packages[i]->descriptor->sub_descriptors_refs);
  848. av_freep(&mxf->packages[i]->descriptor->sub_descriptors);
  849. }
  850. av_freep(&mxf->packages[i]->descriptor);
  851. av_freep(&mxf->packages[i]);
  852. }
  853. av_freep(&mxf->packages_refs);
  854. av_freep(&mxf->packages);
  855. for (i = 0; i < mxf->essence_container_data_sets_count; i++)
  856. av_freep(&mxf->essence_container_data_sets[i]);
  857. av_freep(&mxf->essence_container_data_sets_refs);
  858. av_freep(&mxf->essence_container_data_sets);
  859. av_freep(&mxf->essence_containers_uls);
  860. return 0;
  861. }
  862. static int mxf_probe(AVProbeData *p) {
  863. /* KLV packet describing MXF header partition pack */
  864. if (p->buf_size < sizeof(mxf_header_partition_pack_key))
  865. return 0;
  866. if (IS_KLV_KEY(p->buf, mxf_header_partition_pack_key))
  867. return AVPROBE_SCORE_MAX;
  868. else
  869. return 0;
  870. }
  871. AVInputFormat mxf_demuxer = {
  872. "mxf",
  873. "MXF format",
  874. sizeof(MXFContext),
  875. mxf_probe,
  876. mxf_read_header,
  877. mxf_read_packet,
  878. mxf_read_close,
  879. NULL,
  880. };