Merge pull request #198 from mortezag/fixReadline

Fix Peek method in StreamReader

Author: mortezag

Framework/Core/System/IO/StreamReader.cs

@@ -87,7 +87,8 @@ public override int Peek()
             int nextChar;
 
             // If buffer need refresh take into account max UTF8 bytes if the next character is UTF8 encoded
-            if ((m_curBufPos                       == (m_curBufLen-1)) || 
+            // Note: In some occasions, m_curBufPos may go beyond m_curBufLen-1 (for example, when trying to peek after reading the last character of the buffer), so we need to refresh the buffer in these cases too
+            if ((m_curBufPos                       >= (m_curBufLen-1)) || 
                ((m_buffer[m_curBufPos + 1] & 0x80) !=  0 && 
                 (m_curBufPos + 3                   >=  m_curBufLen)))
             {

Test/Platform/Tests/CLR/System/IO/FileStreamTests.cs

@@ -635,5 +635,51 @@ public MFTestResults FileStreamTest_FileAccessAndFileShare()
 
             return (pass)? MFTestResults.Pass : MFTestResults.Fail;
         }
+        
+        [TestMethod]
+        public MFTestResults Test_Fix2048()
+        {
+            // This test was created for http://netmf.codeplex.com/workitem/2048
+            const string file = "foo.txt";
+            MFTestResults result = MFTestResults.Pass;
+            try
+            {
+                const string content = "\"this is param0 HH:MM:SS-YY-mm-dd\", \"this is param1\", \"this is param2\", \"this is param3\",MAXMOISTURE=4.5,MINLEVEL=10,WATERACTIVE=True";
+
+                StreamWriter sw = new StreamWriter(file);
+                
+                for (int i = 0; i < 616; i++)
+                {
+                    sw.WriteLine(content);
+                }
+
+                sw.Close();
+
+                StreamReader sr = new StreamReader(file);
+                string str = sr.ReadLine();
+
+                if(str != content)
+                {
+                    result = MFTestResults.Fail;
+                }
+                
+                sr.Close();
+            }
+            catch (Exception ex)
+            {
+                result = MFTestResults.Fail;
+                Log.Exception("Unexpected Exception", ex);
+            }
+            finally
+            {
+                try
+                {
+                    File.Delete(file);
+                }
+                catch { }
+            }
+
+            return result;
+        }
     }
 }