Receive()

int Terraria.Social.Steam.SteamP2PReader.Receive ( CSteamID user, byte[] buffer, int bufferOffset, int bufferSize )

inline

Definition at line 131 of file SteamP2PReader.cs.

    {
        //IL_0019: Unknown result type (might be due to invalid IL or missing references)
        //IL_002f: Unknown result type (might be due to invalid IL or missing references)
        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.Steam.SteamP2PReader._bufferPool, Terraria.Social.Steam.SteamP2PReader._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.Steam.NetSocialModule.Receive().