userlandfs/kernel_add_on/Volume.cpp

6 #include "Volume.h"
51 struct Volume::VNode {
73 	void Delete(Volume* volume)
92 struct Volume::VNodeHashDefinition {
108 struct Volume::VNodeMap
114 struct Volume::IORequestInfo {
131 struct Volume::IORequestIDHashDefinition {
147 struct Volume::IORequestStructHashDefinition {
163 struct Volume::IORequestIDMap
169 struct Volume::IORequestStructMap
175 struct Volume::IterativeFDIOCookie : public BReferenceable {
176 	Volume*				volume;
184 	IterativeFDIOCookie(Volume* volume, int fd, int32 requestID,
207 class Volume::AutoIncrementer {
233 class Volume::IORequestRemover {
235 	IORequestRemover(Volume* volume, int32 requestID)
254 	Volume*	fVolume;
260 class Volume::VNodeRemover {
262 	VNodeRemover(Volume* volume, VNode* node)
281 	Volume*	fVolume;
288 Volume::HasVNodeCapability(VNode* vnode, int capability) const
295 Volume::Volume(FileSystem* fileSystem, fs_volume* fsVolume)
320 Volume::~Volume()
334 Volume::GetVNode(ino_t vnid, void** _node)
349 Volume::PutVNode(ino_t vnid)
364 Volume::AcquireVNode(ino_t vnid)
376 Volume::NewVNode(ino_t vnid, void* clientNode,
426 Volume::PublishVNode(ino_t vnid, void* clientNode, int type, uint32 flags,
494 Volume::RemoveVNode(ino_t vnid)
502 Volume::UnremoveVNode(ino_t vnid)
510 Volume::GetVNodeRemoved(ino_t vnid, bool* removed)
520 Volume::CreateFileCache(ino_t vnodeID, off_t size)
552 Volume::DeleteFileCache(ino_t vnodeID)
577 Volume::SetFileCacheEnabled(ino_t vnodeID, bool enabled)
607 Volume::SetFileCacheSize(ino_t vnodeID, off_t size)
629 Volume::SyncFileCache(ino_t vnodeID)
651 Volume::ReadFileCache(ino_t vnodeID, void* cookie,
674 Volume::WriteFileCache(ino_t vnodeID, void* cookie,
696 Volume::ReadFromIORequest(int32 requestID, void* buffer, size_t size)
709 Volume::WriteToIORequest(int32 requestID, const void* buffer, size_t size)
723 Volume::DoIterativeFDIO(int fd, int32 requestID, void* clientCookie,
766 Volume::NotifyIORequest(int32 requestID, status_t status)
784 Volume::Mount(const char* device, uint32 flags, const char* parameters)
818 		ERROR(("Volume::Mount(): new_vnode() was not called for root node! "
838 Volume::Unmount()
884 Volume::Sync()
921 Volume::ReadFSInfo(fs_info* info)
927 		WARN(("Volume::ReadFSInfo(): connection lost, emulating lookup `.'\n"));
945 Volume::WriteFSInfo(const struct fs_info *info, uint32 mask)
988 Volume::Lookup(void* dir, const char* entryName, ino_t* vnid)
995 		WARN(("Volume::Lookup(): connection lost, emulating lookup `.'\n"));
1009 Volume::GetVNodeName(void* _node, char* buffer, size_t bufferSize)
1060 Volume::ReadVNode(ino_t vnid, bool reenter, void** _node, fs_vnode_ops** _ops,
1128 Volume::WriteVNode(void* node, bool reenter)
1135 		WARN(("Volume::WriteVNode(): connection lost, forcing write vnode\n"));
1143 Volume::RemoveVNode(void* _node, bool reenter)
1191 Volume::DoIO(void* _node, void* cookie, io_request* ioRequest)
1257 Volume::CancelIO(void* _node, void* cookie, io_request* ioRequest)
1316 Volume::IOCtl(void* _node, void* cookie, uint32 command, void *buffer,
1338 			PRINT(("Volume::IOCtl(): USERLANDFS_IOCTL\n"));
1349 							PRINT(("Volume::IOCtl(): bad magic\n"));
1351 						PRINT(("Volume::IOCtl(): bad buffer size\n"));
1353 					PRINT(("Volume::IOCtl(): failed to get area info\n"));
1355 				PRINT(("Volume::IOCtl(): bad area\n"));
1363 				PRINT(("Volume::IOCtl(): unknown command\n"));
1374 					PRINT(("Volume::IOCtl(): buffer is NULL\n"));
1380 					PRINT(("Volume::IOCtl(): bad area\n"));
1386 					PRINT(("Volume::IOCtl(): failed to get area info\n"));
1393 					PRINT(("Volume::IOCtl(): bad buffer size\n"));
1398 					PRINT(("Volume::IOCtl(): buffer not writable\n"));
1464 Volume::SetFlags(void* _node, void* cookie, int flags)
1506 Volume::Select(void* _node, void* cookie, uint8 event, selectsync* sync)
1560 Volume::Deselect(void* _node, void* cookie, uint8 event, selectsync* sync)
1612 Volume::FSync(void* _node)
1652 Volume::ReadSymlink(void* _node, char* buffer, size_t bufferSize,
1705 Volume::CreateSymlink(void* _dir, const char* name, const char* target,
1752 Volume::Link(void* _dir, const char* name, void* node)
1797 Volume::Unlink(void* _dir, const char* name)
1840 Volume::Rename(void* _oldDir, const char* oldName, void* _newDir,
1888 Volume::Access(void* _node, int mode)
1929 Volume::ReadStat(void* node, struct stat* st)
1936 		WARN(("Volume::ReadStat(): connection lost, emulating stat for the "
1959 Volume::WriteStat(void* _node, const struct stat* st, uint32 mask)
2004 Volume::Create(void* _dir, const char* name, int openMode, int mode,
2058 Volume::Open(void* _node, int openMode, void** cookie)
2101 Volume::Close(void* node, void* cookie)
2108 		WARN(("Volume::Close(): connection lost, forcing close\n"));
2116 Volume::FreeCookie(void* node, void* cookie)
2123 		WARN(("Volume::FreeCookie(): connection lost, forcing free cookie\n"));
2136 Volume::Read(void* _node, void* cookie, off_t pos, void* buffer,
2194 Volume::Write(void* _node, void* cookie, off_t pos, const void* buffer,
2246 Volume::CreateDir(void* _dir, const char* name, int mode)
2290 Volume::RemoveDir(void* _dir, const char* name)
2333 Volume::OpenDir(void* _node, void** cookie)
2376 Volume::CloseDir(void* node, void* cookie)
2383 		WARN(("Volume::CloseDir(): connection lost, forcing close dir\n"));
2391 Volume::FreeDirCookie(void* node, void* cookie)
2398 		WARN(("Volume::FreeDirCookie(): connection lost, forcing free dir "
2411 Volume::ReadDir(void* _node, void* cookie, void* buffer, size_t bufferSize,
2457 	PRINT(("Volume::ReadDir(): buffer returned: %" B_PRId32 " bytes\n",
2476 Volume::RewindDir(void* _node, void* cookie)
2521 Volume::OpenAttrDir(void* _node, void** cookie)
2564 Volume::CloseAttrDir(void* node, void* cookie)
2571 		WARN(("Volume::CloseAttrDir(): connection lost, forcing close attr "
2580 Volume::FreeAttrDirCookie(void* node, void* cookie)
2587 		WARN(("Volume::FreeAttrDirCookie(): connection lost, forcing free attr "
2601 Volume::ReadAttrDir(void* _node, void* cookie, void* buffer,
2662 Volume::RewindAttrDir(void* _node, void* cookie)
2706 Volume::CreateAttr(void* _node, const char* name, uint32 type, int openMode,
2755 Volume::OpenAttr(void* _node, const char* name, int openMode,
2803 Volume::CloseAttr(void* node, void* cookie)
2810 		WARN(("Volume::CloseAttr(): connection lost, forcing close attr\n"));
2818 Volume::FreeAttrCookie(void* node, void* cookie)
2825 		WARN(("Volume::FreeAttrCookie(): connection lost, forcing free attr "
2839 Volume::ReadAttr(void* _node, void* cookie, off_t pos,
2896 Volume::WriteAttr(void* _node, void* cookie, off_t pos,
2945 Volume::ReadAttrStat(void* _node, void* cookie, struct stat *st)
2987 Volume::WriteAttrStat(void* _node, void* cookie, const struct stat *st,
3031 Volume::RenameAttr(void* _oldNode, const char* oldName, void* _newNode,
3079 Volume::RemoveAttr(void* _node, const char* name)
3126 Volume::OpenIndexDir(void** cookie)
3166 Volume::CloseIndexDir(void* cookie)
3173 		WARN(("Volume::CloseIndexDir(): connection lost, forcing close "
3182 Volume::FreeIndexDirCookie(void* cookie)
3189 		WARN(("Volume::FreeIndexDirCookie(): connection lost, forcing free "
3203 Volume::ReadIndexDir(void* cookie, void* buffer, size_t bufferSize,
3262 Volume::RewindIndexDir(void* cookie)
3300 Volume::CreateIndex(const char* name, uint32 type, uint32 flags)
3342 Volume::RemoveIndex(const char* name)
3382 Volume::ReadIndexStat(const char* name, struct stat *st)
3427 Volume::OpenQuery(const char* queryString, uint32 flags, port_id targetPort,
3474 Volume::CloseQuery(void* cookie)
3481 		WARN(("Volume::CloseQuery(): connection lost, forcing close query\n"));
3489 Volume::FreeQueryCookie(void* cookie)
3496 		WARN(("Volume::FreeQueryCookie(): connection lost, forcing free "
3510 Volume::ReadQuery(void* cookie, void* buffer, size_t bufferSize,
3569 Volume::RewindQuery(void* cookie)
3611 Volume::_InitVolumeOps()
3664 Volume::_Mount(const char* device, uint32 flags, const char* parameters)
3714 Volume::_Unmount()
3747 Volume::_ReadFSInfo(fs_info* info)
3785 Volume::_Lookup(void* _dir, const char* entryName, ino_t* vnid)
3827 Volume::_WriteVNode(void* _node, bool reenter)
3870 Volume::_ReadStat(void* _node, struct stat* st)
3911 Volume::_Close(void* _node, void* cookie)
3952 Volume::_FreeCookie(void* _node, void* cookie)
3993 Volume::_CloseDir(void* _node, void* cookie)
4034 Volume::_FreeDirCookie(void* _node, void* cookie)
4075 Volume::_CloseAttrDir(void* _node, void* cookie)
4116 Volume::_FreeAttrDirCookie(void* _node, void* cookie)
4157 Volume::_CloseAttr(void* _node, void* cookie)
4198 Volume::_FreeAttrCookie(void* _node, void* cookie)
4239 Volume::_CloseIndexDir(void* cookie)
4277 Volume::_FreeIndexDirCookie(void* cookie)
4315 Volume::_CloseQuery(void* cookie)
4353 Volume::_FreeQueryCookie(void* cookie)
4391 Volume::_SendRequest(RequestPort* port, RequestAllocator* allocator,
4417 Volume::_SendReceiptAck(RequestPort* port)
4429 Volume::_IncrementVNodeCount(ino_t vnid)
4438 		ERROR(("Volume::_IncrementVNodeCount(): Node with ID %" B_PRId64
4450 Volume::_DecrementVNodeCount(ino_t vnid)
4459 		ERROR(("Volume::_DecrementVNodeCount(): Node with ID %" B_PRId64 " not "
4471 Volume::_RemoveInvalidVNode(ino_t vnid)
4477 		ERROR(("Volume::_RemoveInvalidVNode(): Node with ID %" B_PRId64
4497 Volume::_InternalIOCtl(userlandfs_ioctl* buffer, int32 bufferSize)
4515 Volume::_PutAllPendingVNodes()
4517 PRINT(("Volume::_PutAllPendingVNodes()\n"));
4519 		PRINT(("Volume::_PutAllPendingVNodes() failed: still connected\n"));
4526 		PRINT(("Volume::_PutAllPendingVNodes() failed: vnode counting "
4532 		PRINT(("Volume::_PutAllPendingVNodes() failed: open files\n"));
4536 		PRINT(("Volume::_PutAllPendingVNodes() failed: open dirs\n"));
4540 		PRINT(("Volume::_PutAllPendingVNodes() failed: open attr dirs\n"));
4544 		PRINT(("Volume::_PutAllPendingVNodes() failed: open attributes\n"));
4548 		PRINT(("Volume::_PutAllPendingVNodes() failed: open index dirs\n"));
4552 		PRINT(("Volume::_PutAllPendingVNodes() failed: open queries\n"));
4602 	PRINT(("Volume::_PutAllPendingVNodes() successful: Put %" B_PRId32
4611 Volume::_RegisterIORequest(io_request* request, int32* requestID)
4637 Volume::_UnregisterIORequest(int32 requestID)
4653 Volume::_FindIORequest(int32 requestID, io_request** request)
4668 Volume::_FindIORequest(io_request* request, int32* requestID)
4682 Volume::_IterativeFDIOGetVecs(void* _cookie, io_request* ioRequest,
4686 	Volume* volume = cookie->volume;
4768 Volume::_IterativeFDIOFinished(void* _cookie, io_request* ioRequest,
4772 	Volume* volume = cookie->volume;