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
- DataList.cs
- ObjectFactoryCodeDomTreeGenerator.cs
- ByteAnimation.cs
- ArrayMergeHelper.cs
- BindingFormattingDialog.cs
- ExtractorMetadata.cs
- ExtensionElement.cs
- SQLRoleProvider.cs
- Content.cs
- InvokeBinder.cs
- PreProcessInputEventArgs.cs
- XmlReflectionMember.cs
- StylusLogic.cs
- DataObjectEventArgs.cs
- OraclePermissionAttribute.cs
- SoapHeaders.cs
- PatternMatcher.cs
- ButtonStandardAdapter.cs
- DataGridViewTextBoxCell.cs
- UpdateRecord.cs
- WorkflowApplicationEventArgs.cs
- MarshalByRefObject.cs
- LogStore.cs
- AsynchronousChannel.cs
- TextShapeableCharacters.cs
- SessionStateItemCollection.cs
- DbException.cs
- DBCSCodePageEncoding.cs
- RangeValueProviderWrapper.cs
- ErrorWrapper.cs
- PublisherIdentityPermission.cs
- CodeTypeParameter.cs
- BevelBitmapEffect.cs
- ParallelActivityDesigner.cs
- CodeDomConfigurationHandler.cs
- TextViewBase.cs
- ListMarkerLine.cs
- XmlNodeReader.cs
- Visitor.cs
- ToolZone.cs
- ProfileProvider.cs
- Math.cs
- Button.cs
- dbdatarecord.cs
- SqlDataSourceQueryEditor.cs
- ParallelTimeline.cs
- HttpHandlersSection.cs
- ParseHttpDate.cs
- IntSecurity.cs
- EndPoint.cs
- CodeRemoveEventStatement.cs
- SimpleParser.cs
- StringInfo.cs
- WebPartUtil.cs
- documentation.cs
- BuildManager.cs
- HiddenFieldPageStatePersister.cs
- StateBag.cs
- MachineKeyConverter.cs
- SerialPinChanges.cs
- Queue.cs
- MenuEventArgs.cs
- DocumentViewerBaseAutomationPeer.cs
- IPAddress.cs
- SequenceRange.cs
- SmiTypedGetterSetter.cs
- TextEffect.cs
- SerialPort.cs
- EmptyImpersonationContext.cs
- PropertyChangingEventArgs.cs
- OneOfElement.cs
- PolyQuadraticBezierSegmentFigureLogic.cs
- RoleService.cs
- WindowsListView.cs
- RightsManagementUser.cs
- BamlResourceSerializer.cs
- Error.cs
- SchemaMapping.cs
- _emptywebproxy.cs
- ParseNumbers.cs
- ComponentResourceKeyConverter.cs
- SQLBytesStorage.cs
- DBConnection.cs
- FloatUtil.cs
- RolePrincipal.cs
- sqlcontext.cs
- UInt16.cs
- GeometryDrawing.cs
- PasswordRecoveryDesigner.cs
- SqlInternalConnectionSmi.cs
- LineBreakRecord.cs
- xmlfixedPageInfo.cs
- altserialization.cs
- RadialGradientBrush.cs
- FontStretches.cs
- SecurityDescriptor.cs
- StreamAsIStream.cs
- ManualResetEvent.cs
- PathData.cs
- NotificationContext.cs