Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / fx / src / Data / System / Data / SqlClient / SqlClientWrapperSmiStream.cs / 1 / SqlClientWrapperSmiStream.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace Microsoft.SqlServer.Server { using System; using System.Data.Common; using System.Diagnostics; using System.IO; // Simple wrapper over SmiStream that handles server events on the SqlClient side of Smi internal class SqlClientWrapperSmiStream : Stream { private SmiEventSink_Default _sink; private SmiStream _stream; internal SqlClientWrapperSmiStream( SmiEventSink_Default sink, SmiStream stream ) { Debug.Assert( null != sink ); Debug.Assert( null != stream ); _sink = sink; _stream = stream; } public override bool CanRead { get { return _stream.CanRead; } } // If CanSeek is false, Position, Seek, Length, and SetLength should throw. public override bool CanSeek { get { return _stream.CanSeek; } } public override bool CanWrite { get { return _stream.CanWrite; } } public override long Length { get { long length = _stream.GetLength( _sink ); _sink.ProcessMessagesAndThrow(); return length; } } public override long Position { get { long position = _stream.GetPosition( _sink ); _sink.ProcessMessagesAndThrow(); return position; } set { _stream.SetPosition( _sink, value ); _sink.ProcessMessagesAndThrow(); } } public override void Flush() { _stream.Flush( _sink ); _sink.ProcessMessagesAndThrow(); } public override long Seek(long offset, SeekOrigin origin) { long result = _stream.Seek( _sink, offset, origin ); _sink.ProcessMessagesAndThrow(); return result; } public override void SetLength(long value) { _stream.SetLength( _sink, value ); _sink.ProcessMessagesAndThrow(); } public override int Read(byte[] buffer, int offset, int count) { int bytesRead = _stream.Read( _sink, buffer, offset, count ); _sink.ProcessMessagesAndThrow(); return bytesRead; } public override void Write(byte[] buffer, int offset, int count) { _stream.Write( _sink, buffer, offset, count ); _sink.ProcessMessagesAndThrow(); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace Microsoft.SqlServer.Server { using System; using System.Data.Common; using System.Diagnostics; using System.IO; // Simple wrapper over SmiStream that handles server events on the SqlClient side of Smi internal class SqlClientWrapperSmiStream : Stream { private SmiEventSink_Default _sink; private SmiStream _stream; internal SqlClientWrapperSmiStream( SmiEventSink_Default sink, SmiStream stream ) { Debug.Assert( null != sink ); Debug.Assert( null != stream ); _sink = sink; _stream = stream; } public override bool CanRead { get { return _stream.CanRead; } } // If CanSeek is false, Position, Seek, Length, and SetLength should throw. public override bool CanSeek { get { return _stream.CanSeek; } } public override bool CanWrite { get { return _stream.CanWrite; } } public override long Length { get { long length = _stream.GetLength( _sink ); _sink.ProcessMessagesAndThrow(); return length; } } public override long Position { get { long position = _stream.GetPosition( _sink ); _sink.ProcessMessagesAndThrow(); return position; } set { _stream.SetPosition( _sink, value ); _sink.ProcessMessagesAndThrow(); } } public override void Flush() { _stream.Flush( _sink ); _sink.ProcessMessagesAndThrow(); } public override long Seek(long offset, SeekOrigin origin) { long result = _stream.Seek( _sink, offset, origin ); _sink.ProcessMessagesAndThrow(); return result; } public override void SetLength(long value) { _stream.SetLength( _sink, value ); _sink.ProcessMessagesAndThrow(); } public override int Read(byte[] buffer, int offset, int count) { int bytesRead = _stream.Read( _sink, buffer, offset, count ); _sink.ProcessMessagesAndThrow(); return bytesRead; } public override void Write(byte[] buffer, int offset, int count) { _stream.Write( _sink, buffer, offset, count ); _sink.ProcessMessagesAndThrow(); } } } // 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
- MenuItem.cs
- ZoneIdentityPermission.cs
- FactoryId.cs
- DefaultValueTypeConverter.cs
- OutputCacheSection.cs
- MaskedTextBoxDesignerActionList.cs
- MissingManifestResourceException.cs
- QilXmlReader.cs
- XmlnsDictionary.cs
- CompensateDesigner.cs
- _SslState.cs
- RegexReplacement.cs
- KeyEvent.cs
- XmlDataProvider.cs
- AbstractSvcMapFileLoader.cs
- PageHandlerFactory.cs
- DataGridItem.cs
- PlaceHolder.cs
- DocobjHost.cs
- UpdatePanelControlTrigger.cs
- ToolStripScrollButton.cs
- CookielessHelper.cs
- RewritingSimplifier.cs
- ApplicationProxyInternal.cs
- DataGridViewControlCollection.cs
- XmlChildNodes.cs
- RangeContentEnumerator.cs
- WorkflowTraceTransfer.cs
- SchemaImporterExtensionElement.cs
- LocationSectionRecord.cs
- Dictionary.cs
- Panel.cs
- Command.cs
- CqlQuery.cs
- HostingEnvironment.cs
- SqlXml.cs
- XmlSchemaAttribute.cs
- ButtonPopupAdapter.cs
- InputMethodStateChangeEventArgs.cs
- keycontainerpermission.cs
- GetPageNumberCompletedEventArgs.cs
- SpellerStatusTable.cs
- WebPartTransformerCollection.cs
- DatatypeImplementation.cs
- ProjectionPath.cs
- MenuItemBinding.cs
- XmlCharType.cs
- DataGridViewBand.cs
- RemotingConfiguration.cs
- TypeElement.cs
- TabPage.cs
- RequestResizeEvent.cs
- ServiceOperation.cs
- BasicDesignerLoader.cs
- XmlDownloadManager.cs
- WebEvents.cs
- DataGridViewEditingControlShowingEventArgs.cs
- TypeSource.cs
- tooltip.cs
- CollectionViewGroup.cs
- NativeMethodsCLR.cs
- HttpClientCertificate.cs
- ToolStripRendererSwitcher.cs
- controlskin.cs
- AccessControlList.cs
- HGlobalSafeHandle.cs
- TextSchema.cs
- MetadataArtifactLoader.cs
- UnwrappedTypesXmlSerializerManager.cs
- KeyEvent.cs
- XmlWhitespace.cs
- storepermissionattribute.cs
- LinearKeyFrames.cs
- TableRowCollection.cs
- ToolStripContentPanel.cs
- CodeAccessSecurityEngine.cs
- DataViewManagerListItemTypeDescriptor.cs
- TextDpi.cs
- WebServiceErrorEvent.cs
- ToolStripItem.cs
- StringUtil.cs
- CodeRemoveEventStatement.cs
- ListViewDeleteEventArgs.cs
- EmitterCache.cs
- DataControlField.cs
- DBSqlParserColumn.cs
- WindowCollection.cs
- documentation.cs
- HitTestFilterBehavior.cs
- ValidationErrorCollection.cs
- SoapException.cs
- QilTargetType.cs
- TransactionFilter.cs
- RangeContentEnumerator.cs
- HuffModule.cs
- PasswordRecovery.cs
- ValueUtilsSmi.cs
- InkCanvasSelection.cs
- MonthCalendar.cs
- RawStylusActions.cs