Receive()

int Terraria.Social.WeGame.WeGameP2PReader.Receive ( RailID user, byte[] buffer, int bufferOffset, int bufferSize )

inline

Definition at line 155 of file WeGameP2PReader.cs.

    {
        uint num = 0u;
        lock (_pendingReadBuffers)
        {
            if (!_pendingReadBuffers.ContainsKey(user))
            {
                return 0;
            }
            Queue<ReadResult> queue = _pendingReadBuffers[user];
            while (queue.Count > 0)
            {
                ReadResult readResult = queue.Peek();
                uint num2 = Math.Min((uint)bufferSize - num, readResult.Size - readResult.Offset);
                if (num2 == 0)
                {
                    return (int)num;
                }
                Array.Copy(readResult.Data, readResult.Offset, buffer, bufferOffset + num, num2);
                if (num2 == readResult.Size - readResult.Offset)
                {
                    _bufferPool.Enqueue(queue.Dequeue().Data);
                }
                else
                {
                    readResult.Offset += num2;
                }
                num += num2;
            }
            return (int)num;
        }
    }

References Terraria.Social.WeGame.WeGameP2PReader._bufferPool, Terraria.Social.WeGame.WeGameP2PReader._pendingReadBuffers, System.buffer, System.Collections.Generic.Dictionary< TKey, TValue >.ContainsKey(), System.Array.Copy(), System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.Collections.Generic.Queue< T >.Enqueue(), and System.Math.Min().

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