Added the JXS functionality again into the core library.

1 files changed, 251 insertions, 0 deletions

diff --git a/src/JXS_Codestream_Parser.cpp b/src/JXS_Codestream_Parser.cpp
new file mode 100644
index 0000000..c27dd45
--- /dev/null
+++ b/src/JXS_Codestream_Parser.cpp
@@ -0,0 +1,251 @@
+/*
+Copyright (c) 2004-2013, John Hurst
+Copyright (c) 2020, Thomas Richter Fraunhofer IIS,
+Copyright (c) 2020, Christian Minuth Fraunhofer IIS,
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions
+are met:
+1. Redistributions of source code must retain the above copyright
+   notice, this list of conditions and the following disclaimer.
+2. Redistributions in binary form must reproduce the above copyright
+   notice, this list of conditions and the following disclaimer in the
+   documentation and/or other materials provided with the distribution.
+3. The name of the author may not be used to endorse or promote products
+   derived from this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
+IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
+OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
+IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
+INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
+NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*/
+/*! \file    JXS_Codestream_Parser.cpp
+	\version $Id$
+	\brief   AS-DCP library, JPEG XS codestream essence reader implementation
+*/
+
+#include <KM_fileio.h>
+#include <AS_DCP.h>
+#include <JXS.h>
+#include <assert.h>
+#include <KM_log.h>
+using Kumu::DefaultLogSink;
+
+//------------------------------------------------------------------------------------------
+
+class ASDCP::JXS::CodestreamParser::h__CodestreamParser
+{
+	ASDCP_NO_COPY_CONSTRUCT(h__CodestreamParser);
+
+public:
+	PictureDescriptor  m_PDesc;
+	Kumu::FileReader   m_File;
+
+	h__CodestreamParser()
+	{
+		memset(&m_PDesc, 0, sizeof(m_PDesc));
+		m_PDesc.EditRate = Rational(24, 1);
+		m_PDesc.SampleRate = m_PDesc.EditRate;
+	}
+
+	~h__CodestreamParser() {}
+
+	Result_t OpenReadFrame(const std::string& filename, FrameBuffer& FB)
+	{
+		m_File.Close();
+		Result_t result = m_File.OpenRead(filename);
+
+		if (ASDCP_SUCCESS(result))
+		{
+			Kumu::fsize_t file_size = m_File.Size();
+
+			if (FB.Capacity() < file_size)
+			{
+				DefaultLogSink().Error("FrameBuf.Capacity: %u frame length: %u\n", FB.Capacity(), (ui32_t)file_size);
+				return RESULT_SMALLBUF;
+			}
+		}
+
+		ui32_t read_count;
+
+		if (ASDCP_SUCCESS(result))
+			result = m_File.Read(FB.Data(), FB.Capacity(), &read_count);
+
+		if (ASDCP_SUCCESS(result))
+			FB.Size(read_count);
+
+		if (ASDCP_SUCCESS(result))
+		{
+			byte_t start_of_data = 0; // out param
+			result = ParseMetadataIntoDesc(FB, m_PDesc, &start_of_data);
+
+			if (ASDCP_SUCCESS(result))
+				FB.PlaintextOffset(start_of_data);
+		}
+
+		return result;
+	}
+};
+
+ASDCP::Result_t
+ASDCP::JXS::ParseMetadataIntoDesc(const FrameBuffer& FB, PictureDescriptor& PDesc, byte_t* start_of_data)
+{
+	Result_t result = RESULT_OK;
+	Marker NextMarker;
+	ui32_t i;
+	const byte_t* p = FB.RoData();
+	const byte_t* end_p = p + FB.Size();
+
+	/* initialize optional items */
+	bool  pih = false;
+	bool  havesoc = false;
+
+	while (p < end_p && ASDCP_SUCCESS(result))
+	{
+		result = GetNextMarker(&p, NextMarker);
+
+		if (ASDCP_FAILURE(result))
+		{
+			result = RESULT_RAW_ESS;
+			break;
+		}
+
+		switch (NextMarker.m_Type)
+		{
+		case MRK_SOC:
+		{
+			// This is the SOC symbol.
+			if (havesoc)
+				DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: found a duplicate SOC marker");
+			havesoc = true;
+		}
+		break;
+		case MRK_EOC:
+		{
+			DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: found an EOC before any actual picture data");
+		}
+		break;
+		
+		case MRK_PIH:
+		{
+			// This is the real picture header.
+
+			if (!havesoc)
+				DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: the SOC marker is missing at the start of the frame");
+			if (pih) {
+				DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: found a duplicate picture header");
+			}
+			else {
+				ui32_t size;
+				ui8_t flags;
+				//
+				
+				Accessor::PIH PIH_(NextMarker);
+				pih = true;
+				size = PIH_.LpihSize();
+
+				if (size != 28 - 2)
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: the jpeg xs picture header has an unsupported size");
+
+				// size of the bitstream: ignore, just store away.
+				size = PIH_.LcodSize();
+				// Profile and level
+				PDesc.Ppih = PIH_.Ppih();
+				PDesc.Plev = PIH_.Plev();
+				// Width and Height
+				PDesc.AspectRatio = Rational(PIH_.Wf(), PIH_.Hf());
+				PDesc.StoredWidth = PIH_.Wf();
+				PDesc.StoredHeight = PIH_.Hf();
+				PDesc.Wf = PIH_.Wf();
+				PDesc.Hf = PIH_.Hf();
+				PDesc.Cw = PIH_.Cw();
+				PDesc.Hsl = PIH_.Hsl();
+				if (PIH_.Hsl() < 1 || PIH_.Hsl() > 0xffff) // This includes the EOF check
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: unsupported slice height specified, must be > 0 and < 65536");
+				// Number of compoennts.
+				PDesc.Nc = PIH_.Nc();
+				if (PDesc.Nc != 3)
+				{
+					DefaultLogSink().Error("Unexpected number of components: %u\n", PDesc.Nc);
+					return RESULT_RAW_FORMAT;
+				}
+				// A lot of settings that must be fixed right now.
+				if (PIH_.Ng() != 4)
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: the number of coefficients per coding group must be 4");
+				if (PIH_.Ss() != 8)
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: the number of coding groups per significance group must be 8");
+				//
+				if (PIH_.Nlx() == 0)
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: number of horizontal decomposition levels is out of range, must be >0");
+				if (PIH_.Nly() > MaxVerticalLevels)
+					DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: number of vertical decomposition levels is out of range, must be <2");
+			}
+		}
+		break;
+		case MRK_CDT:
+		{
+			if(pih) {
+				Accessor::CDT CDT_(NextMarker);
+				int i, count = NextMarker.m_DataSize >> 1;
+
+				for (i = 0; i < count && i < PDesc.Nc; i++) {
+					PDesc.ImageComponents[i].Bc = CDT_.Bc(i);
+					PDesc.ImageComponents[i].Sx = CDT_.Sx(i);
+					PDesc.ImageComponents[i].Sy = CDT_.Sy(i);
+				}
+		}
+		else {
+				DefaultLogSink().Error("JXS::ParseMetadataIntoDesc: found a component table marker upfront the picture header");
+		}
+		}
+		break;
+		case MRK_SLH: /* slice header: the entropy coded data starts here */
+			if (start_of_data != 0)
+				*start_of_data = p - FB.RoData();
+
+			p = end_p;
+			break;
+	}
+}
+	return result;
+}
+//------------------------------------------------------------------------------------------
+
+ASDCP::JXS::CodestreamParser::CodestreamParser()
+{
+}
+
+ASDCP::JXS::CodestreamParser::~CodestreamParser()
+{
+}
+
+// Opens the stream for reading, parses enough data to provide a complete
+// set of stream metadata for the MXFWriter below.
+ASDCP::Result_t
+ASDCP::JXS::CodestreamParser::OpenReadFrame(const std::string& filename, FrameBuffer& FB) const
+{
+	const_cast<ASDCP::JXS::CodestreamParser*>(this)->m_Parser = new h__CodestreamParser;
+	return m_Parser->OpenReadFrame(filename, FB);
+}
+
+//
+ASDCP::Result_t
+ASDCP::JXS::CodestreamParser::FillPictureDescriptor(PictureDescriptor& PDesc) const
+{
+	if (m_Parser.empty())
+		return RESULT_INIT;
+
+	PDesc = m_Parser->m_PDesc;
+	return RESULT_OK;
+}
+
+//
+// end JXS_Codestream_Parser.cpp
+//