Add System.IO.MemoryMappedFiles source and tests

(cherry picked master -> v1.0 from commit f4c9e52)

src/Common/src/System/IO/__Error.cs

@@ -0,0 +1,26 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System.Security;
+
+namespace System.IO
+{
+    // Only static data; no need to serialize
+    internal static class __Error
+    {
+        internal static Exception GetStreamIsClosed()
+        {
+            return new ObjectDisposedException(null, SR.ObjectDisposed_StreamIsClosed);
+        }
+
+        internal static Exception GetReadNotSupported()
+        {
+            return new NotSupportedException(SR.NotSupported_UnreadableStream);
+        }
+
+        internal static Exception GetWriteNotSupported()
+        {
+            return new NotSupportedException(SR.NotSupported_UnwritableStream);
+        }
+    }
+}

src/System.IO.MemoryMappedFiles.sln

@@ -0,0 +1,47 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 2013
+VisualStudioVersion = 12.0.30723.0
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "System.IO.MemoryMappedFiles", "System.IO.MemoryMappedFiles\src\System.IO.MemoryMappedFiles.csproj", "{16EE5522-F387-4C9E-9EF2-B5134B043F37}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tests", "Tests", "{10E9121A-7350-4AB7-BB05-A543BE1EB19B}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MemoryMappedFile.Tests", "System.IO.MemoryMappedFiles\tests\MemoryMappedFile.Tests.csproj", "{9D6F6254-B5A3-40FF-8925-68AA8D1CE933}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MemoryMappedViewAccessor.Tests", "System.IO.MemoryMappedFiles\tests\MemoryMappedViewAccessor.Tests.csproj", "{F26FBD53-C04A-4FFC-90C9-AA804285A7AD}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MemoryMappedViewStream.Tests", "System.IO.MemoryMappedFiles\tests\MemoryMappedViewStream.Tests.csproj", "{688496E1-A7B3-41AE-9E32-C6F1A1127F91}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{16EE5522-F387-4C9E-9EF2-B5134B043F37}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{16EE5522-F387-4C9E-9EF2-B5134B043F37}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{16EE5522-F387-4C9E-9EF2-B5134B043F37}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{16EE5522-F387-4C9E-9EF2-B5134B043F37}.Release|Any CPU.Build.0 = Release|Any CPU
+		{9D6F6254-B5A3-40FF-8925-68AA8D1CE933}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{9D6F6254-B5A3-40FF-8925-68AA8D1CE933}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{9D6F6254-B5A3-40FF-8925-68AA8D1CE933}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{9D6F6254-B5A3-40FF-8925-68AA8D1CE933}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F26FBD53-C04A-4FFC-90C9-AA804285A7AD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F26FBD53-C04A-4FFC-90C9-AA804285A7AD}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F26FBD53-C04A-4FFC-90C9-AA804285A7AD}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F26FBD53-C04A-4FFC-90C9-AA804285A7AD}.Release|Any CPU.Build.0 = Release|Any CPU
+		{688496E1-A7B3-41AE-9E32-C6F1A1127F91}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{688496E1-A7B3-41AE-9E32-C6F1A1127F91}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{688496E1-A7B3-41AE-9E32-C6F1A1127F91}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{688496E1-A7B3-41AE-9E32-C6F1A1127F91}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{9D6F6254-B5A3-40FF-8925-68AA8D1CE933} = {10E9121A-7350-4AB7-BB05-A543BE1EB19B}
+		{F26FBD53-C04A-4FFC-90C9-AA804285A7AD} = {10E9121A-7350-4AB7-BB05-A543BE1EB19B}
+		{688496E1-A7B3-41AE-9E32-C6F1A1127F91} = {10E9121A-7350-4AB7-BB05-A543BE1EB19B}
+	EndGlobalSection
+EndGlobal

src/System.IO.MemoryMappedFiles/src/Interop/Interop.Manual.cs

