component/libfuse/libfuse_handler.go (10 lines): - line 405: // TODO: How does this work if we trim the path? - line 536: // TODO: Investigate why this works in fuse2 but not fuse3 - line 679: // TODO: Should this sit behind a user option? What if we change something to support these in the future? - line 917: // TODO: handle EACCESS, EINVAL? - line 929: // TODO: Support for RENAME_EXCHANGE - line 1075: // TODO : Should we support this? - line 1099: // TODO : Should we support this? - line 1149: // TODO: Implement - line 1160: // TODO: is the conversion from [2]timespec to *timespec ok? - line 1161: // TODO: Implement component/libfuse/libfuse2_handler.go (8 lines): - line 368: // TODO: How does this work if we trim the path? - line 640: // TODO: Should this sit behind a user option? What if we change something to support these in the future? - line 864: // TODO: handle EACCESS, EINVAL? - line 1009: // TODO : Should we support this? - line 1033: // TODO : Should we support this? - line 1083: // TODO: Implement - line 1094: // TODO: is the conversion from [2]timespec to *timespec ok? - line 1095: // TODO: Implement blobfuse2-nightly.yaml (8 lines): - line 1269: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1347: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1433: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1453: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1526: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1604: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1682: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable - line 1760: # TODO: These can be removed one day and replace all instances of ${{ parameters.temp_dir }} with $(TEMP_DIR) since it is a global variable component/xload/splitter.go (6 lines): - line 152: // TODO:: xload : should we delete the file if it already exists - line 153: // TODO:: xload : what should be the flags - line 154: // TODO:: xload : verify if the mode is set correctly - line 155: // TODO:: xload : handle case if blob is a symlink - line 256: // TODO:: xload : verify if the lmt is updated correctly - line 265: // TODO:: xload : retry if md5 validation fails component/attr_cache/attr_cache.go (6 lines): - line 411: // TODO: Could we just update the size and mod time of the file here? Or can other attributes change here? - line 460: // TODO: Could we just update the size and mod time of the file here? Or can other attributes change here? - line 461: // TODO: we're RLocking the cache but we need to also lock this attr item because another thread could be reading this attr item - line 543: ac.invalidatePath(options.Target) // TODO : Why do we invalidate the target? Shouldn't the target remain unchanged? - line 586: // TODO: Implement when datalake chown is supported. - line 597: // TODO: Could we just update the size, etag, modtime of the file here? component/file_cache/file_cache.go (4 lines): - line 454: // TODO : wouldn't this cause a race condition? a thread might get the lock before we purge - and the file would be non-existent - line 529: // TODO : Should we return here if the directory failed to be read from storage? - line 1008: // TODO: When chown is supported should we update that? - line 1251: // // TODO: we can decide here if we want to flush all the files in the directory first or not. Currently I'm just invalidating files component/xload/stats_manager.go (3 lines): - line 123: // TODO:: xload : the stop method runs on unmount. See if the channels can be closed if the job is 100% complete - line 127: close(sm.done) // TODO::xload : check if closing the done channel here will lead to closing the stats exporter thread - line 235: // TODO:: xload : determine more effective way to decide if the listing has completed and the stats exporter can be terminated component/xload/xload.go (3 lines): - line 75: // TODO:: xload : add parallelism parameter - line 150: // TODO:: xload : should we use current working directory in this case - line 271: // TODO:: xload : should we delete the files from local path component/xload/lister.go (3 lines): - line 136: relPath := item.Path // TODO:: xload : check this for subdirectory mounting - line 183: // TODO:: xload : check how many threads can we spawn - line 187: // TODO:: xload : handle error component/azstorage/block_blob.go (2 lines): - line 1406: // TODO: better way to do this? - line 1456: // TODO: make a similar method facing stream that would enable us to write to cached blocks then stage and commit internal/stats_manager/stats_manager.go (2 lines): - line 248: // TODO: check if this lock can be removed - line 336: // TODO: check if this lock can be removed component/azstorage/datalake.go (2 lines): - line 316: // TODO : There is an ability to pass a continuation token here for recursive delete, should we implement this logic to follow continuation token? The SDK does not currently do this. - line 584: // TODO: This is not supported for now. component/loopback/loopback_fs.go (1 line): - line 168: // TODO: we can make it more intricate by generating a token and splitting streamed dir mimicking storage component/block_cache/blockpool.go (1 line): - line 107: // TODO: call terminate after all the threads have completed component/xload/threadpool.go (1 line): - line 161: // TODO:: xload : add retry logic component/azstorage/azauth.go (1 line): - line 211: // TODO:: track2 : check ActiveDirectoryEndpoint and AuthResource part component/file_cache/lru_policy.go (1 line): - line 463: // TODO: Delete directories up the path recursively that are "safe to delete". Ensure there is no race between this code and code that creates directories (like OpenFile) internal/attribute.go (1 line): - line 67: PropFlagModeDefault // TODO: Does this sound better as ModeDefault or DefaultMode? The getter would be IsModeDefault or IsDefaultMode common/version.go (1 line): - line 95: // TODO: Make sure preview version is smaller than GA version component/libfuse/libfuse_handler_test_wrapper.go (1 line): - line 136: // TODO: ReadDir test component/azstorage/azstorage.go (1 line): - line 586: // TODO : Below methods are pending to be implemented component/azstorage/config.go (1 line): - line 270: // TODO : Modify this method when file share support is merged common/log/logger.go (1 line): - line 118: func GetType() string { // TODO: Should I make an enum for this instead? component/xload/xcomponent.go (1 line): - line 83: // TODO:: xload : check if this call goes to the process method of the calling component component/azstorage/azauthspn.go (1 line): - line 63: // TODO:: track2 : test this in Azure Kubernetes setup component/libfuse/libfuse2_handler_test_wrapper.go (1 line): - line 152: // TODO: ReadDir test internal/component.go (1 line): - line 122: UnlinkFile(UnlinkFileOptions) error // TODO: What does this do? Not used anywhere