//#include "fuse.h" add this when layer3 #define FUSE_USE_VERSION 31 #include "files.h" #include #include #include FileNode* FilesOperation::fischl_load_entry(TreeNode *root, const char *path){ return fischl_find_entry(fs, root, path); } void FilesOperation::printbuffer(const char *buff, int len) { for (int i = 0; i < len; i++) { printf("%x ", buff[i]); } printf("\n"); } FilesOperation::FilesOperation(RawDisk &disk_, Fs *fs) : disk(disk_) { this->fs = fs; } void FilesOperation::create_dot_dotdot(INode_Data *inode, u_int64_t parent_inode_number) { char buffer[IO_BLOCK_SIZE] = {0}; DirectoryEntry dot; dot.inode_number = inode->inode_num; strcpy(dot.file_name, "."); dot.serialize(buffer); DirectoryEntry dotdot; dotdot.inode_number = parent_inode_number; strcpy(dotdot.file_name, ".."); dotdot.serialize(buffer + 264); int ret = fs->write(inode, buffer, IO_BLOCK_SIZE, 0); // printf("in create_dot_dotdot: fs->write returned %d\n",ret); } void FilesOperation::initialize_rootinode() { // this method must be called explicitly right after initializion INode_Data *root_inode = new INode_Data(); fs->inode_manager->new_inode(getuid(), getgid(), S_IFDIR|0755, root_inode); u_int64_t root_inode_number = root_inode->inode_num; create_dot_dotdot(root_inode, root_inode_number); root_node = fischl_init_entry(root_inode_number, "/", root_inode); assert(root_node->self_info!=NULL); fs->inode_manager->save_inode(root_inode); } void FilesOperation::initialize(bool load) { if (load){ INode_Data *root_inode = new INode_Data(); root_inode->inode_num = 1; fs->inode_manager->load_inode(root_inode); root_node = fischl_init_entry(1, "/", root_inode); assert(root_node->self_info!=NULL); fs->load_superblock(); } else{ initialize_rootinode(); } } void FilesOperation::printDirectory(u_int64_t inode_number) { INode_Data inode; inode.inode_num = inode_number; fs->inode_manager->load_inode(&inode); char buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { ent.deserialize(buffer + i); if (ent.inode_number) printf("%s\t%llu;\t", ent.file_name, ent.inode_number); } } printf("\n"); } INode_Data *FilesOperation::create_new_inode(u_int64_t parent_inode_number, const char *name, mode_t mode) { // trys to create a file under parent directory if (strlen(name) >= 256) { perror("Name too long, cannot create file or directory"); return NULL; } INode_Data inode; inode.inode_num = parent_inode_number; fs->inode_manager->load_inode(&inode); if ((inode.metadata.permissions & S_IFMT) != S_IFDIR) { fprintf(stderr, "[%s ,%d] please create under directory\n", __func__, __LINE__); return NULL; } // Check if file or directory already exists char r_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, r_buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { ent.deserialize(r_buffer + i); if (strcmp(ent.file_name, name) == 0 && ent.inode_number != 0) { if ((mode & S_IFMT) == S_IFDIR) { fprintf(stderr, "[%s ,%d] %s/ already exists\n", __func__, __LINE__, name); } else { fprintf(stderr, "[%s ,%d] %s already exists\n", __func__, __LINE__, name); } return NULL; } } } bool allocated = false; INode_Data *new_inode = new INode_Data(); fs->inode_manager->new_inode(getuid(), getgid(), mode, new_inode); //printf("%llu\n",new_inode->inode_num); if ((mode & S_IFMT) == S_IFDIR) { create_dot_dotdot(new_inode, parent_inode_number); fs->inode_manager->save_inode(new_inode); } char rw_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, rw_buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { ent.deserialize(rw_buffer + i); if (ent.inode_number == 0) { allocated = true; ent.inode_number = new_inode->inode_num; strcpy(ent.file_name, name); ent.serialize(rw_buffer + i); break; } } if (allocated) { fs->write(&inode, rw_buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); break; } } if (!allocated) { char write_buffer[IO_BLOCK_SIZE] = {0}; DirectoryEntry ent; ent.inode_number = new_inode->inode_num; strcpy(ent.file_name, name); ent.serialize(write_buffer); fs->write(&inode, write_buffer, IO_BLOCK_SIZE, (inode.metadata.size / IO_BLOCK_SIZE) * IO_BLOCK_SIZE); fs->inode_manager->save_inode(&inode); } return new_inode; } u_int64_t FilesOperation::disk_namei(const char *path) { // returns the inode number corresponding to path u_int64_t current_inode = root_node->self_info->inode_number; std::string current_dirname; std::istringstream pathStream(path); std::string new_name; std::getline(pathStream, new_name, '/'); if (!new_name.empty()) { printf("disk_namei: path should start with /\n"); return -1; } while (std::getline(pathStream, new_name, '/')) { INode_Data inode; inode.inode_num = current_inode; fs->inode_manager->load_inode(&inode); if ((inode.metadata.permissions & S_IFMT) != S_IFDIR || inode.metadata.size == 0) { printf("disk_namei: %s is not a non-empty directory\n", current_dirname.c_str()); return -1; } u_int64_t new_inode_number = 0; char buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { ent.deserialize(buffer + i); if (strcmp(ent.file_name, new_name.c_str()) == 0) { new_inode_number = ent.inode_number; break; } } if (new_inode_number) break; } if (!new_inode_number) { printf("disk_namei: no name matching %s under directory %s\n", new_name.c_str(), current_dirname.c_str()); return -1; } current_inode = new_inode_number; current_dirname = new_name; } return current_inode; // path = "/" should return root_inode_number // (root_node->self_info->inode_number) path = "/foo.txt" should return inode // for foo.txt path = "/mydir" should return inode for mydir path = // "/nonemptydir/foo" should return inode for foo path = "/notnonemptydir/foo" // should raise error } u_int64_t FilesOperation::namei(const char* path) { FileNode* filenode = fischl_load_entry(root_node, path); if (filenode) return filenode->inode_number; else return -1; } bool FilesOperation::permission_check(int mask, INode_Data *inode) { mode_t per = (mode_t)inode->metadata.permissions; uid_t uid = (uid_t)inode->metadata.uid; gid_t gid = (gid_t)inode->metadata.gid; //printf("PERMISSION CHECK %d %llu %llu %o\n", mask, uid, gid, per); if(getuid() == uid){ if ((mask & R_OK) && !(per & S_IRUSR)) { return false; // Permission denied for reading } if ((mask & W_OK) && !(per & S_IWUSR)) { return false; // Permission denied for writing } if ((mask & X_OK) && !(per & S_IXUSR)) { return false; // Permission denied for executing } return true; } else if(getgid() == gid){ if ((mask & R_OK) && !(per & S_IRGRP)) { return false; // Permission denied for reading } if ((mask & W_OK) && !(per & S_IWGRP)) { return false; // Permission denied for writing } if ((mask & X_OK) && !(per & S_IXGRP)) { return false; // Permission denied for executing } return true; } else{ if ((mask & R_OK) && !(per & S_IROTH)) { return false; // Permission denied for reading } if ((mask & W_OK) && !(per & S_IWOTH)) { return false; // Permission denied for writing } if ((mask & X_OK) && !(per & S_IXOTH)) { return false; // Permission denied for executing } return true; } } bool FilesOperation::permission_check_by_inode_num(int mask, u_int64_t inode_num) { INode_Data inode; inode.inode_num = inode_num; fs->inode_manager->load_inode(&inode); if(!permission_check(mask, &inode)){ return false; } return true; } int FilesOperation::fischl_access(const char* path, int mask) { u_int64_t fh = namei(path); if (fh == -1){ return -ENOENT; } if(!permission_check_by_inode_num(mask, fh)){ return -EACCES; } // return 0 when access is allowed return 0; } int FilesOperation::fischl_mkdir(const char *path, mode_t mode) { // check path char *pathdup = strdup(path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory // name; \0 char *newDirname = lastSlash + 1; //\0, get from char *ParentPath = pathdup; // pathdup are separated by pathdup, so it take // only FileNode *parent_filenode = strlen(ParentPath)? fischl_load_entry(root_node, ParentPath): root_node->self_info; if (parent_filenode == NULL) { fprintf(stderr,"[%s ,%d] ParentPath:{%s} not found\n",__func__,__LINE__, ParentPath); free(pathdup); return -ENOENT;//parentpath directory does not exist } u_int64_t parent_inode_number = parent_filenode->inode_number; if(!permission_check_by_inode_num(W_OK, parent_inode_number)){ return -EACCES; } //printf("%s, %llu, %s\n", parent_filenode->name, parent_inode_number, newDirname); //make new inode INode_Data* ret = create_new_inode(parent_inode_number, newDirname, mode|S_IFDIR);//specify S_IFDIR as directory if (ret == NULL) return -1;//ENOSPC but create_new_inode handle ENAMETOOLONG EEXIST fischl_add_entry(parent_filenode->subdirectory, ret->inode_num, newDirname, ret); free(pathdup); return 0;//SUCCESS } /* special file */ int FilesOperation::fischl_mknod(const char* path, mode_t mode, dev_t dev) { //check path char *pathdup = strdup(path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory name; \0 char *newFilename = lastSlash+1; //\0, get from char *ParentPath = pathdup;//pathdup are separated by pathdup, so it take only // fprintf(stderr,"[%s ,%d] ParentPath:%s, strlen=%d\n",__func__,__LINE__, ParentPath, strlen(ParentPath)); FileNode *parent_filenode = strlen(ParentPath)? fischl_load_entry(root_node, ParentPath): root_node->self_info; if (parent_filenode == NULL) { fprintf(stderr,"[%s ,%d] ParentPath:{%s} not found\n",__func__,__LINE__, ParentPath); free(pathdup); return -1; } u_int64_t parent_inode_number = parent_filenode->inode_number; if(!permission_check_by_inode_num(W_OK, parent_inode_number)){ return -EACCES; } //make new inode INode_Data* ret = create_new_inode(parent_inode_number, newFilename, mode); if (ret == NULL) return -1;//ENOSPC but create_new_inode handle ENAMETOOLONG EEXIST //make new node fischl_add_entry(parent_filenode->subdirectory, ret->inode_num, newFilename, ret); free(pathdup); return 0;//SUCESS } /* regular file */ int FilesOperation::fischl_create(const char* path, mode_t mode, struct fuse_file_info* fi) { //check path char *pathdup = strdup(path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory name; \0 char *newFilename = lastSlash+1; //\0, get from char *ParentPath = pathdup;//pathdup are separated by pathdup, so it take only // fprintf(stderr,"[%s ,%d] ParentPath:%s, strlen=%d\n",__func__,__LINE__, ParentPath, strlen(ParentPath)); FileNode *parent_filenode = strlen(ParentPath)? fischl_load_entry(root_node, ParentPath): root_node->self_info; if (parent_filenode == NULL) { fprintf(stderr,"[%s ,%d] ParentPath:{%s} not found\n",__func__,__LINE__, ParentPath); free(pathdup); return -1; } u_int64_t parent_inode_number = parent_filenode->inode_number; if(!permission_check_by_inode_num(W_OK, parent_inode_number)){ return -EACCES; } //make new inode INode_Data* ret = create_new_inode(parent_inode_number, newFilename, mode); if (ret == NULL) return -1;//ENOSPC but create_new_inode handle ENAMETOOLONG EEXIST //make new node in RAM fischl_add_entry(parent_filenode->subdirectory, ret->inode_num, newFilename, ret); //directly give inode number rather than create file descriptor table fi->fh = ret->inode_num;//assign file descriptor as inode number to fuse system free(pathdup); return 0;//SUCESS } int FilesOperation::fischl_getattr(const char *path, struct stat *stbuf, struct fuse_file_info *fi) { (void)fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1) { return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); //printf("GETATTR PERM %o\n", (mode_t)inode.metadata.permissions); //memset(stbuf, 0, sizeof(struct stat)); if ((inode.metadata.permissions & S_IFMT) == S_IFDIR) { stbuf->st_mode = (mode_t)inode.metadata.permissions;//S_IFDIR | 0755; stbuf->st_nlink = 2;//inode.metadata.reference_count; stbuf->st_uid = inode.metadata.uid; stbuf->st_gid = inode.metadata.gid; stbuf->st_atime = (time_t)(inode.metadata.access_time / 1000000000ULL); stbuf->st_mtime = (time_t)(inode.metadata.modification_time / 1000000000ULL); stbuf->st_size = IO_BLOCK_SIZE; stbuf->st_ino = inode.inode_num; } else if(S_ISLNK(inode.metadata.permissions)){ stbuf->st_mode = (mode_t)inode.metadata.permissions; stbuf->st_nlink = 1;//inode.metadata.reference_count; stbuf->st_uid = inode.metadata.uid; stbuf->st_gid = inode.metadata.gid; stbuf->st_atime = (time_t)(inode.metadata.access_time / 1000000000ULL); stbuf->st_mtime = (time_t)(inode.metadata.modification_time / 1000000000ULL); stbuf->st_size = inode.metadata.size; stbuf->st_ino = inode.inode_num; } else { stbuf->st_mode = (mode_t)inode.metadata.permissions; stbuf->st_nlink = inode.metadata.reference_count; stbuf->st_uid = inode.metadata.uid; stbuf->st_gid = inode.metadata.gid; stbuf->st_atime = (time_t)(inode.metadata.access_time / 1000000000ULL); stbuf->st_mtime = (time_t)(inode.metadata.modification_time / 1000000000ULL); stbuf->st_size = inode.metadata.size; stbuf->st_ino = inode.inode_num; } perror(std::to_string(inode.inode_num).c_str()); return res; } int FilesOperation::fischl_readdir(const char *path, void *buf, fuse_fill_dir_t filler, off_t ft, struct fuse_file_info *fi, enum fuse_readdir_flags flg) { // check path u_int64_t fh = namei(path); if (fh == -1) { return -1; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); if(!permission_check(R_OK, &inode)){ return -EACCES; } char buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx=0; idxread(&inode, buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(buffer+i); if (ent.inode_number) { filler(buf, ent.file_name, NULL, 0, FUSE_FILL_DIR_PLUS); printf("%s\t%llu;\t\n", ent.file_name, ent.inode_number); } } } return 0; } int FilesOperation::fischl_releasedir(const char *path, struct fuse_file_info *fi){ if(fischl_load_entry(root_node, path) == NULL) return -ENOENT; //do with file descriptor that cannot be used fi->fh = -1; return 0;//SUCESS } void FilesOperation::unlink_inode(u_int64_t inode_number) { INode_Data inode; inode.inode_num = inode_number; fs->inode_manager->load_inode(&inode); if (inode.metadata.reference_count > 1 && (inode.metadata.permissions & S_IFMT) != S_IFDIR){ inode.metadata.reference_count -= 1; fs->inode_manager->save_inode(&inode); return; } if ((inode.metadata.permissions & S_IFMT) == S_IFDIR) { char buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { if (ent.inode_number && strcmp(ent.file_name, ".") && strcmp(ent.file_name, "..")) { unlink_inode(ent.inode_number); } } } } // TODO: error handling int res = fs->truncate(&inode, 0); fs->inode_manager->free_inode(&inode); } int FilesOperation::fischl_opendir(const char* path, struct fuse_file_info* fi) { u_int64_t fh = namei(path); if (fh == -1){ return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); if(!permission_check(X_OK|R_OK, &inode)){ return -EACCES; } fi->fh = fh; return 0; } int FilesOperation::fischl_rmdir(const char* path) { char *pathdup = strdup(path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; char *dirname = lastSlash+1; char *ParentPath = pathdup; if (!strcmp(dirname,".")||!strcmp(dirname,"..")) { printf("refusing to remove . or ..\n"); return -1; } FileNode *parent_filenode = fischl_load_entry(root_node, ParentPath); if (parent_filenode == NULL) { printf("parent %s not found by fischl_load_entry\n", ParentPath); free(pathdup); return -1; } u_int64_t parent_inode_number = parent_filenode->inode_number; u_int64_t target_inode = 0; // remove its record from parent INode_Data parent_INode; parent_INode.inode_num = parent_inode_number; fs->inode_manager->load_inode(&parent_INode); if(!permission_check(W_OK, &parent_INode)){ return -EACCES; } char rw_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx=0; idxread(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(rw_buffer+i); if (strcmp(ent.file_name, dirname)==0) { target_inode = ent.inode_number; ent.inode_number = 0; memset(ent.file_name, 0, sizeof(ent.file_name)); ent.serialize(rw_buffer+i); break; } } if (target_inode) { fs->write(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); break; } } // remove inode itself if (target_inode) { unlink_inode(target_inode); // remove node itself and from parent hash fischl_rm_entry(parent_filenode->subdirectory, dirname); free(pathdup); return 0; } else { printf("cannot find %s in %s", dirname, ParentPath); free(pathdup); return -1; } } int FilesOperation::fischl_chmod(const char *path, mode_t mode, struct fuse_file_info *fi) { (void)fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1) { return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); inode.metadata.permissions = mode; fs->inode_manager->save_inode(&inode); return 0; } int FilesOperation::fischl_chown(const char *path, uid_t uid, gid_t gid, struct fuse_file_info *fi) { (void)fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1) { return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); inode.metadata.uid = uid; inode.metadata.gid = gid; fs->inode_manager->save_inode(&inode); return 0; } int FilesOperation::fischl_unlink(const char* path) { char *pathdup = strdup(path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; char *filename = lastSlash+1; char *ParentPath = pathdup; if (!strcmp(filename,".")||!strcmp(filename,"..")) { printf("refusing to remove . or ..\n"); return -1; } FileNode *parent_filenode = fischl_load_entry(root_node, ParentPath); if (parent_filenode == NULL) { printf("parent %s not found by fischl_load_entry\n", ParentPath); free(pathdup); return -1; } u_int64_t parent_inode_number = parent_filenode->inode_number; u_int64_t target_inode = 0; // remove its record from parent INode_Data parent_INode; parent_INode.inode_num = parent_inode_number; fs->inode_manager->load_inode(&parent_INode); if(!permission_check(W_OK, &parent_INode)){ return -EACCES; } char rw_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx=0; idxread(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(rw_buffer+i); if (strcmp(ent.file_name, filename)==0) { target_inode = ent.inode_number; if(!permission_check_by_inode_num(W_OK, target_inode)){ return -EACCES; } ent.inode_number = 0; memset(ent.file_name, 0, sizeof(ent.file_name)); ent.serialize(rw_buffer+i); break; } } if (target_inode) { fs->write(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); break; } } // remove inode itself if (target_inode) { unlink_inode(target_inode); // remove node itself and from parent hash fischl_rm_entry(parent_filenode->subdirectory, filename); free(pathdup); return 0; } else { printf("cannot find %s in %s", filename, ParentPath); free(pathdup); return -1; } } int FilesOperation::fischl_open(const char *path, struct fuse_file_info *fi){ /*Creation (O_CREAT, O_EXCL, O_NOCTTY) flags will be filtered out / handled by the kernel. if no files will use create function */ FileNode *get_file; if((get_file = fischl_load_entry(root_node, path)) == NULL) return -ENOENT; INode_Data inode; inode.inode_num = get_file->inode_number; fs->inode_manager->load_inode(&inode); if (fi->flags & O_WRONLY){ if (!permission_check(W_OK, &inode)) { return -EACCES; // Permission denied } } if (fi->flags & O_RDONLY){ if (!permission_check(R_OK, &inode)) { return -EACCES; // Permission denied } } if (fi->flags & O_RDWR){ if (!permission_check(R_OK|W_OK, &inode)) { return -EACCES; // Permission denied } } //if need to do with flag fi->flags ((fi->flags & O_ACCMODE)). Initial setting ALL access //create function will handle file descriptor fi->fh fi->fh = get_file->inode_number; return 0;//SUCESS } int FilesOperation::fischl_release(const char *path, struct fuse_file_info *fi){ /*Creation (O_CREAT, O_EXCL, O_NOCTTY) flags will be filtered out / handled by the kernel. if no files will use create function */ FileNode *get_file; if((get_file = fischl_load_entry(root_node, path)) == NULL) return -ENOENT; //do with file descriptor that cannot be used fi->fh = -1; return 0;//SUCESS } int FilesOperation::fischl_write(const char *path, const char *buf, size_t size, off_t offset, struct fuse_file_info *fi){ /** Write data to an open file * * Write should return exactly the number of bytes requested * except on error. An exception to this is when the 'direct_io' * mount option is specified (see read operation). * * Unless FUSE_CAP_HANDLE_KILLPRIV is disabled, this method is * expected to reset the setuid and setgid bits. */ // use path for debug, filedescriptor is enough // FileNode *get_file; // if((get_file = fischl_load_entry(root_node, path)) == NULL) // return -ENOENT; // Caution! this based on content in file are multiple of IO_BLOCK_SIZE, not the exact write size. // based on current write_datablock API implement, when write_datablock pass with actual size not index this function should be fixed INode_Data inode; // Assuming inode is correctly initialized here based on 'path' inode.inode_num = fi->fh; fs->inode_manager->load_inode(&inode); //size_t len = (inode.metadata.size/IO_BLOCK_SIZE) * IO_BLOCK_SIZE; // Assuming each block is 4096 bytes // Determine the length of the buffer // Allocate memory for the new buffer char* buffer = (char*)malloc(size); memcpy(buffer, buf, size); size_t bytes_write = fs->write(&inode, buffer, size, offset); /*size_t block_index = offset / IO_BLOCK_SIZE; // Starting block index size_t block_offset = offset % IO_BLOCK_SIZE; // Offset within the first block while (bytes_write < size) { char block_buffer[IO_BLOCK_SIZE]; // Temporary buffer for each block size_t copy_size = std::min(size - bytes_write, IO_BLOCK_SIZE - block_offset); memcpy(block_buffer + block_offset, buf + bytes_write, copy_size); fs->write(&inode, block_buffer, IO_BLOCK_SIZE, block_index*IO_BLOCK_SIZE); // fprintf(stderr,"[%s ,%d] inode.size %d, block_index %d, block_buffer %s\n",__func__,__LINE__, inode.size, block_index, block_buffer); bytes_write += copy_size; block_index++; block_offset = 0; // Only the first block might have a non-zero offset }*/ fs->inode_manager->save_inode(&inode); free(buffer); return bytes_write; // Return the actual number of bytes read } int FilesOperation::fischl_readlink(const char* path, char* buf, size_t size){ FileNode *get_file; if((get_file = fischl_load_entry(root_node, path)) == NULL) return -ENOENT; INode_Data symlink_inode; symlink_inode.inode_num = get_file->inode_number; fs->inode_manager->load_inode(&symlink_inode); if(!permission_check(R_OK, &symlink_inode)){ return -EACCES; } //char buffer[symlink_inode.metadata.size]; //memset(buffer, 0, sizeof(buffer)); fs->read(&symlink_inode, buf, symlink_inode.metadata.size, 0); //printf("READLINK %d %s\n", symlink_inode.metadata.size, buf); /*u_int64_t fh = namei(buffer); if (fh == -1){ return -ENOENT; } INode_Data inode; // Assuming inode is correctly initialized here based on 'path' inode.inode_num = fh; fs->inode_manager->load_inode(&inode); size_t bytes_read = fs->read(&inode, buf, size, 0); printf("READLINK %d %s\n", bytes_read, buf);*/ return 0; } int FilesOperation::fischl_symlink(const char* to, const char* from){ //check path //printf("SYMLINK %s %s\n", from, to); char *pathdup = strdup(from); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory name; \0 char *newFilename = lastSlash+1; //\0, get from char *ParentPath = pathdup;//pathdup are separated by pathdup, so it take only // fprintf(stderr,"[%s ,%d] ParentPath:%s, strlen=%d\n",__func__,__LINE__, ParentPath, strlen(ParentPath)); FileNode *parent_filenode = strlen(ParentPath)? fischl_load_entry(root_node, ParentPath): root_node->self_info; if (parent_filenode == NULL) { fprintf(stderr,"[%s ,%d] ParentPath:{%s} not found\n",__func__,__LINE__, ParentPath); free(pathdup); return -ENOENT; } u_int64_t parent_inode_number = parent_filenode->inode_number; if(!permission_check_by_inode_num(W_OK, parent_inode_number)){ return -EACCES; } //make new inode INode_Data* ret = create_new_inode(parent_inode_number, newFilename, S_IFLNK|0777); if (ret == NULL) return -1;//ENOSPC but create_new_inode handle ENAMETOOLONG EEXIST //make new node in RAM fischl_add_entry(parent_filenode->subdirectory, ret->inode_num, newFilename, ret); size_t size = strlen(to); char* buffer = (char*)malloc(size); memcpy(buffer, to, size); //printf("%d %s\n", size, buffer); size_t bytes_write = fs->write(ret, buffer, size, 0); free(buffer); free(pathdup); fs->inode_manager->save_inode(ret); //printf("%d %d %llu\n", bytes_write, ret->metadata.size, ret->inode_num); return 0;//SUCESS } int FilesOperation::insert_inode_to(u_int64_t parent_inode_number, const char* name, INode_Data *new_inode, bool check_replace) { // trys to create a file under parent directory if (strlen(name)>=256) { perror("Name too long, cannot create file or directory"); return -1; } INode_Data inode; inode.inode_num = parent_inode_number; fs->inode_manager->load_inode(&inode); if ((inode.metadata.permissions & S_IFMT) != S_IFDIR) { fprintf(stderr,"[%s ,%d] please create under directory\n",__func__,__LINE__); return -1; } // Check if file or directory already exists char r_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx=0; idxread(&inode, r_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(r_buffer+i); if (strcmp(ent.file_name, name)==0 && ent.inode_number != 0) { if(check_replace){ if((new_inode->metadata.permissions & S_IFMT) == S_IFDIR){ fprintf(stderr,"[%s ,%d] %s/ already exists\n",__func__,__LINE__, name); }else{ fprintf(stderr,"[%s ,%d] %s already exists\n",__func__,__LINE__, name); } return -1; } else{ ent.inode_number = new_inode->inode_num; ent.serialize(r_buffer+i); fs->write(&inode, r_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); return 0; } } } } bool allocated = false; char rw_buffer[IO_BLOCK_SIZE] = {0}; for (u_int64_t idx = 0; idx < inode.metadata.size / IO_BLOCK_SIZE; idx++) { fs->read(&inode, rw_buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); DirectoryEntry ent; for (int i = 0; i <= IO_BLOCK_SIZE - 264; i += 264) { ent.deserialize(rw_buffer + i); if (ent.inode_number == 0) { allocated = true; ent.inode_number = new_inode->inode_num; strcpy(ent.file_name, name); ent.serialize(rw_buffer + i); break; } } if (allocated) { fs->write(&inode, rw_buffer, IO_BLOCK_SIZE, idx * IO_BLOCK_SIZE); break; } } if (!allocated) { char write_buffer[IO_BLOCK_SIZE] = {0}; DirectoryEntry ent; ent.inode_number = new_inode->inode_num; strcpy(ent.file_name, name); ent.serialize(write_buffer); fs->write(&inode, write_buffer, IO_BLOCK_SIZE, (inode.metadata.size / IO_BLOCK_SIZE) * IO_BLOCK_SIZE); fs->inode_manager->save_inode(&inode); } return 0; } int FilesOperation::fischl_link(const char* from, const char* to){ FileNode *get_file; if((get_file = fischl_load_entry(root_node, from)) == NULL) return -ENOENT; INode_Data ret; ret.inode_num = get_file->inode_number; fs->inode_manager->load_inode(&ret); //check path char *pathdup = strdup(to); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory name; \0 char *newFilename = lastSlash+1; //\0, get from char *ParentPath = pathdup;//pathdup are separated by pathdup, so it take only // fprintf(stderr,"[%s ,%d] ParentPath:%s, strlen=%d\n",__func__,__LINE__, ParentPath, strlen(ParentPath)); FileNode *parent_filenode = strlen(ParentPath)? fischl_load_entry(root_node, ParentPath): root_node->self_info; if (parent_filenode == NULL) { fprintf(stderr,"[%s ,%d] ParentPath:{%s} not found\n",__func__,__LINE__, ParentPath); free(pathdup); return -1; } u_int64_t parent_inode_number = parent_filenode->inode_number; if(!permission_check_by_inode_num(W_OK, parent_inode_number)){ return -EACCES; } if(insert_inode_to(parent_inode_number, newFilename, &ret, true)<0){ return -1; } ret.metadata.reference_count += 1; fs->inode_manager->save_inode(&ret); fischl_add_entry(parent_filenode->subdirectory, ret.inode_num, newFilename, &ret); free(pathdup); return 0; } // TODO: rename dir and rename fail int FilesOperation::fischl_rename(const char *old_path, const char *new_path, unsigned int flags){ //find old path char *pathdup = strdup(old_path); char *lastSlash = strrchr(pathdup, '/'); *lastSlash = '\0'; char *filename = lastSlash+1; char *oldParentPath = pathdup; if (!strcmp(filename,".")||!strcmp(filename,"..")) { printf("refuse to remove . or ..\n"); return -1; } //put old path info in rename struct RenameInfo rename_info; rename_info.exchangeExist = false; rename_info.oldParentNode = fischl_load_entry(root_node, oldParentPath); //if path end with / means to rename directory rename_info.oldFileNode = strlen(filename)? fischl_load_entry(rename_info.oldParentNode->subdirectory, filename):rename_info.oldParentNode; if (rename_info.oldFileNode == NULL) { fprintf(stderr,"[%s ,%d] path %s not found by fischl_load_entry\n",__func__,__LINE__, old_path); free(pathdup); return -ENOENT; } //find new path char *new_pathdup = strdup(new_path); lastSlash = strrchr(new_pathdup, '/'); *lastSlash = '\0'; // Split the string into parent path and new directory name; \0 char *newParentPath = new_pathdup;//pathdup are separated by pathdup, so it take only //put new path info in rename struct rename_info.newName = lastSlash+1; //\0, get from rename_info.newFileNode = fischl_load_entry(root_node, new_path); rename_info.newParentNode = strlen(newParentPath)? fischl_load_entry(root_node, newParentPath): root_node->self_info; if(!permission_check_by_inode_num(W_OK, rename_info.oldParentNode->inode_number)){ return -EACCES; } if(!permission_check_by_inode_num(W_OK, rename_info.newParentNode->inode_number)){ return -EACCES; } if(!permission_check_by_inode_num(W_OK, rename_info.oldFileNode->inode_number)){ return -EACCES; } if(rename_info.newFileNode != NULL && !permission_check_by_inode_num(W_OK, rename_info.newFileNode->inode_number)){ return -EACCES; } //configure with flag if (flags & RENAME_NOREPLACE) { // Check if newpath exists and return error if it does if(rename_info.newFileNode != NULL){ fprintf(stderr,"[%s ,%d] newpath has already existed\n",__func__,__LINE__); free(new_pathdup);//new path free(pathdup);//old path return -1; } } if (flags & RENAME_EXCHANGE) { // Ensure both oldpath and newpath exist and exchange them atomically if(rename_info.newFileNode == NULL){ fprintf(stderr,"[%s ,%d] newpath does not exist cannot exchange\n",__func__,__LINE__); free(new_pathdup); free(pathdup); return -1; } rename_info.exchangeExist = true; INode_Data parent_INode; parent_INode.inode_num = rename_info.newParentNode->inode_number; fs->inode_manager->load_inode(&parent_INode); char rw_buffer[IO_BLOCK_SIZE] = {0}; bool change_flag = false; //delete record on old path for (u_int64_t idx=0; idxread(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(rw_buffer+i); if (ent.inode_number == rename_info.newFileNode->inode_number) { change_flag = true;//should be change strncpy(ent.file_name, filename, sizeof(ent.file_name) - 1); ent.file_name[sizeof(ent.file_name) - 1] = '\0'; ent.serialize(rw_buffer+i); break; } } if (change_flag) { fs->write(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); change_flag = false; break; } } parent_INode.inode_num = rename_info.oldParentNode->inode_number; fs->inode_manager->load_inode(&parent_INode); change_flag = false; //delete record on old path for (u_int64_t idx=0; idxread(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(rw_buffer+i); if (ent.inode_number == rename_info.oldFileNode->inode_number) { change_flag = true;//should be change strncpy(ent.file_name, rename_info.newName, sizeof(ent.file_name) - 1); ent.file_name[sizeof(ent.file_name) - 1] = '\0'; ent.serialize(rw_buffer+i); break; } } if (change_flag) { fs->write(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); change_flag = false; break; } } fischl_rm_entry(rename_info.oldParentNode->subdirectory, filename); fischl_rm_entry(rename_info.newParentNode->subdirectory, rename_info.newName); return 0; } // Normal rename logic if no flags are specified; can overwirte // Hard Disk rename if(rename_info.oldFileNode->subdirectory != NULL){//secure its directory //remove its record from subdirectory; find .. from subdirectory } // remove its record from parent INode_Data parent_INode; parent_INode.inode_num = rename_info.oldParentNode->inode_number; fs->inode_manager->load_inode(&parent_INode); char rw_buffer[IO_BLOCK_SIZE] = {0}; // relocate the old path file to new path INode_Data ret; ret.inode_num = rename_info.oldFileNode->inode_number; fs->inode_manager->load_inode(&ret); if(insert_inode_to(rename_info.newParentNode->inode_number, rename_info.newName, &ret, false)<0){ return -1; } bool change_flag = false; //delete record on old path for (u_int64_t idx=0; idxread(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); DirectoryEntry ent; for(int i=0;i<=IO_BLOCK_SIZE-264;i+=264){ ent.deserialize(rw_buffer+i); if (strcmp(ent.file_name, filename)==0) { change_flag = true;//should be change ent.inode_number = 0; memset(ent.file_name, 0, sizeof(ent.file_name)); ent.serialize(rw_buffer+i); break; } } if (change_flag) { fs->write(&parent_INode, rw_buffer, IO_BLOCK_SIZE, idx*IO_BLOCK_SIZE); change_flag = false; break; } } fischl_rm_entry(rename_info.oldParentNode->subdirectory, filename); //free path free(pathdup); free(new_pathdup); return 0; } int FilesOperation::fischl_truncate(const char *path, off_t offset, struct fuse_file_info *fi) { (void)fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1) { return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); if(!permission_check(W_OK, &inode)){ return -EACCES; } while(inode.metadata.size > offset + IO_BLOCK_SIZE) { printf("dealloc, %d\n", inode.metadata.size); u_int64_t dummy; fs->deallocate_datablock(&inode, &dummy); if (inode.metadata.size < IO_BLOCK_SIZE){ inode.metadata.size = 0; break; } inode.metadata.size-=IO_BLOCK_SIZE; } inode.metadata.size = offset; fs->inode_manager->save_inode(&inode); return 0; } int FilesOperation::fischl_read(const char *path, char *buf, size_t size, off_t offset, struct fuse_file_info *fi) { /** Read data from an open file * * Read should return exactly the number of bytes requested except * on EOF or error, otherwise the rest of the data will be * substituted with zeroes. An exception to this is when the * 'direct_io' mount option is specified, in which case the return * value of the read system call will reflect the return value of * this operation. */ // Caution! this based on content in file are multiple of IO_BLOCK_SIZE, not // the exact write size. based on current read_datablock API implement, when // read_datablock pass with actual size not index this function should be // fixed INode_Data inode; // Assuming inode is correctly initialized here based on 'path' inode.inode_num = fi->fh; fs->inode_manager->load_inode(&inode); size_t bytes_read = fs->read(&inode, buf, size, offset); /*size_t len = (inode.metadata.size/IO_BLOCK_SIZE) * IO_BLOCK_SIZE; // Assuming each block is 4096 bytes if (offset >= len) return 0; // Offset is beyond the end of the file if (offset + size > len) size = len - offset; // Adjust size if it goes beyond EOF size_t bytes_read = 0; size_t block_index = offset / IO_BLOCK_SIZE; // Starting block index size_t block_offset = offset % IO_BLOCK_SIZE; // Offset within the first block // fprintf(stderr,"[%s ,%d] inode.metadata.size %d\n",__func__,__LINE__, inode.metadata.size); while (bytes_read < size && block_index < inode.metadata.size/IO_BLOCK_SIZE) { char block_buffer[IO_BLOCK_SIZE]; // Temporary buffer for each block fs->read(&inode, block_buffer, IO_BLOCK_SIZE, block_index*IO_BLOCK_SIZE); // fprintf(stderr,"[%s ,%d] block_index %d\n",__func__,__LINE__, block_index); size_t copy_size = std::min(size - bytes_read, IO_BLOCK_SIZE - block_offset); memcpy(buf + bytes_read, block_buffer + block_offset, copy_size); // fprintf(stderr,"[%s ,%d] buf %s, block_buffer %s\n",__func__,__LINE__, buf, block_buffer); bytes_read += copy_size; block_index++; block_offset = 0; // Only the first block might have a non-zero offset }*/ r eturn bytes_read; // Return the actual number of bytes read } int FilesOperation::fischl_utimens(const char *path, const struct timespec tv[2], struct fuse_file_info *fi){ (void) fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1){ return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); inode.metadata.access_time = (u_int64_t)tv[0].tv_sec * 1000000000ULL + tv[0].tv_nsec; inode.metadata.modification_time = (u_int64_t)tv[1].tv_sec * 1000000000ULL + tv[1].tv_nsec; fs->inode_manager->save_inode(&inode); return 0; } int FilesOperation::fischl_statfs(const char* path, struct statvfs* stbuf) { stbuf->f_bsize = 4096; stbuf->f_blocks = 0; stbuf->f_bfree = 0; stbuf->f_files = 0; stbuf->f_ffree = 0; stbuf->f_namemax = 256; return 0; } int FilesOperation::fischl_utimens(const char *path, const struct timespec tv[2], struct fuse_file_info *fi){ (void) fi; int res = 0; u_int64_t fh = namei(path); if (fh == -1){ return -ENOENT; } INode_Data inode; inode.inode_num = fh; fs->inode_manager->load_inode(&inode); inode.metadata.access_time = (u_int64_t)tv[0].tv_sec * 1000000000ULL + tv[0].tv_nsec; inode.metadata.modification_time = (u_int64_t)tv[1].tv_sec * 1000000000ULL + tv[1].tv_nsec; fs->inode_manager->save_inode(&inode); return 0; } int FilesOperation::fischl_statfs(const char* path, struct statvfs* stbuf) { stbuf->f_bsize = 4096; stbuf->f_blocks = 0; stbuf->f_bfree = 0; stbuf->f_files = 0; stbuf->f_ffree = 0; stbuf->f_namemax = 256; return 0; }