Synchronous call in Async method?

[Joshua Coady]

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

[Joshua Coady]

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