file_systems/bfs/Journal.cpp

403 	fVolume(volume),
451 	int32 maxRuns = run_array::MaxRuns(fVolume->BlockSize()) - 1;
464 		if (fVolume->ValidateBlockRun(array->RunAt(i)) != B_OK)
482 	off_t logOffset = fVolume->ToBlock(fVolume->Log());
485 	CachedBlock cachedArray(fVolume);
497 	CachedBlock cached(fVolume);
501 	int32 blockSize = fVolume->BlockSize();
506 		off_t offset = fVolume->ToOffset(run);
538 		off_t offset = fVolume->ToOffset(run);
544 			ssize_t written = write_pos(fVolume->Device(), offset,
571 	if (fVolume->LogStart() == fVolume->LogEnd())
576 	if (fVolume->SuperBlock().flags != SUPER_BLOCK_DISK_DIRTY) {
581 	if (fVolume->IsReadOnly())
584 	int32 start = fVolume->LogStart();
588 		if (start == fVolume->LogEnd())
607 	fVolume->SuperBlock().log_start = HOST_ENDIAN_TO_BFS_INT64(
608 		fVolume->LogEnd());
609 	fVolume->LogStart() = HOST_ENDIAN_TO_BFS_INT64(fVolume->LogEnd());
610 	fVolume->SuperBlock().flags = HOST_ENDIAN_TO_BFS_INT32(
613 	return fVolume->WriteSuperBlock();
621 		return cache_blocks_in_sub_transaction(fVolume->BlockCache(),
625 	return cache_blocks_in_main_transaction(fVolume->BlockCache(),
652 	disk_super_block& superBlock = journal->fVolume->SuperBlock();
666 				journal->fVolume->LogEnd());
686 		status_t status = journal->fVolume->WriteSuperBlock();
692 		journal->fVolume->LogStart() = superBlock.LogStart();
739 				fVolume->BlockCache(), fTransactionID) < (int32)fLogSize) {
753 	int32 blockShift = fVolume->BlockShift();
754 	off_t logOffset = fVolume->ToBlock(fVolume->Log()) << blockShift;
755 	off_t logStart = fVolume->LogEnd() % fLogSize;
765 	while (cache_next_block_in_transaction(fVolume->BlockCache(),
778 			fTransactionID = cache_detach_sub_transaction(fVolume->BlockCache(),
782 			cache_end_transaction(fVolume->BlockCache(), fTransactionID, NULL,
792 		cache_sync_transaction(fVolume->BlockCache(), fTransactionID);
815 		add_to_iovec(vecs, index, maxVecs, (void*)array, fVolume->BlockSize());
821 			off_t blockNumber = fVolume->ToBlock(run);
827 					if (writev_pos(fVolume->Device(), logOffset
839 				const void* data = block_cache_get(fVolume->BlockCache(),
844 				add_to_iovec(vecs, index, maxVecs, data, fVolume->BlockSize());
852 			if (writev_pos(fVolume->Device(), logOffset
860 			off_t blockNumber = fVolume->ToBlock(run);
863 				block_cache_put(fVolume->BlockCache(), blockNumber + j);
870 	LogEntry* logEntry = new(std::nothrow) LogEntry(this, fVolume->LogEnd(),
883 	fVolume->SuperBlock().flags = SUPER_BLOCK_DISK_DIRTY;
884 	fVolume->SuperBlock().log_end = HOST_ENDIAN_TO_BFS_INT64(logPosition);
886 	status = fVolume->WriteSuperBlock();
888 	fVolume->LogEnd() = logPosition;
889 	T(LogEntry(logEntry, fVolume->LogEnd(), true));
894 	ioctl(fVolume->Device(), B_FLUSH_DRIVE_CACHE);
905 		fTransactionID = cache_detach_sub_transaction(fVolume->BlockCache(),
917 		cache_end_transaction(fVolume->BlockCache(), fTransactionID,
952 		status = fVolume->FlushDevice();
999 			cache_start_sub_transaction(fVolume->BlockCache(), fTransactionID);
1002 			fTransactionID = cache_start_transaction(fVolume->BlockCache());
1009 		cache_add_transaction_listener(fVolume->BlockCache(), fTransactionID,
1056 	int32 count = cache_blocks_in_transaction(fVolume->BlockCache(),
1062 	uint32 maxRuns = run_array::MaxRuns(fVolume->BlockSize());
1073 			cache_abort_sub_transaction(fVolume->BlockCache(), fTransactionID);
1076 			cache_abort_transaction(fVolume->BlockCache(), fTransactionID);
1090 			cache_sync_transaction(fVolume->BlockCache(), fTransactionID);
1110 	kprintf("  log start:            %" B_PRId32 "\n", fVolume->LogStart());
1111 	kprintf("  log end:              %" B_PRId32 "\n", fVolume->LogEnd());