Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / ndp / fx / src / Net / System / Net / Sockets / _TransmitFileOverlappedAsyncResult.cs / 1 / _TransmitFileOverlappedAsyncResult.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net.Sockets { using System; using System.Net; using System.IO; using System.Runtime.InteropServices; using System.Threading; using Microsoft.Win32; // // OverlappedAsyncResult - used to take care of storage for async Socket operation // from the BeginSend, BeginSendTo, BeginReceive, BeginReceiveFrom calls. // internal class TransmitFileOverlappedAsyncResult : BaseOverlappedAsyncResult { // // internal class members // private FileStream m_fileStream; private TransmitFileOptions m_flags; private TransmitFileBuffers m_buffers; // Constructor. We take in the socket that's creating us, the caller's // state object, and the buffer on which the I/O will be performed. // We save the socket and state, pin the callers's buffer, and allocate // an event for the WaitHandle. // internal TransmitFileOverlappedAsyncResult(Socket socket, Object asyncState, AsyncCallback asyncCallback) : base(socket, asyncState, asyncCallback) { } internal TransmitFileOverlappedAsyncResult(Socket socket):base(socket){ } // // SetUnmanagedStructures - // Fills in Overlapped Structures used in an Async Overlapped Winsock call // these calls are outside the runtime and are unmanaged code, so we need // to prepare specific structures and ints that lie in unmanaged memory // since the Overlapped calls can be Async // internal void SetUnmanagedStructures(byte[] preBuffer, byte[] postBuffer, FileStream fileStream, TransmitFileOptions flags, bool sync) { // // fill in flags if we use it. // m_fileStream = fileStream; m_flags = flags; // // Fill in Buffer Array structure that will be used for our send/recv Buffer // m_buffers = null; int buffsNumber = 0; if (preBuffer != null && preBuffer.Length>0) ++buffsNumber; if (postBuffer != null && postBuffer.Length>0) ++buffsNumber; object[] objectsToPin = null; if (buffsNumber != 0) { ++buffsNumber; objectsToPin = new object[buffsNumber]; m_buffers = new TransmitFileBuffers(); objectsToPin[--buffsNumber] = m_buffers; if (preBuffer != null && preBuffer.Length>0) { m_buffers.preBufferLength = preBuffer.Length; objectsToPin[--buffsNumber] = preBuffer; } if (postBuffer != null && postBuffer.Length>0) { m_buffers.postBufferLength = postBuffer.Length; objectsToPin[--buffsNumber] = postBuffer; } if (sync) { base.PinUnmanagedObjects(objectsToPin); } else { base.SetUnmanagedStructures(objectsToPin); } if (preBuffer != null && preBuffer.Length > 0) { m_buffers.preBuffer = Marshal.UnsafeAddrOfPinnedArrayElement(preBuffer, 0); } if (postBuffer != null && postBuffer.Length > 0) { m_buffers.postBuffer = Marshal.UnsafeAddrOfPinnedArrayElement(postBuffer, 0); } } else if (!sync) { base.SetUnmanagedStructures(null); } } // SetUnmanagedStructures() internal void SetUnmanagedStructures(byte[] preBuffer, byte[] postBuffer, FileStream fileStream, TransmitFileOptions flags, ref OverlappedCache overlappedCache) { SetupCache(ref overlappedCache); SetUnmanagedStructures(preBuffer, postBuffer, fileStream, flags, false); } // Utility cleanup routine. Frees pinned and unmanged memory. // protected override void ForceReleaseUnmanagedStructures() { if (m_fileStream != null ) { m_fileStream.Close(); m_fileStream = null; } // // clenaup base class // base.ForceReleaseUnmanagedStructures(); } // CleanupUnmanagedStructures() internal void SyncReleaseUnmanagedStructures() { ForceReleaseUnmanagedStructures(); } internal TransmitFileBuffers TransmitFileBuffers{ get{ return m_buffers; } } internal TransmitFileOptions Flags{ get{ return m_flags; } } }; // class OverlappedAsyncResult } // namespace System.Net.Sockets
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Encoder.cs
- PriorityBinding.cs
- TypeLibConverter.cs
- InternalConfigConfigurationFactory.cs
- QueryResult.cs
- StylusTip.cs
- SqlExpressionNullability.cs
- WebServiceClientProxyGenerator.cs
- ComponentEditorForm.cs
- ProjectionCamera.cs
- QilValidationVisitor.cs
- StatusBarDrawItemEvent.cs
- CompositeTypefaceMetrics.cs
- AttributeCollection.cs
- ScriptingRoleServiceSection.cs
- EDesignUtil.cs
- XPathDocument.cs
- XamlPathDataSerializer.cs
- SessionEndedEventArgs.cs
- CapabilitiesSection.cs
- FtpRequestCacheValidator.cs
- xdrvalidator.cs
- AutomationIdentifier.cs
- CodeDesigner.cs
- HashAlgorithm.cs
- AuthenticationService.cs
- CodeDirectoryCompiler.cs
- DataKey.cs
- PersonalizationDictionary.cs
- PerfCounters.cs
- TransactionScope.cs
- StatusBarAutomationPeer.cs
- Highlights.cs
- ImageKeyConverter.cs
- SkipQueryOptionExpression.cs
- IHttpResponseInternal.cs
- ReferentialConstraintRoleElement.cs
- Profiler.cs
- MaterialCollection.cs
- DomainUpDown.cs
- ColumnTypeConverter.cs
- Permission.cs
- ComponentConverter.cs
- PropertyValue.cs
- ComponentManagerBroker.cs
- TableLayoutRowStyleCollection.cs
- DescendantQuery.cs
- EventHandlersStore.cs
- SessionStateContainer.cs
- EncryptedKey.cs
- FlowDocument.cs
- JsonUriDataContract.cs
- HuffmanTree.cs
- dtdvalidator.cs
- GridViewPageEventArgs.cs
- TextElement.cs
- documentation.cs
- Msmq4SubqueuePoisonHandler.cs
- RemoteEndpointMessageProperty.cs
- oledbmetadatacolumnnames.cs
- LicenseProviderAttribute.cs
- GeometryModel3D.cs
- HyperlinkAutomationPeer.cs
- EdmComplexTypeAttribute.cs
- CompositionAdorner.cs
- BindingMAnagerBase.cs
- Animatable.cs
- Polygon.cs
- CompareValidator.cs
- WebPageTraceListener.cs
- ToolStripMenuItemDesigner.cs
- _DisconnectOverlappedAsyncResult.cs
- DataTablePropertyDescriptor.cs
- StringUtil.cs
- Button.cs
- EntityParameter.cs
- Header.cs
- InternalTypeHelper.cs
- WindowsGraphics2.cs
- TrackingMemoryStream.cs
- BasePattern.cs
- TiffBitmapEncoder.cs
- TimersDescriptionAttribute.cs
- sqlser.cs
- ServerIdentity.cs
- ProxyWebPartConnectionCollection.cs
- TargetException.cs
- BinaryCommonClasses.cs
- SiteMapProvider.cs
- ExpressionConverter.cs
- AspNetHostingPermission.cs
- ParameterExpression.cs
- CompilationLock.cs
- ByteStorage.cs
- BitmapImage.cs
- CodeStatementCollection.cs
- HttpValueCollection.cs
- Pair.cs
- DocumentAutomationPeer.cs
- WebScriptMetadataMessage.cs