1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
//------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//------------------------------------------------------------
namespace System.Activities.Tracking
{
using System;
using System.Runtime;
public abstract class TrackingParticipant
{
protected TrackingParticipant()
{
}
public virtual TrackingProfile TrackingProfile
{
get;
set;
}
[Fx.Tag.InheritThrows(From = "Track", FromDeclaringType = typeof(TrackingParticipant))]
protected internal virtual IAsyncResult BeginTrack(TrackingRecord record, TimeSpan timeout, AsyncCallback callback, object state)
{
return new TrackAsyncResult(this, record, timeout, callback, state);
}
[Fx.Tag.InheritThrows(From = "Track", FromDeclaringType = typeof(TrackingParticipant))]
protected internal virtual void EndTrack(IAsyncResult result)
{
TrackAsyncResult.End(result);
}
[Fx.Tag.Throws(typeof(Exception), "extensibility point")]
[Fx.Tag.Throws.Timeout("Tracking data could not be saved before the timeout")]
protected internal abstract void Track(TrackingRecord record, TimeSpan timeout);
class TrackAsyncResult : AsyncResult
{
static Action<object> asyncExecuteTrack = new Action<object>(ExecuteTrack);
TrackingParticipant participant;
TrackingRecord record;
TimeSpan timeout;
public TrackAsyncResult(TrackingParticipant participant, TrackingRecord record, TimeSpan timeout, AsyncCallback callback, object state)
: base(callback, state)
{
this.participant = participant;
this.record = record;
this.timeout = timeout;
ActionItem.Schedule(asyncExecuteTrack, this);
}
public static void End(IAsyncResult result)
{
AsyncResult.End<TrackAsyncResult>(result);
}
static void ExecuteTrack(object state)
{
TrackAsyncResult thisPtr = (TrackAsyncResult)state;
thisPtr.TrackCore();
}
void TrackCore()
{
Exception participantException = null;
try
{
this.participant.Track(this.record, this.timeout);
}
catch (Exception exception)
{
if (Fx.IsFatal(exception))
{
throw;
}
participantException = exception;
}
base.Complete(false, participantException);
}
}
}
}
|
