Microsoft MVP성태의 닷넷 이야기
.NET Framework: 2107. .NET 6+ FileStream의 구조 변화 [링크 복사], [링크+제목 복사],
조회: 18961
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

.NET 6+ FileStream의 구조 변화

아래의 글에,

C# - byte * (바이트 포인터)를 FileStream으로 쓰는 방법
; https://www.sysnet.pe.kr/2/0/12913

다음과 같은 내용의 덧글이 있습니다.

corefx 구현체에서 Span 객체를 인자로 받는 Read/Write 메소드가 array pool을 활용하여 버퍼를 복사하고 다시 Read(byte[], int, int)와 Write(byte[], int, int)를 호출


시간이 좀 지났으니, 현재의 구현이 어떻게 되어 있는지 살펴보겠습니다. ^^




우선, FileStream의 Span을 받는 Write 메서드를 보면,

public override void Write(ReadOnlySpan<byte> buffer) => _strategy.Write(buffer);

호출을 _strategy로 전달하고 있습니다. 이 멤버는 FileStream 생성자에서 결정되는데요,

public FileStream(SafeFileHandle handle, FileAccess access, int bufferSize)
{
    ValidateHandle(handle, access, bufferSize);

    _strategy = FileStreamHelpers.ChooseStrategy(this, handle, access, bufferSize, handle.IsAsync);
}

FileStreamHelpers.ChooseStrategy는 다시,

namespace System.IO.Strategies
{
    internal static partial class FileStreamHelpers
    {
        // ...[생략]...

        internal static FileStreamStrategy ChooseStrategy(FileStream fileStream, SafeFileHandle handle, FileAccess access, int bufferSize, bool isAsync)
        {
            FileStreamStrategy strategy =
                EnableBufferingIfNeeded(ChooseStrategyCore(handle, access, isAsync), bufferSize);

            return WrapIfDerivedType(fileStream, strategy);
        }

        // ...[생략]...
    }
}

ChooseStrategyCore로 역할을 맡기고 있습니다. 여기서 재미있는 것은 FileStreamHelpers 자체가 partial class라는 점입니다. 이유는 짐작 가시죠? ^^

윈도우뿐만 아니라 리눅스 등도 지원해야 하기 때문에 FileStreamHelpers는 partial로 플랫폼에 따라 다른 파일을 포함해 빌드하게 됩니다. 일례로 윈도우의 경우 FileStreamHelpers.Windows.cs 파일을 포함하고, 그 파일의 ChooseStrategyCore를 보면,

private static FileStreamStrategy ChooseStrategyCore(string path, FileMode mode, FileAccess access, FileShare share, FileOptions options, long preallocationSize, UnixFileMode? unixCreateMode) =>
    (options & FileOptions.Asynchronous) != 0 ?
        new AsyncWindowsFileStreamStrategy(path, mode, access, share, options, preallocationSize, unixCreateMode) :
        new SyncWindowsFileStreamStrategy(path, mode, access, share, options, preallocationSize, unixCreateMode);

동기/비동기에 따라 다른 타입을 생성해 반환합니다. 2가지 중에 여기서는 SyncWindowsFileStreamStrategy.cs로 들어가 보겠습니다. ^^

using Microsoft.Win32.SafeHandles;

namespace System.IO.Strategies
{
    internal sealed class SyncWindowsFileStreamStrategy : OSFileStreamStrategy
    {
        internal SyncWindowsFileStreamStrategy(SafeFileHandle handle, FileAccess access) : base(handle, access)
        {
        }

        internal SyncWindowsFileStreamStrategy(string path, FileMode mode, FileAccess access, FileShare share, FileOptions options, long preallocationSize, UnixFileMode? unixCreateMode)
            : base(path, mode, access, share, options, preallocationSize, unixCreateMode)
        {
        }

        internal override bool IsAsync => false;
    }
}

partial이 아니므로 이번에는 대부분의 구현이 부모 클래스에 있을 텐데요, 정의를 가보면 Write 메서드의 본체를 볼 수 있습니다.

// OSFileStreamStrategy.cs

