Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / fx / src / Data / Microsoft / SqlServer / Server / SmiSettersStream.cs / 1 / SmiSettersStream.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace Microsoft.SqlServer.Server { using System; using System.Data.Common; using System.Data.SqlClient; using System.Diagnostics; using System.IO; internal class SmiSettersStream : Stream { private SmiEventSink_Default _sink; private ITypedSettersV3 _setters; private int _ordinal; private long _lengthWritten; private SmiMetaData _metaData; internal SmiSettersStream( SmiEventSink_Default sink, ITypedSettersV3 setters, int ordinal, SmiMetaData metaData ) { Debug.Assert( null != sink ); Debug.Assert( null != setters ); Debug.Assert( 0 <= ordinal ); Debug.Assert( null != metaData ); _sink = sink; _setters = setters; _ordinal = ordinal; _lengthWritten = 0; _metaData = metaData; } public override bool CanRead { get { return false; } } // If CanSeek is false, Position, Seek, Length, and SetLength should throw. public override bool CanSeek { get { return false; } } public override bool CanWrite { get { return true; } } public override long Length { get { return _lengthWritten; } } public override long Position { get { return _lengthWritten; } set { throw SQL.StreamSeekNotSupported(); } } public override void Flush() { _lengthWritten = ValueUtilsSmi.SetBytesLength(_sink, _setters, _ordinal, _metaData, _lengthWritten); } public override long Seek(long offset, SeekOrigin origin) { throw SQL.StreamSeekNotSupported(); } public override void SetLength(long value) { if ( value < 0 ) { throw ADP.ArgumentOutOfRange("value"); } ValueUtilsSmi.SetBytesLength(_sink, _setters, _ordinal, _metaData, value); } public override int Read(byte[] buffer, int offset, int count) { throw SQL.StreamReadNotSupported(); } public override void Write(byte[] buffer, int offset, int count) { _lengthWritten += ValueUtilsSmi.SetBytes(_sink, _setters, _ordinal, _metaData, _lengthWritten, buffer, offset, count); } } } // 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.Data.SqlClient; using System.Diagnostics; using System.IO; internal class SmiSettersStream : Stream { private SmiEventSink_Default _sink; private ITypedSettersV3 _setters; private int _ordinal; private long _lengthWritten; private SmiMetaData _metaData; internal SmiSettersStream( SmiEventSink_Default sink, ITypedSettersV3 setters, int ordinal, SmiMetaData metaData ) { Debug.Assert( null != sink ); Debug.Assert( null != setters ); Debug.Assert( 0 <= ordinal ); Debug.Assert( null != metaData ); _sink = sink; _setters = setters; _ordinal = ordinal; _lengthWritten = 0; _metaData = metaData; } public override bool CanRead { get { return false; } } // If CanSeek is false, Position, Seek, Length, and SetLength should throw. public override bool CanSeek { get { return false; } } public override bool CanWrite { get { return true; } } public override long Length { get { return _lengthWritten; } } public override long Position { get { return _lengthWritten; } set { throw SQL.StreamSeekNotSupported(); } } public override void Flush() { _lengthWritten = ValueUtilsSmi.SetBytesLength(_sink, _setters, _ordinal, _metaData, _lengthWritten); } public override long Seek(long offset, SeekOrigin origin) { throw SQL.StreamSeekNotSupported(); } public override void SetLength(long value) { if ( value < 0 ) { throw ADP.ArgumentOutOfRange("value"); } ValueUtilsSmi.SetBytesLength(_sink, _setters, _ordinal, _metaData, value); } public override int Read(byte[] buffer, int offset, int count) { throw SQL.StreamReadNotSupported(); } public override void Write(byte[] buffer, int offset, int count) { _lengthWritten += ValueUtilsSmi.SetBytes(_sink, _setters, _ordinal, _metaData, _lengthWritten, buffer, offset, count); } } } // 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
- XmlQueryStaticData.cs
- SiteMapNodeItem.cs
- MimeTypePropertyAttribute.cs
- QilCloneVisitor.cs
- TextTrailingCharacterEllipsis.cs
- SyntaxCheck.cs
- PerformanceCounterPermissionEntry.cs
- DeferredElementTreeState.cs
- WebPartConnection.cs
- DelegateHelpers.Generated.cs
- GAC.cs
- KeyedPriorityQueue.cs
- SqlClientWrapperSmiStreamChars.cs
- SqlOuterApplyReducer.cs
- CompilerParameters.cs
- ImageSourceValueSerializer.cs
- ApplicationSecurityInfo.cs
- filewebrequest.cs
- UseAttributeSetsAction.cs
- DifferencingCollection.cs
- ShapingEngine.cs
- AssociationSet.cs
- RawStylusActions.cs
- BindingManagerDataErrorEventArgs.cs
- JoinCqlBlock.cs
- CdpEqualityComparer.cs
- DataGridViewElement.cs
- TextElementEnumerator.cs
- TabPanel.cs
- _NetworkingPerfCounters.cs
- Nodes.cs
- RuleSettings.cs
- RuleAction.cs
- XomlCompilerError.cs
- ConsumerConnectionPoint.cs
- WebConfigurationManager.cs
- XmlParserContext.cs
- BitmapFrameEncode.cs
- ServicePoint.cs
- IteratorFilter.cs
- ProfileProvider.cs
- Int64.cs
- EditingScope.cs
- TextRunCache.cs
- CompilerGeneratedAttribute.cs
- SafePEFileHandle.cs
- SafeNativeMethodsMilCoreApi.cs
- LambdaCompiler.Logical.cs
- ActivityAction.cs
- TaiwanCalendar.cs
- Triangle.cs
- Crypto.cs
- _NegoState.cs
- WindowsSlider.cs
- SuppressIldasmAttribute.cs
- DataContract.cs
- PackWebResponse.cs
- GlobalizationAssembly.cs
- OrderedDictionaryStateHelper.cs
- FormatConvertedBitmap.cs
- GeometryHitTestParameters.cs
- DataRecord.cs
- TreeView.cs
- BitmapSource.cs
- XamlSerializer.cs
- RelationshipWrapper.cs
- TraceLog.cs
- DocumentPageView.cs
- AdRotatorDesigner.cs
- ViewStateException.cs
- NamespaceInfo.cs
- EntityDataSourceSelectingEventArgs.cs
- WebPartCollection.cs
- MaskedTextBoxDesignerActionList.cs
- InstancePersistenceCommand.cs
- Queue.cs
- jithelpers.cs
- CompilerScope.Storage.cs
- RectAnimation.cs
- GridItem.cs
- LinearGradientBrush.cs
- ScriptingRoleServiceSection.cs
- Utils.cs
- AssemblyResourceLoader.cs
- SafeBitVector32.cs
- ResourceContainer.cs
- DataGridViewHitTestInfo.cs
- Vector3DConverter.cs
- AuthenticationService.cs
- DBSchemaTable.cs
- SqlDependency.cs
- CatalogZoneBase.cs
- UniqueContractNameValidationBehavior.cs
- XmlCharacterData.cs
- ContractMapping.cs
- IconConverter.cs
- FormViewDeleteEventArgs.cs
- RelatedImageListAttribute.cs
- ImageListUtils.cs
- WebPartCollection.cs