Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WCF / Log / System / IO / Log / FileLogRecordEnumerator.cs / 1305376 / FileLogRecordEnumerator.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.IO.Log { using System; using System.Collections; using System.Collections.Generic; internal class FileLogRecordEnumerable : IEnumerable{ LogRecordEnumeratorType logRecordEnum; SimpleFileLog log; SequenceNumber start; bool enumRestartAreas; internal FileLogRecordEnumerable( SimpleFileLog log, SequenceNumber start, LogRecordEnumeratorType logRecordEnum, bool enumRestartAreas) { this.log = log; this.start = start; this.logRecordEnum = logRecordEnum; this.enumRestartAreas = enumRestartAreas; } IEnumerator IEnumerable.GetEnumerator() { return this.GetEnumerator(); } public IEnumerator GetEnumerator() { return new FileLogRecordEnumerator( log, start, logRecordEnum, enumRestartAreas); } } internal class FileLogRecordEnumerator : IEnumerator { FileLogRecordStream stream = null; FileLogRecord record = null; bool enumStarted = false; SequenceNumber start; SequenceNumber current; LogRecordEnumeratorType logRecordEnum; SimpleFileLog log; bool disposed = false; bool enumRestartAreas; internal FileLogRecordEnumerator( SimpleFileLog log, SequenceNumber start, LogRecordEnumeratorType logRecordEnum, bool enumRestartAreas) { this.log = log; this.start = start; this.current = start; this.logRecordEnum = logRecordEnum; this.enumRestartAreas = enumRestartAreas; } object IEnumerator.Current { get { return this.Current; } } public LogRecord Current { get { if (this.disposed) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); // IEnumerable interface contract for "current" member can throw InvalidOperationException. Suppressing this warning. if (!this.enumStarted) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.EnumNotStarted()); if (this.record == null) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.EnumEnded()); return this.record; } } public bool MoveNext() { if (this.disposed) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); if (this.current == SequenceNumber.Invalid) return false; if (!this.enumStarted) { this.enumStarted = true; } else { switch (this.logRecordEnum) { case LogRecordEnumeratorType.Next: this.current = this.stream.NextLsn; break; case LogRecordEnumeratorType.Previous: this.current = this.stream.Header.PreviousLsn; break; case LogRecordEnumeratorType.User: this.current = this.stream.Header.NextUndoLsn; break; } } SequenceNumber first; SequenceNumber last; log.GetLogLimits(out first, out last); if (this.current < first || last < this.current || this.current == SequenceNumber.Invalid) { this.record = null; return false; } this.stream = new FileLogRecordStream(this.log, this.current); if (!this.enumRestartAreas && this.stream.Header.IsRestartArea) { if (this.logRecordEnum == LogRecordEnumeratorType.Next) { // Move to the next record after restart area. return MoveNext(); } else { // We have hit a restart area. // Restart areas have special values for prev and next undo in the header. // Cannot enumerate further. this.record = null; return false; } } this.record = new FileLogRecord(this.stream); return true; } public void Reset() { if (this.disposed) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); this.enumStarted = false; this.current = this.start; this.record = null; } public void Dispose() { this.disposed = true; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.IO.Log { using System; using System.Collections; using System.Collections.Generic; internal class FileLogRecordEnumerable : IEnumerable { LogRecordEnumeratorType logRecordEnum; SimpleFileLog log; SequenceNumber start; bool enumRestartAreas; internal FileLogRecordEnumerable( SimpleFileLog log, SequenceNumber start, LogRecordEnumeratorType logRecordEnum, bool enumRestartAreas) { this.log = log; this.start = start; this.logRecordEnum = logRecordEnum; this.enumRestartAreas = enumRestartAreas; } IEnumerator IEnumerable.GetEnumerator() { return this.GetEnumerator(); } public IEnumerator GetEnumerator() { return new FileLogRecordEnumerator( log, start, logRecordEnum, enumRestartAreas); } } internal class FileLogRecordEnumerator : IEnumerator { FileLogRecordStream stream = null; FileLogRecord record = null; bool enumStarted = false; SequenceNumber start; SequenceNumber current; LogRecordEnumeratorType logRecordEnum; SimpleFileLog log; bool disposed = false; bool enumRestartAreas; internal FileLogRecordEnumerator( SimpleFileLog log, SequenceNumber start, LogRecordEnumeratorType logRecordEnum, bool enumRestartAreas) { this.log = log; this.start = start; this.current = start; this.logRecordEnum = logRecordEnum; this.enumRestartAreas = enumRestartAreas; } object IEnumerator.Current { get { return this.Current; } } public LogRecord Current { get { if (this.disposed) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); // IEnumerable interface contract for "current" member can throw InvalidOperationException. Suppressing this warning. if (!this.enumStarted) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.EnumNotStarted()); if (this.record == null) #pragma warning suppress 56503 throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.EnumEnded()); return this.record; } } public bool MoveNext() { if (this.disposed) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); if (this.current == SequenceNumber.Invalid) return false; if (!this.enumStarted) { this.enumStarted = true; } else { switch (this.logRecordEnum) { case LogRecordEnumeratorType.Next: this.current = this.stream.NextLsn; break; case LogRecordEnumeratorType.Previous: this.current = this.stream.Header.PreviousLsn; break; case LogRecordEnumeratorType.User: this.current = this.stream.Header.NextUndoLsn; break; } } SequenceNumber first; SequenceNumber last; log.GetLogLimits(out first, out last); if (this.current < first || last < this.current || this.current == SequenceNumber.Invalid) { this.record = null; return false; } this.stream = new FileLogRecordStream(this.log, this.current); if (!this.enumRestartAreas && this.stream.Header.IsRestartArea) { if (this.logRecordEnum == LogRecordEnumeratorType.Next) { // Move to the next record after restart area. return MoveNext(); } else { // We have hit a restart area. // Restart areas have special values for prev and next undo in the header. // Cannot enumerate further. this.record = null; return false; } } this.record = new FileLogRecord(this.stream); return true; } public void Reset() { if (this.disposed) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ObjectDisposed()); this.enumStarted = false; this.current = this.start; this.record = null; } public void Dispose() { this.disposed = true; } } } // 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
- TypedRowHandler.cs
- CodeObjectCreateExpression.cs
- DataBindingCollection.cs
- ThreadStaticAttribute.cs
- FixedHighlight.cs
- SpellerStatusTable.cs
- KeyValueConfigurationCollection.cs
- GridViewRowCollection.cs
- GlyphInfoList.cs
- WSSecureConversationDec2005.cs
- login.cs
- NetworkInformationPermission.cs
- LabelAutomationPeer.cs
- PartitionResolver.cs
- UserNameSecurityTokenAuthenticator.cs
- PeerEndPoint.cs
- PropertyGroupDescription.cs
- SoapConverter.cs
- ParseHttpDate.cs
- Metafile.cs
- InputProcessorProfilesLoader.cs
- XmlNotation.cs
- BinaryWriter.cs
- Point3DCollection.cs
- WebPartConnection.cs
- XmlSchemaCollection.cs
- _FixedSizeReader.cs
- RetrieveVirtualItemEventArgs.cs
- Icon.cs
- DataSourceCacheDurationConverter.cs
- SparseMemoryStream.cs
- Rotation3D.cs
- EventLogPermissionAttribute.cs
- ExpressionVisitor.cs
- RecommendedAsConfigurableAttribute.cs
- CompoundFileIOPermission.cs
- EndPoint.cs
- ClientApiGenerator.cs
- NullRuntimeConfig.cs
- PathFigureCollectionValueSerializer.cs
- Error.cs
- PrimitiveOperationFormatter.cs
- X509SubjectKeyIdentifierClause.cs
- DBConcurrencyException.cs
- FontConverter.cs
- ItemsPanelTemplate.cs
- SubstitutionDesigner.cs
- SweepDirectionValidation.cs
- DependencyObjectCodeDomSerializer.cs
- _NTAuthentication.cs
- ReadOnlyObservableCollection.cs
- DefaultTextStoreTextComposition.cs
- XmlWriterSettings.cs
- ContractTypeNameCollection.cs
- ArrangedElementCollection.cs
- Lock.cs
- EntityDataSourceMemberPath.cs
- SqlStream.cs
- XmlException.cs
- RestHandler.cs
- XmlName.cs
- Region.cs
- SymDocumentType.cs
- XmlSchemaSimpleContent.cs
- QilIterator.cs
- FontInfo.cs
- PermissionSet.cs
- LineProperties.cs
- HttpListenerPrefixCollection.cs
- CodeNamespace.cs
- ColorPalette.cs
- ValidatingCollection.cs
- OleDbStruct.cs
- AssemblyHash.cs
- DoubleAnimationUsingPath.cs
- CodeSubDirectory.cs
- GridErrorDlg.cs
- NavigationPropertySingletonExpression.cs
- TrackPointCollection.cs
- PageRequestManager.cs
- CompiledIdentityConstraint.cs
- AutomationElement.cs
- KeyValueConfigurationElement.cs
- QuaternionAnimationUsingKeyFrames.cs
- HMACMD5.cs
- AssemblyName.cs
- BitmapEffectGeneralTransform.cs
- CaseCqlBlock.cs
- RightsManagementUser.cs
- DefaultShape.cs
- RuntimeEnvironment.cs
- ButtonColumn.cs
- MatrixKeyFrameCollection.cs
- RightNameExpirationInfoPair.cs
- EditingScope.cs
- CaseCqlBlock.cs
- objectquery_tresulttype.cs
- PropertyItemInternal.cs
- DotExpr.cs
- MobileListItemCollection.cs