https://git.reactos.org/?p=reactos.git;a=commitdiff;h=f381137c89da4ff272e939...
commit f381137c89da4ff272e939bedb91c34262369846 Author: Pierre Schweitzer pierre@reactos.org AuthorDate: Tue Jun 11 12:35:19 2019 +0200 Commit: Pierre Schweitzer pierre@reactos.org CommitDate: Tue Jun 11 12:35:19 2019 +0200
[BTRFS] Upgrade to 1.3
CORE-16111 --- dll/win32/ubtrfs/ubtrfs.rc | 24 +- drivers/filesystems/btrfs/btrfs.c | 166 ++++++--- drivers/filesystems/btrfs/btrfs.h | 3 + drivers/filesystems/btrfs/btrfs.rc | 8 +- drivers/filesystems/btrfs/btrfs_drv.h | 23 +- drivers/filesystems/btrfs/create.c | 269 ++++++++++++-- drivers/filesystems/btrfs/dirctrl.c | 158 +++++++- drivers/filesystems/btrfs/fileinfo.c | 630 +++++++++++++++++++++++++++++--- drivers/filesystems/btrfs/flushthread.c | 196 +++++++++- drivers/filesystems/btrfs/free-space.c | 4 +- drivers/filesystems/btrfs/fsctl.c | 10 +- drivers/filesystems/btrfs/write.c | 2 +- media/doc/README.FSD | 4 +- 13 files changed, 1344 insertions(+), 153 deletions(-)
diff --git a/dll/win32/ubtrfs/ubtrfs.rc b/dll/win32/ubtrfs/ubtrfs.rc index c4c486f92af..2fbce14c1f1 100644 --- a/dll/win32/ubtrfs/ubtrfs.rc +++ b/dll/win32/ubtrfs/ubtrfs.rc @@ -25,18 +25,18 @@ LANGUAGE LANG_ENGLISH, SUBLANG_ENGLISH_UK // TEXTINCLUDE //
-1 TEXTINCLUDE +1 TEXTINCLUDE BEGIN "resource.h\0" END
-2 TEXTINCLUDE +2 TEXTINCLUDE BEGIN "#include ""winres.h""\r\n" "\0" END
-3 TEXTINCLUDE +3 TEXTINCLUDE BEGIN "\r\n" "\0" @@ -51,8 +51,8 @@ END //
VS_VERSION_INFO VERSIONINFO - FILEVERSION 1,1,0,0 - PRODUCTVERSION 1,1,0,0 + FILEVERSION 1,3,0,0 + PRODUCTVERSION 1,3,0,0 FILEFLAGSMASK 0x17L #ifdef _DEBUG FILEFLAGS 0x1L @@ -60,20 +60,20 @@ VS_VERSION_INFO VERSIONINFO FILEFLAGS 0x0L #endif FILEOS 0x4L - FILETYPE 0x0L + FILETYPE 0x2L FILESUBTYPE 0x0L BEGIN BLOCK "StringFileInfo" BEGIN BLOCK "080904b0" BEGIN - VALUE "FileDescription", "Btrfs formatting utility" - VALUE "FileVersion", "1.1" - VALUE "InternalName", "mkbtrfs" - VALUE "LegalCopyright", "Copyright (c) Mark Harmstone 2016-18" - VALUE "OriginalFilename", "mkbtrfs.exe" + VALUE "FileDescription", "Btrfs utility DLL" + VALUE "FileVersion", "1.3" + VALUE "InternalName", "ubtrfs" + VALUE "LegalCopyright", "Copyright (c) Mark Harmstone 2016-19" + VALUE "OriginalFilename", "ubtrfs.dll" VALUE "ProductName", "WinBtrfs" - VALUE "ProductVersion", "1.1" + VALUE "ProductVersion", "1.3" END END BLOCK "VarFileInfo" diff --git a/drivers/filesystems/btrfs/btrfs.c b/drivers/filesystems/btrfs/btrfs.c index 4cd6bb10a10..c480d9f0502 100644 --- a/drivers/filesystems/btrfs/btrfs.c +++ b/drivers/filesystems/btrfs/btrfs.c @@ -795,7 +795,8 @@ static NTSTATUS drv_query_volume_information(_In_ PDEVICE_OBJECT DeviceObject, _ data->FileSystemAttributes = FILE_CASE_PRESERVED_NAMES | FILE_CASE_SENSITIVE_SEARCH | FILE_UNICODE_ON_DISK | FILE_NAMED_STREAMS | FILE_SUPPORTS_HARD_LINKS | FILE_PERSISTENT_ACLS | FILE_SUPPORTS_REPARSE_POINTS | FILE_SUPPORTS_SPARSE_FILES | FILE_SUPPORTS_OBJECT_IDS | - FILE_SUPPORTS_OPEN_BY_FILE_ID | FILE_SUPPORTS_EXTENDED_ATTRIBUTES | FILE_SUPPORTS_BLOCK_REFCOUNTING; + FILE_SUPPORTS_OPEN_BY_FILE_ID | FILE_SUPPORTS_EXTENDED_ATTRIBUTES | FILE_SUPPORTS_BLOCK_REFCOUNTING | + FILE_SUPPORTS_POSIX_UNLINK_RENAME; if (Vcb->readonly) data->FileSystemAttributes |= FILE_READ_ONLY_VOLUME;
@@ -1068,6 +1069,7 @@ NTSTATUS create_root(_In_ _Requires_exclusive_lock_held_(_Curr_->tree_lock) devi RtlZeroMemory(&r->root_item, sizeof(ROOT_ITEM)); r->root_item.num_references = 1; r->fcbs_version = 0; + r->checked_for_orphans = TRUE; InitializeListHead(&r->fcbs); RtlZeroMemory(r->fcbs_ptrs, sizeof(LIST_ENTRY*) * 256);
@@ -1966,7 +1968,63 @@ void uninit(_In_ device_extension* Vcb) { ZwClose(Vcb->flush_thread_handle); }
-NTSTATUS delete_fileref(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject, _In_opt_ PIRP Irp, _In_ LIST_ENTRY* rollback) { +static NTSTATUS delete_fileref_fcb(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject, _In_opt_ PIRP Irp, _In_ LIST_ENTRY* rollback) { + NTSTATUS Status; + LIST_ENTRY* le; + + // excise extents + + if (fileref->fcb->type != BTRFS_TYPE_DIRECTORY && fileref->fcb->inode_item.st_size > 0) { + Status = excise_extents(fileref->fcb->Vcb, fileref->fcb, 0, sector_align(fileref->fcb->inode_item.st_size, fileref->fcb->Vcb->superblock.sector_size), Irp, rollback); + if (!NT_SUCCESS(Status)) { + ERR("excise_extents returned %08x\n", Status); + return Status; + } + } + + fileref->fcb->Header.AllocationSize.QuadPart = 0; + fileref->fcb->Header.FileSize.QuadPart = 0; + fileref->fcb->Header.ValidDataLength.QuadPart = 0; + + if (FileObject) { + CC_FILE_SIZES ccfs; + + ccfs.AllocationSize = fileref->fcb->Header.AllocationSize; + ccfs.FileSize = fileref->fcb->Header.FileSize; + ccfs.ValidDataLength = fileref->fcb->Header.ValidDataLength; + + Status = STATUS_SUCCESS; + + _SEH2_TRY { + CcSetFileSizes(FileObject, &ccfs); + } _SEH2_EXCEPT (EXCEPTION_EXECUTE_HANDLER) { + Status = _SEH2_GetExceptionCode(); + } _SEH2_END; + + if (!NT_SUCCESS(Status)) { + ERR("CcSetFileSizes threw exception %08x\n", Status); + return Status; + } + } + + fileref->fcb->deleted = TRUE; + + le = fileref->children.Flink; + while (le != &fileref->children) { + file_ref* fr2 = CONTAINING_RECORD(le, file_ref, list_entry); + + if (fr2->fcb->ads) { + fr2->fcb->deleted = TRUE; + mark_fcb_dirty(fr2->fcb); + } + + le = le->Flink; + } + + return STATUS_SUCCESS; +} + +NTSTATUS delete_fileref(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject, _In_ BOOL make_orphan, _In_opt_ PIRP Irp, _In_ LIST_ENTRY* rollback) { LARGE_INTEGER newlength, time; BTRFS_TIME now; NTSTATUS Status; @@ -2002,61 +2060,17 @@ NTSTATUS delete_fileref(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject
fileref->fcb->inode_item_changed = TRUE;
- if (fileref->fcb->inode_item.st_nlink > 1) { + if (fileref->fcb->inode_item.st_nlink > 1 || make_orphan) { fileref->fcb->inode_item.st_nlink--; fileref->fcb->inode_item.transid = fileref->fcb->Vcb->superblock.generation; fileref->fcb->inode_item.sequence++; fileref->fcb->inode_item.st_ctime = now; } else { - // excise extents - - if (fileref->fcb->type != BTRFS_TYPE_DIRECTORY && fileref->fcb->inode_item.st_size > 0) { - Status = excise_extents(fileref->fcb->Vcb, fileref->fcb, 0, sector_align(fileref->fcb->inode_item.st_size, fileref->fcb->Vcb->superblock.sector_size), Irp, rollback); - if (!NT_SUCCESS(Status)) { - ERR("excise_extents returned %08x\n", Status); - ExReleaseResourceLite(fileref->fcb->Header.Resource); - return Status; - } - } - - fileref->fcb->Header.AllocationSize.QuadPart = 0; - fileref->fcb->Header.FileSize.QuadPart = 0; - fileref->fcb->Header.ValidDataLength.QuadPart = 0; - - if (FileObject) { - CC_FILE_SIZES ccfs; - - ccfs.AllocationSize = fileref->fcb->Header.AllocationSize; - ccfs.FileSize = fileref->fcb->Header.FileSize; - ccfs.ValidDataLength = fileref->fcb->Header.ValidDataLength; - - Status = STATUS_SUCCESS; - - _SEH2_TRY { - CcSetFileSizes(FileObject, &ccfs); - } _SEH2_EXCEPT (EXCEPTION_EXECUTE_HANDLER) { - Status = _SEH2_GetExceptionCode(); - } _SEH2_END; - - if (!NT_SUCCESS(Status)) { - ERR("CcSetFileSizes threw exception %08x\n", Status); - ExReleaseResourceLite(fileref->fcb->Header.Resource); - return Status; - } - } - - fileref->fcb->deleted = TRUE; - - le = fileref->children.Flink; - while (le != &fileref->children) { - file_ref* fr2 = CONTAINING_RECORD(le, file_ref, list_entry); - - if (fr2->fcb->ads) { - fr2->fcb->deleted = TRUE; - mark_fcb_dirty(fr2->fcb); - } - - le = le->Flink; + Status = delete_fileref_fcb(fileref, FileObject, Irp, rollback); + if (!NT_SUCCESS(Status)) { + ERR("delete_fileref_fcb returned %08x\n", Status); + ExReleaseResourceLite(fileref->fcb->Header.Resource); + return Status; } }
@@ -2271,9 +2285,26 @@ static NTSTATUS drv_cleanup(_In_ PDEVICE_OBJECT DeviceObject, _In_ PIRP Irp) { // FIXME - flush all of subvol's fcbs }
- if (fileref && oc == 0) { + if (fileref && (oc == 0 || (fileref->delete_on_close && fileref->posix_delete))) { if (!fcb->Vcb->removing) { - if (fileref && fileref->delete_on_close && fileref != fcb->Vcb->root_fileref && fcb != fcb->Vcb->volume_fcb) { + if (oc == 0 && fileref->fcb->inode_item.st_nlink == 0 && fileref != fcb->Vcb->root_fileref && fcb != fcb->Vcb->volume_fcb) { // last handle closed on POSIX-deleted file + LIST_ENTRY rollback; + + InitializeListHead(&rollback); + + Status = delete_fileref_fcb(fileref, FileObject, Irp, &rollback); + if (!NT_SUCCESS(Status)) { + ERR("delete_fileref_fcb returned %08x\n", Status); + do_rollback(fcb->Vcb, &rollback); + ExReleaseResourceLite(fileref->fcb->Header.Resource); + ExReleaseResourceLite(&fcb->Vcb->tree_lock); + goto exit; + } + + clear_rollback(&rollback); + + mark_fcb_dirty(fileref->fcb); + } else if (fileref->delete_on_close && fileref != fcb->Vcb->root_fileref && fcb != fcb->Vcb->volume_fcb) { LIST_ENTRY rollback;
InitializeListHead(&rollback); @@ -2292,7 +2323,7 @@ static NTSTATUS drv_cleanup(_In_ PDEVICE_OBJECT DeviceObject, _In_ PIRP Irp) { // fileref_lock needs to be acquired before fcb->Header.Resource ExAcquireResourceExclusiveLite(&fcb->Vcb->fileref_lock, TRUE);
- Status = delete_fileref(fileref, FileObject, Irp, &rollback); + Status = delete_fileref(fileref, FileObject, oc > 0 && fileref->posix_delete, Irp, &rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status); do_rollback(fcb->Vcb, &rollback); @@ -2677,6 +2708,7 @@ static NTSTATUS add_root(_Inout_ device_extension* Vcb, _In_ UINT64 id, _In_ UIN r->parent = 0; r->send_ops = 0; r->fcbs_version = 0; + r->checked_for_orphans = FALSE; InitializeListHead(&r->fcbs); RtlZeroMemory(r->fcbs_ptrs, sizeof(LIST_ENTRY*) * 256);
@@ -3530,6 +3562,26 @@ void protect_superblocks(_Inout_ chunk* c) { } }
+UINT64 chunk_estimate_phys_size(device_extension* Vcb, chunk* c, UINT64 u) { + UINT64 nfactor, dfactor; + + if (c->chunk_item->type & BLOCK_FLAG_DUPLICATE || c->chunk_item->type & BLOCK_FLAG_RAID1 || c->chunk_item->type & BLOCK_FLAG_RAID10) { + nfactor = 1; + dfactor = 2; + } else if (c->chunk_item->type & BLOCK_FLAG_RAID5) { + nfactor = Vcb->superblock.num_devices - 1; + dfactor = Vcb->superblock.num_devices; + } else if (c->chunk_item->type & BLOCK_FLAG_RAID6) { + nfactor = Vcb->superblock.num_devices - 2; + dfactor = Vcb->superblock.num_devices; + } else { + nfactor = 1; + dfactor = 1; + } + + return u * dfactor / nfactor; +} + NTSTATUS find_chunk_usage(_In_ _Requires_lock_held_(_Curr_->tree_lock) device_extension* Vcb, _In_opt_ PIRP Irp) { LIST_ENTRY* le = Vcb->chunks.Flink; chunk* c; @@ -3540,6 +3592,8 @@ NTSTATUS find_chunk_usage(_In_ _Requires_lock_held_(_Curr_->tree_lock) device_ex
searchkey.obj_type = TYPE_BLOCK_GROUP_ITEM;
+ Vcb->superblock.bytes_used = 0; + while (le != &Vcb->chunks) { c = CONTAINING_RECORD(le, chunk, list_entry);
@@ -3559,6 +3613,8 @@ NTSTATUS find_chunk_usage(_In_ _Requires_lock_held_(_Curr_->tree_lock) device_ex c->used = c->oldused = bgi->used;
TRACE("chunk %llx has %llx bytes used\n", c->offset, c->used); + + Vcb->superblock.bytes_used += chunk_estimate_phys_size(Vcb, c, bgi->used); } else { ERR("(%llx;%llx,%x,%llx) is %u bytes, expected %u\n", Vcb->extent_root->id, tp.item->key.obj_id, tp.item->key.obj_type, tp.item->key.offset, tp.item->size, sizeof(BLOCK_GROUP_ITEM)); diff --git a/drivers/filesystems/btrfs/btrfs.h b/drivers/filesystems/btrfs/btrfs.h index eede4059854..d0d2c933d42 100644 --- a/drivers/filesystems/btrfs/btrfs.h +++ b/drivers/filesystems/btrfs/btrfs.h @@ -19,6 +19,7 @@ static const UINT64 superblock_addrs[] = { 0x10000, 0x4000000, 0x4000000000, 0x4 #define TYPE_INODE_REF 0x0C #define TYPE_INODE_EXTREF 0x0D #define TYPE_XATTR_ITEM 0x18 +#define TYPE_ORPHAN_INODE 0x30 #define TYPE_DIR_ITEM 0x54 #define TYPE_DIR_INDEX 0x60 #define TYPE_EXTENT_DATA 0x6C @@ -113,6 +114,8 @@ static const UINT64 superblock_addrs[] = { 0x10000, 0x4000000, 0x4000000000, 0x4
#define BTRFS_SUPERBLOCK_FLAGS_SEEDING 0x100000000
+#define BTRFS_ORPHAN_INODE_OBJID 0xFFFFFFFFFFFFFFFB + #pragma pack(push, 1)
typedef struct { diff --git a/drivers/filesystems/btrfs/btrfs.rc b/drivers/filesystems/btrfs/btrfs.rc index d10323e56c3..da8380e5562 100644 --- a/drivers/filesystems/btrfs/btrfs.rc +++ b/drivers/filesystems/btrfs/btrfs.rc @@ -51,8 +51,8 @@ END //
VS_VERSION_INFO VERSIONINFO - FILEVERSION 1,2,1,0 - PRODUCTVERSION 1,2,1,0 + FILEVERSION 1,3,0,0 + PRODUCTVERSION 1,3,0,0 FILEFLAGSMASK 0x17L #ifdef _DEBUG FILEFLAGS 0x1L @@ -68,12 +68,12 @@ BEGIN BLOCK "080904b0" BEGIN VALUE "FileDescription", "WinBtrfs" - VALUE "FileVersion", "1.2.1" + VALUE "FileVersion", "1.3" VALUE "InternalName", "btrfs" VALUE "LegalCopyright", "Copyright (c) Mark Harmstone 2016-19" VALUE "OriginalFilename", "btrfs.sys" VALUE "ProductName", "WinBtrfs" - VALUE "ProductVersion", "1.2.1" + VALUE "ProductVersion", "1.3" END END BLOCK "VarFileInfo" diff --git a/drivers/filesystems/btrfs/btrfs_drv.h b/drivers/filesystems/btrfs/btrfs_drv.h index b41c9794d30..b5d1cd2e4f0 100644 --- a/drivers/filesystems/btrfs/btrfs_drv.h +++ b/drivers/filesystems/btrfs/btrfs_drv.h @@ -101,6 +101,9 @@ #define EA_EA "user.EA" #define EA_EA_HASH 0x8270dd43
+#define EA_CASE_SENSITIVE "user.casesensitive" +#define EA_CASE_SENSITIVE_HASH 0x1a9d97d4 + #define EA_PROP_COMPRESSION "btrfs.compression" #define EA_PROP_COMPRESSION_HASH 0x20ccdf69
@@ -132,10 +135,20 @@ #define FILE_SUPPORTS_BLOCK_REFCOUNTING 0x08000000 #endif
+#ifndef FILE_SUPPORTS_POSIX_UNLINK_RENAME +#define FILE_SUPPORTS_POSIX_UNLINK_RENAME 0x00000400 +#endif + #ifndef FILE_DEVICE_ALLOW_APPCONTAINER_TRAVERSAL #define FILE_DEVICE_ALLOW_APPCONTAINER_TRAVERSAL 0x00020000 #endif
+#ifndef _MSC_VER +typedef struct _FILE_ID_128 { + UCHAR Identifier[16]; +} FILE_ID_128, *PFILE_ID_128; +#endif + typedef struct _DUPLICATE_EXTENTS_DATA { HANDLE FileHandle; LARGE_INTEGER SourceFileOffset; @@ -280,6 +293,9 @@ typedef struct _fcb { BOOL inode_item_changed; enum prop_compression_type prop_compression; LIST_ENTRY xattrs; + BOOL marked_as_orphan; + BOOL case_sensitive; + BOOL case_sensitive_set;
LIST_ENTRY dir_children_index; LIST_ENTRY dir_children_hash; @@ -317,6 +333,7 @@ typedef struct _file_ref { ANSI_STRING oldutf8; UINT64 oldindex; BOOL delete_on_close; + BOOL posix_delete; BOOL deleted; BOOL created; file_ref_nonpaged* nonpaged; @@ -434,6 +451,7 @@ typedef struct _root { UINT64 parent; LONG send_ops; UINT64 fcbs_version; + BOOL checked_for_orphans; LIST_ENTRY fcbs; LIST_ENTRY* fcbs_ptrs[256]; LIST_ENTRY list_entry; @@ -1123,7 +1141,7 @@ WCHAR* file_desc(_In_ PFILE_OBJECT FileObject); WCHAR* file_desc_fileref(_In_ file_ref* fileref); void mark_fcb_dirty(_In_ fcb* fcb); void mark_fileref_dirty(_In_ file_ref* fileref); -NTSTATUS delete_fileref(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject, _In_opt_ PIRP Irp, _In_ LIST_ENTRY* rollback); +NTSTATUS delete_fileref(_In_ file_ref* fileref, _In_opt_ PFILE_OBJECT FileObject, _In_ BOOL make_orphan, _In_opt_ PIRP Irp, _In_ LIST_ENTRY* rollback); void chunk_lock_range(_In_ device_extension* Vcb, _In_ chunk* c, _In_ UINT64 start, _In_ UINT64 length); void chunk_unlock_range(_In_ device_extension* Vcb, _In_ chunk* c, _In_ UINT64 start, _In_ UINT64 length); void init_device(_In_ device_extension* Vcb, _Inout_ device* dev, _In_ BOOL get_nums); @@ -1142,6 +1160,7 @@ void reap_fcb(fcb* fcb); void reap_fcbs(device_extension* Vcb); void reap_fileref(device_extension* Vcb, file_ref* fr); void reap_filerefs(device_extension* Vcb, file_ref* fr); +UINT64 chunk_estimate_phys_size(device_extension* Vcb, chunk* c, UINT64 u);
#ifdef _MSC_VER #define funcname __FUNCTION__ @@ -1412,7 +1431,7 @@ NTSTATUS open_fileref(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusiv _In_ PUNICODE_STRING fnus, _In_opt_ file_ref* related, _In_ BOOL parent, _Out_opt_ USHORT* parsed, _Out_opt_ ULONG* fn_offset, _In_ POOL_TYPE pooltype, _In_ BOOL case_sensitive, _In_opt_ PIRP Irp); NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lock_held_(_Curr_->fcb_lock) device_extension* Vcb, - root* subvol, UINT64 inode, UINT8 type, PANSI_STRING utf8, fcb* parent, fcb** pfcb, POOL_TYPE pooltype, PIRP Irp); + root* subvol, UINT64 inode, UINT8 type, PANSI_STRING utf8, BOOL always_add_hl, fcb* parent, fcb** pfcb, POOL_TYPE pooltype, PIRP Irp); NTSTATUS load_csum(_Requires_lock_held_(_Curr_->tree_lock) device_extension* Vcb, UINT32* csum, UINT64 start, UINT64 length, PIRP Irp); NTSTATUS load_dir_children(_Requires_lock_held_(_Curr_->tree_lock) device_extension* Vcb, fcb* fcb, BOOL ignore_size, PIRP Irp); NTSTATUS add_dir_child(fcb* fcb, UINT64 inode, BOOL subvol, PANSI_STRING utf8, PUNICODE_STRING name, UINT8 type, dir_child** pdc); diff --git a/drivers/filesystems/btrfs/create.c b/drivers/filesystems/btrfs/create.c index 089b19c8a83..2d996edc7c5 100644 --- a/drivers/filesystems/btrfs/create.c +++ b/drivers/filesystems/btrfs/create.c @@ -593,7 +593,7 @@ cont: }
NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lock_held_(_Curr_->fcb_lock) device_extension* Vcb, - root* subvol, UINT64 inode, UINT8 type, PANSI_STRING utf8, fcb* parent, fcb** pfcb, POOL_TYPE pooltype, PIRP Irp) { + root* subvol, UINT64 inode, UINT8 type, PANSI_STRING utf8, BOOL always_add_hl, fcb* parent, fcb** pfcb, POOL_TYPE pooltype, PIRP Irp) { KEY searchkey; traverse_ptr tp, next_tp; NTSTATUS Status; @@ -719,7 +719,7 @@ NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lo if ((no_data && tp.item->key.obj_type > TYPE_XATTR_ITEM) || tp.item->key.obj_type > TYPE_EXTENT_DATA) break;
- if (fcb->inode_item.st_nlink > 1 && tp.item->key.obj_type == TYPE_INODE_REF) { + if ((always_add_hl || fcb->inode_item.st_nlink > 1) && tp.item->key.obj_type == TYPE_INODE_REF) { ULONG len; INODE_REF* ir;
@@ -784,7 +784,7 @@ NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lo len -= sizeof(INODE_REF) - 1 + ir->n; ir = (INODE_REF*)&ir->name[ir->n]; } - } else if (fcb->inode_item.st_nlink > 1 && tp.item->key.obj_type == TYPE_INODE_EXTREF) { + } else if ((always_add_hl || fcb->inode_item.st_nlink > 1) && tp.item->key.obj_type == TYPE_INODE_EXTREF) { ULONG len; INODE_EXTREF* ier;
@@ -971,6 +971,11 @@ NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lo else fcb->prop_compression = PropCompression_None; } + } else if (tp.item->key.offset == EA_CASE_SENSITIVE_HASH && di->n == sizeof(EA_CASE_SENSITIVE) - 1 && RtlCompareMemory(EA_CASE_SENSITIVE, di->name, di->n) == di->n) { + if (di->m > 0) { + fcb->case_sensitive = di->m == 1 && di->name[di->n] == '1'; + fcb->case_sensitive_set = TRUE; + } } else if (di->n > sizeof(xapref) - 1 && RtlCompareMemory(xapref, di->name, sizeof(xapref) - 1) == sizeof(xapref) - 1) { dir_child* dc; ULONG utf16len; @@ -1165,8 +1170,8 @@ NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lo #endif
*pfcb = fcb2; - release_fcb_lock(Vcb); reap_fcb(fcb); + release_fcb_lock(Vcb); return STATUS_SUCCESS; } } @@ -1174,8 +1179,8 @@ NTSTATUS open_fcb(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusive_lo if (deleted_fcb) { InterlockedIncrement(&deleted_fcb->refcount); *pfcb = deleted_fcb; - release_fcb_lock(Vcb); reap_fcb(fcb); + release_fcb_lock(Vcb); return STATUS_SUCCESS; }
@@ -1514,7 +1519,7 @@ NTSTATUS open_fileref_child(_Requires_lock_held_(_Curr_->tree_lock) _Requires_ex #ifdef DEBUG_STATS time1 = KeQueryPerformanceCounter(NULL); #endif - Status = open_fcb(Vcb, subvol, inode, dc->type, &dc->utf8, sf->fcb, &fcb, pooltype, Irp); + Status = open_fcb(Vcb, subvol, inode, dc->type, &dc->utf8, FALSE, sf->fcb, &fcb, pooltype, Irp); #ifdef DEBUG_STATS time2 = KeQueryPerformanceCounter(NULL); Vcb->stats.open_fcb_calls++; @@ -1692,7 +1697,16 @@ NTSTATUS open_fileref(_Requires_lock_held_(_Curr_->tree_lock) _Requires_exclusiv #ifdef DEBUG_STATS time1 = KeQueryPerformanceCounter(NULL); #endif - Status = open_fileref_child(Vcb, sf, &nb->us, case_sensitive, lastpart, streampart, pooltype, &sf2, Irp); + BOOL cs = case_sensitive; + + if (!cs) { + if (streampart) + cs = sf->parent->fcb->case_sensitive; + else + cs = sf->fcb->case_sensitive; + } + + Status = open_fileref_child(Vcb, sf, &nb->us, cs, lastpart, streampart, pooltype, &sf2, Irp); #ifdef DEBUG_STATS time2 = KeQueryPerformanceCounter(NULL); Vcb->stats.open_fileref_child_calls++; @@ -2529,6 +2543,7 @@ static NTSTATUS create_stream(_Requires_lock_held_(_Curr_->tree_lock) _Requires_ static const WCHAR DOSATTRIB[] = L"DOSATTRIB"; static const WCHAR EA[] = L"EA"; static const WCHAR reparse[] = L"reparse"; + static const WCHAR casesensitive_str[] = L"casesensitive"; LARGE_INTEGER time; BTRFS_TIME now; ULONG utf8len, overhead; @@ -2634,7 +2649,8 @@ static NTSTATUS create_stream(_Requires_lock_held_(_Curr_->tree_lock) _Requires_
if ((stream->Length == sizeof(DOSATTRIB) - sizeof(WCHAR) && RtlCompareMemory(stream->Buffer, DOSATTRIB, stream->Length) == stream->Length) || (stream->Length == sizeof(EA) - sizeof(WCHAR) && RtlCompareMemory(stream->Buffer, EA, stream->Length) == stream->Length) || - (stream->Length == sizeof(reparse) - sizeof(WCHAR) && RtlCompareMemory(stream->Buffer, reparse, stream->Length) == stream->Length)) { + (stream->Length == sizeof(reparse) - sizeof(WCHAR) && RtlCompareMemory(stream->Buffer, reparse, stream->Length) == stream->Length) || + (stream->Length == sizeof(casesensitive_str) - sizeof(WCHAR) && RtlCompareMemory(stream->Buffer, casesensitive_str, stream->Length) == stream->Length)) { free_fileref(parfileref); return STATUS_OBJECT_NAME_INVALID; } @@ -3774,7 +3790,7 @@ static NTSTATUS open_file2(device_extension* Vcb, ULONG RequestedDisposition, PO if (dc->fileref) { send_notification_fcb(fileref, FILE_NOTIFY_CHANGE_STREAM_NAME, FILE_ACTION_REMOVED_STREAM, &dc->name);
- Status = delete_fileref(dc->fileref, NULL, NULL, rollback); + Status = delete_fileref(dc->fileref, NULL, FALSE, NULL, rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status);
@@ -3953,30 +3969,198 @@ NTSTATUS open_fileref_by_inode(_Requires_exclusive_lock_held_(_Curr_->fcb_lock) UNICODE_STRING name; BOOL hl_alloc = FALSE; file_ref *parfr, *fr; -#ifdef __REACTOS__ - hardlink* hl; -#endif
- Status = open_fcb(Vcb, subvol, inode, 0, NULL, NULL, &fcb, PagedPool, Irp); + Status = open_fcb(Vcb, subvol, inode, 0, NULL, TRUE, NULL, &fcb, PagedPool, Irp); if (!NT_SUCCESS(Status)) { ERR("open_fcb returned %08x\n", Status); return Status; }
+ ExAcquireResourceSharedLite(fcb->Header.Resource, TRUE); + + if (fcb->inode_item.st_nlink == 0 || fcb->deleted) { + ExReleaseResourceLite(fcb->Header.Resource); + free_fcb(fcb); + return STATUS_OBJECT_NAME_NOT_FOUND; + } + if (fcb->fileref) { *pfr = fcb->fileref; increase_fileref_refcount(fcb->fileref); + free_fcb(fcb); + ExReleaseResourceLite(fcb->Header.Resource); return STATUS_SUCCESS; }
+ if (IsListEmpty(&fcb->hardlinks)) { + ExReleaseResourceLite(fcb->Header.Resource); + + ExAcquireResourceSharedLite(&Vcb->dirty_filerefs_lock, TRUE); + + if (!IsListEmpty(&Vcb->dirty_filerefs)) { + LIST_ENTRY* le = Vcb->dirty_filerefs.Flink; + while (le != &Vcb->dirty_filerefs) { + file_ref* fr = CONTAINING_RECORD(le, file_ref, list_entry_dirty); + + if (fr->fcb == fcb) { + ExReleaseResourceLite(&Vcb->dirty_filerefs_lock); + increase_fileref_refcount(fr); + free_fcb(fcb); + *pfr = fr; + return STATUS_SUCCESS; + } + + le = le->Flink; + } + } + + ExReleaseResourceLite(&Vcb->dirty_filerefs_lock); + + { + KEY searchkey; + traverse_ptr tp; + + searchkey.obj_id = fcb->inode; + searchkey.obj_type = TYPE_INODE_REF; + searchkey.offset = 0; + + Status = find_item(Vcb, subvol, &tp, &searchkey, FALSE, Irp); + if (!NT_SUCCESS(Status)) { + ERR("find_item returned %08x\n", Status); + free_fcb(fcb); + return Status; + } + + do { + traverse_ptr next_tp; + + if (tp.item->key.obj_id > fcb->inode || (tp.item->key.obj_id == fcb->inode && tp.item->key.obj_type > TYPE_INODE_EXTREF)) + break; + + if (tp.item->key.obj_id == fcb->inode) { + if (tp.item->key.obj_type == TYPE_INODE_REF) { + INODE_REF* ir = (INODE_REF*)tp.item->data; +#ifdef __REACTOS__ + ULONG stringlen; +#endif + + if (tp.item->size < offsetof(INODE_REF, name[0]) || tp.item->size < offsetof(INODE_REF, name[0]) + ir->n) { + ERR("INODE_REF was too short\n"); + free_fcb(fcb); + return STATUS_INTERNAL_ERROR; + } + #ifndef __REACTOS__ - hardlink* hl = CONTAINING_RECORD(fcb->hardlinks.Flink, hardlink, list_entry); -#else - hl = CONTAINING_RECORD(fcb->hardlinks.Flink, hardlink, list_entry); + ULONG stringlen; #endif
- name = hl->name; - parent = hl->parent; + Status = RtlUTF8ToUnicodeN(NULL, 0, &stringlen, ir->name, ir->n); + if (!NT_SUCCESS(Status)) { + ERR("RtlUTF8ToUnicodeN 1 returned %08x\n", Status); + free_fcb(fcb); + return Status; + } + + name.Length = name.MaximumLength = (UINT16)stringlen; + + if (stringlen == 0) + name.Buffer = NULL; + else { + name.Buffer = ExAllocatePoolWithTag(PagedPool, name.MaximumLength, ALLOC_TAG); + + if (!name.Buffer) { + ERR("out of memory\n"); + free_fcb(fcb); + return STATUS_INSUFFICIENT_RESOURCES; + } + + Status = RtlUTF8ToUnicodeN(name.Buffer, stringlen, &stringlen, ir->name, ir->n); + if (!NT_SUCCESS(Status)) { + ERR("RtlUTF8ToUnicodeN 2 returned %08x\n", Status); + ExFreePool(name.Buffer); + free_fcb(fcb); + return Status; + } + + hl_alloc = TRUE; + } + + parent = tp.item->key.offset; + + break; + } else if (tp.item->key.obj_type == TYPE_INODE_EXTREF) { + INODE_EXTREF* ier = (INODE_EXTREF*)tp.item->data; +#ifdef __REACTOS__ + ULONG stringlen; +#endif + + if (tp.item->size < offsetof(INODE_EXTREF, name[0]) || tp.item->size < offsetof(INODE_EXTREF, name[0]) + ier->n) { + ERR("INODE_EXTREF was too short\n"); + free_fcb(fcb); + return STATUS_INTERNAL_ERROR; + } + +#ifndef __REACTOS__ + ULONG stringlen; +#endif + + Status = RtlUTF8ToUnicodeN(NULL, 0, &stringlen, ier->name, ier->n); + if (!NT_SUCCESS(Status)) { + ERR("RtlUTF8ToUnicodeN 1 returned %08x\n", Status); + free_fcb(fcb); + return Status; + } + + name.Length = name.MaximumLength = (UINT16)stringlen; + + if (stringlen == 0) + name.Buffer = NULL; + else { + name.Buffer = ExAllocatePoolWithTag(PagedPool, name.MaximumLength, ALLOC_TAG); + + if (!name.Buffer) { + ERR("out of memory\n"); + free_fcb(fcb); + return STATUS_INSUFFICIENT_RESOURCES; + } + + Status = RtlUTF8ToUnicodeN(name.Buffer, stringlen, &stringlen, ier->name, ier->n); + if (!NT_SUCCESS(Status)) { + ERR("RtlUTF8ToUnicodeN 2 returned %08x\n", Status); + ExFreePool(name.Buffer); + free_fcb(fcb); + return Status; + } + + hl_alloc = TRUE; + } + + parent = ier->dir; + + break; + } + } + + if (find_next_item(Vcb, &tp, &next_tp, FALSE, Irp)) + tp = next_tp; + else + break; + } while (TRUE); + } + + if (parent == 0) { + WARN("trying to open inode with no references\n"); + free_fcb(fcb); + return STATUS_INVALID_PARAMETER; + } + } else { + hardlink* hl = CONTAINING_RECORD(fcb->hardlinks.Flink, hardlink, list_entry); + + name = hl->name; + parent = hl->parent; + + ExReleaseResourceLite(fcb->Header.Resource); + }
if (parent == inode) { // subvolume root KEY searchkey; @@ -4048,6 +4232,9 @@ NTSTATUS open_fileref_by_inode(_Requires_exclusive_lock_held_(_Curr_->fcb_lock) if (stringlen == 0) name.Buffer = NULL; else { + if (hl_alloc) + ExFreePool(name.Buffer); + name.Buffer = ExAllocatePoolWithTag(PagedPool, name.MaximumLength, ALLOC_TAG);
if (!name.Buffer) { @@ -4190,9 +4377,21 @@ static NTSTATUS open_file(PDEVICE_OBJECT DeviceObject, _Requires_lock_held_(_Cur }
if (options & FILE_OPEN_BY_FILE_ID) { - if (fn.Length == sizeof(UINT64) && related && RequestedDisposition == FILE_OPEN) { + if (RequestedDisposition != FILE_OPEN) { + WARN("FILE_OPEN_BY_FILE_ID not supported for anything other than FILE_OPEN\n"); + Status = STATUS_INVALID_PARAMETER; + goto exit; + } + + if (fn.Length == sizeof(UINT64)) { UINT64 inode;
+ if (!related) { + WARN("cannot open by short file ID unless related fileref also provided"); + Status = STATUS_INVALID_PARAMETER; + goto exit; + } + RtlCopyMemory(&inode, fn.Buffer, sizeof(UINT64));
if (related->fcb == Vcb->root_fileref->fcb && inode == 0) @@ -4205,10 +4404,38 @@ static NTSTATUS open_file(PDEVICE_OBJECT DeviceObject, _Requires_lock_held_(_Cur } else Status = open_fileref_by_inode(Vcb, related->fcb->subvol, inode, &fileref, Irp);
+ goto loaded; + } else if (fn.Length == sizeof(FILE_ID_128)) { + UINT64 inode, subvol_id; + root* subvol = NULL; + + RtlCopyMemory(&inode, fn.Buffer, sizeof(UINT64)); + RtlCopyMemory(&subvol_id, (UINT8*)fn.Buffer + sizeof(UINT64), sizeof(UINT64)); + + if (subvol_id == BTRFS_ROOT_FSTREE || (subvol_id >= 0x100 && subvol_id < 0x8000000000000000)) { + LIST_ENTRY* le = Vcb->roots.Flink; + while (le != &Vcb->roots) { + root* r = CONTAINING_RECORD(le, root, list_entry); + + if (r->id == subvol_id) { + subvol = r; + break; + } + + le = le->Flink; + } + } + + if (!subvol) { + WARN("subvol %llx not found\n", subvol_id); + Status = STATUS_OBJECT_NAME_NOT_FOUND; + } else + Status = open_fileref_by_inode(Vcb, subvol, inode, &fileref, Irp); + goto loaded; } else { - WARN("FILE_OPEN_BY_FILE_ID only supported for inodes\n"); - Status = STATUS_NOT_IMPLEMENTED; + WARN("invalid ID size for FILE_OPEN_BY_FILE_ID\n"); + Status = STATUS_INVALID_PARAMETER; goto exit; } } diff --git a/drivers/filesystems/btrfs/dirctrl.c b/drivers/filesystems/btrfs/dirctrl.c index 19b261b0180..48e7fc2aca6 100644 --- a/drivers/filesystems/btrfs/dirctrl.c +++ b/drivers/filesystems/btrfs/dirctrl.c @@ -17,6 +17,49 @@
#include "btrfs_drv.h"
+// not currently in mingw +#ifndef _MSC_VER +#define FileIdExtdDirectoryInformation (enum _FILE_INFORMATION_CLASS)60 +#define FileIdExtdBothDirectoryInformation (enum _FILE_INFORMATION_CLASS)63 + +typedef struct _FILE_ID_EXTD_DIR_INFORMATION { + ULONG NextEntryOffset; + ULONG FileIndex; + LARGE_INTEGER CreationTime; + LARGE_INTEGER LastAccessTime; + LARGE_INTEGER LastWriteTime; + LARGE_INTEGER ChangeTime; + LARGE_INTEGER EndOfFile; + LARGE_INTEGER AllocationSize; + ULONG FileAttributes; + ULONG FileNameLength; + ULONG EaSize; + ULONG ReparsePointTag; + FILE_ID_128 FileId; + WCHAR FileName[1]; +} FILE_ID_EXTD_DIR_INFORMATION, *PFILE_ID_EXTD_DIR_INFORMATION; + +typedef struct _FILE_ID_EXTD_BOTH_DIR_INFORMATION { + ULONG NextEntryOffset; + ULONG FileIndex; + LARGE_INTEGER CreationTime; + LARGE_INTEGER LastAccessTime; + LARGE_INTEGER LastWriteTime; + LARGE_INTEGER ChangeTime; + LARGE_INTEGER EndOfFile; + LARGE_INTEGER AllocationSize; + ULONG FileAttributes; + ULONG FileNameLength; + ULONG EaSize; + ULONG ReparsePointTag; + FILE_ID_128 FileId; + CCHAR ShortNameLength; + WCHAR ShortName[12]; + WCHAR FileName[1]; +} FILE_ID_EXTD_BOTH_DIR_INFORMATION, *PFILE_ID_EXTD_BOTH_DIR_INFORMATION; + +#endif + enum DirEntryType { DirEntryType_File, DirEntryType_Self, @@ -79,7 +122,7 @@ ULONG get_reparse_tag(device_extension* Vcb, root* subvol, UINT64 inode, UINT8 t if (!(atts & FILE_ATTRIBUTE_REPARSE_POINT)) return 0;
- Status = open_fcb(Vcb, subvol, inode, type, NULL, NULL, &fcb, PagedPool, Irp); + Status = open_fcb(Vcb, subvol, inode, type, NULL, FALSE, NULL, &fcb, PagedPool, Irp); if (!NT_SUCCESS(Status)) { ERR("open_fcb returned %08x\n", Status); return 0; @@ -221,7 +264,9 @@ static NTSTATUS query_dir_item(fcb* fcb, ccb* ccb, void* buf, LONG* len, PIRP Ir IrpSp->Parameters.QueryDirectory.FileInformationClass == FileDirectoryInformation || IrpSp->Parameters.QueryDirectory.FileInformationClass == FileFullDirectoryInformation || IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdBothDirectoryInformation || - IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdFullDirectoryInformation) { + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdFullDirectoryInformation || + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdExtdDirectoryInformation || + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdExtdBothDirectoryInformation) {
BOOL dotfile = de->name.Length > sizeof(WCHAR) && de->name.Buffer[0] == '.';
@@ -231,7 +276,9 @@ static NTSTATUS query_dir_item(fcb* fcb, ccb* ccb, void* buf, LONG* len, PIRP Ir if (IrpSp->Parameters.QueryDirectory.FileInformationClass == FileBothDirectoryInformation || IrpSp->Parameters.QueryDirectory.FileInformationClass == FileFullDirectoryInformation || IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdBothDirectoryInformation || - IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdFullDirectoryInformation) { + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdFullDirectoryInformation || + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdExtdDirectoryInformation || + IrpSp->Parameters.QueryDirectory.FileInformationClass == FileIdExtdBothDirectoryInformation) { ealen = get_ea_len(fcb->Vcb, r, inode, Irp); } } @@ -465,6 +512,102 @@ static NTSTATUS query_dir_item(fcb* fcb, ccb* ccb, void* buf, LONG* len, PIRP Ir return STATUS_SUCCESS; }
+#ifndef _MSC_VER +#pragma GCC diagnostic push +#pragma GCC diagnostic ignored "-Wswitch" +#endif + case FileIdExtdDirectoryInformation: + { + FILE_ID_EXTD_DIR_INFORMATION* fiedi = buf; + + TRACE("FileIdExtdDirectoryInformation\n"); + + needed = offsetof(FILE_ID_EXTD_DIR_INFORMATION, FileName[0]) + de->name.Length; + + if (needed > *len) { + TRACE("buffer overflow - %u > %u\n", needed, *len); + return STATUS_BUFFER_OVERFLOW; + } + + fiedi->NextEntryOffset = 0; + fiedi->FileIndex = 0; + fiedi->CreationTime.QuadPart = unix_time_to_win(&ii.otime); + fiedi->LastAccessTime.QuadPart = unix_time_to_win(&ii.st_atime); + fiedi->LastWriteTime.QuadPart = unix_time_to_win(&ii.st_mtime); + fiedi->ChangeTime.QuadPart = unix_time_to_win(&ii.st_ctime); + fiedi->EndOfFile.QuadPart = de->type == BTRFS_TYPE_SYMLINK ? 0 : ii.st_size; + + if (de->type == BTRFS_TYPE_SYMLINK) + fiedi->AllocationSize.QuadPart = 0; + else if (atts & FILE_ATTRIBUTE_SPARSE_FILE) + fiedi->AllocationSize.QuadPart = ii.st_blocks; + else + fiedi->AllocationSize.QuadPart = sector_align(ii.st_size, fcb->Vcb->superblock.sector_size); + + fiedi->FileAttributes = atts; + fiedi->FileNameLength = de->name.Length; + fiedi->EaSize = ealen; + fiedi->ReparsePointTag = get_reparse_tag(fcb->Vcb, r, inode, de->type, atts, ccb->lxss, Irp); + + RtlCopyMemory(&fiedi->FileId.Identifier[0], &fcb->inode, sizeof(UINT64)); + RtlCopyMemory(&fiedi->FileId.Identifier[sizeof(UINT64)], &fcb->subvol->id, sizeof(UINT64)); + + RtlCopyMemory(fiedi->FileName, de->name.Buffer, de->name.Length); + + *len -= needed; + + return STATUS_SUCCESS; + } + + case FileIdExtdBothDirectoryInformation: + { + FILE_ID_EXTD_BOTH_DIR_INFORMATION* fiebdi = buf; + + TRACE("FileIdExtdBothDirectoryInformation\n"); + + needed = offsetof(FILE_ID_EXTD_BOTH_DIR_INFORMATION, FileName[0]) + de->name.Length; + + if (needed > *len) { + TRACE("buffer overflow - %u > %u\n", needed, *len); + return STATUS_BUFFER_OVERFLOW; + } + + fiebdi->NextEntryOffset = 0; + fiebdi->FileIndex = 0; + fiebdi->CreationTime.QuadPart = unix_time_to_win(&ii.otime); + fiebdi->LastAccessTime.QuadPart = unix_time_to_win(&ii.st_atime); + fiebdi->LastWriteTime.QuadPart = unix_time_to_win(&ii.st_mtime); + fiebdi->ChangeTime.QuadPart = unix_time_to_win(&ii.st_ctime); + fiebdi->EndOfFile.QuadPart = de->type == BTRFS_TYPE_SYMLINK ? 0 : ii.st_size; + + if (de->type == BTRFS_TYPE_SYMLINK) + fiebdi->AllocationSize.QuadPart = 0; + else if (atts & FILE_ATTRIBUTE_SPARSE_FILE) + fiebdi->AllocationSize.QuadPart = ii.st_blocks; + else + fiebdi->AllocationSize.QuadPart = sector_align(ii.st_size, fcb->Vcb->superblock.sector_size); + + fiebdi->FileAttributes = atts; + fiebdi->FileNameLength = de->name.Length; + fiebdi->EaSize = ealen; + fiebdi->ReparsePointTag = get_reparse_tag(fcb->Vcb, r, inode, de->type, atts, ccb->lxss, Irp); + + RtlCopyMemory(&fiebdi->FileId.Identifier[0], &fcb->inode, sizeof(UINT64)); + RtlCopyMemory(&fiebdi->FileId.Identifier[sizeof(UINT64)], &fcb->subvol->id, sizeof(UINT64)); + + fiebdi->ShortNameLength = 0; + + RtlCopyMemory(fiebdi->FileName, de->name.Buffer, de->name.Length); + + *len -= needed; + + return STATUS_SUCCESS; + } + +#ifndef _MSC_VER +#pragma GCC diagnostic pop +#endif + case FileNamesInformation: { FILE_NAMES_INFORMATION* fni = buf; @@ -857,13 +1000,22 @@ static NTSTATUS query_directory(PIRP Irp) {
while (length > 0) { switch (IrpSp->Parameters.QueryDirectory.FileInformationClass) { +#ifndef _MSC_VER +#pragma GCC diagnostic push +#pragma GCC diagnostic ignored "-Wswitch" +#endif case FileBothDirectoryInformation: case FileDirectoryInformation: case FileIdBothDirectoryInformation: case FileFullDirectoryInformation: case FileIdFullDirectoryInformation: + case FileIdExtdDirectoryInformation: + case FileIdExtdBothDirectoryInformation: length -= length % 8; break; +#ifndef _MSC_VER +#pragma GCC diagnostic pop +#endif
case FileNamesInformation: length -= length % 4; diff --git a/drivers/filesystems/btrfs/fileinfo.c b/drivers/filesystems/btrfs/fileinfo.c index 2339c5dedaa..06ae42ac65c 100644 --- a/drivers/filesystems/btrfs/fileinfo.c +++ b/drivers/filesystems/btrfs/fileinfo.c @@ -21,7 +21,32 @@ // not currently in mingw - introduced with Windows 10 #ifndef _MSC_VER #define FileIdInformation (enum _FILE_INFORMATION_CLASS)59 +#define FileHardLinkFullIdInformation (enum _FILE_INFORMATION_CLASS)62 +#define FileDispositionInformationEx (enum _FILE_INFORMATION_CLASS)64 +#define FileRenameInformationEx (enum _FILE_INFORMATION_CLASS)65 +#define FileStatInformation (enum _FILE_INFORMATION_CLASS)68 #define FileStatLxInformation (enum _FILE_INFORMATION_CLASS)70 +#define FileCaseSensitiveInformation (enum _FILE_INFORMATION_CLASS)71 +#define FileLinkInformationEx (enum _FILE_INFORMATION_CLASS)72 + +typedef struct _FILE_ID_INFORMATION { + ULONGLONG VolumeSerialNumber; + FILE_ID_128 FileId; +} FILE_ID_INFORMATION, *PFILE_ID_INFORMATION; + +typedef struct _FILE_STAT_INFORMATION { + LARGE_INTEGER FileId; + LARGE_INTEGER CreationTime; + LARGE_INTEGER LastAccessTime; + LARGE_INTEGER LastWriteTime; + LARGE_INTEGER ChangeTime; + LARGE_INTEGER AllocationSize; + LARGE_INTEGER EndOfFile; + ULONG FileAttributes; + ULONG ReparseTag; + ULONG NumberOfLinks; + ACCESS_MASK EffectiveAccess; +} FILE_STAT_INFORMATION, *PFILE_STAT_INFORMATION;
typedef struct _FILE_STAT_LX_INFORMATION { LARGE_INTEGER FileId; @@ -49,9 +74,119 @@ typedef struct _FILE_STAT_LX_INFORMATION { #define LX_FILE_METADATA_HAS_DEVICE_ID 0x08 #define LX_FILE_CASE_SENSITIVE_DIR 0x10
+typedef struct _FILE_RENAME_INFORMATION_EX { + union { + BOOLEAN ReplaceIfExists; + ULONG Flags; + }; + HANDLE RootDirectory; + ULONG FileNameLength; + WCHAR FileName[1]; +} FILE_RENAME_INFORMATION_EX, *PFILE_RENAME_INFORMATION_EX; + +typedef struct _FILE_DISPOSITION_INFORMATION_EX { + ULONG Flags; +} FILE_DISPOSITION_INFORMATION_EX, *PFILE_DISPOSITION_INFORMATION_EX; + +typedef struct _FILE_LINK_INFORMATION_EX { + union { + BOOLEAN ReplaceIfExists; + ULONG Flags; + }; + HANDLE RootDirectory; + ULONG FileNameLength; + WCHAR FileName[1]; +} FILE_LINK_INFORMATION_EX, *PFILE_LINK_INFORMATION_EX; + +typedef struct _FILE_CASE_SENSITIVE_INFORMATION { + ULONG Flags; +} FILE_CASE_SENSITIVE_INFORMATION, *PFILE_CASE_SENSITIVE_INFORMATION; + +typedef struct _FILE_LINK_ENTRY_FULL_ID_INFORMATION { + ULONG NextEntryOffset; + FILE_ID_128 ParentFileId; + ULONG FileNameLength; + WCHAR FileName[1]; +} FILE_LINK_ENTRY_FULL_ID_INFORMATION, *PFILE_LINK_ENTRY_FULL_ID_INFORMATION; + +typedef struct _FILE_LINKS_FULL_ID_INFORMATION { + ULONG BytesNeeded; + ULONG EntriesReturned; + FILE_LINK_ENTRY_FULL_ID_INFORMATION Entry; +} FILE_LINKS_FULL_ID_INFORMATION, *PFILE_LINKS_FULL_ID_INFORMATION; + +#define FILE_RENAME_REPLACE_IF_EXISTS 0x001 +#define FILE_RENAME_POSIX_SEMANTICS 0x002 +#define FILE_RENAME_SUPPRESS_PIN_STATE_INHERITANCE 0x004 +#define FILE_RENAME_SUPPRESS_STORAGE_RESERVE_INHERITANCE 0x008 +#define FILE_RENAME_NO_INCREASE_AVAILABLE_SPACE 0x010 +#define FILE_RENAME_NO_DECREASE_AVAILABLE_SPACE 0x020 +#define FILE_RENAME_IGNORE_READONLY_ATTRIBUTE 0x040 +#define FILE_RENAME_FORCE_RESIZE_TARGET_SR 0x080 +#define FILE_RENAME_FORCE_RESIZE_SOURCE_SR 0x100 + +#define FILE_DISPOSITION_DELETE 0x1 +#define FILE_DISPOSITION_POSIX_SEMANTICS 0x2 +#define FILE_DISPOSITION_FORCE_IMAGE_SECTION_CHECK 0x4 +#define FILE_DISPOSITION_ON_CLOSE 0x8 + +#define FILE_LINK_REPLACE_IF_EXISTS 0x001 +#define FILE_LINK_POSIX_SEMANTICS 0x002 +#define FILE_LINK_SUPPRESS_STORAGE_RESERVE_INHERITANCE 0x008 +#define FILE_LINK_NO_INCREASE_AVAILABLE_SPACE 0x010 +#define FILE_LINK_NO_DECREASE_AVAILABLE_SPACE 0x020 +#define FILE_LINK_IGNORE_READONLY_ATTRIBUTE 0x040 +#define FILE_LINK_FORCE_RESIZE_TARGET_SR 0x080 +#define FILE_LINK_FORCE_RESIZE_SOURCE_SR 0x100 + +#define FILE_CS_FLAG_CASE_SENSITIVE_DIR 1 + +#else + +#define FILE_RENAME_INFORMATION_EX FILE_RENAME_INFORMATION +#define FILE_LINK_INFORMATION_EX FILE_LINK_INFORMATION + #endif #endif
+#ifdef __REACTOS__ +typedef struct _FILE_RENAME_INFORMATION_EX { + union { + BOOLEAN ReplaceIfExists; + ULONG Flags; + }; + HANDLE RootDirectory; + ULONG FileNameLength; + WCHAR FileName[1]; +} FILE_RENAME_INFORMATION_EX, *PFILE_RENAME_INFORMATION_EX; + +typedef struct _FILE_DISPOSITION_INFORMATION_EX { + ULONG Flags; +} FILE_DISPOSITION_INFORMATION_EX, *PFILE_DISPOSITION_INFORMATION_EX; + +typedef struct _FILE_LINK_INFORMATION_EX { + union { + BOOLEAN ReplaceIfExists; + ULONG Flags; + }; + HANDLE RootDirectory; + ULONG FileNameLength; + WCHAR FileName[1]; +} FILE_LINK_INFORMATION_EX, *PFILE_LINK_INFORMATION_EX; + +#define FILE_RENAME_REPLACE_IF_EXISTS 0x001 +#define FILE_RENAME_POSIX_SEMANTICS 0x002 +#define FILE_RENAME_IGNORE_READONLY_ATTRIBUTE 0x040 + +#define FILE_DISPOSITION_DELETE 0x1 +#define FILE_DISPOSITION_POSIX_SEMANTICS 0x2 +#define FILE_DISPOSITION_FORCE_IMAGE_SECTION_CHECK 0x4 + +#define FILE_LINK_REPLACE_IF_EXISTS 0x001 +#define FILE_LINK_POSIX_SEMANTICS 0x002 +#define FILE_LINK_IGNORE_READONLY_ATTRIBUTE 0x040 +#endif + static NTSTATUS set_basic_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject) { FILE_BASIC_INFORMATION* fbi = Irp->AssociatedIrp.SystemBuffer; fcb* fcb = FileObject->FsContext; @@ -219,20 +354,29 @@ end: return Status; }
-static NTSTATUS set_disposition_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject) { - FILE_DISPOSITION_INFORMATION* fdi = Irp->AssociatedIrp.SystemBuffer; +static NTSTATUS set_disposition_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject, BOOL ex) { fcb* fcb = FileObject->FsContext; ccb* ccb = FileObject->FsContext2; file_ref* fileref = ccb ? ccb->fileref : NULL; - ULONG atts; + ULONG atts, flags; NTSTATUS Status;
if (!fileref) return STATUS_INVALID_PARAMETER;
+ if (ex) { + FILE_DISPOSITION_INFORMATION_EX* fdi = Irp->AssociatedIrp.SystemBuffer; + + flags = fdi->Flags; + } else { + FILE_DISPOSITION_INFORMATION* fdi = Irp->AssociatedIrp.SystemBuffer; + + flags = fdi->DeleteFile ? FILE_DISPOSITION_DELETE : 0; + } + ExAcquireResourceExclusiveLite(fcb->Header.Resource, TRUE);
- TRACE("changing delete_on_close to %s for %S (fcb %p)\n", fdi->DeleteFile ? "TRUE" : "FALSE", file_desc(FileObject), fcb); + TRACE("changing delete_on_close to %s for %S (fcb %p)\n", flags & FILE_DISPOSITION_DELETE ? "TRUE" : "FALSE", file_desc(FileObject), fcb);
if (fcb->ads) { if (fileref->parent) @@ -261,14 +405,19 @@ static NTSTATUS set_disposition_information(device_extension* Vcb, PIRP Irp, PFI }
if (!MmFlushImageSection(&fcb->nonpaged->segment_object, MmFlushForDelete)) { - TRACE("trying to delete file which is being mapped as an image\n"); - Status = STATUS_CANNOT_DELETE; - goto end; + if (!ex || flags & FILE_DISPOSITION_FORCE_IMAGE_SECTION_CHECK) { + TRACE("trying to delete file which is being mapped as an image\n"); + Status = STATUS_CANNOT_DELETE; + goto end; + } }
- ccb->fileref->delete_on_close = fdi->DeleteFile; + ccb->fileref->delete_on_close = flags & FILE_DISPOSITION_DELETE; + + FileObject->DeletePending = flags & FILE_DISPOSITION_DELETE;
- FileObject->DeletePending = fdi->DeleteFile; + if (flags & FILE_DISPOSITION_DELETE && flags & FILE_DISPOSITION_POSIX_SEMANTICS) + ccb->fileref->posix_delete = TRUE;
Status = STATUS_SUCCESS;
@@ -276,7 +425,7 @@ end: ExReleaseResourceLite(fcb->Header.Resource);
// send notification that directory is about to be deleted - if (NT_SUCCESS(Status) && fdi->DeleteFile && fcb->type == BTRFS_TYPE_DIRECTORY) { + if (NT_SUCCESS(Status) && flags & FILE_DISPOSITION_DELETE && fcb->type == BTRFS_TYPE_DIRECTORY) { FsRtlNotifyFullChangeDirectory(Vcb->NotifySync, &Vcb->DirNotifyList, FileObject->FsContext, NULL, FALSE, FALSE, 0, NULL, NULL, NULL); } @@ -1161,7 +1310,7 @@ static NTSTATUS move_across_subvols(file_ref* fileref, ccb* ccb, file_ref* destd }
if (!me->dummyfileref->fcb->ads) { - Status = delete_fileref(me->dummyfileref, NULL, Irp, rollback); + Status = delete_fileref(me->dummyfileref, NULL, FALSE, Irp, rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status); goto end; @@ -1217,7 +1366,7 @@ static NTSTATUS move_across_subvols(file_ref* fileref, ccb* ccb, file_ref* destd me = CONTAINING_RECORD(le, move_entry, list_entry);
if (me->dummyfileref->fcb->ads && me->parent->dummyfileref->fcb->deleted) { - Status = delete_fileref(me->dummyfileref, NULL, Irp, rollback); + Status = delete_fileref(me->dummyfileref, NULL, FALSE, Irp, rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status); goto end; @@ -1349,9 +1498,8 @@ void insert_dir_child_into_hash_lists(fcb* fcb, dir_child* dc) { } }
-static NTSTATUS set_rename_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject, PFILE_OBJECT tfo) { - PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); - FILE_RENAME_INFORMATION* fri = Irp->AssociatedIrp.SystemBuffer; +static NTSTATUS set_rename_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject, PFILE_OBJECT tfo, BOOL ex) { + FILE_RENAME_INFORMATION_EX* fri = Irp->AssociatedIrp.SystemBuffer; fcb *fcb = FileObject->FsContext; ccb* ccb = FileObject->FsContext2; file_ref *fileref = ccb ? ccb->fileref : NULL, *oldfileref = NULL, *related = NULL, *fr2 = NULL; @@ -1366,11 +1514,17 @@ static NTSTATUS set_rename_information(device_extension* Vcb, PIRP Irp, PFILE_OB hardlink* hl; SECURITY_SUBJECT_CONTEXT subjcont; ACCESS_MASK access; + ULONG flags;
InitializeListHead(&rollback);
+ if (ex) + flags = fri->Flags; + else + flags = fri->ReplaceIfExists ? FILE_RENAME_REPLACE_IF_EXISTS : 0; + TRACE("tfo = %p\n", tfo); - TRACE("ReplaceIfExists = %u\n", IrpSp->Parameters.SetFile.ReplaceIfExists); + TRACE("Flags = %x\n", flags); TRACE("RootDirectory = %p\n", fri->RootDirectory); TRACE("FileName = %.*S\n", fri->FileNameLength / sizeof(WCHAR), fri->FileName);
@@ -1451,16 +1605,21 @@ static NTSTATUS set_rename_information(device_extension* Vcb, PIRP Irp, PFILE_OB TRACE("destination file %S already exists\n", file_desc_fileref(oldfileref));
if (fileref != oldfileref && !oldfileref->deleted) { - if (!IrpSp->Parameters.SetFile.ReplaceIfExists) { + if (!(flags & FILE_RENAME_REPLACE_IF_EXISTS)) { Status = STATUS_OBJECT_NAME_COLLISION; goto end; - } else if ((oldfileref->open_count >= 1 || has_open_children(oldfileref)) && !oldfileref->deleted) { + } else if (fileref == oldfileref) { + Status = STATUS_ACCESS_DENIED; + goto end; + } else if (!(flags & FILE_RENAME_POSIX_SEMANTICS) && (oldfileref->open_count > 0 || has_open_children(oldfileref)) && !oldfileref->deleted) { WARN("trying to overwrite open file\n"); Status = STATUS_ACCESS_DENIED; goto end; - } - - if (oldfileref->fcb->type == BTRFS_TYPE_DIRECTORY) { + } else if (!(flags & FILE_RENAME_IGNORE_READONLY_ATTRIBUTE) && oldfileref->fcb->atts & FILE_ATTRIBUTE_READONLY) { + WARN("trying to overwrite readonly file\n"); + Status = STATUS_ACCESS_DENIED; + goto end; + } else if (oldfileref->fcb->type == BTRFS_TYPE_DIRECTORY) { WARN("trying to overwrite directory\n"); Status = STATUS_ACCESS_DENIED; goto end; @@ -1516,7 +1675,12 @@ static NTSTATUS set_rename_information(device_extension* Vcb, PIRP Irp, PFILE_OB
SeReleaseSubjectContext(&subjcont);
- Status = delete_fileref(oldfileref, NULL, Irp, &rollback); + if (oldfileref->open_count > 0 && flags & FILE_RENAME_POSIX_SEMANTICS) { + oldfileref->delete_on_close = TRUE; + oldfileref->posix_delete = TRUE; + } + + Status = delete_fileref(oldfileref, NULL, oldfileref->open_count > 0 && flags & FILE_RENAME_POSIX_SEMANTICS, Irp, &rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status); goto end; @@ -2177,8 +2341,8 @@ static NTSTATUS set_position_information(PFILE_OBJECT FileObject, PIRP Irp) { return STATUS_SUCCESS; }
-static NTSTATUS set_link_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject, PFILE_OBJECT tfo) { - FILE_LINK_INFORMATION* fli = Irp->AssociatedIrp.SystemBuffer; +static NTSTATUS set_link_information(device_extension* Vcb, PIRP Irp, PFILE_OBJECT FileObject, PFILE_OBJECT tfo, BOOL ex) { + FILE_LINK_INFORMATION_EX* fli = Irp->AssociatedIrp.SystemBuffer; fcb *fcb = FileObject->FsContext, *tfofcb, *parfcb; ccb* ccb = FileObject->FsContext2; file_ref *fileref = ccb ? ccb->fileref : NULL, *oldfileref = NULL, *related = NULL, *fr2 = NULL; @@ -2194,13 +2358,19 @@ static NTSTATUS set_link_information(device_extension* Vcb, PIRP Irp, PFILE_OBJE ACCESS_MASK access; SECURITY_SUBJECT_CONTEXT subjcont; dir_child* dc = NULL; + ULONG flags;
InitializeListHead(&rollback);
// FIXME - check fli length // FIXME - don't ignore fli->RootDirectory
- TRACE("ReplaceIfExists = %x\n", fli->ReplaceIfExists); + if (ex) + flags = fli->Flags; + else + flags = fli->ReplaceIfExists ? FILE_LINK_REPLACE_IF_EXISTS : 0; + + TRACE("flags = %x\n", flags); TRACE("RootDirectory = %p\n", fli->RootDirectory); TRACE("FileNameLength = %x\n", fli->FileNameLength); TRACE("FileName = %.*S\n", fli->FileNameLength / sizeof(WCHAR), fli->FileName); @@ -2292,19 +2462,21 @@ static NTSTATUS set_link_information(device_extension* Vcb, PIRP Irp, PFILE_OBJE if (!oldfileref->deleted) { WARN("destination file %S already exists\n", file_desc_fileref(oldfileref));
- if (!fli->ReplaceIfExists) { + if (!(flags & FILE_LINK_REPLACE_IF_EXISTS)) { Status = STATUS_OBJECT_NAME_COLLISION; goto end; - } else if (oldfileref->open_count >= 1 && !oldfileref->deleted) { + } else if (fileref == oldfileref) { + Status = STATUS_ACCESS_DENIED; + goto end; + } else if (!(flags & FILE_LINK_POSIX_SEMANTICS) && (oldfileref->open_count > 0 || has_open_children(oldfileref)) && !oldfileref->deleted) { WARN("trying to overwrite open file\n"); Status = STATUS_ACCESS_DENIED; goto end; - } else if (fileref == oldfileref) { + } else if (!(flags & FILE_LINK_IGNORE_READONLY_ATTRIBUTE) && oldfileref->fcb->atts & FILE_ATTRIBUTE_READONLY) { + WARN("trying to overwrite readonly file\n"); Status = STATUS_ACCESS_DENIED; goto end; - } - - if (oldfileref->fcb->type == BTRFS_TYPE_DIRECTORY) { + } else if (oldfileref->fcb->type == BTRFS_TYPE_DIRECTORY) { WARN("trying to overwrite directory\n"); Status = STATUS_ACCESS_DENIED; goto end; @@ -2353,7 +2525,12 @@ static NTSTATUS set_link_information(device_extension* Vcb, PIRP Irp, PFILE_OBJE
SeReleaseSubjectContext(&subjcont);
- Status = delete_fileref(oldfileref, NULL, Irp, &rollback); + if (oldfileref->open_count > 0 && flags & FILE_RENAME_POSIX_SEMANTICS) { + oldfileref->delete_on_close = TRUE; + oldfileref->posix_delete = TRUE; + } + + Status = delete_fileref(oldfileref, NULL, oldfileref->open_count > 0 && flags & FILE_RENAME_POSIX_SEMANTICS, Irp, &rollback); if (!NT_SUCCESS(Status)) { ERR("delete_fileref returned %08x\n", Status); goto end; @@ -2608,6 +2785,40 @@ end: return Status; }
+#ifndef __REACTOS__ +static NTSTATUS set_case_sensitive_information(PIRP Irp) { + FILE_CASE_SENSITIVE_INFORMATION* fcsi = (FILE_CASE_SENSITIVE_INFORMATION*)Irp->AssociatedIrp.SystemBuffer; + PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation(Irp); + + if (IrpSp->Parameters.FileSystemControl.InputBufferLength < sizeof(FILE_CASE_SENSITIVE_INFORMATION)) + return STATUS_INFO_LENGTH_MISMATCH; + + PFILE_OBJECT FileObject = IrpSp->FileObject; + + if (!FileObject) + return STATUS_INVALID_PARAMETER; + + fcb* fcb = FileObject->FsContext; + + if (!fcb) + return STATUS_INVALID_PARAMETER; + + if (!(fcb->atts & FILE_ATTRIBUTE_DIRECTORY)) { + WARN("cannot set case-sensitive flag on anything other than directory\n"); + return STATUS_INVALID_PARAMETER; + } + + ExAcquireResourceSharedLite(&fcb->Vcb->tree_lock, TRUE); + + fcb->case_sensitive = fcsi->Flags & FILE_CS_FLAG_CASE_SENSITIVE_DIR; + mark_fcb_dirty(fcb); + + ExReleaseResourceLite(&fcb->Vcb->tree_lock); + + return STATUS_SUCCESS; +} +#endif + _Dispatch_type_(IRP_MJ_SET_INFORMATION) _Function_class_(DRIVER_DISPATCH) NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) { @@ -2655,7 +2866,11 @@ NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) }
if (fcb != Vcb->dummy_fcb && is_subvol_readonly(fcb->subvol, Irp) && IrpSp->Parameters.SetFile.FileInformationClass != FilePositionInformation && +#ifndef __REACTOS__ + (fcb->inode != SUBVOL_ROOT_INODE || (IrpSp->Parameters.SetFile.FileInformationClass != FileBasicInformation && IrpSp->Parameters.SetFile.FileInformationClass != FileRenameInformation && IrpSp->Parameters.SetFile.FileInformationClass != FileRenameInformationEx))) { +#else (fcb->inode != SUBVOL_ROOT_INODE || (IrpSp->Parameters.SetFile.FileInformationClass != FileBasicInformation && IrpSp->Parameters.SetFile.FileInformationClass != FileRenameInformation))) { +#endif Status = STATUS_ACCESS_DENIED; goto end; } @@ -2704,7 +2919,7 @@ NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) break; }
- Status = set_disposition_information(Vcb, Irp, IrpSp->FileObject); + Status = set_disposition_information(Vcb, Irp, IrpSp->FileObject, FALSE);
break; } @@ -2726,7 +2941,7 @@ NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp)
case FileLinkInformation: TRACE("FileLinkInformation\n"); - Status = set_link_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject); + Status = set_link_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject, FALSE); break;
case FilePositionInformation: @@ -2737,7 +2952,7 @@ NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) case FileRenameInformation: TRACE("FileRenameInformation\n"); // FIXME - make this work with streams - Status = set_rename_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject); + Status = set_rename_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject, FALSE); break;
case FileValidDataLengthInformation: @@ -2755,6 +2970,52 @@ NTSTATUS NTAPI drv_set_information(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) break; }
+#ifndef _MSC_VER +#pragma GCC diagnostic push +#pragma GCC diagnostic ignored "-Wswitch" +#endif +#ifndef __REACTOS__ + case FileDispositionInformationEx: + { + TRACE("FileDispositionInformationEx\n"); + + if (Irp->RequestorMode == UserMode && !(ccb->access & DELETE)) { + WARN("insufficient privileges\n"); + Status = STATUS_ACCESS_DENIED; + break; + } + + Status = set_disposition_information(Vcb, Irp, IrpSp->FileObject, TRUE); + + break; + } + + case FileRenameInformationEx: + TRACE("FileRenameInformationEx\n"); + Status = set_rename_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject, TRUE); + break; + + case FileLinkInformationEx: + TRACE("FileLinkInformationEx\n"); + Status = set_link_information(Vcb, Irp, IrpSp->FileObject, IrpSp->Parameters.SetFile.FileObject, TRUE); + break; + + case FileCaseSensitiveInformation: + TRACE("FileCaseSensitiveInformation\n"); + + if (Irp->RequestorMode == UserMode && !(ccb->access & FILE_WRITE_ATTRIBUTES)) { + WARN("insufficient privileges\n"); + Status = STATUS_ACCESS_DENIED; + break; + } + + Status = set_case_sensitive_information(Irp); + break; +#endif +#ifndef _MSC_VER +#pragma GCC diagnostic pop +#endif + default: WARN("unknown FileInformationClass %u\n", IrpSp->Parameters.SetFile.FileInformationClass); } @@ -3362,16 +3623,176 @@ static NTSTATUS fill_in_hard_link_information(FILE_LINKS_INFORMATION* fli, file_ #endif /* __REACTOS__ */
#if (NTDDI_VERSION >= NTDDI_WIN10) -#ifdef __MINGW32__ -typedef struct _FILE_ID_128 { - UCHAR Identifier[16]; -} FILE_ID_128, *PFILE_ID_128; +static NTSTATUS fill_in_hard_link_full_id_information(FILE_LINKS_FULL_ID_INFORMATION* flfii, file_ref* fileref, PIRP Irp, LONG* length) { + NTSTATUS Status; + LIST_ENTRY* le; + LONG bytes_needed; + FILE_LINK_ENTRY_FULL_ID_INFORMATION* flefii; + BOOL overflow = FALSE; + fcb* fcb = fileref->fcb; + ULONG len;
-typedef struct _FILE_ID_INFORMATION { - ULONGLONG VolumeSerialNumber; - FILE_ID_128 FileId; -} FILE_ID_INFORMATION, *PFILE_ID_INFORMATION; -#endif + if (fcb->ads) + return STATUS_INVALID_PARAMETER; + + if (*length < (LONG)offsetof(FILE_LINKS_FULL_ID_INFORMATION, Entry)) + return STATUS_INVALID_PARAMETER; + + RtlZeroMemory(flfii, *length); + + bytes_needed = offsetof(FILE_LINKS_FULL_ID_INFORMATION, Entry); + len = bytes_needed; + flefii = NULL; + + ExAcquireResourceSharedLite(fcb->Header.Resource, TRUE); + + if (fcb->inode == SUBVOL_ROOT_INODE) { + ULONG namelen; + + if (fcb == fcb->Vcb->root_fileref->fcb) + namelen = sizeof(WCHAR); + else + namelen = fileref->dc->name.Length; + + bytes_needed += offsetof(FILE_LINK_ENTRY_FULL_ID_INFORMATION, FileName[0]) + namelen; + + if (bytes_needed > *length) + overflow = TRUE; + + if (!overflow) { + flefii = &flfii->Entry; + + flefii->NextEntryOffset = 0; + + if (fcb == fcb->Vcb->root_fileref->fcb) { + RtlZeroMemory(&flefii->ParentFileId.Identifier[0], sizeof(FILE_ID_128)); + flefii->FileNameLength = 1; + flefii->FileName[0] = '.'; + } else { + RtlCopyMemory(&flefii->ParentFileId.Identifier[0], &fileref->parent->fcb->inode, sizeof(UINT64)); + RtlCopyMemory(&flefii->ParentFileId.Identifier[sizeof(UINT64)], &fileref->parent->fcb->subvol->id, sizeof(UINT64)); + + flefii->FileNameLength = fileref->dc->name.Length / sizeof(WCHAR); + RtlCopyMemory(flefii->FileName, fileref->dc->name.Buffer, fileref->dc->name.Length); + } + + flfii->EntriesReturned++; + + len = bytes_needed; + } + } else { + ExAcquireResourceExclusiveLite(&fcb->Vcb->fileref_lock, TRUE); + + if (IsListEmpty(&fcb->hardlinks)) { + bytes_needed += offsetof(FILE_LINK_ENTRY_FULL_ID_INFORMATION, FileName[0]) + fileref->dc->name.Length; + + if (bytes_needed > *length) + overflow = TRUE; + + if (!overflow) { + flefii = &flfii->Entry; + + flefii->NextEntryOffset = 0; + + RtlCopyMemory(&flefii->ParentFileId.Identifier[0], &fileref->parent->fcb->inode, sizeof(UINT64)); + RtlCopyMemory(&flefii->ParentFileId.Identifier[sizeof(UINT64)], &fileref->parent->fcb->subvol->id, sizeof(UINT64)); + + flefii->FileNameLength = fileref->dc->name.Length / sizeof(WCHAR); + RtlCopyMemory(flefii->FileName, fileref->dc->name.Buffer, fileref->dc->name.Length); + + flfii->EntriesReturned++; + + len = bytes_needed; + } + } else { + le = fcb->hardlinks.Flink; + while (le != &fcb->hardlinks) { + hardlink* hl = CONTAINING_RECORD(le, hardlink, list_entry); + file_ref* parfr; + + TRACE("parent %llx, index %llx, name %.*S\n", hl->parent, hl->index, hl->name.Length / sizeof(WCHAR), hl->name.Buffer); + + Status = open_fileref_by_inode(fcb->Vcb, fcb->subvol, hl->parent, &parfr, Irp); + + if (!NT_SUCCESS(Status)) { + ERR("open_fileref_by_inode returned %08x\n", Status); + } else if (!parfr->deleted) { + LIST_ENTRY* le2; + BOOL found = FALSE, deleted = FALSE; + UNICODE_STRING* fn = NULL; + + le2 = parfr->children.Flink; + while (le2 != &parfr->children) { + file_ref* fr2 = CONTAINING_RECORD(le2, file_ref, list_entry); + + if (fr2->dc->index == hl->index) { + found = TRUE; + deleted = fr2->deleted; + + if (!deleted) + fn = &fr2->dc->name; + + break; + } + + le2 = le2->Flink; + } + + if (!found) + fn = &hl->name; + + if (!deleted) { + TRACE("fn = %.*S (found = %u)\n", fn->Length / sizeof(WCHAR), fn->Buffer, found); + + if (flefii) + bytes_needed = (LONG)sector_align(bytes_needed, 8); + + bytes_needed += offsetof(FILE_LINK_ENTRY_FULL_ID_INFORMATION, FileName[0]) + fn->Length; + + if (bytes_needed > *length) + overflow = TRUE; + + if (!overflow) { + if (flefii) { + flefii->NextEntryOffset = (ULONG)sector_align(offsetof(FILE_LINK_ENTRY_FULL_ID_INFORMATION, FileName[0]) + (flefii->FileNameLength * sizeof(WCHAR)), 8); + flefii = (FILE_LINK_ENTRY_FULL_ID_INFORMATION*)((UINT8*)flefii + flefii->NextEntryOffset); + } else + flefii = &flfii->Entry; + + flefii->NextEntryOffset = 0; + + RtlCopyMemory(&flefii->ParentFileId.Identifier[0], &parfr->fcb->inode, sizeof(UINT64)); + RtlCopyMemory(&flefii->ParentFileId.Identifier[sizeof(UINT64)], &parfr->fcb->subvol->id, sizeof(UINT64)); + + flefii->FileNameLength = fn->Length / sizeof(WCHAR); + RtlCopyMemory(flefii->FileName, fn->Buffer, fn->Length); + + flfii->EntriesReturned++; + + len = bytes_needed; + } + } + + free_fileref(parfr); + } + + le = le->Flink; + } + } + + ExReleaseResourceLite(&fcb->Vcb->fileref_lock); + } + + flfii->BytesNeeded = bytes_needed; + + *length -= len; + + Status = overflow ? STATUS_BUFFER_OVERFLOW : STATUS_SUCCESS; + + ExReleaseResourceLite(fcb->Header.Resource); + + return Status; +}
static NTSTATUS fill_in_file_id_information(FILE_ID_INFORMATION* fii, fcb* fcb, LONG* length) { RtlCopyMemory(&fii->VolumeSerialNumber, &fcb->Vcb->superblock.uuid.uuid[8], sizeof(UINT64)); @@ -3385,6 +3806,66 @@ static NTSTATUS fill_in_file_id_information(FILE_ID_INFORMATION* fii, fcb* fcb, #endif
#ifndef __REACTOS__ +static NTSTATUS fill_in_file_stat_information(FILE_STAT_INFORMATION* fsi, fcb* fcb, ccb* ccb, LONG* length) { + INODE_ITEM* ii; + + fsi->FileId.LowPart = (UINT32)fcb->inode; + fsi->FileId.HighPart = (UINT32)fcb->subvol->id; + + if (fcb->ads) + ii = &ccb->fileref->parent->fcb->inode_item; + else + ii = &fcb->inode_item; + + if (fcb == fcb->Vcb->dummy_fcb) { + LARGE_INTEGER time; + + KeQuerySystemTime(&time); + fsi->CreationTime = fsi->LastAccessTime = fsi->LastWriteTime = fsi->ChangeTime = time; + } else { + fsi->CreationTime.QuadPart = unix_time_to_win(&ii->otime); + fsi->LastAccessTime.QuadPart = unix_time_to_win(&ii->st_atime); + fsi->LastWriteTime.QuadPart = unix_time_to_win(&ii->st_mtime); + fsi->ChangeTime.QuadPart = unix_time_to_win(&ii->st_ctime); + } + + if (fcb->ads) { + fsi->AllocationSize.QuadPart = fsi->EndOfFile.QuadPart = fcb->adsdata.Length; + fsi->FileAttributes = ccb->fileref->parent->fcb->atts == 0 ? FILE_ATTRIBUTE_NORMAL : ccb->fileref->parent->fcb->atts; + } else { + fsi->AllocationSize.QuadPart = fcb_alloc_size(fcb); + fsi->EndOfFile.QuadPart = S_ISDIR(fcb->inode_item.st_mode) ? 0 : fcb->inode_item.st_size; + fsi->FileAttributes = fcb->atts == 0 ? FILE_ATTRIBUTE_NORMAL : fcb->atts; + } + + if (fcb->type == BTRFS_TYPE_SOCKET) + fsi->ReparseTag = IO_REPARSE_TAG_LXSS_SOCKET; + else if (fcb->type == BTRFS_TYPE_FIFO) + fsi->ReparseTag = IO_REPARSE_TAG_LXSS_FIFO; + else if (fcb->type == BTRFS_TYPE_CHARDEV) + fsi->ReparseTag = IO_REPARSE_TAG_LXSS_CHARDEV; + else if (fcb->type == BTRFS_TYPE_BLOCKDEV) + fsi->ReparseTag = IO_REPARSE_TAG_LXSS_BLOCKDEV; + else if (!(fsi->FileAttributes & FILE_ATTRIBUTE_REPARSE_POINT)) + fsi->ReparseTag = 0; + else + fsi->ReparseTag = get_reparse_tag_fcb(fcb); + + if (fcb->type == BTRFS_TYPE_SOCKET || fcb->type == BTRFS_TYPE_FIFO || fcb->type == BTRFS_TYPE_CHARDEV || fcb->type == BTRFS_TYPE_BLOCKDEV) + fsi->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT; + + if (fcb->ads) + fsi->NumberOfLinks = ccb->fileref->parent->fcb->inode_item.st_nlink; + else + fsi->NumberOfLinks = fcb->inode_item.st_nlink; + + fsi->EffectiveAccess = ccb->access; + + *length -= sizeof(FILE_STAT_INFORMATION); + + return STATUS_SUCCESS; +} + static NTSTATUS fill_in_file_stat_lx_information(FILE_STAT_LX_INFORMATION* fsli, fcb* fcb, ccb* ccb, LONG* length) { INODE_ITEM* ii;
@@ -3439,7 +3920,11 @@ static NTSTATUS fill_in_file_stat_lx_information(FILE_STAT_LX_INFORMATION* fsli, fsli->NumberOfLinks = fcb->inode_item.st_nlink;
fsli->EffectiveAccess = ccb->access; - fsli->LxFlags = LX_FILE_METADATA_HAS_UID | LX_FILE_METADATA_HAS_GID | LX_FILE_METADATA_HAS_MODE | LX_FILE_METADATA_HAS_DEVICE_ID; // FIXME - LX_FILE_CASE_SENSITIVE_DIR + fsli->LxFlags = LX_FILE_METADATA_HAS_UID | LX_FILE_METADATA_HAS_GID | LX_FILE_METADATA_HAS_MODE | LX_FILE_METADATA_HAS_DEVICE_ID; + + if (fcb->case_sensitive) + fsli->LxFlags |= LX_FILE_CASE_SENSITIVE_DIR; + fsli->LxUid = ii->st_uid; fsli->LxGid = ii->st_gid; fsli->LxMode = ii->st_mode; @@ -3456,6 +3941,14 @@ static NTSTATUS fill_in_file_stat_lx_information(FILE_STAT_LX_INFORMATION* fsli,
return STATUS_SUCCESS; } + +static NTSTATUS fill_in_file_case_sensitive_information(FILE_CASE_SENSITIVE_INFORMATION* fcsi, fcb* fcb, LONG* length) { + fcsi->Flags = fcb->case_sensitive ? FILE_CS_FLAG_CASE_SENSITIVE_DIR : 0; + + *length -= sizeof(FILE_CASE_SENSITIVE_INFORMATION); + + return STATUS_SUCCESS; +} #endif
static NTSTATUS query_info(device_extension* Vcb, PFILE_OBJECT FileObject, PIRP Irp) { @@ -3746,6 +4239,23 @@ static NTSTATUS query_info(device_extension* Vcb, PFILE_OBJECT FileObject, PIRP break; }
+ case FileStatInformation: + { + FILE_STAT_INFORMATION* fsi = Irp->AssociatedIrp.SystemBuffer; + + if (IrpSp->Parameters.QueryFile.Length < sizeof(FILE_STAT_LX_INFORMATION)) { + WARN("overflow\n"); + Status = STATUS_BUFFER_OVERFLOW; + goto exit; + } + + TRACE("FileStatInformation\n"); + + Status = fill_in_file_stat_information(fsi, fcb, ccb, &length); + + break; + } + case FileStatLxInformation: { FILE_STAT_LX_INFORMATION* fsli = Irp->AssociatedIrp.SystemBuffer; @@ -3762,6 +4272,36 @@ static NTSTATUS query_info(device_extension* Vcb, PFILE_OBJECT FileObject, PIRP
break; } + + case FileCaseSensitiveInformation: + { + FILE_CASE_SENSITIVE_INFORMATION* fcsi = Irp->AssociatedIrp.SystemBuffer; + + if (IrpSp->Parameters.QueryFile.Length < sizeof(FILE_CASE_SENSITIVE_INFORMATION)) { + WARN("overflow\n"); + Status = STATUS_BUFFER_OVERFLOW; + goto exit; + } + + TRACE("FileCaseSensitiveInformation\n"); + + Status = fill_in_file_case_sensitive_information(fcsi, fcb, &length); + + break; + } + + case FileHardLinkFullIdInformation: + { + FILE_LINKS_FULL_ID_INFORMATION* flfii = Irp->AssociatedIrp.SystemBuffer; + + TRACE("FileHardLinkFullIdInformation\n"); + + ExAcquireResourceSharedLite(&Vcb->tree_lock, TRUE); + Status = fill_in_hard_link_full_id_information(flfii, fileref, Irp, &length); + ExReleaseResourceLite(&Vcb->tree_lock); + + break; + } #ifndef _MSC_VER #pragma GCC diagnostic pop #endif diff --git a/drivers/filesystems/btrfs/flushthread.c b/drivers/filesystems/btrfs/flushthread.c index 6784de5277e..5801ff3329d 100644 --- a/drivers/filesystems/btrfs/flushthread.c +++ b/drivers/filesystems/btrfs/flushthread.c @@ -515,6 +515,9 @@ static NTSTATUS add_parents(device_extension* Vcb, PIRP Irp) { KEY searchkey; traverse_ptr tp; NTSTATUS Status; +#ifdef __REACTOS__ + tree* t2; +#endif
searchkey.obj_id = t->root->id; searchkey.obj_type = TYPE_ROOT_ITEM; @@ -555,6 +558,17 @@ static NTSTATUS add_parents(device_extension* Vcb, PIRP Irp) { return Status; } } + +#ifndef __REACTOS__ + tree* t2 = tp.tree; +#else + t2 = tp.tree; +#endif + while (t2) { + t2->write = TRUE; + + t2 = t2->parent; + } } }
@@ -2713,6 +2727,9 @@ static NTSTATUS update_chunk_usage(device_extension* Vcb, PIRP Irp, LIST_ENTRY* }
if (c->used != c->oldused) { +#ifdef __REACTOS__ + UINT64 old_phys_used, phys_used; +#endif searchkey.obj_id = c->offset; searchkey.obj_type = TYPE_BLOCK_GROUP_ITEM; searchkey.offset = c->chunk_item->size; @@ -2767,11 +2784,18 @@ static NTSTATUS update_chunk_usage(device_extension* Vcb, PIRP Irp, LIST_ENTRY* goto end; }
- TRACE("bytes_used = %llx\n", Vcb->superblock.bytes_used); - - Vcb->superblock.bytes_used += c->used - c->oldused; +#ifndef __REACTOS__ + UINT64 old_phys_used = chunk_estimate_phys_size(Vcb, c, c->oldused); + UINT64 phys_used = chunk_estimate_phys_size(Vcb, c, c->used); +#else + old_phys_used = chunk_estimate_phys_size(Vcb, c, c->oldused); + phys_used = chunk_estimate_phys_size(Vcb, c, c->used); +#endif
- TRACE("bytes_used = %llx\n", Vcb->superblock.bytes_used); + if (Vcb->superblock.bytes_used + phys_used > old_phys_used) + Vcb->superblock.bytes_used += phys_used - old_phys_used; + else + Vcb->superblock.bytes_used = 0;
c->oldused = c->used; } @@ -4118,6 +4142,8 @@ static NTSTATUS create_chunk(device_extension* Vcb, chunk* c, PIRP Irp) { c->created = FALSE; c->oldused = c->used;
+ Vcb->superblock.bytes_used += chunk_estimate_phys_size(Vcb, c, c->used); + return STATUS_SUCCESS; }
@@ -4652,6 +4678,15 @@ NTSTATUS flush_fcb(fcb* fcb, BOOL cache, LIST_ENTRY* batchlist, PIRP Irp) { } }
+ if (fcb->marked_as_orphan) { + Status = insert_tree_item_batch(batchlist, fcb->Vcb, fcb->subvol, BTRFS_ORPHAN_INODE_OBJID, TYPE_ORPHAN_INODE, + fcb->inode, NULL, 0, Batch_Delete); + if (!NT_SUCCESS(Status)) { + ERR("insert_tree_item_batch returned %08x\n", Status); + goto end; + } + } + Status = STATUS_SUCCESS; goto end; } @@ -5146,6 +5181,37 @@ NTSTATUS flush_fcb(fcb* fcb, BOOL cache, LIST_ENTRY* batchlist, PIRP Irp) { fcb->xattrs_changed = FALSE; }
+ if ((fcb->case_sensitive_set && !fcb->case_sensitive)) { + Status = delete_xattr(fcb->Vcb, batchlist, fcb->subvol, fcb->inode, EA_CASE_SENSITIVE, + sizeof(EA_CASE_SENSITIVE) - 1, EA_CASE_SENSITIVE_HASH); + if (!NT_SUCCESS(Status)) { + ERR("delete_xattr returned %08x\n", Status); + goto end; + } + + fcb->case_sensitive_set = FALSE; + } else if ((!fcb->case_sensitive_set && fcb->case_sensitive)) { + Status = set_xattr(fcb->Vcb, batchlist, fcb->subvol, fcb->inode, EA_CASE_SENSITIVE, + sizeof(EA_CASE_SENSITIVE) - 1, EA_CASE_SENSITIVE_HASH, (UINT8*)"1", 1); + if (!NT_SUCCESS(Status)) { + ERR("set_xattr returned %08x\n", Status); + goto end; + } + + fcb->case_sensitive_set = TRUE; + } + + if (fcb->inode_item.st_nlink == 0 && !fcb->marked_as_orphan) { // mark as orphan + Status = insert_tree_item_batch(batchlist, fcb->Vcb, fcb->subvol, BTRFS_ORPHAN_INODE_OBJID, TYPE_ORPHAN_INODE, + fcb->inode, NULL, 0, Batch_Insert); + if (!NT_SUCCESS(Status)) { + ERR("insert_tree_item_batch returned %08x\n", Status); + goto end; + } + + fcb->marked_as_orphan = TRUE; + } + Status = STATUS_SUCCESS;
end: @@ -5197,6 +5263,9 @@ static NTSTATUS drop_chunk(device_extension* Vcb, chunk* c, LIST_ENTRY* batchlis KEY searchkey; traverse_ptr tp; UINT64 i, factor; +#ifdef __REACTOS__ + UINT64 phys_used; +#endif CHUNK_ITEM_STRIPE* cis = (CHUNK_ITEM_STRIPE*)&c->chunk_item[1];;
TRACE("dropping chunk %llx\n", c->offset); @@ -5441,7 +5510,16 @@ static NTSTATUS drop_chunk(device_extension* Vcb, chunk* c, LIST_ENTRY* batchlis Vcb->superblock.incompat_flags &= ~BTRFS_INCOMPAT_FLAGS_RAID56; }
- Vcb->superblock.bytes_used -= c->oldused; +#ifndef __REACTOS__ + UINT64 phys_used = chunk_estimate_phys_size(Vcb, c, c->oldused); +#else + phys_used = chunk_estimate_phys_size(Vcb, c, c->oldused); +#endif + + if (phys_used < Vcb->superblock.bytes_used) + Vcb->superblock.bytes_used -= phys_used; + else + Vcb->superblock.bytes_used = 0;
ExFreePool(c->chunk_item); ExFreePool(c->devices); @@ -6943,6 +7021,108 @@ static NTSTATUS test_not_full(device_extension* Vcb) { return STATUS_DISK_FULL; }
+static NTSTATUS check_for_orphans_root(device_extension* Vcb, root* r, PIRP Irp) { + NTSTATUS Status; + KEY searchkey; + traverse_ptr tp; + LIST_ENTRY rollback; + + TRACE("(%p, %p)\n", Vcb, r); + + InitializeListHead(&rollback); + + searchkey.obj_id = BTRFS_ORPHAN_INODE_OBJID; + searchkey.obj_type = TYPE_ORPHAN_INODE; + searchkey.offset = 0; + + Status = find_item(Vcb, r, &tp, &searchkey, FALSE, Irp); + if (!NT_SUCCESS(Status)) { + ERR("find_item returned %08x\n", Status); + return Status; + } + + do { + traverse_ptr next_tp; + + if (tp.item->key.obj_id > searchkey.obj_id || (tp.item->key.obj_id == searchkey.obj_id && tp.item->key.obj_type > searchkey.obj_type)) + break; + + if (tp.item->key.obj_id == searchkey.obj_id && tp.item->key.obj_type == searchkey.obj_type) { + fcb* fcb; + + TRACE("removing orphaned inode %llx\n", tp.item->key.offset); + + Status = open_fcb(Vcb, r, tp.item->key.offset, 0, NULL, FALSE, NULL, &fcb, PagedPool, Irp); + if (!NT_SUCCESS(Status)) + ERR("open_fcb returned %08x\n", Status); + else { + if (fcb->inode_item.st_nlink == 0) { + if (fcb->type != BTRFS_TYPE_DIRECTORY && fcb->inode_item.st_size > 0) { + Status = excise_extents(Vcb, fcb, 0, sector_align(fcb->inode_item.st_size, Vcb->superblock.sector_size), Irp, &rollback); + if (!NT_SUCCESS(Status)) { + ERR("excise_extents returned %08x\n", Status); + goto end; + } + } + + fcb->deleted = TRUE; + + mark_fcb_dirty(fcb); + } + + free_fcb(fcb); + + Status = delete_tree_item(Vcb, &tp); + if (!NT_SUCCESS(Status)) { + ERR("delete_tree_item returned %08x\n", Status); + goto end; + } + } + } + + if (find_next_item(Vcb, &tp, &next_tp, FALSE, Irp)) + tp = next_tp; + else + break; + } while (TRUE); + + Status = STATUS_SUCCESS; + + clear_rollback(&rollback); + +end: + do_rollback(Vcb, &rollback); + + return Status; +} + +static NTSTATUS check_for_orphans(device_extension* Vcb, PIRP Irp) { + NTSTATUS Status; + LIST_ENTRY* le; + + if (IsListEmpty(&Vcb->dirty_filerefs)) + return STATUS_SUCCESS; + + le = Vcb->dirty_filerefs.Flink; + while (le != &Vcb->dirty_filerefs) { + file_ref* fr = CONTAINING_RECORD(le, file_ref, list_entry_dirty); + + if (!fr->fcb->subvol->checked_for_orphans) { + Status = check_for_orphans_root(Vcb, fr->fcb->subvol, Irp); + if (!NT_SUCCESS(Status)) { + ERR("check_for_orphans_root returned %08x\n", Status); + return Status; + } + + fr->fcb->subvol->checked_for_orphans = TRUE; + } + + le = le->Flink; + } + + return STATUS_SUCCESS; +} + static NTSTATUS do_write2(device_extension* Vcb, PIRP Irp, LIST_ENTRY* rollback) { NTSTATUS Status; LIST_ENTRY *le, batchlist; @@ -6965,6 +7145,12 @@ static NTSTATUS do_write2(device_extension* Vcb, PIRP Irp, LIST_ENTRY* rollback) time1 = KeQueryPerformanceCounter(&freq); #endif
+ Status = check_for_orphans(Vcb, Irp); + if (!NT_SUCCESS(Status)) { + ERR("check_for_orphans returned %08x\n", Status); + return Status; + } + ExAcquireResourceExclusiveLite(&Vcb->dirty_filerefs_lock, TRUE);
while (!IsListEmpty(&Vcb->dirty_filerefs)) { diff --git a/drivers/filesystems/btrfs/free-space.c b/drivers/filesystems/btrfs/free-space.c index cd3de367f45..e74a4a5346f 100644 --- a/drivers/filesystems/btrfs/free-space.c +++ b/drivers/filesystems/btrfs/free-space.c @@ -25,7 +25,7 @@ static NTSTATUS remove_free_space_inode(device_extension* Vcb, UINT64 inode, LIS NTSTATUS Status; fcb* fcb;
- Status = open_fcb(Vcb, Vcb->root_root, inode, BTRFS_TYPE_FILE, NULL, NULL, &fcb, PagedPool, Irp); + Status = open_fcb(Vcb, Vcb->root_root, inode, BTRFS_TYPE_FILE, NULL, FALSE, NULL, &fcb, PagedPool, Irp); if (!NT_SUCCESS(Status)) { ERR("open_fcb returned %08x\n", Status); return Status; @@ -497,7 +497,7 @@ NTSTATUS load_stored_free_space_cache(device_extension* Vcb, chunk* c, BOOL load num_entries = fsi->num_entries; num_bitmaps = fsi->num_bitmaps;
- Status = open_fcb(Vcb, Vcb->root_root, inode, BTRFS_TYPE_FILE, NULL, NULL, &c->cache, PagedPool, Irp); + Status = open_fcb(Vcb, Vcb->root_root, inode, BTRFS_TYPE_FILE, NULL, FALSE, NULL, &c->cache, PagedPool, Irp); if (!NT_SUCCESS(Status)) { ERR("open_fcb returned %08x\n", Status); return STATUS_NOT_FOUND; diff --git a/drivers/filesystems/btrfs/fsctl.c b/drivers/filesystems/btrfs/fsctl.c index 3845965ca19..90622508cb2 100644 --- a/drivers/filesystems/btrfs/fsctl.c +++ b/drivers/filesystems/btrfs/fsctl.c @@ -432,7 +432,7 @@ static NTSTATUS do_create_snapshot(device_extension* Vcb, PFILE_OBJECT parent, f goto end; }
- Status = open_fcb(Vcb, r, r->root_item.objid, BTRFS_TYPE_DIRECTORY, utf8, fcb, &fr->fcb, PagedPool, Irp); + Status = open_fcb(Vcb, r, r->root_item.objid, BTRFS_TYPE_DIRECTORY, utf8, FALSE, fcb, &fr->fcb, PagedPool, Irp); if (!NT_SUCCESS(Status)) { ERR("open_fcb returned %08x\n", Status); free_fileref(fr); @@ -4342,6 +4342,14 @@ static NTSTATUS fsctl_set_xattr(device_extension* Vcb, PFILE_OBJECT FileObject, fcb->ea_changed = TRUE; mark_fcb_dirty(fcb);
+ Status = STATUS_SUCCESS; + goto end; + } else if (bsxa->namelen == sizeof(EA_CASE_SENSITIVE) - 1 && RtlCompareMemory(bsxa->data, EA_CASE_SENSITIVE, sizeof(EA_CASE_SENSITIVE) - 1) == sizeof(EA_CASE_SENSITIVE) - 1) { + if (bsxa->valuelen > 0 && bsxa->data[bsxa->namelen] == '1') { + fcb->case_sensitive = TRUE; + mark_fcb_dirty(fcb); + } + Status = STATUS_SUCCESS; goto end; } else if (bsxa->namelen == sizeof(EA_PROP_COMPRESSION) - 1 && RtlCompareMemory(bsxa->data, EA_PROP_COMPRESSION, sizeof(EA_PROP_COMPRESSION) - 1) == sizeof(EA_PROP_COMPRESSION) - 1) { diff --git a/drivers/filesystems/btrfs/write.c b/drivers/filesystems/btrfs/write.c index ed1df4c897a..a38ea7fb890 100644 --- a/drivers/filesystems/btrfs/write.c +++ b/drivers/filesystems/btrfs/write.c @@ -4498,7 +4498,7 @@ NTSTATUS write_file2(device_extension* Vcb, PIRP Irp, LARGE_INTEGER offset, void ExFreePool(data); } else { if (write_irp && Irp->MdlAddress && no_buf) { - BOOL locked = Irp->MdlAddress->MdlFlags & MDL_PAGES_LOCKED; + BOOL locked = Irp->MdlAddress->MdlFlags & (MDL_PAGES_LOCKED | MDL_PARTIAL);
if (!locked) { Status = STATUS_SUCCESS; diff --git a/media/doc/README.FSD b/media/doc/README.FSD index f70f2a54a93..d86c5bd5861 100644 --- a/media/doc/README.FSD +++ b/media/doc/README.FSD @@ -3,9 +3,9 @@
The following FSD are shared with: https://github.com/maharmstone/btrfs.
-reactos/drivers/filesystems/btrfs # Synced to 1.2.1 +reactos/drivers/filesystems/btrfs # Synced to 1.3 reactos/dll/shellext/shellbtrfs # Synced to 1.1 -reactos/sdk/lib/fslib/btrfslib # Synced to 1.2.1 +reactos/sdk/lib/fslib/btrfslib # Synced to 1.3
The following FSD are shared with: http://www.ext2fsd.com/
-
Pierre Schweitzer