Code:
/ FXUpdate3074 / FXUpdate3074 / 1.1 / DEVDIV / depot / DevDiv / releases / whidbey / QFE / ndp / fx / src / xsp / System / Web / Management / BufferedWebEventProvider.cs / 2 / BufferedWebEventProvider.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web.Management { using System; using System.Web; using System.Diagnostics; using System.Web.Util; using System.Web.Configuration; using System.Configuration.Provider; using System.Collections; using System.Collections.Specialized; using System.Configuration; using System.Security; using Debug=System.Web.Util.Debug; using System.Security.Permissions; // Interface for buffered event provider [AspNetHostingPermission(SecurityAction.LinkDemand, Level=AspNetHostingPermissionLevel.Minimal)] [AspNetHostingPermission(SecurityAction.InheritanceDemand, Level=AspNetHostingPermissionLevel.Minimal)] public abstract class BufferedWebEventProvider : WebEventProvider { bool _buffer = true; string _bufferMode; WebEventBuffer _webEventBuffer; public override void Initialize(string name, NameValueCollection config) { // create buffer according to the buffer mode settings specified, like we do in sql/mail providers // wire up the delegate to the ProcessEventFlush method Debug.Trace("BufferedWebEventProvider", "Initializing: name=" + name); ProviderUtil.GetAndRemoveBooleanAttribute(config, "buffer", name, ref _buffer); if (_buffer) { ProviderUtil.GetAndRemoveRequiredNonEmptyStringAttribute(config, "bufferMode", name, ref _bufferMode); _webEventBuffer = new WebEventBuffer(this, _bufferMode, new WebEventBufferFlushCallback(this.ProcessEventFlush)); } else { ProviderUtil.GetAndRemoveStringAttribute(config, "bufferMode", name, ref _bufferMode); } base.Initialize(name, config); ProviderUtil.CheckUnrecognizedAttributes(config, name); } public bool UseBuffering { get { return _buffer; } } public string BufferMode { get { return _bufferMode; } } public override void ProcessEvent(WebBaseEvent eventRaised) { if (_buffer) { // register the event with the buffer instead of writing it out Debug.Trace("BufferedWebEventProvider", "Saving event to buffer: event=" + eventRaised.GetType().Name); _webEventBuffer.AddEvent(eventRaised); } else { WebEventBufferFlushInfo flushInfo = new WebEventBufferFlushInfo( new WebBaseEventCollection(eventRaised), EventNotificationType.Unbuffered, 0, DateTime.MinValue, 0, 0); ProcessEventFlush(flushInfo); } } public abstract void ProcessEventFlush(WebEventBufferFlushInfo flushInfo); public override void Flush() { if (_buffer) { _webEventBuffer.Flush(Int32.MaxValue, FlushCallReason.StaticFlush); } } public override void Shutdown() { if (_webEventBuffer != null) { _webEventBuffer.Shutdown(); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web.Management { using System; using System.Web; using System.Diagnostics; using System.Web.Util; using System.Web.Configuration; using System.Configuration.Provider; using System.Collections; using System.Collections.Specialized; using System.Configuration; using System.Security; using Debug=System.Web.Util.Debug; using System.Security.Permissions; // Interface for buffered event provider [AspNetHostingPermission(SecurityAction.LinkDemand, Level=AspNetHostingPermissionLevel.Minimal)] [AspNetHostingPermission(SecurityAction.InheritanceDemand, Level=AspNetHostingPermissionLevel.Minimal)] public abstract class BufferedWebEventProvider : WebEventProvider { bool _buffer = true; string _bufferMode; WebEventBuffer _webEventBuffer; public override void Initialize(string name, NameValueCollection config) { // create buffer according to the buffer mode settings specified, like we do in sql/mail providers // wire up the delegate to the ProcessEventFlush method Debug.Trace("BufferedWebEventProvider", "Initializing: name=" + name); ProviderUtil.GetAndRemoveBooleanAttribute(config, "buffer", name, ref _buffer); if (_buffer) { ProviderUtil.GetAndRemoveRequiredNonEmptyStringAttribute(config, "bufferMode", name, ref _bufferMode); _webEventBuffer = new WebEventBuffer(this, _bufferMode, new WebEventBufferFlushCallback(this.ProcessEventFlush)); } else { ProviderUtil.GetAndRemoveStringAttribute(config, "bufferMode", name, ref _bufferMode); } base.Initialize(name, config); ProviderUtil.CheckUnrecognizedAttributes(config, name); } public bool UseBuffering { get { return _buffer; } } public string BufferMode { get { return _bufferMode; } } public override void ProcessEvent(WebBaseEvent eventRaised) { if (_buffer) { // register the event with the buffer instead of writing it out Debug.Trace("BufferedWebEventProvider", "Saving event to buffer: event=" + eventRaised.GetType().Name); _webEventBuffer.AddEvent(eventRaised); } else { WebEventBufferFlushInfo flushInfo = new WebEventBufferFlushInfo( new WebBaseEventCollection(eventRaised), EventNotificationType.Unbuffered, 0, DateTime.MinValue, 0, 0); ProcessEventFlush(flushInfo); } } public abstract void ProcessEventFlush(WebEventBufferFlushInfo flushInfo); public override void Flush() { if (_buffer) { _webEventBuffer.Flush(Int32.MaxValue, FlushCallReason.StaticFlush); } } public override void Shutdown() { if (_webEventBuffer != null) { _webEventBuffer.Shutdown(); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- EpmTargetPathSegment.cs
- HwndProxyElementProvider.cs
- UniqueIdentifierService.cs
- ProxyHelper.cs
- WebPartTracker.cs
- DataGridViewButtonCell.cs
- TextProperties.cs
- NativeMethods.cs
- MatrixCamera.cs
- ErrorsHelper.cs
- ObjectQueryProvider.cs
- FileSystemInfo.cs
- OneOf.cs
- FormView.cs
- AuthorizationRule.cs
- UInt64Converter.cs
- SrgsRuleRef.cs
- HttpApplicationFactory.cs
- XmlSerializerAssemblyAttribute.cs
- FixedSOMImage.cs
- ComAdminInterfaces.cs
- LoginAutoFormat.cs
- InputMethod.cs
- MetaModel.cs
- WebContext.cs
- SqlDependencyUtils.cs
- PasswordBoxAutomationPeer.cs
- ComponentConverter.cs
- MatchingStyle.cs
- SplitterEvent.cs
- StackSpiller.Generated.cs
- ReadOnlyCollectionBuilder.cs
- DependencyObject.cs
- Atom10FeedFormatter.cs
- PersonalizationProviderHelper.cs
- XmlCountingReader.cs
- CancellationTokenSource.cs
- PropertyCollection.cs
- IDQuery.cs
- ObjectDisposedException.cs
- XmlSerializerOperationGenerator.cs
- DateTime.cs
- ImageSource.cs
- IPEndPointCollection.cs
- EditorZoneAutoFormat.cs
- SortedDictionary.cs
- TextMetrics.cs
- FontWeightConverter.cs
- XpsResourceDictionary.cs
- ConnectionManagementElementCollection.cs
- WorkflowApplicationIdleEventArgs.cs
- HatchBrush.cs
- ChildTable.cs
- SchemaMapping.cs
- HMACSHA256.cs
- SessionPageStatePersister.cs
- ComponentResourceKeyConverter.cs
- HttpContextServiceHost.cs
- DoubleAnimationBase.cs
- TrustManagerMoreInformation.cs
- Select.cs
- ScalarType.cs
- DictionaryTraceRecord.cs
- BaseCodePageEncoding.cs
- AudioBase.cs
- BindingElementExtensionElement.cs
- InitializationEventAttribute.cs
- SimpleRecyclingCache.cs
- StreamGeometry.cs
- CounterSetInstance.cs
- ISessionStateStore.cs
- LinkArea.cs
- ComponentEditorPage.cs
- Utils.cs
- FontStretchConverter.cs
- WinFormsSpinner.cs
- AncillaryOps.cs
- InputScope.cs
- FileRecordSequenceHelper.cs
- SourceItem.cs
- JournalNavigationScope.cs
- Oid.cs
- TaiwanLunisolarCalendar.cs
- Effect.cs
- OutOfMemoryException.cs
- HostedImpersonationContext.cs
- SqlVisitor.cs
- DecoderFallback.cs
- RuntimeHandles.cs
- OwnerDrawPropertyBag.cs
- CalendarButtonAutomationPeer.cs
- StringFunctions.cs
- DoubleLinkList.cs
- SchemaAttDef.cs
- DataBoundControl.cs
- SqlDataSourceStatusEventArgs.cs
- PropertyGridEditorPart.cs
- RawStylusInput.cs
- TimeoutStream.cs
- CodeCommentStatement.cs