1 files changed, 154 insertions, 0 deletions
diff --git a/orkaudio/audiofile/MediaChunkFile.cpp b/orkaudio/audiofile/MediaChunkFile.cpp
new file mode 100644
index 0000000..47b2e8b
--- /dev/null
+++ b/orkaudio/audiofile/MediaChunkFile.cpp
@@ -0,0 +1,154 @@
+/*
+ * Oreka -- A media capture and retrieval platform
+ * 
+ * Copyright (C) 2005, orecx LLC
+ *
+ * http://www.orecx.com
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License.
+ * Please refer to http://www.gnu.org/copyleft/gpl.html
+ *
+ */
+
+#include "MediaChunkFile.h"
+
+#define MAX_CHUNK_SIZE 100000
+
+
+MediaChunkFile::MediaChunkFile()
+{
+	m_stream = NULL;
+	m_mode = READ;
+	m_numChunksWritten = 0;
+	m_sampleRate = 0;
+}
+
+MediaChunkFile::~MediaChunkFile()
+{
+	Close();
+}
+
+
+void MediaChunkFile::Close()
+{
+	if(m_stream)
+	{
+		ACE_OS::fclose(m_stream);
+		m_stream = NULL;
+	}
+}
+
+void MediaChunkFile::WriteChunk(AudioChunkRef chunkRef)
+{
+	if(chunkRef.get() == NULL)
+	{
+		return;
+	}
+	if(chunkRef->GetDetails()->m_numBytes == 0)
+	{
+		return;
+	}
+
+	unsigned int numWritten = 0;
+	bool writeError = false;
+	if (m_stream)
+	{
+		int tmp = sizeof(AudioChunkDetails);
+		numWritten = ACE_OS::fwrite(chunkRef->GetDetails(), sizeof(AudioChunkDetails), 1, m_stream);
+		if(numWritten != 1)
+		{
+			writeError = true;
+		}
+		numWritten = ACE_OS::fwrite(chunkRef->m_pBuffer, sizeof(char), chunkRef->GetNumBytes(), m_stream);
+		if(numWritten != chunkRef->GetNumBytes())
+		{
+			writeError = true;
+		}
+	}
+	else
+	{
+		throw(CStdString("Write attempt on unopened file:")+ m_filename);
+	}
+
+	if (writeError)
+	{
+		throw(CStdString("Could not write to file:")+ m_filename);
+	}
+}
+
+int MediaChunkFile::ReadChunkMono(AudioChunkRef& chunkRef)
+{
+	unsigned int numRead = 0;
+	bool readError = false;
+
+	if (m_stream)
+	{
+		chunkRef.reset(new AudioChunk());
+		short temp[MAX_CHUNK_SIZE];
+		numRead = ACE_OS::fread(temp, sizeof(AudioChunkDetails), 1, m_stream);
+		if(numRead == 1)
+		{
+			AudioChunkDetails details;
+			memcpy(&details, temp, sizeof(AudioChunkDetails));
+
+			if(details.m_marker != MEDIA_CHUNK_MARKER)
+			{
+				throw(CStdString("Invalid marker in file:")+ m_filename);
+			}
+			if(details.m_numBytes >= MAX_CHUNK_SIZE)
+			{
+				throw(CStdString("Chunk too big in file:")+ m_filename);
+			}
+			else
+			{
+				numRead = ACE_OS::fread(temp, sizeof(char), details.m_numBytes, m_stream);
+				if(numRead != details.m_numBytes)
+				{
+					throw(CStdString("Incomplete chunk in file:")+ m_filename);
+				}
+				chunkRef->SetBuffer(temp, details.m_numBytes, details);
+			}
+		}
+	}
+	else
+	{
+		throw(CStdString("Read attempt on unopened file:")+ m_filename);
+	}
+	
+	return numRead;
+}
+
+
+void MediaChunkFile::Open(CStdString& filename, fileOpenModeEnum mode, bool stereo, int sampleRate)
+{
+	if(m_sampleRate == 0)
+	{
+		m_sampleRate = sampleRate;
+	}
+
+	if(!m_filename.Equals(filename))
+	{
+		m_filename = filename + GetExtension();
+	}
+	m_stream = NULL;
+	m_mode = mode;
+	if (mode == READ)
+	{
+		m_stream = ACE_OS::fopen((PCSTR)m_filename, "rb");
+	}
+	else
+	{
+		RecursiveMkdir(m_filename);
+		m_stream = ACE_OS::fopen((PCSTR)m_filename, "wb");
+	}
+	if(!m_stream)
+	{
+		throw(CStdString("Could not open file: ") + m_filename);
+	}
+}
+
+CStdString MediaChunkFile::GetExtension()
+{
+	return ".mcf";
+}