チェンジセット 1655 (default)

日時:

2024/08/08 1:13:45 (2ヵ月前)

更新者:

hizuya@…

ログメッセージ:

• Stream.Close 時に例外を無視する機能を追加。

場所:

framework/trunk

ファイル:

• CoreLibrary/CoreLibrary.csproj (更新) (1個の差分)
• CoreLibrary/Sources/IO/CloseExceptionIgnorableStream.cs (追加)
• CoreLibrary/Sources/IO/IOUtility.cs (更新) (1個の差分)
• CoreTest/Sources/IO/IOUtilityTest.cs (更新) (1個の差分)

framework/trunk/CoreLibrary/CoreLibrary.csproj

@@ -164 +164 @@
     <Compile Include="Sources\IO\AutoDetectEncodingStreamReader.cs" />
     <Compile Include="Sources\IO\BufferedPipeStream.cs" />
+    <Compile Include="Sources\IO\CloseExceptionIgnorableStream.cs" />
     <Compile Include="Sources\IO\CountedStream.cs" />
     <Compile Include="Sources\IO\DeliveryStream.cs" />

framework/trunk/CoreLibrary/Sources/IO/IOUtility.cs

@@ -1420 +1420 @@
 
         /// <summary>
+        /// 指定したストリームを、破棄時に発生する例外を無視するストリームでラップします。
+        /// </summary>
+        /// <param name="stream">元にするストリーム。</param>
+        /// <returns>
+        /// ラップしたストリーム。
+        /// </returns>
+        /// <exception cref="ArgumentNullException">
+        /// <paramref name="stream"/> が <see langword="null"/> 参照です。
+        /// </exception>
+        public static Stream CreateCloseExceptionIgnorableStream(Stream stream)
+        {
+            return new CloseExceptionIgnorableStream(stream);
+        }
+
+        /// <summary>
         /// 文字がディレクトリセパレータを表すかを取得します。
         /// </summary>

framework/trunk/CoreTest/Sources/IO/IOUtilityTest.cs

@@ -679 +679 @@
 
         /// <summary>
+        /// <see cref="IOUtility.CreateCloseExceptionIgnorableStream"/> をテストします。
+        /// </summary>
+        [Test]
+        public void TestCreateCloseExceptionIgnorableStream()
+        {
+            Action<bool, Action<Stream>> action = delegate(bool useWrapper, Action<Stream> callback)
+            {
+                using (MemoryStream rootStream = new MemoryStream())
+                {
+                    Stream targetStream = new BufferedStream(rootStream, 0x1000);
+                    if (useWrapper)
+                    {
+                        targetStream = IOUtility.CreateCloseExceptionIgnorableStream(targetStream);
+                    }
+
+                    try
+                    {
+                        targetStream.WriteByte(1);
+                    }
+                    finally
+                    {
+                        // 元のストリームを破棄
+                        rootStream.Close();
+
+                        // BufferedStream.Close() では書き込まれたデータがある場合 Flush() を呼ぶので例外が発生する
+                        callback(targetStream);
+                    }
+                }
+            };
+
+            // Close() で例外が発生することを確認
+            action(
+                false,
+                delegate(Stream stream)
+                {
+                    Assert.That(
+                        stream.Close,
+                        Throws.TypeOf<ObjectDisposedException>(),
+                        "Normal close");
+                });
+
+            // Close() で例外が発生しないことを確認
+            action(
+                true,
+                delegate(Stream stream)
+                {
+                    stream.Close();
+                });
+        }
+
+        /// <summary>
         /// 再解析ポイントを作成します。
         /// </summary>