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
|
using System;
using System.Collections.Generic;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Security;
using System.ServiceModel.Security.Tokens;
using System.Text;
namespace System.ServiceModel.Dispatcher
{
internal class InputOrReplyRequestProcessor : BaseRequestProcessor
{
DispatchRuntime dispatch_runtime;
IChannel reply_or_input;
public InputOrReplyRequestProcessor (DispatchRuntime runtime, IChannel replyOrInput)
{
Init (runtime, replyOrInput);
//initialization
InitializeChain.AddHandler (new InitializingHandler ());
//processing
ProcessingChain.AddHandler (new PostReceiveRequestHandler ()).
AddHandler(new SecurityHandler ()).
AddHandler(new OperationInvokerHandler (replyOrInput));
//errors
ErrorChain.AddHandler (new ErrorProcessingHandler (replyOrInput));
//finalize
FinalizationChain.AddHandler (new FinalizeProcessingHandler ());
}
void Init (DispatchRuntime runtime, IChannel replyOrInput)
{
dispatch_runtime = runtime;
reply_or_input = replyOrInput;
}
public void ProcessInput (Message message)
{
OperationContext opcx = CreateOperationContext (message);
ProcessRequest (new MessageProcessingContext (opcx));
}
public void ProcessReply (RequestContext rc)
{
OperationContext opcx = CreateOperationContext (rc.RequestMessage);
opcx.RequestContext = rc;
ProcessRequest (new MessageProcessingContext (opcx));
}
OperationContext CreateOperationContext (Message incoming)
{
ServiceRuntimeChannel contextChannel;
if (dispatch_runtime.HasCallbackRuntime) {
var type = ServiceProxyGenerator.CreateCallbackProxyType (dispatch_runtime.Type, dispatch_runtime.CallbackClientRuntime.CallbackClientType);
contextChannel = (ServiceRuntimeChannel) Activator.CreateInstance (type, new object [] {reply_or_input, dispatch_runtime});
}
else
contextChannel = new ServiceRuntimeChannel (reply_or_input, dispatch_runtime);
OperationContext opCtx = new OperationContext (contextChannel);
opCtx.IncomingMessage = incoming;
opCtx.EndpointDispatcher = dispatch_runtime.EndpointDispatcher;
return opCtx;
}
}
}
|
