file_systems/ext2/DataStream.cpp

10 #include "DataStream.h"
25 DataStream::DataStream(Volume* volume, ext2_data_stream* stream,
50 DataStream::~DataStream()
56 DataStream::FindBlock(off_t offset, fsblock_t& block, uint32 *_count)
180 DataStream::Enlarge(Transaction& transaction, off_t& numBlocks)
182 	TRACE("DataStream::Enlarge(): current size: %llu, target size: %llu\n",
195 			ERROR("DataStream::Enlarge(): _AddForDirectBlocks() failed\n");
199 		TRACE("DataStream::Enlarge(): current size: %llu, target size: %llu\n",
206 	TRACE("DataStream::Enlarge(): indirect current size: %llu, target size: %llu\n",
213 			ERROR("DataStream::Enlarge(): _AddForIndirectBlock() failed\n");
217 		TRACE("DataStream::Enlarge(): current size: %llu, target size: %llu\n",
224 	TRACE("DataStream::Enlarge(): indirect2 current size: %llu, target size: %llu\n",
231 			ERROR("DataStream::Enlarge(): _AddForDoubleIndirectBlock() failed\n");
235 		TRACE("DataStream::Enlarge(): current size: %llu, target size: %llu\n",
242 	TRACE("DataStream::Enlarge(): indirect3 current size: %llu, target size: %llu\n",
245 	TRACE("DataStream::Enlarge(): allocated: %lu, waiting: %lu\n", fAllocated,
253 DataStream::Shrink(Transaction& transaction, off_t& numBlocks)
255 	TRACE("DataStream::Shrink(): current size: %llu, target size: %llu\n",
271 			ERROR("DataStream::Shrink(): _RemoveFromDirectBlocks() failed\n");
287 			ERROR("DataStream::Shrink(): _RemoveFromIndirectBlock() failed\n");
303 			ERROR("DataStream::Shrink(): _RemoveFromDoubleIndirectBlock() failed\n");
318 		ERROR("DataStream::Shrink(): _RemoveFromTripleIndirectBlock() failed\n");
330 DataStream::_BlocksNeeded(off_t numBlocks)
332 	TRACE("DataStream::BlocksNeeded(): num blocks %llu\n", numBlocks);
366 	TRACE("DataStream::BlocksNeeded(): %llu\n", blocksNeeded);
372 DataStream::_GetBlock(Transaction& transaction, uint32& blockNum)
374 	TRACE("DataStream::_GetBlock(): allocated: %lu, pos: %llu, waiting: %lu\n",
384 			ERROR("DataStream::_GetBlock(): AllocateBlocks() failed()\n");
390 		TRACE("DataStream::_GetBlock(): newAllocated: %lu, newpos: %llu,"
402 DataStream::_PrepareBlock(Transaction& transaction, uint32* pos,
411 			ERROR("DataStream::_PrepareBlock() _GetBlock() failed blockNum %ld\n", blockNum);
424 DataStream::_AddBlocks(Transaction& transaction, uint32* block, off_t _count)
427 	TRACE("DataStream::_AddBlocks(): count: %llu\n", count);
446 DataStream::_AddBlocks(Transaction& transaction, uint32* block, off_t start,
449 	TRACE("DataStream::_AddBlocks(): start: %llu, end %llu, recursion: %d\n",
480 	TRACE("DataStream::_AddBlocks(): element pos: %lu, end pos: %lu\n",
494 			ERROR("DataStream::_AddBlocks() _AddBlocks() start failed\n");
505 			ERROR("DataStream::_AddBlocks() _AddBlocks() mid failed\n");
516 			ERROR("DataStream::_AddBlocks() _AddBlocks() end failed\n");
526 DataStream::_AddForDirectBlocks(Transaction& transaction, uint32 numBlocks)
528 	TRACE("DataStream::_AddForDirectBlocks(): current size: %llu, target size: "
538 DataStream::_AddForIndirectBlock(Transaction& transaction, uint32 numBlocks)
540 	TRACE("DataStream::_AddForIndirectBlocks(): current size: %llu, target "
554 DataStream::_AddForDoubleIndirectBlock(Transaction& transaction,
557 	TRACE("DataStream::_AddForDoubleIndirectBlock(): current size: %llu, "
571 DataStream::_AddForTripleIndirectBlock(Transaction& transaction,
574 	TRACE("DataStream::_AddForTripleIndirectBlock(): current size: %llu, "
585 DataStream::_PerformFree(Transaction& transaction)
587 	TRACE("DataStream::_PerformFree(): start: %lu, count: %lu\n", fFreeStart,
604 DataStream::_MarkBlockForRemoval(Transaction& transaction, uint32* block)
607 	TRACE("DataStream::_MarkBlockForRemoval(*(%p) = %lu): free start: %lu, "
632 DataStream::_FreeBlocks(Transaction& transaction, uint32* block, uint32 _count)
635 	TRACE("DataStream::_FreeBlocks(%p, %lu)\n", block, count);
653 DataStream::_FreeBlocks(Transaction& transaction, uint32* block, off_t start,
657 	TRACE("DataStream::_FreeBlocks(%p, %llu, %llu, %c, %d)\n",
727 DataStream::_RemoveFromDirectBlocks(Transaction& transaction, uint32 numBlocks)
729 	TRACE("DataStream::_RemoveFromDirectBlocks(): current size: %llu, "
739 DataStream::_RemoveFromIndirectBlock(Transaction& transaction, uint32 numBlocks)
741 	TRACE("DataStream::_RemoveFromIndirectBlock(): current size: %llu, "
757 DataStream::_RemoveFromDoubleIndirectBlock(Transaction& transaction,
760 	TRACE("DataStream::_RemoveFromDoubleIndirectBlock(): current size: %llu, "
776 DataStream::_RemoveFromTripleIndirectBlock(Transaction& transaction,
779 	TRACE("DataStream::_RemoveFromTripleIndirectBlock(): current size: %llu, "