Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / TransactionBridge / Microsoft / Transactions / Wsat / Protocol / DebugTracing.cs / 1 / DebugTracing.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- // This file contains debug tracing support for the WS-AT protocol using System; using System.ServiceModel.Channels; using System.Diagnostics; using System.Globalization; using System.ServiceModel; using System.Threading; using Microsoft.Transactions.Bridge; using Microsoft.Transactions.Wsat.Messaging; using Microsoft.Transactions.Wsat.InputOutput; using Microsoft.Transactions.Wsat.StateMachines; namespace Microsoft.Transactions.Wsat.Protocol { class DebugTracingEventSink : IIncomingEventSink { // // Generic trace methods // void TraceGenericEvent (SynchronizationEvent e) { DebugTrace.TxTrace (TraceLevel.Info, e.Enlistment.EnlistmentId, "{0}", e); } void TraceNotificationMessage (CompletionEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.Completion.ParticipantProxy) ); } void TraceNotificationMessage (CoordinatorEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.Coordinator.CoordinatorProxy) ); } void TraceNotificationMessage (VolatileCoordinatorEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.VolatileCoordinator.CoordinatorProxy) ); } void TraceNotificationMessage (ParticipantEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.Participant.ParticipantProxy) ); } void TraceTmEvent (ParticipantCallbackEvent e) { DebugTrace.TxTrace( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} for {1}", e, Ports.TryGetAddress(e.Participant.ParticipantProxy) ); } void TraceTmResponse (SynchronizationEvent e, Status status) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1}", e, status ); } void TraceTmEvent (CoordinatorCallbackEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} for {1}", e, Ports.TryGetAddress (e.Coordinator.CoordinatorProxy) ); } void TraceFault (MessageFault fault, SynchronizationEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1}: {2}", e, Library.GetFaultCodeName(fault), Library.GetFaultCodeReason(fault) ); } // // IIncomingEventSink implementation // public void OnEvent(MsgCreateTransactionEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0}", e ); } public void OnEvent(MsgEnlistTransactionEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0}{1}", e, e.Body.IssuedToken != null ? " with issued token" : string.Empty ); } public void OnEvent(TmCreateTransactionResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1}", e, e.Status ); } public void OnEvent(TmEnlistTransactionResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1}", e, e.Status ); } public void OnEvent(MsgRegisterCompletionEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} for {1} at {2}", e, ControlProtocol.Completion, Ports.TryGetAddress (e.Proxy) ); } public void OnEvent(MsgRegisterDurableResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.Coordinator.RegistrationProxy) ); } public void OnEvent(MsgRegisterVolatileResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} from {1}", e, Ports.TryGetAddress (e.VolatileCoordinator.Coordinator.RegistrationProxy) ); } public void OnEvent(MsgRegistrationCoordinatorFaultEvent e) { TraceFault (e.Fault, e); } public void OnEvent(MsgRegistrationCoordinatorSendFailureEvent e) { TraceGenericEvent (e); } public void OnEvent(TmRegisterResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1} for {2}", e, e.Status, e.Participant.ControlProtocol ); } public void OnEvent(TmSubordinateRegisterResponseEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} {1} for {2}", e, e.Status, e.Participant.ControlProtocol ); } public void OnEvent(TmEnlistPrePrepareEvent e) { TraceGenericEvent (e); } public void OnEvent(MsgCompletionCommitEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgCompletionRollbackEvent e) { TraceNotificationMessage (e); } public void OnEvent(TmCompletionCommitResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(TmCompletionRollbackResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(MsgVolatilePrepareEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgDurablePrepareEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgVolatileCommitEvent e) { TraceNotificationMessage(e); } public void OnEvent(MsgDurableCommitEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgVolatileRollbackEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgDurableRollbackEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgDurableCoordinatorFaultEvent e) { TraceFault (e.Fault, e); } public void OnEvent(MsgVolatileCoordinatorFaultEvent e) { TraceFault (e.Fault, e); } public void OnEvent(MsgDurableCoordinatorSendFailureEvent e) { TraceGenericEvent (e); } public void OnEvent(MsgVolatileCoordinatorSendFailureEvent e) { TraceGenericEvent (e); } public void OnEvent(MsgPreparedEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgAbortedEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgReadOnlyEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgCommittedEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgReplayEvent e) { TraceNotificationMessage (e); } public void OnEvent(MsgParticipantFaultEvent e) { TraceFault (e.Fault, e); } public void OnEvent(MsgParticipantSendFailureEvent e) { TraceGenericEvent (e); } public void OnEvent(TmPrePrepareResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(TmPrepareResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(TmCommitResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(TmRollbackResponseEvent e) { TraceTmResponse (e, e.Status); } public void OnEvent(TmPrePrepareEvent e) { TraceTmEvent (e); } public void OnEvent(TmPrepareEvent e) { TraceTmEvent (e); } public void OnEvent(TmSinglePhaseCommitEvent e) { TraceTmEvent(e); } public void OnEvent(TmCommitEvent e) { TraceTmEvent (e); } public void OnEvent(TmRollbackEvent e) { TraceTmEvent (e); } public void OnEvent(TmParticipantForgetEvent e) { TraceTmEvent (e); } public void OnEvent(TmRejoinEvent e) { TraceTmEvent (e); } public void OnEvent(TmReplayEvent e) { TraceTmEvent (e); } public void OnEvent(TmCoordinatorForgetEvent e) { TraceTmEvent (e); } public void OnEvent(TmAsyncRollbackEvent e) { TraceGenericEvent (e); } public void OnEvent(TimerCoordinatorEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} for coordinator at {1}", e, Ports.TryGetAddress (e.Coordinator.CoordinatorProxy) ); } public void OnEvent(TimerParticipantEvent e) { DebugTrace.TxTrace ( TraceLevel.Info, e.Enlistment.EnlistmentId, "{0} for {1} participant at {2}", e, e.Participant.ControlProtocol, Ports.TryGetAddress (e.Participant.ParticipantProxy) ); } public void OnEvent(InternalEnlistSubordinateTransactionEvent e) { TraceGenericEvent(e); } public void OnEvent(TransactionContextEnlistTransactionEvent e) { TraceGenericEvent(e); } public void OnEvent(TransactionContextCreatedEvent e) { TraceGenericEvent(e); } public void OnEvent(TransactionContextTransactionDoneEvent e) { TraceGenericEvent(e); } } } // 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
- WebMessageEncoderFactory.cs
- CodeObjectCreateExpression.cs
- DataListItem.cs
- DynamicValidatorEventArgs.cs
- ModulesEntry.cs
- QueryOperator.cs
- DescriptionAttribute.cs
- AnimatedTypeHelpers.cs
- TextLineBreak.cs
- QueryOptionExpression.cs
- EntityClientCacheKey.cs
- Operand.cs
- XsltLoader.cs
- TargetInvocationException.cs
- KeyConstraint.cs
- ListControl.cs
- HotSpotCollectionEditor.cs
- ChoiceConverter.cs
- TogglePattern.cs
- NumericUpDown.cs
- ProfileProvider.cs
- WebPartExportVerb.cs
- BaseDataList.cs
- ThreadInterruptedException.cs
- OptimalTextSource.cs
- PolyQuadraticBezierSegment.cs
- AgileSafeNativeMemoryHandle.cs
- EntityObject.cs
- GeometryDrawing.cs
- ILGenerator.cs
- Rect.cs
- BitmapImage.cs
- MultiDataTrigger.cs
- MetadataItem_Static.cs
- Helper.cs
- Size3D.cs
- ConfigXmlElement.cs
- DecoderNLS.cs
- SolidColorBrush.cs
- DateTimeOffsetStorage.cs
- OrderedDictionaryStateHelper.cs
- XmlReaderSettings.cs
- ApplicationTrust.cs
- WaitHandleCannotBeOpenedException.cs
- ParserStreamGeometryContext.cs
- TemplateBamlTreeBuilder.cs
- PipeSecurity.cs
- SqlDataSourceCustomCommandEditor.cs
- Int64.cs
- TimeoutConverter.cs
- CodeMemberProperty.cs
- XmlDictionaryWriter.cs
- RankException.cs
- Matrix.cs
- DataGridCaption.cs
- WorkflowOperationBehavior.cs
- ServiceObjectContainer.cs
- XdrBuilder.cs
- ErrorFormatterPage.cs
- XmlWriterSettings.cs
- DependencyPropertyAttribute.cs
- IQueryable.cs
- XmlSchemaGroup.cs
- FlowLayoutPanelDesigner.cs
- _UriTypeConverter.cs
- securitymgrsite.cs
- CopyEncoder.cs
- EntityDataSourceChangedEventArgs.cs
- SqlError.cs
- AnnotationObservableCollection.cs
- validationstate.cs
- ServiceDebugElement.cs
- ExpressionEditorAttribute.cs
- Thread.cs
- NumericExpr.cs
- XmlKeywords.cs
- DataGridViewBand.cs
- Utils.cs
- GridPatternIdentifiers.cs
- ProcessHostMapPath.cs
- PtsHelper.cs
- DesignTimeResourceProviderFactoryAttribute.cs
- HyperLinkStyle.cs
- SerTrace.cs
- RecordBuilder.cs
- Point4D.cs
- TypeUtil.cs
- Inflater.cs
- TransformerConfigurationWizardBase.cs
- DispatcherProcessingDisabled.cs
- MailHeaderInfo.cs
- RuleInfoComparer.cs
- SystemWebCachingSectionGroup.cs
- SamlAttribute.cs
- ScrollBar.cs
- XmlSchemaExternal.cs
- Solver.cs
- TypeDescriptorFilterService.cs
- WebPart.cs
- TemplateBamlTreeBuilder.cs