Method write

src/IECore/StreamIndexedIO.cpp:2246–2305

}

uint64_t StreamIndexedIO::Index::write()
{
	StreamIndexedIO::StreamFile &f = *m_stream;

	/// Write index at end
	std::streampos indexStart = m_next;

	f.seekp( m_next, std::ios::beg );

	m_offset = indexStart;

	// todo estimate the memory required to avoid re-allocations?
	MemoryStreamSink sink;
	io::filtering_ostream indexOutStream;
	indexOutStream.push( sink );

	assert( indexOutStream.is_complete() );

	m_stringCache.write( indexOutStream );

	writeNode( m_root, indexOutStream );

	assert( m_freePagesOffset.size() == m_freePagesSize.size() );
	uint64_t numFreePages = m_freePagesSize.size();

	// Write out number of free "pages"
	writeLittleEndian( indexOutStream, numFreePages);

	/// Write out each free page
	for ( FreePagesSizeMap::const_iterator it = m_freePagesSize.begin(); it != m_freePagesSize.end(); ++it)
	{
		writeLittleEndian( indexOutStream, it->second->m_offset );
		writeLittleEndian( indexOutStream, it->second->m_size );
	}

	/// To synchronize/close, etc.
	indexOutStream.pop();

	// compress the output stream using blosc before writing
	char* indexData = nullptr;
	std::streamsize indexDataSize;

	sink.get(indexData, indexDataSize);

	std::vector<char> compressedIndex;
	compress( indexData, indexDataSize, compressedIndex, indexCompressionLevel, indexCompressor, 1, BLOSC_MAX_BUFFERSIZE, 0);

	f.write( &compressedIndex[0], compressedIndex.size() );

	writeLittleEndian( f, getCompressionCode( m_compressor ));
	writeLittleEndian( f, m_compressionLevel );

	writeLittleEndian( f, m_offset );
	writeLittleEndian( f, g_currentVersion );
	writeLittleEndian( f, g_versionedMagicNumber );

	m_hasChanged = false;