Lines Matching refs:transaction

180 DataStream::Enlarge(Transaction& transaction, off_t& numBlocks)
192 status = _AddForDirectBlocks(transaction, targetBlocks);
210 status = _AddForIndirectBlock(transaction, targetBlocks);
228 status = _AddForDoubleIndirectBlock(transaction, targetBlocks);
248 return _AddForTripleIndirectBlock(transaction, targetBlocks);
253 DataStream::Shrink(Transaction& transaction, off_t& numBlocks)
268 status = _RemoveFromDirectBlocks(transaction, numBlocks);
279 return _PerformFree(transaction);
284 status = _RemoveFromIndirectBlock(transaction, numBlocks);
295 return _PerformFree(transaction);
300 status = _RemoveFromDoubleIndirectBlock(transaction, numBlocks);
311 return _PerformFree(transaction);
315 status = _RemoveFromTripleIndirectBlock(transaction, numBlocks);
325 return _PerformFree(transaction);
372 DataStream::_GetBlock(Transaction& transaction, uint32& blockNum)
381 status_t status = fVolume->AllocateBlocks(transaction, 1, fWaiting,
405 DataStream::_PrepareBlock(Transaction& transaction, uint32* pos,
412 status_t status = _GetBlock(transaction, blockNum);
428 DataStream::_AddBlocks(Transaction& transaction, uint32* block, off_t _count)
435 status_t status = _GetBlock(transaction, blockNum);
450 DataStream::_AddBlocks(Transaction& transaction, uint32* block, off_t start,
458 status_t status = _PrepareBlock(transaction, block, blockNum, clear);
463 uint32* childBlock = (uint32*)cached.SetToWritable(transaction, blockNum,
469 return _AddBlocks(transaction, &childBlock[start], end - start);
490 return _AddBlocks(transaction, &childBlock[elementPos],
495 status = _AddBlocks(transaction, &childBlock[elementPos],
506 status = _AddBlocks(transaction, &childBlock[elementPos], 0,
517 status = _AddBlocks(transaction, &childBlock[elementPos], 0,
530 DataStream::_AddForDirectBlocks(Transaction& transaction, uint32 numBlocks)
537 return _AddBlocks(transaction, direct, end - fNumBlocks);
542 DataStream::_AddForIndirectBlock(Transaction& transaction, uint32 numBlocks)
553 return _AddBlocks(transaction, indirect, start, end, 0);
558 DataStream::_AddForDoubleIndirectBlock(Transaction& transaction,
570 return _AddBlocks(transaction, doubleIndirect, start, end, 1);
575 DataStream::_AddForTripleIndirectBlock(Transaction& transaction,
584 return _AddBlocks(transaction, tripleIndirect, start, end, 2);
589 DataStream::_PerformFree(Transaction& transaction)
598 status = fVolume->FreeBlocks(transaction, fFreeStart, fFreeCount);
608 DataStream::_MarkBlockForRemoval(Transaction& transaction, uint32* block)
619 status_t status = fVolume->FreeBlocks(transaction, fFreeStart,
636 DataStream::_FreeBlocks(Transaction& transaction, uint32* block, uint32 _count)
642 status_t status = _MarkBlockForRemoval(transaction, block);
657 DataStream::_FreeBlocks(Transaction& transaction, uint32* block, off_t start,
667 status_t status = _MarkBlockForRemoval(transaction, block);
673 uint32* childBlock = (uint32*)cached.SetToWritable(transaction, blockNum);
678 return _FreeBlocks(transaction, &childBlock[start], end - start);
697 return _FreeBlocks(transaction, &childBlock[elementPos],
704 status = _FreeBlocks(transaction, &childBlock[elementPos],
713 status = _FreeBlocks(transaction, &childBlock[elementPos], 0,
722 status = _FreeBlocks(transaction, &childBlock[elementPos], 0,
731 DataStream::_RemoveFromDirectBlocks(Transaction& transaction, uint32 numBlocks)
738 return _FreeBlocks(transaction, direct, end - numBlocks);
743 DataStream::_RemoveFromIndirectBlock(Transaction& transaction, uint32 numBlocks)
756 return _FreeBlocks(transaction, indirect, start, end, freeAll, 0);
761 DataStream::_RemoveFromDoubleIndirectBlock(Transaction& transaction,
775 return _FreeBlocks(transaction, doubleIndirect, start, end, freeAll, 1);
780 DataStream::_RemoveFromTripleIndirectBlock(Transaction& transaction,
792 return _FreeBlocks(transaction, tripleIndirect, start, end, freeAll, 2);