mirror of
https://github.com/SSCLI/sscli_20021101
synced 2026-06-08 12:28:57 +00:00
yallie
466 lines
18 KiB
C#
466 lines
18 KiB
C#
// ==++==
|
|
//
|
|
//
|
|
// Copyright (c) 2002 Microsoft Corporation. All rights reserved.
|
|
//
|
|
// The use and distribution terms for this software are contained in the file
|
|
// named license.txt, which can be found in the root of this distribution.
|
|
// By using this software in any fashion, you are agreeing to be bound by the
|
|
// terms of this license.
|
|
//
|
|
// You must not remove this notice, or any other, from this software.
|
|
//
|
|
//
|
|
// ==--==
|
|
using System;
|
|
using System.IO;
|
|
using System.Collections;
|
|
using System.Globalization;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Net.Sockets;
|
|
using System.Net;
|
|
using System.Runtime.Serialization.Formatters.Binary;
|
|
public class Co5640ReadBytes
|
|
{
|
|
public static String s_strActiveBugNums = "";
|
|
public static String s_strDtTmVer = "";
|
|
public static String s_strClassMethod = "BinaryReader.ReadBytes(Int32)";
|
|
public static String s_strTFName = "Co5640ReadBytes.cs";
|
|
public static String s_strTFAbbrev = s_strTFName.Substring(0,6);
|
|
public static String s_strTFPath = Environment.CurrentDirectory;
|
|
private static Byte[] bInputBytes ;
|
|
public static int iPortNumber = 0;
|
|
private static int iCountErrors = 0;
|
|
public static ManualResetEvent m_PortSetEvent = new ManualResetEvent(false);
|
|
|
|
private static Char[] chArr = new Char[]{
|
|
Char.MinValue
|
|
,Char.MaxValue
|
|
,'\t'
|
|
,' '
|
|
,'$'
|
|
,'@'
|
|
,'#'
|
|
,'\0'
|
|
,'\v'
|
|
,'\''
|
|
,'\u3190'
|
|
,'\uC3A0'
|
|
,'A'
|
|
,'5'
|
|
,'\uFE70'
|
|
,'-'
|
|
,'\n'
|
|
,'\r'
|
|
,'6'
|
|
,'T'
|
|
,';'
|
|
,'\u00E6'
|
|
};
|
|
Random rand = new Random( (int) DateTime.Now.Ticks );
|
|
int[] iArrInvalidValues = new Int32[]{ -1, -2, -100, -1000, -10000, -100000, -1000000, -10000000, -100000000, -1000000000, Int32.MinValue, Int16.MinValue};
|
|
int[] iArrLargeValues = new Int32[]{ Int32.MaxValue, Int32.MaxValue-1, Int32.MaxValue/2 , Int32.MaxValue/10 , Int32.MaxValue/100 };
|
|
int[] iArrValidValues = new Int32[]{ 10000, 100000 , Int32.MaxValue/2000 , Int32.MaxValue/10000, Int16.MaxValue };
|
|
public bool runTest()
|
|
{
|
|
Console.WriteLine(s_strTFPath + "\\" + s_strTFName + " , for " + s_strClassMethod + " , Source ver " + s_strDtTmVer);
|
|
int iCountTestcases = 0;
|
|
String strLoc = "Loc_000oo";
|
|
String strValue = String.Empty;
|
|
try
|
|
{
|
|
BinaryReader sr2;
|
|
StreamWriter sw2;
|
|
MemoryStream ms2;
|
|
FileStream fs2;
|
|
Byte[] bArrReturn;
|
|
Byte[] bArr;
|
|
String filName = s_strTFAbbrev+"Test.tmp";
|
|
if(File.Exists(filName))
|
|
File.Delete(filName);
|
|
strLoc = "Loc_948yv";
|
|
ms2 = new MemoryStream();
|
|
sr2 = new BinaryReader(ms2);
|
|
iCountTestcases++;
|
|
for(int iLoop = 0 ; iLoop < iArrInvalidValues.Length ; iLoop++ )
|
|
{
|
|
try
|
|
{
|
|
sr2.ReadBytes(iArrInvalidValues[iLoop]);
|
|
iCountErrors++;
|
|
printerr( "Error_1098g! Expected exception not thrown");
|
|
}
|
|
catch (ArgumentOutOfRangeException aexc)
|
|
{
|
|
printinfo( "Info_7587b! Caught expected exception, exc=="+aexc.Message);
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_789gy! Incorrect exception thrown, exc=="+exc.ToString());
|
|
}
|
|
}
|
|
sr2.Close();
|
|
strLoc = "Loc_948yv";
|
|
ms2 = new MemoryStream();
|
|
sw2 = new StreamWriter(ms2);
|
|
for(int i = 0 ; i < chArr.Length ; i++)
|
|
sw2.Write(chArr[i]);
|
|
sw2.Flush();
|
|
ms2.Position = 0;
|
|
sr2 = new BinaryReader(ms2);
|
|
iCountTestcases++;
|
|
Byte[] bNewArray = null ;
|
|
for(int iLoop = 0 ; iLoop < iArrLargeValues.Length ; iLoop++ )
|
|
{
|
|
try
|
|
{
|
|
bNewArray = sr2.ReadBytes(iArrLargeValues[iLoop]);
|
|
Console.WriteLine("length..." + bNewArray.Length );
|
|
if(!( bNewArray.Length == 0 || bNewArray.Length == 31))
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_5543! Unexpected bytes are read from the stream... Length:" + bNewArray.Length);
|
|
}
|
|
}
|
|
catch (OutOfMemoryException aexc)
|
|
{
|
|
printinfo( "Info_7342! Caught expected exception, exc=="+aexc.Message);
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_0843! Incorrect exception thrown, exc=="+exc.ToString());
|
|
}
|
|
}
|
|
sr2.Close();
|
|
strLoc = "Loc_7t09b";
|
|
ms2 = new MemoryStream();
|
|
sr2 = new BinaryReader(ms2);
|
|
iCountTestcases++;
|
|
bArrReturn = sr2.ReadBytes(3);
|
|
if(bArrReturn.Length != 0)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_2098uv! Read from empty stream, read=="+bArrReturn.Length);
|
|
}
|
|
sr2.Close();
|
|
strLoc = "Loc_2698b";
|
|
try
|
|
{
|
|
ms2 = new MemoryStream();
|
|
sw2 = new StreamWriter(ms2);
|
|
for(int i = 0 ; i < chArr.Length ; i++)
|
|
sw2.Write(chArr[i]);
|
|
sw2.Flush();
|
|
ms2.Position = 0;
|
|
sr2 = new BinaryReader(ms2);
|
|
bArr = ms2.ToArray();
|
|
bInputBytes = ms2.ToArray();
|
|
bArrReturn = sr2.ReadBytes(bArr.Length);
|
|
iCountTestcases++;
|
|
if(bArrReturn.Length != bArr.Length)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_1900c! Incorrect number of chars read");
|
|
}
|
|
for(int i = 0 ; i < bArr.Length ; i++)
|
|
{
|
|
iCountTestcases++;
|
|
if(bArrReturn[i] != bArr[i])
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_298vc_"+i+"! Expected=="+(Int32)bArr[i]+", got=="+(Int32)bArrReturn[i]);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_298yg! Unexpected exception thrown, exc=="+exc.ToString());
|
|
}
|
|
strLoc = "Loc_9848v";
|
|
try
|
|
{
|
|
fs2 = new FileStream(filName, FileMode.Create);
|
|
sw2 = new StreamWriter(fs2);
|
|
for(int i = 0 ; i < chArr.Length ; i++)
|
|
sw2.Write(chArr[i]);
|
|
sw2.Flush();
|
|
sw2.Close();
|
|
fs2 = new FileStream(filName, FileMode.Open);
|
|
bArr = new Byte[(Int32)fs2.Length];
|
|
fs2.EndRead(fs2.BeginRead(bArr, 0, (Int32)fs2.Length, null, null));
|
|
fs2.Position = 0;
|
|
sr2 = new BinaryReader(fs2);
|
|
bArrReturn = sr2.ReadBytes(bArr.Length);
|
|
iCountTestcases++;
|
|
if(bArrReturn.Length != bArr.Length)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_0901x! Incorrect number of chars read, length=="+bArr.Length);
|
|
}
|
|
for(int i = 0 ; i < bArr.Length ; i++)
|
|
{
|
|
iCountTestcases++;
|
|
if(bArrReturn[i] != bArr[i])
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_98yv8!_"+i+"! Expected=="+(Int32)bArr[i]+", got=="+(Int32)bArrReturn[i]);
|
|
}
|
|
}
|
|
sr2.Close();
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_698y7! Unexpected exception thrown, exc=="+exc.ToString());
|
|
}
|
|
Byte[] bytes = BitConverter.GetBytes('\u00FC');
|
|
for(int i = 0 ; i < bytes.Length ; i++)
|
|
Console.WriteLine(bytes[i]);
|
|
strLoc = "Loc_958hb";
|
|
fs2 = new FileStream(filName, FileMode.Create);
|
|
BinaryWriter bw2 = new BinaryWriter(fs2, Encoding.Unicode);
|
|
bw2.Write("\u00FA\u00FB\u00FC\u00FD\uFFFE");
|
|
bw2.Close();
|
|
fs2 = new FileStream(filName, FileMode.Open);
|
|
sr2 = new BinaryReader(fs2, Encoding.Unicode);
|
|
sr2.BaseStream.Position = 1 ;
|
|
iCountTestcases++;
|
|
if(sr2.ReadChar() != (Char)0xFA )
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_t8yc! Incorrect character read");
|
|
}
|
|
if(sr2.ReadChar() != (Char)0xFB)
|
|
{
|
|
iCountErrors++;
|
|
printerr("Error_8yb78! Incorrect character read");
|
|
}
|
|
bArrReturn = sr2.ReadBytes(4);
|
|
iCountTestcases++;
|
|
if(bArrReturn.Length != 4)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_tg777! Incorrect number of chars read");
|
|
}
|
|
iCountTestcases++;
|
|
if(bArrReturn[0] != 252)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_9t8yv! Incorrect byte read=="+bArrReturn[0]);
|
|
}
|
|
iCountTestcases++;
|
|
if(bArrReturn[1] != 0)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_2098b! Incorrect byte read=="+bArrReturn[1]);
|
|
}
|
|
iCountTestcases++;
|
|
if(bArrReturn[2] != 253)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_0199x! Incorrect byte read=="+bArrReturn[2]);
|
|
}
|
|
iCountTestcases++;
|
|
if(bArrReturn[3] != 0)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error! Incorrect byte read=="+bArrReturn[3]);
|
|
}
|
|
iCountTestcases++;
|
|
Int32 tmp;
|
|
if((tmp = sr2.Read()) != 0xFFFE)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_928yb! Incorrect value read, tmp=="+tmp);
|
|
}
|
|
iCountTestcases++;
|
|
if((tmp = sr2.Read()) != -1)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_t8753! Incorrect position in stream, tmp=="+tmp);
|
|
}
|
|
sr2.Close();
|
|
strLoc = "Loc_7y8f8";
|
|
ms2 = new MemoryStream();
|
|
sr2 = new BinaryReader(ms2);
|
|
iCountTestcases++;
|
|
if(sr2.ReadBytes(1).Length != 0)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_398yc! Incorrect number of bytes read");
|
|
}
|
|
m_PortSetEvent.Reset();
|
|
Thread tcpListenerThread = new Thread(new ThreadStart(Co5640ReadBytes.StartListeningTcp));
|
|
tcpListenerThread.Start();
|
|
Console.WriteLine("Listening");
|
|
Thread.Sleep( 1000 );
|
|
m_PortSetEvent.WaitOne();
|
|
Teleport("127.0.0.1");
|
|
Thread.Sleep( 1000 );
|
|
strLoc = "Loc_9066";
|
|
chArr = new Char[Int32.MaxValue/2000];
|
|
ms2 = new MemoryStream();
|
|
sw2 = new StreamWriter(ms2);
|
|
for(int i = 0 ; i < chArr.Length ; i++)
|
|
sw2.Write(rand.Next(Char.MinValue, Char.MaxValue));
|
|
Console.WriteLine("Scenario started");
|
|
sw2.Flush();
|
|
ms2.Position = 0;
|
|
sr2 = new BinaryReader(ms2);
|
|
iCountTestcases++;
|
|
for(int iLoop = 0 ; iLoop < iArrValidValues.Length ; iLoop++ )
|
|
{
|
|
try
|
|
{
|
|
ms2.Position = 0 ;
|
|
bNewArray = sr2.ReadBytes(iArrValidValues[iLoop]);
|
|
if(bNewArray.Length !=iArrValidValues[iLoop])
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_5543! Unexpected bytes are read from the stream... Length:" + bNewArray.Length);
|
|
}
|
|
}
|
|
catch (OutOfMemoryException aexc)
|
|
{
|
|
printinfo( "Info_7342! Caught expected exception, exc=="+aexc.Message);
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_0843! Incorrect exception thrown, exc=="+exc.ToString());
|
|
}
|
|
}
|
|
sr2.Close();
|
|
if(File.Exists(filName))
|
|
File.Delete(filName);
|
|
}
|
|
catch (Exception exc_general )
|
|
{
|
|
++iCountErrors;
|
|
Console.WriteLine (s_strTFAbbrev + " : Error Err_8888yyy! strLoc=="+ strLoc +", exc_general=="+exc_general.ToString());
|
|
}
|
|
if ( iCountErrors == 0 )
|
|
{
|
|
Console.WriteLine( "paSs. "+s_strTFName+" ,iCountTestcases=="+iCountTestcases.ToString());
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("FAiL! "+s_strTFName+" ,iCountErrors=="+iCountErrors.ToString()+" , BugNums?: "+s_strActiveBugNums );
|
|
return false;
|
|
}
|
|
}
|
|
public void printerr ( String err )
|
|
{
|
|
Console.WriteLine ("POINTTOBREAK: ("+ s_strTFAbbrev + ") "+ err);
|
|
}
|
|
public void printinfo ( String info )
|
|
{
|
|
Console.WriteLine ("INFO: ("+ s_strTFAbbrev + ") "+ info);
|
|
}
|
|
public static void StartListeningTcp()
|
|
{
|
|
TcpThreadListener listener = new TcpThreadListener(0);
|
|
NetworkStream ns = null;
|
|
BinaryReader br = null;
|
|
|
|
try
|
|
{
|
|
listener.Start();
|
|
IPEndPoint ipe = (IPEndPoint) listener.LocalEndpoint;
|
|
Interlocked.Exchange(ref iPortNumber, ipe.Port);
|
|
Console.WriteLine("Using port: {0}", iPortNumber);
|
|
m_PortSetEvent.Set();
|
|
|
|
Socket s = listener.AcceptSocket();
|
|
ns = new NetworkStream(s);
|
|
br = new BinaryReader( ns );
|
|
Byte[] bArrReturn = br.ReadBytes(bInputBytes.Length);
|
|
if(bArrReturn.Length != bInputBytes.Length)
|
|
{
|
|
iCountErrors++;
|
|
Console.WriteLine( "Error_1900c! Incorrect number of chars read");
|
|
}
|
|
for(int i = 0 ; i < bInputBytes.Length ; i++)
|
|
{
|
|
if(bArrReturn[i] != bInputBytes[i])
|
|
{
|
|
iCountErrors++;
|
|
Console.WriteLine( "Error_298vc_"+i+"! Expected=="+(Int32)bInputBytes[i]+", got=="+(Int32)bArrReturn[i]);
|
|
}
|
|
}
|
|
Console.WriteLine("We are done with the listening");
|
|
}
|
|
catch(Exception e)
|
|
{
|
|
iCountErrors++ ;
|
|
Console.WriteLine("Exception receiving Teleportation: " + e.Message + Environment.NewLine + e.StackTrace);
|
|
m_PortSetEvent.Set();
|
|
}
|
|
finally
|
|
{
|
|
if (listener != null)
|
|
{
|
|
listener.Stop();
|
|
}
|
|
if (ns != null)
|
|
{
|
|
ns.Close();
|
|
}
|
|
if(br != null)
|
|
{
|
|
br.Close();
|
|
}
|
|
} //finally
|
|
}
|
|
internal class TcpThreadListener : TcpListener
|
|
{
|
|
public TcpThreadListener(int port) : base(port)
|
|
{
|
|
}
|
|
internal void Shutdown()
|
|
{
|
|
if ( Server != null )
|
|
Server.Close();
|
|
}
|
|
}
|
|
public static void Teleport(string address)
|
|
{
|
|
TcpClient tcpClient = new TcpClient();
|
|
IPEndPoint epSend = null;
|
|
IPAddress sendAddress = IPAddress.Parse(address);
|
|
epSend = new IPEndPoint(sendAddress, iPortNumber);
|
|
tcpClient.Connect(epSend);
|
|
Stream stream = tcpClient.GetStream();
|
|
BinaryWriter bw = new BinaryWriter( stream );
|
|
for(int i = 0 ; i < chArr.Length ; i++)
|
|
bw.Write(chArr[i]);
|
|
}
|
|
public static void Main(String[] args)
|
|
{
|
|
bool bResult = false;
|
|
Co5640ReadBytes cbA = new Co5640ReadBytes();
|
|
try
|
|
{
|
|
bResult = cbA.runTest();
|
|
}
|
|
catch (Exception exc_main)
|
|
{
|
|
bResult = false;
|
|
Console.WriteLine(s_strTFAbbrev + " : FAiL! Error Err_9999zzz! Uncaught Exception in main(), exc_main=="+exc_main.ToString());
|
|
}
|
|
if (!bResult)
|
|
{
|
|
Console.WriteLine ("Path: "+s_strTFName + s_strTFPath);
|
|
Console.WriteLine( " " );
|
|
Console.WriteLine( "FAiL! "+ s_strTFAbbrev);
|
|
Console.WriteLine( " " );
|
|
}
|
|
if (bResult) Environment.ExitCode = 0; else Environment.ExitCode = 1;
|
|
}
|
|
}
|