BeginReadCore()

unsafe IAsyncResult System.Net.HttpRequestStream.BeginReadCore ( byte[] buffer, int offset, int size, AsyncCallback callback, object state )

inline

Definition at line 295 of file HttpRequestStream.cs.

    {
        if (size == 0 || _closed)
        {
            HttpRequestStreamAsyncResult httpRequestStreamAsyncResult = new HttpRequestStreamAsyncResult(this, state, callback);
            httpRequestStreamAsyncResult.InvokeCallback(0u);
            return httpRequestStreamAsyncResult;
        }
        HttpRequestStreamAsyncResult httpRequestStreamAsyncResult2 = null;
        uint num = 0u;
        if (_dataChunkIndex != -1)
        {
            num = global::Interop.HttpApi.GetChunks(_httpContext.Request.RequestBuffer, _httpContext.Request.OriginalBlobAddress, ref _dataChunkIndex, ref _dataChunkOffset, buffer, offset, size);
            if (_dataChunkIndex != -1 && num == size)
            {
                httpRequestStreamAsyncResult2 = new HttpRequestStreamAsyncResult(_httpContext.RequestQueueBoundHandle, this, state, callback, buffer, offset, (uint)size, 0u);
                httpRequestStreamAsyncResult2.InvokeCallback(num);
            }
        }
        if (_dataChunkIndex == -1 && num < size)
        {
            if (System.Net.NetEventSource.Log.IsEnabled())
            {
                System.Net.NetEventSource.Info(this, "size:" + size + " offset:" + offset, "BeginReadCore");
            }
            uint num2 = 0u;
            offset += (int)num;
            size -= (int)num;
            if (size > 131072)
            {
                size = 131072;
            }
            httpRequestStreamAsyncResult2 = new HttpRequestStreamAsyncResult(_httpContext.RequestQueueBoundHandle, this, state, callback, buffer, offset, (uint)size, num);
            uint bytesReturned;
            try
            {
                fixed (byte* ptr = buffer)
                {
                    if (System.Net.NetEventSource.Log.IsEnabled())
                    {
                        System.Net.NetEventSource.Info(this, "Calling Interop.HttpApi.HttpReceiveRequestEntityBody", "BeginReadCore");
                    }
                    uint flags = 0u;
                    if (!_inOpaqueMode)
                    {
                        flags = 1u;
                    }
                    num2 = global::Interop.HttpApi.HttpReceiveRequestEntityBody(_httpContext.RequestQueueHandle, _httpContext.RequestId, flags, httpRequestStreamAsyncResult2._pPinnedBuffer, (uint)size, out bytesReturned, httpRequestStreamAsyncResult2._pOverlapped);
                    if (System.Net.NetEventSource.Log.IsEnabled())
                    {
                        System.Net.NetEventSource.Info(this, "Call to Interop.HttpApi.HttpReceiveRequestEntityBody returned:" + num2 + " dataRead:" + num, "BeginReadCore");
                    }
                }
            }
            catch (Exception ex)
            {
                if (System.Net.NetEventSource.Log.IsEnabled())
                {
                    System.Net.NetEventSource.Error(this, ex.ToString(), "BeginReadCore");
                }
                httpRequestStreamAsyncResult2.InternalCleanup();
                throw;
            }
            if (num2 != 0 && num2 != 997)
            {
                httpRequestStreamAsyncResult2.InternalCleanup();
                if (num2 != 38)
                {
                    Exception ex2 = new HttpListenerException((int)num2);
                    if (System.Net.NetEventSource.Log.IsEnabled())
                    {
                        System.Net.NetEventSource.Error(this, ex2.ToString(), "BeginReadCore");
                    }
                    httpRequestStreamAsyncResult2.InternalCleanup();
                    throw ex2;
                }
                httpRequestStreamAsyncResult2 = new HttpRequestStreamAsyncResult(this, state, callback, num);
                httpRequestStreamAsyncResult2.InvokeCallback(0u);
            }
            else if (num2 == 0 && HttpListener.SkipIOCPCallbackOnSuccess)
            {
                httpRequestStreamAsyncResult2.IOCompleted(num2, bytesReturned);
            }
        }
        return httpRequestStreamAsyncResult2;
    }

References System.Net.HttpRequestStream._closed, System.Net.HttpRequestStream._dataChunkIndex, System.Net.HttpRequestStream._dataChunkOffset, System.Net.HttpRequestStream._httpContext, System.Net.HttpRequestStream._inOpaqueMode, System.Net.HttpRequestStream.HttpRequestStreamAsyncResult._pOverlapped, System.Net.HttpRequestStream.HttpRequestStreamAsyncResult._pPinnedBuffer, System.buffer, System.Net.NetEventSource.Error(), System.Net.NetEventSource.Info(), System.Net.LazyAsyncResult.InternalCleanup(), System.Net.LazyAsyncResult.InvokeCallback(), System.Net.HttpRequestStream.HttpRequestStreamAsyncResult.IOCompleted(), System.Net.NetEventSource.Log, System.offset, System.Net.HttpListenerRequest.OriginalBlobAddress, System.Net.HttpListenerContext.Request, System.Net.HttpListenerRequest.RequestBuffer, System.Net.HttpListenerContext.RequestId, System.Net.HttpListenerContext.RequestQueueBoundHandle, System.Net.HttpListenerContext.RequestQueueHandle, System.Net.HttpListener.SkipIOCPCallbackOnSuccess, System.state, and System.Exception.ToString().

Referenced by System.Net.HttpRequestStream.BeginRead().