@@ -0,0 +1,250 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using Microsoft.Win32.SafeHandles;
+using System;
+using System.Runtime.InteropServices;
+using System.Security;
+using System.Text;
+using System.Threading;
+
+internal static partial class Interop
+{
+    private const String HANDLEDLL = "api-ms-win-core-handle-l1-1-0.dll";
+    private const String MEMORYDLL = "api-ms-win-core-memory-l1-1-0.dll";
+    private const String SYSINFODLL = "api-ms-win-core-sysinfo-l1-1-0.dll";
+    private const String LOCALIZATIONDLL = "api-ms-win-core-localization-l1-2-0.dll";
+
+    //
+    // Win32 IO
+    //
+
+    // WinError.h codes:
+
+    internal const int ERROR_SUCCESS = 0x0;
+    internal const int ERROR_FILE_NOT_FOUND = 0x2;
+    internal const int ERROR_PATH_NOT_FOUND = 0x3;
+    internal const int ERROR_ACCESS_DENIED = 0x5;
+    internal const int ERROR_INVALID_HANDLE = 0x6;
+
+    // Can occurs when filled buffers are trying to flush to disk, but disk IOs are not fast enough. 
+    // This happens when the disk is slow and event traffic is heavy. 
+    // Eventually, there are no more free (empty) buffers and the event is dropped.
+    internal const int ERROR_NOT_ENOUGH_MEMORY = 0x8;
+
+    internal const int ERROR_INVALID_DRIVE = 0xF;
+    internal const int ERROR_NO_MORE_FILES = 0x12;
+    internal const int ERROR_NOT_READY = 0x15;
+    internal const int ERROR_BAD_LENGTH = 0x18;
+    internal const int ERROR_SHARING_VIOLATION = 0x20;
+    internal const int ERROR_LOCK_VIOLATION = 0x21;  // 33
+    internal const int ERROR_HANDLE_EOF = 0x26;  // 38
+    internal const int ERROR_FILE_EXISTS = 0x50;
+    internal const int ERROR_INVALID_PARAMETER = 0x57;  // 87
+    internal const int ERROR_BROKEN_PIPE = 0x6D;  // 109
+    internal const int ERROR_INSUFFICIENT_BUFFER = 0x7A;  // 122
+    internal const int ERROR_INVALID_NAME = 0x7B;
+    internal const int ERROR_BAD_PATHNAME = 0xA1;
+    internal const int ERROR_ALREADY_EXISTS = 0xB7;
+    internal const int ERROR_ENVVAR_NOT_FOUND = 0xCB;
+    internal const int ERROR_FILENAME_EXCED_RANGE = 0xCE;  // filename too long
+    internal const int ERROR_PIPE_BUSY = 0xE7;  // 231
+    internal const int ERROR_NO_DATA = 0xE8;  // 232
+    internal const int ERROR_PIPE_NOT_CONNECTED = 0xE9;  // 233
+    internal const int ERROR_MORE_DATA = 0xEA;
+    internal const int ERROR_NO_MORE_ITEMS = 0x103;  // 259
+    internal const int ERROR_PIPE_CONNECTED = 0x217;  // 535
+    internal const int ERROR_PIPE_LISTENING = 0x218;  // 536
+    internal const int ERROR_OPERATION_ABORTED = 0x3E3;  // 995; For IO Cancellation
+    internal const int ERROR_IO_PENDING = 0x3E5;  // 997
+    internal const int ERROR_NOT_FOUND = 0x490;  // 1168      
+
+    // The event size is larger than the allowed maximum (64k - header).
+    internal const int ERROR_ARITHMETIC_OVERFLOW = 0x216;  // 534
+
+    internal const int ERROR_RESOURCE_LANG_NOT_FOUND = 0x717;  // 1815
+
+
+    // Event log specific codes:
+
+    internal const int ERROR_EVT_MESSAGE_NOT_FOUND = 15027;
+    internal const int ERROR_EVT_MESSAGE_ID_NOT_FOUND = 15028;
+    internal const int ERROR_EVT_UNRESOLVED_VALUE_INSERT = 15029;
+    internal const int ERROR_EVT_UNRESOLVED_PARAMETER_INSERT = 15030;
+    internal const int ERROR_EVT_MAX_INSERTS_REACHED = 15031;
+    internal const int ERROR_EVT_MESSAGE_LOCALE_NOT_FOUND = 15033;
+    internal const int ERROR_MUI_FILE_NOT_FOUND = 15100;
+
+
+    internal const int SECURITY_SQOS_PRESENT = 0x00100000;
+    internal const int SECURITY_ANONYMOUS = 0 << 16;
+    internal const int SECURITY_IDENTIFICATION = 1 << 16;
+    internal const int SECURITY_IMPERSONATION = 2 << 16;
+    internal const int SECURITY_DELEGATION = 3 << 16;
+
+    internal const int GENERIC_READ = unchecked((int)0x80000000);
+    internal const int GENERIC_WRITE = 0x40000000;
+
+    internal const int STD_INPUT_HANDLE = -10;
+    internal const int STD_OUTPUT_HANDLE = -11;
+    internal const int STD_ERROR_HANDLE = -12;
+
+    internal const int DUPLICATE_SAME_ACCESS = 0x00000002;
+
+    internal const int PIPE_ACCESS_INBOUND = 1;
+    internal const int PIPE_ACCESS_OUTBOUND = 2;
+    internal const int PIPE_ACCESS_DUPLEX = 3;
+    internal const int PIPE_TYPE_BYTE = 0;
+    internal const int PIPE_TYPE_MESSAGE = 4;
+    internal const int PIPE_READMODE_BYTE = 0;
+    internal const int PIPE_READMODE_MESSAGE = 2;
+    internal const int PIPE_UNLIMITED_INSTANCES = 255;
+
+    internal const int FILE_FLAG_FIRST_PIPE_INSTANCE = 0x00080000;
+    internal const int FILE_SHARE_READ = 0x00000001;
+    internal const int FILE_SHARE_WRITE = 0x00000002;
+    internal const int FILE_ATTRIBUTE_NORMAL = 0x00000080;
+
+    internal const int FILE_FLAG_OVERLAPPED = 0x40000000;
+
+    internal const int OPEN_EXISTING = 3;
+
+    // From WinBase.h
+    internal const int FILE_TYPE_DISK = 0x0001;
+    internal const int FILE_TYPE_CHAR = 0x0002;
+    internal const int FILE_TYPE_PIPE = 0x0003;
+
+    // Memory mapped file constants
+    internal const int MEM_COMMIT = 0x1000;
+    internal const int MEM_RESERVE = 0x2000;
+    internal const int INVALID_FILE_SIZE = -1;
+    internal const int PAGE_READWRITE = 0x04;
+    internal const int PAGE_READONLY = 0x02;
+    internal const int PAGE_WRITECOPY = 0x08;
+    internal const int PAGE_EXECUTE_READ = 0x20;
+    internal const int PAGE_EXECUTE_READWRITE = 0x40;
+
+    internal const int FILE_MAP_COPY = 0x0001;
+    internal const int FILE_MAP_WRITE = 0x0002;
+    internal const int FILE_MAP_READ = 0x0004;
+    internal const int FILE_MAP_EXECUTE = 0x0020;
+
+    // From WinBase.h
+    internal const int SEM_FAILCRITICALERRORS = 1;
+
+    [StructLayout(LayoutKind.Sequential)]
+    internal struct SYSTEM_INFO
+    {
+        internal int dwOemId;
+        internal int dwPageSize;
+        internal IntPtr lpMinimumApplicationAddress;
+        internal IntPtr lpMaximumApplicationAddress;
+        internal IntPtr dwActiveProcessorMask;
+        internal int dwNumberOfProcessors;
+        internal int dwProcessorType;
+        internal int dwAllocationGranularity;
+        internal short wProcessorLevel;
+        internal short wProcessorRevision;
+    }
+
+    [StructLayout(LayoutKind.Sequential)]
+    internal struct SECURITY_ATTRIBUTES
+    {
+        public uint nLength;
+        public IntPtr lpSecurityDescriptor;
+        public bool bInheritHandle;
+    }
+
+    [StructLayout(LayoutKind.Sequential)]
+    internal struct MEMORYSTATUSEX
+    {
+        internal uint dwLength;
+        internal uint dwMemoryLoad;
+        internal ulong ullTotalPhys;
+        internal ulong ullAvailPhys;
+        internal ulong ullTotalPageFile;
+        internal ulong ullAvailPageFile;
+        internal ulong ullTotalVirtual;
+        internal ulong ullAvailVirtual;
+        internal ulong ullAvailExtendedVirtual;
+    }
+
+    [StructLayout(LayoutKind.Sequential)]
+    internal unsafe struct MEMORY_BASIC_INFORMATION
+    {
+        internal void* BaseAddress;
+        internal void* AllocationBase;
+        internal uint AllocationProtect;
+        internal UIntPtr RegionSize;
+        internal uint State;
+        internal uint Protect;
+        internal uint Type;
+    }
+
+    internal static partial class mincore
+    {
+        [DllImport(LOCALIZATIONDLL, EntryPoint = "FormatMessageW", CharSet = CharSet.Unicode)]
+        internal extern static uint FormatMessage(
+                    uint dwFlags,
+                    IntPtr lpSource,
+                    uint dwMessageId,
+                    uint dwLanguageId,
+                    char[] lpBuffer,
+                    uint nSize,
+                    IntPtr Arguments);
+
+        [DllImport(MEMORYDLL)]
+        internal extern static int FlushViewOfFile(IntPtr lpBaseAddress, UIntPtr dwNumberOfBytesToFlush);
+
+        [DllImport(MEMORYDLL)]
+        internal extern static int UnmapViewOfFile(IntPtr lpBaseAddress);
+
+        [DllImport(SYSINFODLL)]
+        internal extern static void GetSystemInfo(out SYSTEM_INFO lpSystemInfo);
+
+        [DllImport(SYSINFODLL)]
+        internal extern static int GlobalMemoryStatusEx(out MEMORYSTATUSEX lpBuffer);
+
+        [DllImport(MEMORYDLL, EntryPoint = "CreateFileMappingW", CharSet = CharSet.Unicode, SetLastError = true)]
+        [SecurityCritical]
+        internal static extern SafeMemoryMappedFileHandle CreateFileMapping(SafeFileHandle hFile,
+            ref SECURITY_ATTRIBUTES lpFileMappingAttributes, int flProtect,
+            int dwMaximumSizeHigh, int dwMaximumSizeLow, string lpName);
+
+        [DllImport(MEMORYDLL, EntryPoint = "OpenFileMappingW", CharSet = CharSet.Unicode, SetLastError = true)]
+        [SecurityCritical]
+        internal static extern SafeMemoryMappedFileHandle OpenFileMapping(
+                        int dwDesiredAccess,
+                        [MarshalAs(UnmanagedType.Bool)] bool bInheritHandle,
+                        string lpName);
+
+        [DllImport(MEMORYDLL, EntryPoint = "MapViewOfFile", CharSet = CharSet.Unicode, SetLastError = true)]
+        [SecurityCritical]
+        internal static extern SafeMemoryMappedViewHandle MapViewOfFile(
+                        SafeMemoryMappedFileHandle hFileMappingObject,
+                        int dwDesiredAccess,
+                        int dwFileOffsetHigh,
+                        int dwFileOffsetLow,
+                        UIntPtr dwNumberOfBytesToMap);
+
+        [DllImport(MEMORYDLL, EntryPoint = "VirtualQuery", CharSet = CharSet.Unicode, SetLastError = true)]
+        [SecurityCritical]
+        internal extern static UIntPtr VirtualQuery(
+                        SafeMemoryMappedViewHandle lpAddress,
+                        ref MEMORY_BASIC_INFORMATION lpBuffer,
+                        UIntPtr dwLength);
+
+        [DllImport(MEMORYDLL, EntryPoint = "VirtualAlloc", CharSet = CharSet.Unicode, SetLastError = true)]
+        [SecurityCritical]
+        internal extern static IntPtr VirtualAlloc(
+                        SafeHandle lpAddress,
+                        UIntPtr dwSize,
+                        int flAllocationType,
+                        int flProtect);
+
+        [DllImport(HANDLEDLL, SetLastError = true)]
+        [return: MarshalAs(UnmanagedType.Bool)]
+        [SecurityCritical]
+        internal static extern bool CloseHandle(IntPtr handle);
+    }
+}

src/System.IO.MemoryMappedFiles/src/Microsoft/Win32/SafeMemoryMappedFileHandle.cs

@@ -0,0 +1,39 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System;
+using System.Runtime.InteropServices;
+using System.Security;
+
+namespace Microsoft.Win32.SafeHandles
+{
+    // Reliability notes:
+    // ReleaseHandle has reliability guarantee of Cer.Success, as defined by SafeHandle.
+    // It gets prepared as a CER at instance construction time.
+
+    [SecurityCritical]
+    public sealed class SafeMemoryMappedFileHandle : SafeHandle
+    {
+        internal SafeMemoryMappedFileHandle() : base(IntPtr.Zero, true) { }
+
+        internal SafeMemoryMappedFileHandle(IntPtr handle, bool ownsHandle)
+            : base(IntPtr.Zero, ownsHandle)
+        {
+            SetHandle(handle);
+        }
+
+        override protected bool ReleaseHandle()
+        {
+            return Interop.mincore.CloseHandle(handle);
+        }
+
+        public override bool IsInvalid
+        {
+            [SecurityCritical]
+            get
+            {
+                return handle == new IntPtr(0) || handle == new IntPtr(-1);
+            }
+        }
+    }
+}