/foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/cloud_disk/ |
H A D | fuse_operations.cpp | 40 auto inoPtr = GetCloudDiskInode(req, parent); in Lookup() local 41 if (inoPtr == nullptr) { in Lookup() 46 inoPtr->ops->Lookup(req, parent, name); in Lookup() 56 auto inoPtr = GetCloudDiskInode(req, ino); in Access() local 57 if (inoPtr == nullptr) { in Access() 62 inoPtr->ops->Access(req, ino, mask); in Access() 72 auto inoPtr = GetCloudDiskInode(req, ino); in GetAttr() local 73 if (inoPtr == nullptr) { in GetAttr() 78 inoPtr->ops->GetAttr(req, ino, fi); in GetAttr() 88 auto inoPtr in Open() local 104 auto inoPtr = GetCloudDiskInode(req, ino); Forget() local 118 auto inoPtr = GetCloudDiskInode(req, forgets[0].ino); ForgetMulti() local 135 auto inoPtr = GetCloudDiskInode(req, parent); MkNod() local 152 auto inoPtr = GetCloudDiskInode(req, parent); Create() local 170 auto inoPtr = GetCloudDiskInode(req, ino); ReadDir() local 187 auto inoPtr = GetCloudDiskInode(req, ino); SetXattr() local 204 auto inoPtr = GetCloudDiskInode(req, ino); GetXattr() local 220 auto inoPtr = GetCloudDiskInode(req, parent); MkDir() local 236 auto inoPtr = GetCloudDiskInode(req, parent); RmDir() local 252 auto inoPtr = GetCloudDiskInode(req, parent); Unlink() local 269 auto inoPtr = GetCloudDiskInode(req, parent); Rename() local 286 auto inoPtr = GetCloudDiskInode(req, ino); Read() local 303 auto inoPtr = GetCloudDiskInode(req, ino); WriteBuf() local 319 auto inoPtr = GetCloudDiskInode(req, ino); Release() local 335 auto inoPtr = GetCloudDiskInode(req, ino); SetAttr() local 351 auto inoPtr = GetCloudDiskInode(req, ino); Lseek() local [all...] |
H A D | file_operations_cloud.cpp | 182 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, inodeId); in LookupRecycledFile() local 183 if (inoPtr == nullptr) { in LookupRecycledFile() 187 inoPtr = UpdateChildCache(data, inodeId, inoPtr); in LookupRecycledFile() 188 inoPtr->refCount++; in LookupRecycledFile() 189 InitInodeAttr(data, RECYCLE_LOCAL_ID, inoPtr.get(), metaBase, inodeId); in LookupRecycledFile() 190 inoPtr->parent = UNKNOWN_INODE_ID; in LookupRecycledFile() 193 FileOperationsHelper::GetInodeAttr(inoPtr, &e->attr); in LookupRecycledFile() 234 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, inodeId); in DoCloudLookup() local 235 // if inoPtr i in DoCloudLookup() 269 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); GetAttr() local 324 CloudOpen(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr, struct fuse_file_info *fi, string path) CloudOpen() argument 378 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); Open() local 610 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); GetChildInfos() local 754 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); HandleCloudLocation() local 784 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); HandleCloudRecycle() local 828 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); HandleFavorite() local 850 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); HandleExtAttribute() local 898 GetIsFavorite(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr) GetIsFavorite() argument 913 GetFileStatus(fuse_req_t req, struct CloudDiskInode *inoPtr) GetFileStatus() argument 932 GetLocation(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr) GetLocation() argument 952 GetExtAttr(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr, const char *extAttrKey) GetExtAttr() argument 981 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); GetXattr() local 1228 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, localId); Rename() local 1290 UpdateCloudDiskInode(shared_ptr<CloudDiskRdbStore> rdbStore, shared_ptr<CloudDiskInode> inoPtr) UpdateCloudDiskInode() argument 1303 UpdateCloudStore(CloudDiskFuseData *data, const std::string &fileName, const std::string &parentCloudId, int fileDirty, shared_ptr<CloudDiskInode> inoPtr) UpdateCloudStore() argument 1325 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); UpdateCacheDentrySize() local 1396 UploadLocalFile(CloudDiskFuseData *data, const std::string &fileName, const std::string &parentCloudId, int fileDirty, shared_ptr<CloudDiskInode> inoPtr) UploadLocalFile() argument 1427 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); Release() local 1481 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); SetAttr() local 1530 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); Lseek() local [all...] |
H A D | file_operations_helper.cpp | 70 int32_t FileOperationsHelper::GetNextLayer(std::shared_ptr<CloudDiskInode> inoPtr, fuse_ino_t ino) in GetNextLayer() argument 75 if (inoPtr->layer >= CLOUD_DISK_INODE_OTHER_LAYER) { in GetNextLayer() 78 return inoPtr->layer + 1; in GetNextLayer() 204 shared_ptr<CloudDiskInode> inoPtr, uint64_t num, int64_t key) in PutCloudDiskInode() 207 if (inoPtr == nullptr) { in PutCloudDiskInode() 211 inoPtr->refCount -= num; in PutCloudDiskInode() 212 if (inoPtr->refCount == 0) { in PutCloudDiskInode() 237 std::shared_ptr<CloudDiskInode> inoPtr, in PutLocalId() 241 if (inoPtr == nullptr) { in PutLocalId() 245 inoPtr in PutLocalId() 203 PutCloudDiskInode(struct CloudDiskFuseData *data, shared_ptr<CloudDiskInode> inoPtr, uint64_t num, int64_t key) PutCloudDiskInode() argument 236 PutLocalId(struct CloudDiskFuseData *data, std::shared_ptr<CloudDiskInode> inoPtr, uint64_t num, const std::string &key) PutLocalId() argument [all...] |
H A D | file_operations_base.cpp | 70 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(forgets[i].ino)); in ForgetMulti() local 71 if (inoPtr == nullptr) { in ForgetMulti() 75 string localIdKey = std::to_string(inoPtr->parent) + inoPtr->fileName; in ForgetMulti() 76 FileOperationsHelper::PutCloudDiskInode(data, inoPtr, forgets[i].nlookup, forgets[i].ino); in ForgetMulti() 77 FileOperationsHelper::PutLocalId(data, inoPtr, forgets[i].nlookup, localIdKey); in ForgetMulti()
|
H A D | file_operations_local.cpp | 115 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); in GetAttr() local 116 if (inoPtr == nullptr) { in GetAttr() 121 fuse_reply_attr(req, &inoPtr->stat, 0); in GetAttr() 134 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); in ReadDir() local 135 if (inoPtr == nullptr) { in ReadDir() 140 path = inoPtr->path; in ReadDir()
|
/foundation/filemanagement/dfs_service/services/clouddisk_database/src/ |
H A D | clouddisk_notify_utils.cpp | 39 shared_ptr<CloudDiskInode> inoPtr, string &uri) in GetUriRecursively() 41 string bundleName = inoPtr->bundleName; in GetUriRecursively() 45 while (!isRoot(inoPtr->parent)) { in GetUriRecursively() 46 inoPtr = func(data, inoPtr->parent); in GetUriRecursively() 47 if (!inoPtr || inoPtr->fileName.empty()) { in GetUriRecursively() 50 uri = inoPtr->fileName + BACKFLASH + uri; in GetUriRecursively() 67 auto inoPtr = func(data, ino); in GetNotifyData() local 68 if (inoPtr in GetNotifyData() 38 GetUriRecursively(CloudDiskFuseData* data, FindCloudDiskInodeFunc func, shared_ptr<CloudDiskInode> inoPtr, string &uri) GetUriRecursively() argument 80 auto inoPtr = func(data, parent); GetNotifyData() local 92 GetNotifyData(CloudDiskFuseData* data, FindCloudDiskInodeFunc func, shared_ptr<CloudDiskInode> inoPtr, NotifyData ¬ifyData) GetNotifyData() argument [all...] |
H A D | clouddisk_notify.cpp | 56 if (paramDisk.inoPtr == nullptr) { in GetTrashNotifyData() 61 paramDisk.inoPtr->bundleName); in GetTrashNotifyData() 62 notifyData.uri = realPrefix + BACKFLASH + RECYCLE_BIN + BACKFLASH + paramDisk.inoPtr->fileName; in GetTrashNotifyData() 90 if (paramDisk.inoPtr != nullptr) { in GetDataInner() 92 paramDisk.inoPtr, notifyData); in GetDataInner() 106 if (paramDisk.inoPtr != nullptr) { in GetDataInnerWithName() 108 paramDisk.inoPtr, paramDisk.name, notifyData); in GetDataInnerWithName() 134 shared_ptr<CloudDiskRdbStore> rdbStore = GetRdbStore(paramDisk.inoPtr->bundleName, paramDisk.data->userId); in HandleRecycleRestore() 136 LOGE("Get rdb store fail, bundleName: %{public}s", paramDisk.inoPtr->bundleName.c_str()); in HandleRecycleRestore() 139 if (TrashUriAddRowId(rdbStore, paramDisk.inoPtr in HandleRecycleRestore() [all...] |
/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/mock/ |
H A D | file_operations_cloud_mock.cpp | 131 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, inodeId); in LookupRecycledFile() local 132 if (inoPtr == nullptr) { in LookupRecycledFile() 136 inoPtr = UpdateChildCache(data, inodeId, inoPtr); in LookupRecycledFile() 137 inoPtr->refCount++; in LookupRecycledFile() 138 InitInodeAttr(data, RECYCLE_LOCAL_ID, inoPtr.get(), metaBase, inodeId); in LookupRecycledFile() 139 inoPtr->parent = UNKNOWN_INODE_ID; in LookupRecycledFile() 142 FileOperationsHelper::GetInodeAttr(inoPtr, &e->attr); in LookupRecycledFile() 214 shared_ptr<CloudDiskInode> inoPtr, struct fuse_file_info *fi, string path) in CloudOpen() 349 auto inoPtr in GetChildInfos() local 213 CloudOpen(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr, struct fuse_file_info *fi, string path) CloudOpen() argument 454 GetIsFavorite(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr) GetIsFavorite() argument 468 GetFileStatus(fuse_req_t req, struct CloudDiskInode *inoPtr) GetFileStatus() argument 486 GetLocation(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr) GetLocation() argument 506 GetExtAttr(fuse_req_t req, shared_ptr<CloudDiskInode> inoPtr, const char *extAttrKey) GetExtAttr() argument 607 UpdateCloudDiskInode(shared_ptr<CloudDiskRdbStore> rdbStore, shared_ptr<CloudDiskInode> inoPtr) UpdateCloudDiskInode() argument 612 UpdateCloudStore(CloudDiskFuseData *data, const std::string &fileName, const std::string &parentCloudId, int32_t userId, shared_ptr<CloudDiskInode> inoPtr) UpdateCloudStore() argument 624 UploadLocalFile(CloudDiskFuseData *data, const std::string &fileName, const std::string &parentCloudId, int fileDirty, shared_ptr<CloudDiskInode> inoPtr) UploadLocalFile() argument [all...] |
H A D | file_operations_local_mock.cpp | 50 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); in GetAttr() local 51 if (inoPtr == nullptr) { in GetAttr() 56 fuse_reply_attr(req, &inoPtr->stat, 0); in GetAttr() 69 auto inoPtr = FileOperationsHelper::FindCloudDiskInode(data, static_cast<int64_t>(ino)); in ReadDir() local 70 if (inoPtr == nullptr) { in ReadDir() 75 path = inoPtr->path; in ReadDir()
|
H A D | file_operations_helper_mock.cpp | 76 int32_t FileOperationsHelper::GetNextLayer(std::shared_ptr<CloudDiskInode> inoPtr, fuse_ino_t ino) in GetNextLayer() argument 81 if (inoPtr->layer >= CLOUD_DISK_INODE_OTHER_LAYER) { in GetNextLayer() 84 return inoPtr->layer + 1; in GetNextLayer() 197 shared_ptr<CloudDiskInode> inoPtr, uint64_t num, int64_t key) in PutCloudDiskInode() 200 if (inoPtr == nullptr) { in PutCloudDiskInode() 204 inoPtr->refCount -= num; in PutCloudDiskInode() 205 if (inoPtr->refCount == 0) { in PutCloudDiskInode() 230 std::shared_ptr<CloudDiskInode> inoPtr, in PutLocalId() 234 if (inoPtr == nullptr) { in PutLocalId() 238 inoPtr in PutLocalId() 196 PutCloudDiskInode(struct CloudDiskFuseData *data, shared_ptr<CloudDiskInode> inoPtr, uint64_t num, int64_t key) PutCloudDiskInode() argument 229 PutLocalId(struct CloudDiskFuseData *data, std::shared_ptr<CloudDiskInode> inoPtr, uint64_t num, const std::string &key) PutLocalId() argument [all...] |
/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/ |
H A D | file_operations_helper_test.cpp | 149 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in HWTEST_F() local 151 inoPtr->stat.st_mode |= S_IFREG; in HWTEST_F() 153 fuseoperationshelper_->GetInodeAttr(inoPtr, &statBuf); in HWTEST_F() 172 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in HWTEST_F() local 174 inoPtr->stat.st_mode |= S_IFMT; in HWTEST_F() 176 fuseoperationshelper_->GetInodeAttr(inoPtr, &statBuf); in HWTEST_F() 195 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in HWTEST_F() local 198 int ret = fuseoperationshelper_->GetNextLayer(inoPtr, ino); in HWTEST_F() 218 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in HWTEST_F() local 219 inoPtr in HWTEST_F() 242 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); HWTEST_F() local 634 std::shared_ptr<CloudDiskInode> inoPtr = nullptr; HWTEST_F() local 659 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); HWTEST_F() local 685 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); HWTEST_F() local 785 std::shared_ptr<CloudDiskInode> inoPtr = nullptr; HWTEST_F() local 810 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); HWTEST_F() local 836 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); HWTEST_F() local [all...] |
/foundation/filemanagement/dfs_service/test/unittests/clouddisk_database/mock/ |
H A D | clouddisk_notify_utils_mock.cpp | 40 shared_ptr<CloudDiskInode> inoPtr, string &uri)
in GetUriRecursively() 42 string bundleName = inoPtr->bundleName;
in GetUriRecursively() 46 while (!isRoot(inoPtr->parent)) {
in GetUriRecursively() 47 inoPtr = func(data, inoPtr->parent);
in GetUriRecursively() 48 if (!inoPtr || inoPtr->fileName.empty()) {
in GetUriRecursively() 51 uri = inoPtr->fileName + BACKFLASH + uri;
in GetUriRecursively() 82 shared_ptr<CloudDiskInode> inoPtr, NotifyData ¬ifyData)
in GetNotifyData() 39 GetUriRecursively(CloudDiskFuseData* data, FindCloudDiskInodeFunc func, shared_ptr<CloudDiskInode> inoPtr, string &uri) GetUriRecursively() argument 81 GetNotifyData(CloudDiskFuseData* data, FindCloudDiskInodeFunc func, shared_ptr<CloudDiskInode> inoPtr, NotifyData ¬ifyData) GetNotifyData() argument
|
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/include/cloud_disk/ |
H A D | file_operations_helper.h | 25 static int32_t GetNextLayer(std::shared_ptr<CloudDiskInode> inoPtr, fuse_ino_t parent); 40 std::shared_ptr<CloudDiskInode> inoPtr, uint64_t num, int64_t key); 44 std::shared_ptr<CloudDiskInode> inoPtr, uint64_t num, const std::string &key);
|
/foundation/filemanagement/dfs_service/test/unittests/clouddisk_database/ |
H A D | clouddisk_notify_test.cpp | 74 paramDisk.inoPtr = nullptr; in HWTEST_F() 96 paramDisk.inoPtr = ino; in HWTEST_F() 117 paramDisk.inoPtr = nullptr; in HWTEST_F() 139 paramDisk.inoPtr = ino; in HWTEST_F() 160 paramDisk.inoPtr = nullptr; in HWTEST_F() 183 paramDisk.inoPtr = ino; in HWTEST_F() 208 paramDisk.inoPtr = ino; in HWTEST_F() 232 paramDisk.inoPtr = ino; in HWTEST_F() 256 paramDisk.inoPtr = ino; in HWTEST_F() 280 paramDisk.inoPtr in HWTEST_F() [all...] |
H A D | clouddisk_notify_utils_test.cpp | 40 std::shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in MockFunc() local 42 inoPtr->parent = FUSE_ROOT_ID; in MockFunc() 45 inoPtr->parent = 0; in MockFunc() 46 inoPtr->fileName = ""; in MockFunc() 48 return inoPtr; in MockFunc() 237 shared_ptr<CloudDiskInode> inoPtr = make_shared<CloudDiskInode>(); in HWTEST_F() local 239 int ret = CloudDiskNotifyUtils.GetNotifyData(data, func, inoPtr, notifyData); in HWTEST_F()
|
/foundation/filemanagement/dfs_service/services/clouddisk_database/include/ |
H A D | clouddisk_notify_utils.h | 37 shared_ptr<CloudDiskInode> inoPtr, NotifyData ¬ifyData); 39 shared_ptr<CloudDiskInode> inoPtr, const string &name, NotifyData ¬ifyData);
|
H A D | clouddisk_notify_const.h | 51 std::shared_ptr<CloudDiskInode> inoPtr = nullptr; member
|
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/fuse_manager/ |
H A D | fuse_manager.cpp | 381 struct CloudInode *inoPtr = reinterpret_cast<struct CloudInode *>(ino); in GetCloudInode() local 382 if (inoPtr == nullptr) { in GetCloudInode() 383 LOGE("inoPtr is nullptr"); in GetCloudInode() 386 return FindNode(data, inoPtr->path); in GetCloudInode()
|