public sealed override void Write(ReadOnlySpan<byte> buffer)
{
    if (_fileHandle.IsClosed)
    {
        ThrowHelper.ThrowObjectDisposedException_FileClosed();
    }
    else if ((_access & FileAccess.Write) == 0)
    {
        ThrowHelper.ThrowNotSupportedException_UnwritableStream();
    }

    RandomAccess.WriteAtOffset(_fileHandle, buffer, _filePosition);
    _filePosition += buffer.Length;
}

아쉽게도 여기가 끝이 아니군요. ^^ RandomAccess.WriteAtOffset으로 인자를 그대로 전달하는데, 이것 역시 partial 클래스로,

// RandomAccess.cs

namespace System.IO
{
    public static partial class RandomAccess
    {
         // ...[생략]...
    }
}

빌드 시 대상 플랫폼에 따라 다른 소스코드 파일과 엮이게 됩니다. 윈도우의 경우는 RandomAccess.Windows.cs 파일이 포함되는데,

// RandomAccess.Windows.cs

namespace System.IO
{
    public static partial class RandomAccess
    {
        // ...[생략]...

        internal static unsafe void WriteAtOffset(SafeFileHandle handle, ReadOnlySpan<byte> buffer, long fileOffset)
        {
            // ...[생략]...

            NativeOverlapped overlapped = GetNativeOverlappedForSyncHandle(handle, fileOffset);
            fixed (byte* pinned = &MemoryMarshal.GetReference(buffer))
            {
                if (Interop.Kernel32.WriteFile(handle, pinned, buffer.Length, out int numBytesWritten, &overlapped) != 0)
                {
                    Debug.Assert(numBytesWritten == buffer.Length);
                    return;
                }

                int errorCode = FileStreamHelpers.GetLastWin32ErrorAndDisposeHandleIfInvalid(handle);
                throw Win32Marshal.GetExceptionForWin32Error(errorCode, handle.Path);
            }
        }
    }
}

보는 바와 같이 Kernel32.WriteFile Win32 API 호출을 바로 하고 있습니다. 즉, Span 인자로 넘긴 데이터의 복사는 발생하지 않으니 안심하고 사용하셔도 되겠습니다. ^^




시작은 Write 메서드의 버퍼 복사를 살펴보려는 것이었는데, 뜻하지 않게 다중 플랫폼 지원을 추가하느라 바뀐 FileStream의 구현을 들여다보게 되었습니다. 아울러, 아래의 문서를 보면,

File IO improvements in .NET 6
; https://devblogs.microsoft.com/dotnet/file-io-improvements-in-dotnet-6/

The increased amount of allocated memory comes from the abstraction layer that we have introduced to support the .NET 5 Compatibility mode, which also helped increase the code maintainability: we now have a few separate FileStream strategy implementations instead of one with a lot of if blocks.


.NET 5까지는 Span Write 메서드에 대해 Net5CompatFileStreamStrategy 소스코드에서 확인할 수 있는 것처럼, 버퍼 복사가 이뤄집니다.

// Net5CompatFileStreamStrategy.Windows.cs

private void WriteSpan(ReadOnlySpan<byte> source)
{
    // ...[생략]...

    if (_writePos > 0)
    {
        int numBytes = _bufferLength - _writePos;   // space left in buffer
        if (numBytes > 0)
        {
            if (numBytes >= source.Length)
            {
                source.CopyTo(GetBuffer().AsSpan(_writePos));
                _writePos += source.Length;
                return;
            }
            else
            {
                source.Slice(0, numBytes).CopyTo(GetBuffer().AsSpan(_writePos));
                _writePos += numBytes;
                source = source.Slice(numBytes);
            }
        }

        // ...[생략]...
    }

    // ...[생략]...

    // Copy remaining bytes into buffer, to write at a later date.
    source.CopyTo(GetBuffer().AsSpan(_writePos));
    _writePos = source.Length;
    return;
}

그러니까, .NET 6+로 업데이트하는 것만으로도 "File IO improvements in .NET 6" 문서의 내용대로 성능 향상을 볼 수 있습니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 4/5/2023]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




