test 1 - using memorystream

main
syneffort 2 years ago
parent 1c2b35345a
commit b4fb2a3e69
  1. 22
      SocketStudy/PComm/PClient.cs

@ -184,6 +184,7 @@ namespace PComm
if (dataSize >= BUFF_SIZE) if (dataSize >= BUFF_SIZE)
Thread.Sleep(100); Thread.Sleep(100);
byte[] receivedData = new byte[dataSize];
using (MemoryStream ms = new MemoryStream(dataSize)) using (MemoryStream ms = new MemoryStream(dataSize))
{ {
while (dataSize > 0) while (dataSize > 0)
@ -201,18 +202,19 @@ namespace PComm
dataSize -= receiveSize; dataSize -= receiveSize;
} }
byte[] receivedData = ms.ToArray(); receivedData = ms.ToArray();
byte[] data; }
if (isCompressed)
data = PUtil.DecompressBytes(receivedData);
else
data = receivedData;
if (OnReceived != null) byte[] data;
OnReceived(this, dataType, data); if (isCompressed)
data = PUtil.DecompressBytes(receivedData);
else
data = receivedData;
socket.BeginReceive(new byte[] { 0 }, 0, 0, 0, AcceptCallback, null); if (OnReceived != null)
} OnReceived(this, dataType, data);
socket.BeginReceive(new byte[] { 0 }, 0, 0, 0, AcceptCallback, null);
} }
catch (Exception ex) catch (Exception ex)
{ {

Loading…
Cancel
Save