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
|
//------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//------------------------------------------------------------
namespace System.ServiceModel.Channels
{
using System.Collections.ObjectModel;
using System.ServiceModel;
// Neighbor interface
interface IPeerNeighbor : IExtensibleObject<IPeerNeighbor>
{
bool IsConnected { get; } // True if the neighbor is connected
PeerNodeAddress ListenAddress { get; set; } // Neighbor's listen address
bool IsInitiator { get; }
ulong NodeId { get; set; } // NodeID of the neighboring node
PeerNeighborState State { get; set; }
bool IsClosing { get; }
IAsyncResult BeginSend(Message message, AsyncCallback callback, object state);
IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state);
void EndSend(IAsyncResult result);
void Send(Message message);
bool TrySetState(PeerNeighborState state);
void Abort(PeerCloseReason reason, PeerCloseInitiator initiator);
Message RequestSecurityToken(Message request);
void Ping(Message request);
UtilityExtension Utility { get; }
}
// Neighbor states
// If add new states, carefully consider where they should occur in state transition and make
// appropriate changes to PeerNeighbor implementation.
enum PeerNeighborState
{
Created,
Opened,
Authenticated,
Connecting,
Connected,
Disconnecting,
Disconnected,
Faulted,
Closed,
}
static class PeerNeighborStateHelper
{
// Returns true if the specified state can be set for the neighbor
public static bool IsSettable(PeerNeighborState state)
{
return (
(state == PeerNeighborState.Authenticated) ||
(state == PeerNeighborState.Connecting) ||
(state == PeerNeighborState.Connected) ||
(state == PeerNeighborState.Disconnecting) ||
(state == PeerNeighborState.Disconnected));
}
// Returns true if the specified state is a "connected" state
public static bool IsConnected(PeerNeighborState state)
{
return ((state == PeerNeighborState.Connected));
}
// Returns true if the specified state is either authenticated or closing
public static bool IsAuthenticatedOrClosed(PeerNeighborState state)
{
return ((state == PeerNeighborState.Authenticated) ||
(state == PeerNeighborState.Faulted) ||
(state == PeerNeighborState.Closed));
}
}
}
|
