Searched refs:transaction (Results 26 - 50 of 85) sorted by path

1234

/haiku/src/tests/system/kernel/file_corruption/fs/
H A DBlockAllocator.h26 status_t Initialize(Transaction& transaction);
29 Transaction& transaction,
33 uint64 count, Transaction& transaction);
35 Transaction& transaction);
42 uint64 count, Transaction& transaction,
46 uint32 count, Transaction& transaction,
50 uint32 count, Transaction& transaction,
55 Transaction& transaction);
57 Transaction& transaction);
59 Transaction& transaction);
77 AllocatedBlock(BlockAllocator* allocator, Transaction& transaction) argument
[all...]
H A DDirectory.cpp73 Transaction& transaction);
75 Transaction& transaction);
77 status_t FreeTree(Transaction& transaction);
93 status_t _InitWritable(Transaction& transaction);
99 bool insertKey, Transaction& transaction);
102 Transaction& transaction);
105 Transaction& transaction, Block& newBlock,
753 Transaction& transaction)
757 status_t error = _InitWritable(transaction);
839 transaction);
752 InsertEntry(const char* name, uint64 blockIndex, Transaction& transaction) argument
844 RemoveEntry(const char* name, Transaction& transaction) argument
985 FreeTree(Transaction& transaction) argument
1075 _InitWritable(Transaction& transaction) argument
1104 _UpdateOrInsertKey(LevelInfo* infos, int32 level, const char* name, size_t nameLength, uint64 blockIndex, bool insertKey, Transaction& transaction) argument
[all...]
H A DDirectory.h28 Transaction& transaction);
30 Transaction& transaction,
H A DFile.cpp112 // start a transaction
113 Transaction transaction(GetVolume());
114 status_t error = transaction.Start();
116 ERROR("Failed to start transaction for deleting contents of file at %"
121 error = Resize(0, false, transaction);
128 error = transaction.Commit();
130 ERROR("Failed to commit transaction for deleting contents of file at %"
137 File::Resize(uint64 newSize, bool fillWithZeroes, Transaction& transaction) argument
151 error = _ShrinkTree(blockCount, newBlockCount, transaction);
153 error = _GrowTree(blockCount, newBlockCount, transaction);
486 _ShrinkTree(uint64 blockCount, uint64 newBlockCount, Transaction& transaction) argument
596 _GrowTree(uint64 blockCount, uint64 newBlockCount, Transaction& transaction) argument
[all...]
H A DFile.h26 Transaction& transaction);
54 Transaction& transaction);
57 Transaction& transaction);
H A DNode.cpp108 Node::Resize(uint64 newSize, bool fillWithZeroes, Transaction& transaction) argument
259 Node::Flush(Transaction& transaction) argument
265 if (!block.GetWritable(fVolume, fBlockIndex, transaction))
H A DNode.h42 Transaction& transaction);
90 status_t Flush(Transaction& transaction);
H A DSymLink.cpp69 Transaction& transaction)
84 if (!block.GetWritable(GetVolume(), BlockIndex(), transaction))
68 WriteSymLink(const char* buffer, size_t toWrite, Transaction& transaction) argument
H A DSymLink.h22 Transaction& transaction);
H A DVolume.cpp48 mutex_init(&fTransactionLock, "checksumfs transaction");
194 Transaction transaction(this);
195 status_t error = transaction.Start();
199 error = fBlockAllocator->Initialize(transaction);
205 transaction, fRootDirectory);
209 transaction.KeepNode(fRootDirectory);
215 transaction)) {
224 // commit the transaction and flush the block cache
225 error = transaction.Commit();
334 Volume::CreateDirectory(mode_t mode, Transaction& transaction, argument
350 CreateFile(mode_t mode, Transaction& transaction, File*& _file) argument
364 CreateSymLink(mode_t mode, Transaction& transaction, SymLink*& _symLink) argument
484 _CreateNode(Node* node, Transaction& transaction) argument
[all...]
H A DVolume.h49 Transaction& transaction,
52 Transaction& transaction, File*& _file);
54 Transaction& transaction,
78 Transaction& transaction);
/haiku/headers/os/drivers/
H A Dfs_cache.h14 /* transaction events */
68 int32 transaction);
70 off_t base, off_t length, int32 transaction, void** _block);
72 int32 transaction);
74 int32 transaction);
79 bool isDirty, int32 transaction);
/haiku/headers/private/fs_shell/
H A Dfssh_fs_cache.h78 fssh_off_t blockNumber, int32_t transaction);
81 fssh_off_t length, int32_t transaction,
84 fssh_off_t blockNumber, int32_t transaction);
86 fssh_off_t blockNumber, int32_t transaction);
94 int32_t transaction);
/haiku/src/add-ons/kernel/file_systems/bfs/
H A DAttribute.cpp215 Attribute::Write(Transaction& transaction, attr_cookie* cookie, off_t pos, argument
221 return fInode->WriteAttribute(transaction, cookie->name, cookie->type,
236 Transaction transaction(fAttribute->GetVolume(),
238 fAttribute->WriteLockInTransaction(transaction);
240 status_t status = fAttribute->SetFileSize(transaction, 0);
242 status = fAttribute->WriteBack(transaction);
247 transaction.Done();
H A DBPlusTree.cpp249 CachedNode::UnsetUnchanged(Transaction& transaction) argument
257 block_cache_set_dirty(cache, fBlockNumber, false, transaction.ID());
333 CachedNode::SetToWritable(Transaction& transaction, off_t offset, bool check) argument
350 if (InternalSetTo(&transaction, offset) != NULL && check) {
364 CachedNode::MakeWritable(Transaction& transaction) argument
369 if (block_cache_make_writable(transaction.GetVolume()->BlockCache(),
370 fBlockNumber, transaction.ID()) == B_OK) {
396 CachedNode::SetToWritableHeader(Transaction& transaction) argument
405 InternalSetTo(&transaction, 0LL);
408 transaction
423 InternalSetTo(Transaction* transaction, off_t offset) argument
481 Free(Transaction& transaction, off_t offset) argument
522 Allocate(Transaction& transaction, bplustree_node** _node, off_t* _offset) argument
582 BPlusTree(Transaction& transaction, Inode* stream, int32 nodeSize) argument
643 SetTo(Transaction& transaction, Inode* stream, int32 nodeSize) argument
1156 _FindFreeDuplicateFragment(Transaction& transaction, const bplustree_node* node, CachedNode& cached, off_t* _offset, bplustree_node** _fragment, uint32* _index) argument
1198 _InsertDuplicate(Transaction& transaction, CachedNode& cached, const bplustree_node* node, uint16 index, off_t value) argument
1678 Insert(Transaction& transaction, const uint8* key, uint16 keyLength, off_t value) argument
1828 _RemoveDuplicate(Transaction& transaction, const bplustree_node* node, CachedNode& cached, uint16 index, off_t value) argument
2098 Remove(Transaction& transaction, const uint8* key, uint16 keyLength, off_t value) argument
2221 Replace(Transaction& transaction, const uint8* key, uint16 keyLength, off_t value) argument
[all...]
H A DBPlusTree.h221 bplustree_node* SetToWritable(Transaction& transaction,
223 bplustree_node* MakeWritable(Transaction& transaction);
224 bplustree_header* SetToWritableHeader(Transaction& transaction);
226 void UnsetUnchanged(Transaction& transaction);
228 status_t Free(Transaction& transaction, off_t offset);
229 status_t Allocate(Transaction& transaction,
237 bplustree_node* InternalSetTo(Transaction* transaction,
254 BPlusTree(Transaction& transaction,
263 status_t SetTo(Transaction& transaction, Inode* stream,
278 status_t Remove(Transaction& transaction,
448 Remove(Transaction& transaction, const char* key, off_t value) argument
457 Insert(Transaction& transaction, const char* key, off_t value) argument
466 Insert(Transaction& transaction, int32 key, off_t value) argument
475 Insert(Transaction& transaction, uint32 key, off_t value) argument
484 Insert(Transaction& transaction, int64 key, off_t value) argument
493 Insert(Transaction& transaction, uint64 key, off_t value) argument
502 Insert(Transaction& transaction, float key, off_t value) argument
511 Insert(Transaction& transaction, double key, off_t value) argument
[all...]
H A DBlockAllocator.cpp179 status_t SetToWritable(Transaction& transaction, AllocationGroup& group,
201 status_t Allocate(Transaction& transaction, uint16 start, int32 length);
202 status_t Free(Transaction& transaction, uint16 start, int32 length);
246 AllocationBlock::SetToWritable(Transaction& transaction, AllocationGroup& group, argument
258 return CachedBlock::SetToWritable(transaction, group.Start() + block);
379 AllocationGroup::Allocate(Transaction& transaction, uint16 start, int32 length)
411 Volume* volume = transaction.GetVolume();
421 if (cached.SetToWritable(transaction, *this, block) < B_OK) {
448 AllocationGroup::Free(Transaction& transaction, uint16 start, int32 length)
472 Volume* volume = transaction
[all...]
H A DBlockAllocator.h30 status_t InitializeAndClearBitmap(Transaction& transaction);
34 status_t AllocateForInode(Transaction& transaction,
37 status_t Allocate(Transaction& transaction, Inode* inode,
40 status_t Free(Transaction& transaction, block_run run);
42 status_t AllocateBlocks(Transaction& transaction,
H A DCachedBlock.h36 inline status_t SetToWritable(Transaction& transaction,
39 inline status_t SetToWritable(Transaction& transaction,
41 inline status_t SetToWritable(Transaction& transaction,
43 inline status_t MakeWritable(Transaction& transaction);
138 CachedBlock::SetToWritable(Transaction& transaction, off_t block, off_t base, argument
146 block, transaction.ID());
151 block, base, length, transaction.ID(), (void**)&fBlock);
156 CachedBlock::SetToWritable(Transaction& transaction, off_t block, bool empty) argument
158 return SetToWritable(transaction, block, block, 1, empty);
163 CachedBlock::SetToWritable(Transaction& transaction, block_ru argument
170 MakeWritable(Transaction& transaction) argument
[all...]
H A DCheckVisitor.cpp142 Transaction transaction(GetVolume(), 1 + i);
148 status_t status = transaction.WriteBlocks(1 + i,
154 transaction.Done();
230 Transaction transaction(GetVolume(), inode->BlockNumber());
234 status_t status = inode->SetName(transaction, treeName);
236 status = inode->WriteBack(transaction);
238 status = transaction.Done();
393 // It's safe to start a transaction, because Inode::Remove()
397 Transaction transaction(GetVolume(), parent->BlockNumber());
403 status = parent->Remove(transaction, nam
[all...]
H A DInode.cpp143 InodeAllocator(Transaction& transaction);
162 InodeAllocator::InodeAllocator(Transaction& transaction) argument
164 fTransaction(&transaction),
301 panic("transaction %d aborted, inode %p still around!\n", (int)id, inode);
373 Inode::Inode(Volume* volume, Transaction& transaction, ino_t id, mode_t mode, argument
383 PRINT(("Inode::Inode(volume = %p, transaction = %p, id = %" B_PRIdINO
384 ") @ %p\n", volume, &transaction, id, this));
390 status_t status = node.SetToWritable(transaction, this, true);
467 /*! Adds this inode to the specified transaction. This means that the inode will
468 be write locked until the transaction ende
473 WriteLockInTransaction(Transaction& transaction) argument
495 WriteBack(Transaction& transaction) argument
560 _MakeSpaceForSmallData(Transaction& transaction, bfs_inode* node, const char* name, int32 bytes) argument
664 _RemoveSmallData(Transaction& transaction, NodeGetter& nodeGetter, const char* name) argument
713 _AddSmallData(Transaction& transaction, NodeGetter& nodeGetter, const char* name, uint32 type, off_t pos, const uint8* data, size_t length, bool force) argument
970 SetName(Transaction& transaction, const char* name) argument
988 _RemoveAttribute(Transaction& transaction, const char* name, bool hasIndex, Index* index) argument
1094 WriteAttribute(Transaction& transaction, const char* name, int32 type, off_t pos, const uint8* buffer, size_t* _length, bool* _created) argument
1266 RemoveAttribute(Transaction& transaction, const char* name) argument
1358 CreateAttribute(Transaction& transaction, const char* name, uint32 type, Inode** attribute) argument
1407 ContainerContentsChanged(Transaction& transaction) argument
1582 WriteAt(Transaction& transaction, off_t pos, const uint8* buffer, size_t* _length) argument
1694 _AllocateBlockArray(Transaction& transaction, block_run& run, size_t length, bool variableSize) argument
1723 _GrowStream(Transaction& transaction, off_t size) argument
2079 _FreeStaticStreamArray(Transaction& transaction, int32 level, block_run run, off_t size, off_t offset, off_t& max) argument
2153 _FreeStreamArray(Transaction& transaction, block_run* array, uint32 arrayLength, off_t size, off_t& offset, off_t& max) argument
2206 _ShrinkStream(Transaction& transaction, off_t size) argument
2270 SetFileSize(Transaction& transaction, off_t size) argument
2305 Append(Transaction& transaction, off_t bytes) argument
2335 TrimPreallocation(Transaction& transaction) argument
2350 Free(Transaction& transaction) argument
2521 Remove(Transaction& transaction, const char* name, ino_t* _id, bool isDirectory, bool force) argument
2620 Create(Transaction& transaction, Inode* parent, const char* name, int32 mode, int openMode, uint32 type, bool* _created, ino_t* _id, Inode** _inode, fs_vnode_ops* vnodeOps, uint32 publishFlags) argument
[all...]
H A DInode.h35 Inode(Volume* volume, Transaction& transaction,
47 void WriteLockInTransaction(Transaction& transaction);
51 status_t WriteBack(Transaction& transaction);
117 status_t SetName(Transaction& transaction,
123 status_t WriteAttribute(Transaction& transaction,
127 status_t RemoveAttribute(Transaction& transaction,
134 status_t CreateAttribute(Transaction& transaction,
142 Transaction& transaction);
149 status_t WriteAt(Transaction& transaction, off_t pos,
153 status_t SetFileSize(Transaction& transaction,
355 SetToWritable(Transaction& transaction, const Inode* inode, bool empty = false) argument
[all...]
H A DJournal.cpp569 // TODO: this logic won't work whenever the size of the pending transaction
638 all blocks of a transaction have been flushed to disk.
648 PRINT(("Log entry %p has been finished, transaction ID = %" B_PRId32 "\n",
701 // The current transaction seems to be idle - flush it. (We can't do this
702 // in this thread, as flushing the log can produce new transaction events.)
722 /*! Writes the blocks that are part of current transaction into the log,
723 and ends the current transaction.
724 If the current transaction is too large to fit into the log, it will
725 try to detach an existing sub-transaction.
736 // The current transaction wo
1221 MoveListenersTo(Transaction* transaction) argument
[all...]
H A DVolume.cpp351 Volume::CreateIndicesRoot(Transaction& transaction) argument
354 status_t status = Inode::Create(transaction, NULL, NULL,
366 Volume::CreateVolumeID(Transaction& transaction) argument
382 attr.Write(transaction, cookie, 0, (uint8_t *)&id, &length, NULL);
390 Volume::AllocateForInode(Transaction& transaction, const Inode* parent, argument
393 return fBlockAllocator.AllocateForInode(transaction, &parent->BlockRun(),
608 Transaction transaction(this, 0);
610 if (fBlockAllocator.InitializeAndClearBitmap(transaction) < B_OK)
614 status_t status = Inode::Create(transaction, NULL, NULL,
625 status = index.Create(transaction, "nam
[all...]
H A Dkernel_interface.cpp346 Transaction transaction(volume, inode->BlockNumber());
348 if (inode->TrimPreallocation(transaction) == B_OK)
349 transaction.Done();
350 else if (transaction.HasParent()) {
352 transaction.Done();
371 // transaction which has already deleted the inode.
372 Transaction transaction(volume, volume->ToBlock(inode->Parent()));
385 status_t status = inode->Free(transaction);
387 status = transaction.Done();
388 } else if (transaction
1449 Transaction transaction; local
1494 Transaction transaction; local
[all...]

Completed in 148 milliseconds

1234