1 files changed, 253 insertions, 0 deletions
diff --git a/gpr/source/lib/dng_sdk/dng_memory_stream.cpp b/gpr/source/lib/dng_sdk/dng_memory_stream.cpp
new file mode 100644
index 0000000..9368d67
--- /dev/null
+++ b/gpr/source/lib/dng_sdk/dng_memory_stream.cpp
@@ -0,0 +1,253 @@
+/*****************************************************************************/
+// Copyright 2006-2007 Adobe Systems Incorporated
+// All Rights Reserved.
+//
+// NOTICE:  Adobe permits you to use, modify, and distribute this file in
+// accordance with the terms of the Adobe license agreement accompanying it.
+/*****************************************************************************/
+
+/* $Id: //mondo/dng_sdk_1_4/dng_sdk/source/dng_memory_stream.cpp#1 $ */ 
+/* $DateTime: 2012/05/30 13:28:51 $ */
+/* $Change: 832332 $ */
+/* $Author: tknoll $ */
+
+/*****************************************************************************/
+
+#include "dng_memory_stream.h"
+
+#include "dng_bottlenecks.h"
+#include "dng_exceptions.h"
+#include "dng_utils.h"
+
+#include "gpr_allocator.h"
+
+/*****************************************************************************/
+
+dng_memory_stream::dng_memory_stream (dng_memory_allocator &allocator,
+									  dng_abort_sniffer *sniffer,
+						   			  uint32 pageSize)
+						   			  
+	:	dng_stream (sniffer, 
+					kDefaultBufferSize,
+					kDNGStreamInvalidOffset)
+	
+	,	fAllocator (allocator)
+	,	fPageSize  (pageSize )
+	
+	,	fPageCount      (0)
+	,	fPagesAllocated (0)
+	,	fPageList       (NULL)
+	
+	,	fMemoryStreamLength (0)
+	
+	{
+	
+	}
+		
+/*****************************************************************************/
+
+dng_memory_stream::~dng_memory_stream ()
+	{
+	
+	if (fPageList)
+		{
+		
+		for (uint32 index = 0; index < fPageCount; index++)
+			{
+			
+			delete fPageList [index];
+			
+			}
+			
+        gpr_global_free( fPageList );
+		
+		}
+	
+	}
+		
+/*****************************************************************************/
+		
+uint64 dng_memory_stream::DoGetLength ()
+	{
+	
+	return fMemoryStreamLength;
+	
+	}
+		
+/*****************************************************************************/
+		
+void dng_memory_stream::DoRead (void *data,
+							    uint32 count,
+							    uint64 offset)
+	{
+	
+	if (offset + count > fMemoryStreamLength)
+		{
+		
+		ThrowEndOfFile ();
+		
+		}
+		
+	uint64 baseOffset = offset;
+	
+	while (count)
+		{
+		
+		uint32 pageIndex  = (uint32) (offset / fPageSize);
+		uint32 pageOffset = (uint32) (offset % fPageSize);
+		
+		uint32 blockCount = Min_uint32 (fPageSize - pageOffset, count);
+		
+		const uint8 *sPtr = fPageList [pageIndex]->Buffer_uint8 () +
+						    pageOffset;
+		
+		uint8 *dPtr = ((uint8 *) data) + (uint32) (offset - baseOffset);
+		
+		DoCopyBytes (sPtr, dPtr, blockCount);
+		
+		offset += blockCount;
+		count  -= blockCount;
+		
+		}
+	
+	}
+							 
+/*****************************************************************************/
+
+void dng_memory_stream::DoSetLength (uint64 length)
+	{
+	
+	while (length > fPageCount * (uint64) fPageSize)
+		{
+		
+		if (fPageCount == fPagesAllocated)
+			{
+			
+			uint32 newSize = Max_uint32 (fPagesAllocated + 32,
+										 fPagesAllocated * 2);
+                
+            dng_memory_block **list = (dng_memory_block **) gpr_global_malloc( newSize * sizeof (dng_memory_block *) );
+                
+			if (!list)
+				{
+				
+				ThrowMemoryFull ();
+				
+				}
+			
+			if (fPageCount)
+				{
+				
+				DoCopyBytes (fPageList,
+							 list,
+							 fPageCount * (uint32) sizeof (dng_memory_block *));
+				
+				}
+				
+			if (fPageList)
+				{
+                gpr_global_free( fPageList );
+                }
+				
+			fPageList = list;
+			
+			fPagesAllocated = newSize;
+			
+			}
+			
+		fPageList [fPageCount] = fAllocator.Allocate (fPageSize);
+		
+		fPageCount++;
+		
+		}
+		
+	fMemoryStreamLength = length;
+	
+	}
+							 
+/*****************************************************************************/
+
+void dng_memory_stream::DoWrite (const void *data,
+							     uint32 count,
+							     uint64 offset)
+	{
+	
+	DoSetLength (Max_uint64 (fMemoryStreamLength,
+							 offset + count));
+	
+	uint64 baseOffset = offset;
+	
+	while (count)
+		{
+		
+		uint32 pageIndex  = (uint32) (offset / fPageSize);
+		uint32 pageOffset = (uint32) (offset % fPageSize);
+		
+		uint32 blockCount = Min_uint32 (fPageSize - pageOffset, count);
+		
+		const uint8 *sPtr = ((const uint8 *) data) + (uint32) (offset - baseOffset);
+		
+		uint8 *dPtr = fPageList [pageIndex]->Buffer_uint8 () +
+					  pageOffset;
+		
+		DoCopyBytes (sPtr, dPtr, blockCount);
+		
+		offset += blockCount;
+		count  -= blockCount;
+		
+		}
+	
+	}
+		
+/*****************************************************************************/
+
+void dng_memory_stream::CopyToStream (dng_stream &dstStream,
+									  uint64 count)
+	{
+	
+	if (count < kBigBufferSize)
+		{
+	
+		dng_stream::CopyToStream (dstStream, count);
+		
+		}
+		
+	else
+		{
+		
+		Flush ();
+		
+		uint64 offset = Position ();
+		
+		if (offset + count > Length ())
+			{
+			
+			ThrowEndOfFile ();
+			
+			}
+			
+		while (count)
+			{
+			
+			uint32 pageIndex  = (uint32) (offset / fPageSize);
+			uint32 pageOffset = (uint32) (offset % fPageSize);
+			
+			uint32 blockCount = (uint32) Min_uint64 (fPageSize - pageOffset, count);
+			
+			const uint8 *sPtr = fPageList [pageIndex]->Buffer_uint8 () +
+								pageOffset;
+								
+			dstStream.Put (sPtr, blockCount);
+			
+			offset += blockCount;
+			count  -= blockCount;
+			
+			}
+			
+		SetReadPosition (offset);
+	
+		}
+	
+	}
+		
+/*****************************************************************************/