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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
//-----------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//-----------------------------------------------------------------------------
namespace System.ServiceModel.Dispatcher
{
using System;
using System.Runtime;
using System.ServiceModel;
using System.ServiceModel.Channels;
class RequestChannelBinder : IChannelBinder
{
IRequestChannel channel;
internal RequestChannelBinder(IRequestChannel channel)
{
if (channel == null)
{
Fx.Assert("RequestChannelBinder.RequestChannelBinder: (channel != null)");
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("channel");
}
this.channel = channel;
}
public IChannel Channel
{
get { return this.channel; }
}
public bool HasSession
{
get { return this.channel is ISessionChannel<IOutputSession>; }
}
public Uri ListenUri
{
get { return null; }
}
public EndpointAddress LocalAddress
{
get { return EndpointAddress.AnonymousAddress; }
}
public EndpointAddress RemoteAddress
{
get { return this.channel.RemoteAddress; }
}
public void Abort()
{
this.channel.Abort();
}
public void CloseAfterFault(TimeSpan timeout)
{
this.channel.Close(timeout);
}
public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public bool EndTryReceive(IAsyncResult result, out RequestContext requestContext)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public RequestContext CreateRequestContext(Message message)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
{
return this.channel.BeginRequest(message, timeout, callback, state);
}
public void EndSend(IAsyncResult result)
{
ValidateNullReply(this.channel.EndRequest(result));
}
public void Send(Message message, TimeSpan timeout)
{
ValidateNullReply(this.channel.Request(message, timeout));
}
public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
{
return this.channel.BeginRequest(message, timeout, callback, state);
}
public Message EndRequest(IAsyncResult result)
{
return this.channel.EndRequest(result);
}
public bool TryReceive(TimeSpan timeout, out RequestContext requestContext)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public Message Request(Message message, TimeSpan timeout)
{
return this.channel.Request(message, timeout);
}
void ValidateNullReply(Message message)
{
if (message != null && !(message is NullMessage))
{
ProtocolException error = ProtocolException.OneWayOperationReturnedNonNull(message);
throw System.ServiceModel.Diagnostics.TraceUtility.ThrowHelperError(error, message);
}
}
public bool WaitForMessage(TimeSpan timeout)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public bool EndWaitForMessage(IAsyncResult result)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
}
}
|
