203m_Connection = connection; 261m_Connection = connection;

219GlobalLog.Print("ConnectStream#" + ValidationHelper.HashString(this) + "::.ctor() Connection:" + ValidationHelper.HashString(m_Connection) + " BytesToWrite:" + BytesLeftToWrite); 265m_ChunkParser = new ChunkParser(m_Connection, buffer, offset, bufferCount, 279GlobalLog.Print("ConnectStream#" + ValidationHelper.HashString(this) + "::.ctor() Connection:" + ValidationHelper.HashString(m_Connection) + 304return m_Connection; 408m_Connection.SetLeftoverBytes(leftoverBuffer, leftoverBufferOffset, leftoverBufferSize); 411m_Connection.ReadStartNextRequest(m_Request, ref returnResult); 431m_Connection.WriteStartNextRequest(m_Request, ref returnResult); 446m_Connection.SyncRead(m_Request, true, false); 635m_Connection.Write(bufferedData); 645m_Connection.Write(NclConstants.ChunkTerminator, 0, NclConstants.ChunkTerminator.Length); 664m_Connection.MultipleWrite(sendBuffers); 865GlobalLog.Print("ConnectStream#" + ValidationHelper.HashString(this) + "::BeginWrite " + ValidationHelper.HashString(m_Connection) + ", " + offset.ToString() + ", " + size.ToString()); 997m_Connection.BeginMultipleWrite(buffers, m_WriteCallbackDelegate, asyncResult); 1001m_Connection.MultipleWrite(buffers); 1095m_Connection.BeginWrite(buffer, offset, size, m_WriteCallbackDelegate, asyncResult); 1104m_Connection.Write(buffer, offset, size); 1207m_Connection.EndWrite(asyncResult); 1236m_Connection.EndMultipleWrite(asyncResult); 1630GlobalLog.Print("ConnectStream#" + ValidationHelper.HashString(this) + "::BeginRead() " + ValidationHelper.HashString(m_Connection) + ", " + offset.ToString() + ", " + size.ToString()); 1726GlobalLog.Enter("ConnectStream#" + ValidationHelper.HashString(this) + "::BeginReadWithoutValidation", ValidationHelper.HashString(m_Connection) + ", " + offset.ToString() + ", " + size.ToString()); 1789IAsyncResult asyncResult = m_Connection.BeginRead(buffer, offset, bytesToRead, callback, state); 1837bytesToRead = m_Connection.Read( 1876int bytesTransferred = thisConnectStream.m_Connection.EndRead(asyncResult); 1984bytesTransferred = m_Connection.EndRead(asyncResult); 2110GlobalLog.Enter("ConnectStream#" + ValidationHelper.HashString(stream) + "::WriteHeadersCallback", "Connection#" + ValidationHelper.HashString(stream.m_Connection) + ", " + request.WriteBufferLength.ToString()); 2113stream.m_Connection.EndWrite(ar); 2118if (stream.m_Connection.m_InnerException != null) 2119throw stream.m_Connection.m_InnerException; 2136stream.m_Connection.CheckStartReceive(request); 2138if (stream.m_Connection.m_InnerException != null) 2139throw stream.m_Connection.m_InnerException; 2169GlobalLog.Enter("ConnectStream#" + ValidationHelper.HashString(this) + "::WriteHeaders", "Connection#" + ValidationHelper.HashString(m_Connection) + ", headers buffer size = " + m_Request.WriteBufferLength.ToString()); 2189IAsyncResult ar = m_Connection.UnsafeBeginWrite(writeBuffer,0,writeBufferLength, m_WriteHeadersCallback, state); 2193m_Connection.EndWrite(ar); 2214m_Connection.Write(writeBuffer, 0, writeBufferLength); 2255m_Connection.CheckStartReceive(m_Request); 2260m_Connection.CheckStartReceive(m_Request); 2283if (!m_Connection.AtLeastOneResponseReceived && !m_Request.BodyStarted) { 2294m_Connection.AtLeastOneResponseReceived ? WebExceptionInternalStatus.Isolated : WebExceptionInternalStatus.RequestFatal, 2307TlsStream tlsStream = m_Connection.NetworkStream as TlsStream; 2320m_Connection.PollAndRead(m_Request, userRetrievedStream); 2335Connection connection = m_Connection; 2364Connection connection = m_Connection; 2445m_Connection.Write(NclConstants.ChunkTerminator, 0, NclConstants.ChunkTerminator.Length); 2449m_Connection.BeginWrite(NclConstants.ChunkTerminator, 0, NclConstants.ChunkTerminator.Length, new AsyncCallback(ResumeClose_Part2_Wrapper), userResult); 2463m_Connection.EndWrite(ar); 2480m_Connection.AbortSocket(true); 2580Connection connection = m_Connection; 2620m_Connection.Write(NclConstants.ChunkTerminator, 0, NclConstants.ChunkTerminator.Length); 2633m_Connection.AbortSocket(true); 2707m_Connection.AbortSocket(true); 2899m_Connection.AbortSocket(false); 2911NetworkStream networkStream = m_Connection.NetworkStream; 2962m_Connection.AbortSocket(false); 3023GlobalLog.Enter("ConnectStream#" + ValidationHelper.HashString(this) + "::IOError", "Connection# " + ValidationHelper.HashString(m_Connection)); 3049m_Connection.HandleConnectStreamException(true, false, WebExceptionStatus.SendFailure, ref returnResult, m_ErrorException); 3051m_Connection.HandleConnectStreamException(false, true, WebExceptionStatus.ReceiveFailure, ref returnResult, m_ErrorException);