Hello,

It has been nice performing simple server/client tests with the XF.Server control over the past 24hrs. We now want to start implementing into our current project, but would appreciate any feedback in the following scenario:
1. Server Starts Listening (Network.AcceptAsync....)
2. Client ConnectAsync, onConnectComplete calls server.ReadAsync(delegate) and waits
3. Server begins to stream 1 - 8192byte data buffers

This is where we are running into problems, as we seem to only get the first buffer to the client. In the client readcomplete delegate, we are

buffer.Acquire();
work on buffer data
buffer.Release
calling connection.ReadAsync(delegate) ready for next buffer of data from server

We are missing something, if someone could provide additional help so we can overcome this problem. The final objective would be a open connection between client and server with constant flow of adhoc data at any time, any buffer length, either end.

Kind Regards,
Troy

Thank you, below is the basic code/concept we need:

SERVER:
private void StartTCPServer()
{
using (var listener =
Network.AcceptAsync(new IPEndPoint(IPAddress.Any, 4040),
ProcessClient, new ExtendedParameters { BufferSize = 8192, Optimized = false }))
{
Console.WriteLine("Server is ready to accept connections at {0}.", listener.EndPoint);
Console.WriteLine("Press any key to exit.");
Console.ReadKey(true);
}
}

private static void ProcessClient(IConnection connection)
{
WriteCompleteDelegate c = new WriteCompleteDelegate(WriteComplete);

List<byte[]> dataList = GetData();//reason for this List is each byte[8192] has its own mini header
foreach (byte[] data in dataList)
{
connection.WriteAsync(data, c);
}

}

public static void WriteComplete(IConnection connection, int i)
{
}



CLIENT:
public string Connect3()
{
data = new List<PacketStaffHeader>();

Network.ConnectAsync(new IPEndPoint(IPAddress.Parse(serverIP), 4040), OnConnectComplete, OnConnectError);

return string.Empty;
}


private void OnConnectError(int errorCode)
{
Console.WriteLine("Error code: {0}", errorCode);
}



private void OnConnectComplete(IConnection server)
{
ReadCompleteDelegate c = new ReadCompleteDelegate(ReadComplete);

server.ReadAsync(c);
}

private static List<PacketStaffHeader> data = new List<PacketStaffHeader>();

public static void ReadComplete(IConnection server, IMemoryBuffer buffer)
{
if (buffer == null) return;
buffer.Acquire();
PacketHeader header = new PacketStuff().UnpackHeader(buffer.Data);
buffer.Release();
data.Add(header);
if (data.Count == header.PacketCount)
{
ProcessAllData(data);
}
ReadCompleteDelegate c = new ReadCompleteDelegate(ReadComplete);
server.ReadAsync(c);
}