mirror of
https://github.com/SSCLI/sscli_20021101
synced 2026-06-08 12:28:57 +00:00
yallie
274 lines
9.6 KiB
C#
274 lines
9.6 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.Text;
|
|
using System.Threading;
|
|
using System.Net.Sockets;
|
|
using System.Net;
|
|
public class Co5651ReadString
|
|
{
|
|
public static String s_strActiveBugNums = "";
|
|
public static String s_strDtTmVer = "";
|
|
public static String s_strClassMethod = "BinaryReader.ReadString()";
|
|
public static String s_strTFName = "Co5651ReadString.cs";
|
|
public static String s_strTFAbbrev = "Co5651";
|
|
public static String s_strTFPath = Environment.CurrentDirectory.ToString();
|
|
public static int iPortNumber = 0;
|
|
private static int iCountErrors = 0;
|
|
public static ManualResetEvent m_PortSetEvent = new ManualResetEvent(false);
|
|
|
|
private static String[] strArr = new String[0] ;
|
|
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
|
|
{
|
|
BinaryWriter dw2 = null;
|
|
Stream fs2 = null;
|
|
BinaryReader dr2 = null;
|
|
FileInfo fil2 = null;
|
|
MemoryStream mstr = null;
|
|
String str2 = String.Empty;
|
|
int ii = 0;
|
|
String filName = s_strTFAbbrev+"Test.tmp";
|
|
StringBuilder sb = new StringBuilder();
|
|
String str1;
|
|
for(ii = 0 ; ii < 100 ; ii++)
|
|
sb.Append("abc");
|
|
str1 = sb.ToString();
|
|
strArr = new String[] {
|
|
"ABC"
|
|
,"\t\t\n\n\n\0\r\r\v\v\t\0\rHello"
|
|
,"This is a normal string"
|
|
,"12345667789!@#$%^&&())_+_)@#"
|
|
,"ABSDAFJPIRUETROPEWTGRUOGHJDOLJHLDHWEROTYIETYWsdifhsiudyoweurscnkjhdfusiyugjlskdjfoiwueriye"
|
|
," "
|
|
,"\0\0\0\t\t\tHey\"\""
|
|
,str1
|
|
,String.Empty
|
|
};
|
|
if(File.Exists(filName))
|
|
File.Delete(filName);
|
|
strLoc = "Loc_8yfv7";
|
|
fil2 = new FileInfo(filName);
|
|
fs2 = fil2.Open(FileMode.Create);
|
|
dw2 = new BinaryWriter(fs2);
|
|
try
|
|
{
|
|
for(ii = 0 ; ii < strArr.Length ; ii++)
|
|
dw2.Write(strArr[ii]);
|
|
dw2.Flush();
|
|
fs2.Close();
|
|
strLoc = "Loc_987hg";
|
|
fs2 = fil2.Open(FileMode.Open);
|
|
dr2 = new BinaryReader(fs2);
|
|
for(ii = 0 ; ii < strArr.Length ;ii++)
|
|
{
|
|
iCountTestcases++;
|
|
if(!(str2 = dr2.ReadString()).Equals(strArr[ii]))
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_298hg_"+ii+"! Expected=="+strArr[ii]+" , got=="+str2);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_278gy_"+ii+"! Unexpected exception, exc=="+exc.ToString());
|
|
}
|
|
fs2.Close();
|
|
fil2.Delete();
|
|
strLoc = "Loc_98yss";
|
|
mstr = new MemoryStream();
|
|
dw2 = new BinaryWriter(mstr);
|
|
try
|
|
{
|
|
for(ii = 0 ; ii < strArr.Length ; ii++)
|
|
dw2.Write(strArr[ii]);
|
|
dw2.Flush();
|
|
mstr.Position = 0;
|
|
strLoc = "Loc_287y5";
|
|
dr2 = new BinaryReader(mstr);
|
|
for(ii = 0 ; ii < strArr.Length ;ii++)
|
|
{
|
|
iCountTestcases++;
|
|
if(!(str2 = dr2.ReadString()).Equals(strArr[ii]))
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_48yf4_"+ii+"! Expected=="+strArr[ii]+" , got=="+str2);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_38f85_"+ii+"! Unexpected exception, exc=="+exc.ToString());
|
|
}
|
|
mstr.Close();
|
|
strLoc = "Loc_489vy";
|
|
mstr = new MemoryStream();
|
|
dw2 = new BinaryWriter(mstr);
|
|
try
|
|
{
|
|
dw2.Write((String)null);
|
|
iCountErrors++;
|
|
printerr( "Error_398ty! Expected exception not thrown");
|
|
}
|
|
catch (ArgumentNullException)
|
|
{
|
|
}
|
|
catch (Exception exc)
|
|
{
|
|
iCountErrors++;
|
|
printerr( "Error_298t7! Unexpected exception, exc=="+exc.ToString());
|
|
}
|
|
m_PortSetEvent.Reset();
|
|
Thread tcpListenerThread = new Thread(new ThreadStart(Co5651ReadString.StartListeningTcp));
|
|
tcpListenerThread.Start();
|
|
Console.WriteLine("Listening");
|
|
Thread.Sleep( 1000 );
|
|
m_PortSetEvent.WaitOne();
|
|
Teleport("127.0.0.1");
|
|
Thread.Sleep( 1000 );
|
|
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 );
|
|
String iTemp ;
|
|
for(int i = 0 ; i < strArr.Length ; i++)
|
|
{
|
|
iTemp = br.ReadString();
|
|
if(iTemp != strArr[i])
|
|
{
|
|
iCountErrors++;
|
|
Console.WriteLine( "Error_0000_"+i+"! Expected=="+strArr[i]+", got=="+iTemp);
|
|
}
|
|
}
|
|
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 < strArr.Length ; i++)
|
|
bw.Write(strArr[i]);
|
|
}
|
|
public static void Main(String[] args)
|
|
{
|
|
bool bResult = false;
|
|
Co5651ReadString cbA = new Co5651ReadString();
|
|
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;
|
|
}
|
|
}
|