... 46  47  48  49  50  51  52  53  54  55  56  57  [58]  59  60  ...
NoWriterDateCnt.TitleFile(s)
12593정성태4/10/202121728개발 환경 구성: 567. Docker Desktop for Windows - kubectl proxy 없이 k8s 대시보드 접근 방법
12592정성태4/10/202121339개발 환경 구성: 566. Docker Desktop for Windows - k8s dashboard의 Kubeconfig 로그인 및 Skip 방법
12591정성태4/9/202126211.NET Framework: 1034. C# - byte 배열을 Hex(16진수) 문자열로 고속 변환하는 방법 [2]파일 다운로드1
12590정성태4/9/202122261.NET Framework: 1033. C# - .NET 4.0 이하에서 Console.IsInputRedirected 구현 [1]
12589정성태4/8/202121833.NET Framework: 1032. C# - Environment.OSVersion의 문제점 및 윈도우 운영체제의 버전을 구하는 다양한 방법 [1]
12588정성태4/7/202125582개발 환경 구성: 565. PowerShell - New-SelfSignedCertificate를 사용해 CA 인증서 생성 및 인증서 서명 방법
12587정성태4/6/202127541개발 환경 구성: 564. Windows 10 - ClickOnce 배포처럼 사용할 수 있는 MSIX 설치 파일 [1]
12586정성태4/5/202123843오류 유형: 710. Windows - Restart-Computer / shutdown 명령어 수행 시 Access is denied(E_ACCESSDENIED)
12585정성태4/5/202122469개발 환경 구성: 563. 기본 생성된 kubeconfig 파일의 내용을 새롭게 생성한 인증서로 구성하는 방법
12584정성태4/1/202123864개발 환경 구성: 562. kubeconfig 파일 없이 kubectl 옵션만으로 실행하는 방법
12583정성태3/29/202123207개발 환경 구성: 561. kubectl 수행 시 다른 k8s 클러스터로 접속하는 방법
12582정성태3/29/202123743오류 유형: 709. Visual C++ - 컴파일 에러 error C2059: syntax error: '__stdcall'
12581정성태3/28/202124246.NET Framework: 1031. WinForm/WPF에서 Console 창을 띄워 출력하는 방법 (2) - Output 디버깅 출력을 AllocConsole로 우회 [2]
12580정성태3/28/202121767오류 유형: 708. SQL Server Management Studio - Execution Timeout Expired.
12579정성태3/28/202122027오류 유형: 707. 중첩 가상화(Nested Virtualization) - The virtual machine could not be started because this platform does not support nested virtualization.
12578정성태3/27/202123293개발 환경 구성: 560. Docker Desktop for Windows 기반의 Kubernetes 구성 (2) - WSL 2 인스턴스에 kind가 구성한 k8s 서비스 위치
12577정성태3/26/202123909개발 환경 구성: 559. Docker Desktop for Windows 기반의 Kubernetes 구성 - WSL 2 인스턴스에 kind 도구로 k8s 클러스터 구성
12576정성태3/25/202122535개발 환경 구성: 558. Docker Desktop for Windows에서 DockerDesktopVM 기반의 Kubernetes 구성 (2) - k8s 서비스 위치
12575정성태3/24/202121913개발 환경 구성: 557. Docker Desktop for Windows에서 DockerDesktopVM 기반의 Kubernetes 구성 [1]
12574정성태3/23/202127185.NET Framework: 1030. C# Socket의 Close/Shutdown 동작 (동기 모드)
12573정성태3/22/202124247개발 환경 구성: 556. WSL 인스턴스 초기 설정 명령어 [1]
12572정성태3/22/202123537.NET Framework: 1029. C# - GC 호출로 인한 메모리 압축(Compaction)을 확인하는 방법파일 다운로드1
12571정성태3/21/202120412오류 유형: 706. WSL 2 기반으로 "Enable Kubernetes" 활성화 시 초기화 실패 [1]
12570정성태3/19/202127400개발 환경 구성: 555. openssl - CA로부터 인증받은 새로운 인증서를 생성하는 방법
12569정성태3/18/202126540개발 환경 구성: 554. WSL 인스턴스 export/import 방법 및 단축 아이콘 설정 방법
12568정성태3/18/202119411오류 유형: 705. C# 빌드 - Couldn't process file ... due to its being in the Internet or Restricted zone or having the mark of the web on the file.
... 46  47  48  49  50  51  52  53  54  55  56  57  [58]  59  60  ...