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
- MethodImplAttribute.cs
- CompilerHelpers.cs
- TextParaClient.cs
- NullableLongSumAggregationOperator.cs
- MultipartIdentifier.cs
- FontWeightConverter.cs
- dtdvalidator.cs
- TableProvider.cs
- XmlC14NWriter.cs
- PersonalizationDictionary.cs
- ToolZone.cs
- StaticDataManager.cs
- PartialCachingAttribute.cs
- WindowsSlider.cs
- SingleObjectCollection.cs
- DbReferenceCollection.cs
- TextFormatterContext.cs
- ComponentDispatcherThread.cs
- TreeViewItemAutomationPeer.cs
- Camera.cs
- wgx_commands.cs
- DesignerDataConnection.cs
- SvcMapFile.cs
- ProfilePropertyNameValidator.cs
- Vector3DAnimationUsingKeyFrames.cs
- TextServicesCompartment.cs
- SlipBehavior.cs
- TopClause.cs
- TableRowCollection.cs
- ContextStack.cs
- ObjectView.cs
- PresentationTraceSources.cs
- SelectorAutomationPeer.cs
- TraceContextRecord.cs
- securitycriticaldata.cs
- StringDictionaryEditor.cs
- IPipelineRuntime.cs
- ProgressiveCrcCalculatingStream.cs
- TableLayout.cs
- FieldBuilder.cs
- ZipIOFileItemStream.cs
- ScopelessEnumAttribute.cs
- BitmapImage.cs
- ValidationErrorEventArgs.cs
- KeysConverter.cs
- HttpProcessUtility.cs
- EventSchemaTraceListener.cs
- ThreadPool.cs
- Comparer.cs
- XmlSiteMapProvider.cs
- ErrorsHelper.cs
- XmlSerializationWriter.cs
- Ref.cs
- PageSetupDialog.cs
- PropertyChangedEventManager.cs
- RuntimeConfigLKG.cs
- XmlUnspecifiedAttribute.cs
- VisualStateGroup.cs
- ImagingCache.cs
- HWStack.cs
- AmbientProperties.cs
- System.Data_BID.cs
- HTMLTextWriter.cs
- WhitespaceSignificantCollectionAttribute.cs
- WindowsImpersonationContext.cs
- ManipulationVelocities.cs
- Qualifier.cs
- DbDataRecord.cs
- ProviderMetadataCachedInformation.cs
- PolyBezierSegment.cs
- DataContractSet.cs
- Subtree.cs
- CompositionAdorner.cs
- RangeBase.cs
- SqlStatistics.cs
- VirtualDirectoryMapping.cs
- WebColorConverter.cs
- CodeStatement.cs
- ResourcesChangeInfo.cs
- HyperLinkColumn.cs
- Solver.cs
- MappingSource.cs
- HttpResponseHeader.cs
- InheritanceAttribute.cs
- ApplyTemplatesAction.cs
- ImpersonationOption.cs
- MulticastNotSupportedException.cs
- ZipFileInfoCollection.cs
- UnionCodeGroup.cs
- TextRangeEditLists.cs
- TimeZoneInfo.cs
- Vector3DCollection.cs
- XhtmlBasicTextBoxAdapter.cs
- Condition.cs
- AssemblyName.cs
- PtsHelper.cs
- Renderer.cs
- ExclusiveTcpTransportManager.cs
- ConfigurationStrings.cs
- ExpressionParser.cs