1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
|
while (true)
{
if (stream.CanRead)
{
byte[] buffer = new byte[1024];
int numberByteRead = 0;
mem = new MemoryStream();
while (stream.DataAvailable)
{
numberByteRead = stream.Read(buffer, 0, buffer.Length);
//mem.Write(buffer, (int)mem.Length, numberByteRead);
mem.Write(buffer, 0, numberByteRead);
}
if (mem.Length > 0)
{
Object o = SerializationTools.Deserialize(mem.GetBuffer());
if (o.GetType() == tankInformation.GetType())
{
lock (mutexTankInformation)
{
this.tankInformation = (TankInformation)o;
}
serv.AddTankToUpdate(this.id);
Console.WriteLine("Server\tX : " + tankInformation.GetX() + " --- Y : " + tankInformation.GetY());
}
}
}
} |
Partager