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
|
//----------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//----------------------------------------------------------------------------
namespace System.ServiceModel.Channels
{
using System;
using System.Net;
public sealed class RemoteEndpointMessageProperty
{
string address;
int port;
IPEndPoint remoteEndPoint;
IRemoteEndpointProvider remoteEndpointProvider;
InitializationState state;
object thisLock = new object();
public RemoteEndpointMessageProperty(string address, int port)
{
if (string.IsNullOrEmpty(address))
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("address");
}
if (port < IPEndPoint.MinPort || port > IPEndPoint.MaxPort)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("port",
SR.GetString(SR.ValueMustBeInRange, IPEndPoint.MinPort, IPEndPoint.MaxPort));
}
this.port = port;
this.address = address;
this.state = InitializationState.All;
}
internal RemoteEndpointMessageProperty(IRemoteEndpointProvider remoteEndpointProvider)
{
this.remoteEndpointProvider = remoteEndpointProvider;
}
internal RemoteEndpointMessageProperty(IPEndPoint remoteEndPoint)
{
this.remoteEndPoint = remoteEndPoint;
}
public static string Name
{
get { return "System.ServiceModel.Channels.RemoteEndpointMessageProperty"; }
}
public string Address
{
get
{
if ((this.state & InitializationState.Address) != InitializationState.Address)
{
lock (ThisLock)
{
if ((this.state & InitializationState.Address) != InitializationState.Address)
{
Initialize(false);
}
}
}
return this.address;
}
}
public int Port
{
get
{
if ((this.state & InitializationState.Port) != InitializationState.Port)
{
lock (ThisLock)
{
if ((this.state & InitializationState.Port) != InitializationState.Port)
{
Initialize(true);
}
}
}
return this.port;
}
}
object ThisLock
{
get { return thisLock; }
}
void Initialize(bool getHostedPort)
{
if (remoteEndPoint != null)
{
this.address = remoteEndPoint.Address.ToString();
this.port = remoteEndPoint.Port;
this.state = InitializationState.All;
this.remoteEndPoint = null;
}
else
{
if ((this.state & InitializationState.Address) != InitializationState.Address)
{
this.address = remoteEndpointProvider.GetAddress();
this.state |= InitializationState.Address;
}
if (getHostedPort)
{
this.port = remoteEndpointProvider.GetPort();
this.state |= InitializationState.Port;
this.remoteEndpointProvider = null;
}
}
}
internal interface IRemoteEndpointProvider
{
string GetAddress();
int GetPort();
}
[Flags]
enum InitializationState
{
None = 0,
Address = 1,
Port = 2,
All = 3
}
}
}
|
