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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
//-----------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//-----------------------------------------------------------------------------
namespace System.ServiceModel.Dispatcher
{
using System;
using System.ServiceModel;
using System.ServiceModel.Channels;
public interface IInstanceContextProvider
{
InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel);
void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel);
bool IsIdle(InstanceContext instanceContext);
void NotifyIdle(InstanceContextIdleCallback callback, InstanceContext instanceContext);
}
internal abstract class InstanceContextProviderBase : IInstanceContextProvider
{
DispatchRuntime dispatchRuntime;
public DispatchRuntime DispatchRuntime
{
get
{
return this.dispatchRuntime;
}
}
internal InstanceContextProviderBase(DispatchRuntime dispatchRuntime)
{
this.dispatchRuntime = dispatchRuntime;
}
internal static bool IsProviderSingleton(IInstanceContextProvider provider)
{
return (provider is SingletonInstanceContextProvider);
}
internal static bool IsProviderSessionful(IInstanceContextProvider provider)
{
return (provider is PerSessionInstanceContextProvider);
}
internal static IInstanceContextProvider GetProviderForMode(InstanceContextMode instanceMode, DispatchRuntime runtime)
{
switch (instanceMode)
{
case InstanceContextMode.PerCall:
return new PerCallInstanceContextProvider(runtime);
case InstanceContextMode.PerSession:
return new PerSessionInstanceContextProvider(runtime);
case InstanceContextMode.Single:
return new SingletonInstanceContextProvider(runtime);
default:
DiagnosticUtility.FailFast("InstanceContextProviderBase.GetProviderForMode: default");
return null;
}
}
internal static bool IsProviderPerCall(IInstanceContextProvider provider)
{
return (provider is PerCallInstanceContextProvider);
}
internal ServiceChannel GetServiceChannelFromProxy(IContextChannel channel)
{
ServiceChannel serviceChannel = channel as ServiceChannel;
if (serviceChannel == null)
{
serviceChannel = ServiceChannelFactory.GetServiceChannel(channel);
}
return serviceChannel;
}
#region IInstanceContextProvider Members
public virtual InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public virtual void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public virtual bool IsIdle(InstanceContext instanceContext)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public virtual void NotifyIdle(InstanceContextIdleCallback callback, InstanceContext instanceContext)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
#endregion
}
}
|
