QueueSend()

void Terraria.Social.WeGame.WeGameP2PWriter.QueueSend ( RailID user, byte[] data, int length )

inline

Definition at line 40 of file WeGameP2PWriter.cs.

    {
        lock (_lock)
        {
            Queue<WriteInformation> queue2 = (_pendingSendData.ContainsKey(user) ? _pendingSendData[user] : (_pendingSendData[user] = new Queue<WriteInformation>()));
            int num = length;
            int num2 = 0;
            while (num > 0)
            {
                WriteInformation writeInformation;
                if (queue2.Count == 0 || 1024 - queue2.Peek().Size == 0)
                {
                    writeInformation = ((_bufferPool.Count <= 0) ? new WriteInformation() : new WriteInformation(_bufferPool.Dequeue()));
                    queue2.Enqueue(writeInformation);
                }
                else
                {
                    writeInformation = queue2.Peek();
                }
                int num3 = Math.Min(num, 1024 - writeInformation.Size);
                Array.Copy(data, num2, writeInformation.Data, writeInformation.Size, num3);
                writeInformation.Size += num3;
                num -= num3;
                num2 += num3;
            }
        }
    }

References Terraria.Social.WeGame.WeGameP2PWriter._bufferPool, Terraria.Social.WeGame.WeGameP2PWriter._lock, Terraria.Social.WeGame.WeGameP2PWriter._pendingSendData, System.Collections.Generic.Dictionary< TKey, TValue >.ContainsKey(), System.Array.Copy(), System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.Collections.Generic.Queue< T >.Dequeue(), System.length, and System.Math.Min().

Referenced by Terraria.Social.WeGame.NetSocialModule.Send().