Method writeUniqueData

src/IECore/StreamIndexedIO.cpp:2501–2548

}

uint64_t StreamIndexedIO::Index::writeUniqueData( const char *data, size_t size, bool prefixSize )
{
	m_hasChanged = true;

	/// Find next writable location
	uint64_t loc;

	// compute hash for the data
	MurmurHash hash;
	hash.append( data, size );

	if ( size >= UINT32_MAX )
	{
		throw IOException( "StreamIndexedIO: Data size too long!" );
	}
	uint32_t clampedSize = size;
	size_t totalSize = size;

	if ( prefixSize )
	{
		totalSize += sizeof( clampedSize );
	}

	// see if it's already stored by another node..
	std::pair< HashToDataMap::iterator,bool > ret = m_hashToDataMap.insert( HashToDataMap::value_type( std::pair< MurmurHash,uint64_t>(hash,totalSize), 0 ) );
	if ( !ret.second )
	{
		// we already saved this data, so we dont save any additional data
		return ret.first->second;
	}

	/// New data, find next writable location.
	loc = allocate( totalSize );
	ret.first->second = loc;

	/// Seek 'write' pointer to writable location
	m_stream->seekp( loc, std::ios::beg );

	if ( prefixSize )
	{
		writeLittleEndian( *m_stream, clampedSize );
	}

	/// Write data
	m_stream->write( data, size );

	return loc;
}

StreamIndexedIO::Index::WriteInfo StreamIndexedIO::Index::writeUniqueDataCompressed( const char *data, size_t size, bool prefixSize )
{