Jump to content

View more

Image of the Day

The night is still, but the invasion brings chaos. #screenshotsaturday #hanako #indiegame #gameart #ue4 #samurai https://t.co/cgILXuokoS
IOTD | Top Screenshots

The latest, straight to your Inbox.

Subscribe to GameDev.net Direct to receive the latest updates and exclusive content.


Sign up now

Blocking collection return the wrong byte array

4: Adsense

Old topic!

Guest, the last post of this topic is over 60 days old and at this point you may not reply in this topic. If you wish to continue this conversation start a new topic.


  • You cannot reply to this topic
1 reply to this topic

#1 MJLaukala   Members   

110
Like
0Likes
Like

Posted 10 July 2012 - 05:45 PM

I am having an issue where an object with a byte[20] is being passed into a BlockingCollection on one thread and another thread returning the object with a byte[0] using BlockingCollection.Take(). I think this is a threading issue but I do not know where or why this is happening considering that BlockingCollection is a concurrent collection.

Sometimes on thread2, myclass2.mybytes equals byte[0]. Any information on how to fix this is greatly appreciated.

MessageBuffer.cs

public class MessageBuffer : BlockingCollection<Message>
	{
	}

In the class that has Listener() and ReceivedMessageHandler(object messageProcessor)

private MessageBuffer RecievedMessageBuffer;

On Thread1

private void Listener()
		{
			while (this.IsListening)
			{
				try
				{
					Message message = Message.ReadMessage(this.Stream, this);
					if (message != null)
					{
						this.RecievedMessageBuffer.Add(message);
					}
				}
				catch (IOException ex)
				{
					if (!this.Client.Connected)
					{
						this.OnDisconnected();
					}
					else
					{
						Logger.LogException(ex.ToString());
						this.OnDisconnected();
					}
				}
				catch (Exception ex)
				{
					Logger.LogException(ex.ToString());
					this.OnDisconnected();
				}
			}
		}

Message.ReadMessage(NetworkStream stream, iTcpConnectClient client)

public static Message ReadMessage(NetworkStream stream, iTcpConnectClient client)
		{
			int ClassType = -1;
			Message message = null;

			try
			{
				ClassType = stream.ReadByte();
				if (ClassType == -1)
				{
					return null;
				}

				if (!Message.IDTOCLASS.ContainsKey((byte)ClassType))
				{
					throw new IOException("Class type not found");
				}

				message = Message.GetNewMessage((byte)ClassType);
				message.Client = client;
				message.ReadData(stream);

				if (message.Buffer.Length < message.MessageSize + Message.HeaderSize)
				{
					return null;
				}

			}
			catch (IOException ex)
			{
				Logger.LogException(ex.ToString());
				throw ex;
			}
			catch (Exception ex)
			{
				Logger.LogException(ex.ToString());
				//throw ex;
			}

			return message;
		}

On Thread2

private void ReceivedMessageHandler(object messageProcessor)
		{
			if (messageProcessor != null)
			{
				while (this.IsListening)
				{
					Message message = this.RecievedMessageBuffer.Take();
					message.Reconstruct();
					message.HandleMessage(messageProcessor);
				}
			}
			else
			{
				while (this.IsListening)
				{
					Message message = this.RecievedMessageBuffer.Take();
					message.Reconstruct();
					message.HandleMessage();
				}
			}
		}

PlayerStateMessage.cs

public class PlayerStateMessage : Message
	{
		public GameObject PlayerState;

		public override int MessageSize
		{
			get { return 12; }
		}

		public PlayerStateMessage()
			: base()
		{
			this.PlayerState = new GameObject();
		}

		public PlayerStateMessage(GameObject playerState)
		{
			this.PlayerState = playerState;
		}

		public override void Reconstruct()
		{
			this.PlayerState.Poisiton = this.GetVector2FromBuffer(0);
			this.PlayerState.Rotation = this.GetFloatFromBuffer(8);
			base.Reconstruct();
		}

		public override void Deconstruct()
		{
			this.CreateBuffer();
			this.AddToBuffer(this.PlayerState.Poisiton, 0);
			this.AddToBuffer(this.PlayerState.Rotation, 8);
			base.Deconstruct();
		}

		public override void HandleMessage(object messageProcessor)
		{
			((MessageProcessor)messageProcessor).ProcessPlayerStateMessage(this);
		}
	}

Message.GetVector2FromBuffer(int bufferlocation)
This is where the exception is thrown because this.Buffer is byte[0] when it should be byte[20].

public Vector2 GetVector2FromBuffer(int bufferlocation)
		{
			return new Vector2(
				BitConverter.ToSingle(this.Buffer, Message.HeaderSize + bufferlocation),
				BitConverter.ToSingle(this.Buffer, Message.HeaderSize + bufferlocation + 4));
		}


#2 hplus0603   Moderators   

11125
Like
0Likes
Like

Posted 10 July 2012 - 08:00 PM

You're not showing the implementation of GetNewMessage(). It's quite possible you have more than one reference to the same message in your program.
enum Bool { True, False, FileNotFound };




Old topic!

Guest, the last post of this topic is over 60 days old and at this point you may not reply in this topic. If you wish to continue this conversation start a new topic.