Problem with Socket Receive

[irfanullah]

I have written an application for Receiving Stock Market Feed over a 2 Mbps Connection with Exchange with average incoming data of 800kbps.

The program works fine for sometime i.e. for an hour or so but then it throws SocketException Saying "An Operation on socket could not be performed because the system lacked sufficient buffer space ir because a queue was full".

But in my program i am receiving it very fast that on my internal LAN it works fine for 24 hours without any problem.

But in production environment it throws this exception after sometime i.e. 1.5 hours or 30 min or 15 min sometime. even i set buffer size 8k, 16k, 32k, 64k, 128k. still a problem.
Program is written in .Net Framework 1.1 using C#.

My ListenTCP code & Receive Data Code is like:

private void ListenTSTCPFeed ()
{
while(doRecieve TDFeed)
{
try
{
if(tdGatewaySoc ket.Poll(Config urations.POLL_T IMER,SelectMode .SelectRead) && tdGatewaySocket .Connected)
{
byte[] dataBuffer = ReceiveVarDataT weaked();
if(dataBuffer != null)
{
AddToQueue(data Buffer);
totalMessagesRe ceived++;
tdFeedProcessor .BeginInvoke(nu ll, null);
}
else
{
break;
}
}
else
{

#region Sleep Thread
Thread.Sleep(ne w TimeSpan(Net.Ta wasol.Config.Co nfigurations.ME SSAGES_PER_SECO ND));
#endregion
}
}
catch(NotSuppor tedException e)
{
//Start Fire Event OnDisConnection
TDConnectionSta tusEventArgs args = new TDConnectionSta tusEventArgs();
args.Message = "Unable to Connect with Reason:::: >> NotSupportedExc eption >>>"+e.Messag e;
OnDisConnection (args);
break;
//End Fire Event OnDisConnection
}
catch(SocketExc eption e)
{
//Start Fire Event OnDisConnection
TDConnectionSta tusEventArgs args = new TDConnectionSta tusEventArgs();
args.Message = "Unable to Connect with Reason:::: >> SocketException >>>"+e.Messag e;
OnDisConnection (args);
break;
//End Fire Event OnDisConnection
}
catch(ObjectDis posedException e)
{
//Start Fire Event OnDisConnection
TDConnectionSta tusEventArgs args = new TDConnectionSta tusEventArgs();
args.Message = "Unable to Connect with Reason:::: >> ObjectDisposedE xception >>>"+e.Messag e;
OnDisConnection (args);
break;
//End Fire Event OnDisConnection
}
}
Close(false);
}



{
int size;
byte[] datasize = new byte[4];
byte[] datasizeCopy = new byte[4];
byte[] data = new byte[0];
int i = 0;

#region Receive Bytes & Get Length of Data
while( i<4 )
{
try
{
i += tdGatewaySocket .Receive(datasi ze, i, 4-i, SocketFlags.Non e);
}
catch(Exception ex)
{
throw ex;
}
}

datasize.CopyTo (datasizeCopy, 0);

if(BitConverter .IsLittleEndian )
{
Array.Reverse(d atasize);
}

size = BitConverter.To Int32(datasize, 0);

try
{
data = new byte[size];
}
catch(Exception ome)
{
throw ome;
}
#endregion

#region Get Data Bytes
i = 0;
while(i < size)
{
try
{
int recv = tdGatewaySocket .Receive(data, i, size-i, SocketFlags.Non e);
if(recv == 0)
{
return null;
}
i += recv;
}
catch(Exception ex)
{
throw ex;
}
}
#endregion

byte[] msg = new byte[data.Length+4];
datasizeCopy.Co pyTo(msg, 0);
data.CopyTo(msg , 4);
DataReceived+=m sg.Length;
return msg;
}


Can anybody guide me about the problem.

Thanks.