Does this code look like it will work as expected for asynchronous
operations? Or, do my calls to stream.Read and socket.Send need to be
changed to stream.BeginRea d and socket.BeginSen d?
Thanks
// AsyncTest.cs
using System;
using System.Diagnost ics;
using System.IO;
using System.Net;
using System.Net.Sock ets;
using System.Text;
namespace JLCoady
{
public class AsyncTest
{
#region Fields
private int dataBufferSize = 512;
private int totalBytes;
#endregion
#region Properties
//--------------------------------------------------------------------------
---------
public int DataBufferSize
{
get { return dataBufferSize; }
set { dataBufferSize = value; }
}
//--------------------------------------------------------------------------
---------
public int TotalBytes
{
get { return totalBytes; }
}
#endregion
#region Constructors
//--------------------------------------------------------------------------
---------
public AsyncTest()
{
}
#endregion
#region Methods
//--------------------------------------------------------------------------
---------
private Socket OpenSocket(stri ng hostName, int port)
{
if(hostName == null)
throw new ArgumentNullExc eption("hostNam e");
Trace.WriteLine (
string.Format(" {0}:{1}", hostName, port), "OpenSocket ");
Socket result = null;
try
{
result = new Socket(AddressF amily.InterNetw ork,
SocketType.Stre am,
ProtocolType.Tc p);
result.Connect(
new IPEndPoint(Dns. Resolve(hostNam e).AddressList[0], port));
}
catch(Exception exc)
{
CloseSocket(res ult);
throw new FtpException(st ring.Format(
"Could not connect to {0} on port {1}.", hostName, port),
exc);
}
return result;
}
//--------------------------------------------------------------------------
---------
private void CloseSocket(Soc ket socket)
{
Trace.WriteLine ("CloseSocket") ;
if(socket != null && socket.Connecte d)
{
socket.Close();
socket = null;
}
}
//--------------------------------------------------------------------------
---------
public void Send(string hostName, int port, Stream stream)
{
if(hostName == null)
throw new ArgumentNullExc eption("hostNam e");
if(stream == null)
throw new ArgumentNullExc eption("stream" );
Trace.WriteLine ("Send");
totalBytes = 0;
byte[] buffer = new byte[DataBufferSize];
Socket socket = OpenSocket(host Name, port);
int bytes = stream.Read(buf fer, 0, buffer.Length);
while(bytes > 0)
{
socket.Send(buf fer, bytes, SocketFlags.Non e);
totalBytes += bytes;
bytes = stream.Read(buf fer, 0, buffer.Length);
}
CloseSocket(soc ket);
}
//--------------------------------------------------------------------------
---------
private delegate void SendCallback(st ring hostName, int port, Stream
stream);
private SendCallback send;
//--------------------------------------------------------------------------
---------
public IAsyncResult BeginSend(strin g hostName, int port, Stream
stream,
AsyncCallback callback, object state)
{
if(hostName == null)
throw new ArgumentNullExc eption("hostNam e");
if(stream == null)
throw new ArgumentNullExc eption("stream" );
Trace.WriteLine ("BeginSend" );
if(send == null)
send = new SendCallback(th is.Send);
return send.BeginInvok e(hostName, port, stream, callback, state);
}
//--------------------------------------------------------------------------
---------
public void EndSend(IAsyncR esult asyncResult)
{
if(asyncResult == null)
throw new ArgumentNullExc eption("asyncRe sult");
Trace.WriteLine ("EndSend");
if(!asyncResult .IsCompleted)
asyncResult.Asy ncWaitHandle.Wa itOne();
send.EndInvoke( asyncResult);
}
#endregion
}
}
"Joshua Coady" <jo**@coady.u s> wrote in message
news:eH******** ******@tk2msftn gp13.phx.gbl...
I am writing a class that includes several async methods following the
BeginXxx, EndXxx pattern. Some of these methods will call methods in the
framework such as Stream.Read or Socket.Send. Do I need to, or is it
recommended to use the async method calls instead (Stream.BeginRe ad, etc)?
Example:
MyMethod()
{
//...
Stream.Read();// I know this method requires parameters
//
// Should it be this instead?
// Stream.BeginRea d();
// Stream.EndRead( );
//...
}
BeginMyMethod()
{
}
EndMyMethod()
{
}
Thanks,
Josh
