Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / clr / src / ManagedLibraries / Remoting / Channels / CORE / SocketStream.cs / 1305376 / SocketStream.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== //========================================================================== // File: SocketStream.cs // // Summary: Stream used for reading from a socket by remoting channels. // //========================================================================= using System; using System.IO; using System.Runtime.Remoting; using System.Net; using System.Net.Sockets; namespace System.Runtime.Remoting.Channels { // Basically the same as NetworkStream, but adds support for timeouts. internal sealed class SocketStream : Stream { private Socket _socket; private int _timeout = 0; // throw timout exception if a read takes longer than this many milliseconds // as per http://support.microsoft.com/default.aspx?scid=kb%3ben-us%3b201213 // we shouldn't write more than 64K synchronously to a socket const int maxSocketWrite = 64 * 1024; // 64k const int maxSocketRead = 4 * 1024 * 1024; // 4 MB public SocketStream(Socket socket) { if (socket == null) throw new ArgumentNullException("socket"); _socket = socket; } // SocketStream // Stream implementation public override bool CanRead { get { return true; } } public override bool CanSeek { get { return false; } } public override bool CanWrite { get { return true; } } public override long Length { get { throw new NotSupportedException(); } } public override long Position { get { throw new NotSupportedException(); } set { throw new NotSupportedException(); } } // Position public override long Seek(long offset, SeekOrigin origin) { throw new NotSupportedException(); } public override int Read(byte[] buffer, int offset, int size) { if (_timeout <= 0) { return _socket.Receive(buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None); } else { IAsyncResult ar = _socket.BeginReceive(buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None, null, null); if (_timeout>0 && !ar.IsCompleted) { ar.AsyncWaitHandle.WaitOne(_timeout, false); if (!ar.IsCompleted) throw new RemotingTimeoutException(); } return _socket.EndReceive(ar); } } // Read public override void Write(byte[] buffer, int offset, int count) { int bytesToWrite = count; while (bytesToWrite > 0) { count = Math.Min(bytesToWrite, maxSocketWrite); _socket.Send(buffer, offset, count, SocketFlags.None); bytesToWrite -= count; offset += count; } } // Write protected override void Dispose(bool disposing) { try { if (disposing) _socket.Close(); } finally { base.Dispose(disposing); } } public override void Flush() {} public override IAsyncResult BeginRead( byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { IAsyncResult asyncResult = _socket.BeginReceive( buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None, callback, state); return asyncResult; } // BeginRead public override int EndRead(IAsyncResult asyncResult) { return _socket.EndReceive(asyncResult); } // EndRead public override IAsyncResult BeginWrite( byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { IAsyncResult asyncResult = _socket.BeginSend( buffer, offset, size, SocketFlags.None, callback, state); return asyncResult; } // BeginWrite public override void EndWrite(IAsyncResult asyncResult) { _socket.EndSend(asyncResult); } // EndWrite public override void SetLength(long value) { throw new NotSupportedException(); } } // class SocketStream } // namespace System.Runtime.Remoting.Channels // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== //========================================================================== // File: SocketStream.cs // // Summary: Stream used for reading from a socket by remoting channels. // //========================================================================= using System; using System.IO; using System.Runtime.Remoting; using System.Net; using System.Net.Sockets; namespace System.Runtime.Remoting.Channels { // Basically the same as NetworkStream, but adds support for timeouts. internal sealed class SocketStream : Stream { private Socket _socket; private int _timeout = 0; // throw timout exception if a read takes longer than this many milliseconds // as per http://support.microsoft.com/default.aspx?scid=kb%3ben-us%3b201213 // we shouldn't write more than 64K synchronously to a socket const int maxSocketWrite = 64 * 1024; // 64k const int maxSocketRead = 4 * 1024 * 1024; // 4 MB public SocketStream(Socket socket) { if (socket == null) throw new ArgumentNullException("socket"); _socket = socket; } // SocketStream // Stream implementation public override bool CanRead { get { return true; } } public override bool CanSeek { get { return false; } } public override bool CanWrite { get { return true; } } public override long Length { get { throw new NotSupportedException(); } } public override long Position { get { throw new NotSupportedException(); } set { throw new NotSupportedException(); } } // Position public override long Seek(long offset, SeekOrigin origin) { throw new NotSupportedException(); } public override int Read(byte[] buffer, int offset, int size) { if (_timeout <= 0) { return _socket.Receive(buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None); } else { IAsyncResult ar = _socket.BeginReceive(buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None, null, null); if (_timeout>0 && !ar.IsCompleted) { ar.AsyncWaitHandle.WaitOne(_timeout, false); if (!ar.IsCompleted) throw new RemotingTimeoutException(); } return _socket.EndReceive(ar); } } // Read public override void Write(byte[] buffer, int offset, int count) { int bytesToWrite = count; while (bytesToWrite > 0) { count = Math.Min(bytesToWrite, maxSocketWrite); _socket.Send(buffer, offset, count, SocketFlags.None); bytesToWrite -= count; offset += count; } } // Write protected override void Dispose(bool disposing) { try { if (disposing) _socket.Close(); } finally { base.Dispose(disposing); } } public override void Flush() {} public override IAsyncResult BeginRead( byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { IAsyncResult asyncResult = _socket.BeginReceive( buffer, offset, Math.Min(size, maxSocketRead), SocketFlags.None, callback, state); return asyncResult; } // BeginRead public override int EndRead(IAsyncResult asyncResult) { return _socket.EndReceive(asyncResult); } // EndRead public override IAsyncResult BeginWrite( byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { IAsyncResult asyncResult = _socket.BeginSend( buffer, offset, size, SocketFlags.None, callback, state); return asyncResult; } // BeginWrite public override void EndWrite(IAsyncResult asyncResult) { _socket.EndSend(asyncResult); } // EndWrite public override void SetLength(long value) { throw new NotSupportedException(); } } // class SocketStream } // namespace System.Runtime.Remoting.Channels // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ProfileParameter.cs
- Point.cs
- UInt32Converter.cs
- NavigationExpr.cs
- DynamicRendererThreadManager.cs
- DataGridViewCellToolTipTextNeededEventArgs.cs
- OdbcDataAdapter.cs
- BitVec.cs
- Matrix.cs
- GZipStream.cs
- ReachBasicContext.cs
- XmlSchemaComplexType.cs
- WebHttpSecurityModeHelper.cs
- Int16Storage.cs
- ForeignConstraint.cs
- TdsParserHelperClasses.cs
- PartitionedStream.cs
- ApplicationServicesHostFactory.cs
- CodeAttributeDeclarationCollection.cs
- SqlConnectionPoolProviderInfo.cs
- WebPartDeleteVerb.cs
- Item.cs
- Internal.cs
- BaseProcessor.cs
- DesignerProperties.cs
- AuthenticodeSignatureInformation.cs
- CodeDelegateCreateExpression.cs
- DispatcherEventArgs.cs
- QilChoice.cs
- EventDescriptorCollection.cs
- CurrencyWrapper.cs
- InputReportEventArgs.cs
- TemplateAction.cs
- ExtensionSurface.cs
- FormView.cs
- RadialGradientBrush.cs
- LoginView.cs
- MetricEntry.cs
- PrivacyNoticeBindingElementImporter.cs
- DataPagerCommandEventArgs.cs
- DockPatternIdentifiers.cs
- DnsPermission.cs
- DecoderFallback.cs
- ArrayItemValue.cs
- LinqDataView.cs
- WindowInteropHelper.cs
- RequestNavigateEventArgs.cs
- PropertiesTab.cs
- RoutedCommand.cs
- RSAOAEPKeyExchangeDeformatter.cs
- InlineCollection.cs
- TemplatePropertyEntry.cs
- LiteralText.cs
- SoapRpcServiceAttribute.cs
- QilGeneratorEnv.cs
- PackageRelationshipSelector.cs
- ThreadAttributes.cs
- DataContract.cs
- DataRelationPropertyDescriptor.cs
- DropShadowEffect.cs
- WsatTransactionInfo.cs
- ListViewAutomationPeer.cs
- SrgsDocumentParser.cs
- CodeAttributeDeclaration.cs
- DecimalAnimationUsingKeyFrames.cs
- COM2PropertyBuilderUITypeEditor.cs
- ResourcesChangeInfo.cs
- RegexRunnerFactory.cs
- ReferencedAssembly.cs
- PropagatorResult.cs
- FixedTextSelectionProcessor.cs
- wgx_sdk_version.cs
- HtmlShim.cs
- WindowsProgressbar.cs
- AudioFormatConverter.cs
- NavigationProgressEventArgs.cs
- BCryptHashAlgorithm.cs
- TextEditorSelection.cs
- FileLevelControlBuilderAttribute.cs
- DrawingAttributes.cs
- EncryptedReference.cs
- AccessDataSourceView.cs
- WebPartsSection.cs
- SqlRetyper.cs
- DataRowComparer.cs
- PropertyItem.cs
- AmbiguousMatchException.cs
- Speller.cs
- LexicalChunk.cs
- DefaultDialogButtons.cs
- FastEncoder.cs
- AdapterDictionary.cs
- XmlSerializerFactory.cs
- FontInfo.cs
- embossbitmapeffect.cs
- ValidationErrorCollection.cs
- XmlDigitalSignatureProcessor.cs
- ObjectDataSourceView.cs
- COM2ColorConverter.cs
- XmlEventCache.cs