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
136
137
138
139
140
141
142
143
144
145
|
/*
* Copyright 2014-2015 Open Networking Laboratory
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.onosproject.cordvtn;
import org.onosproject.cluster.LeadershipService;
import org.onosproject.cluster.NodeId;
import org.onosproject.core.ApplicationId;
import org.onosproject.mastership.MastershipService;
import org.onosproject.net.DeviceId;
import org.onosproject.store.service.EventuallyConsistentMap;
import org.slf4j.Logger;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import static org.onlab.util.Tools.groupedThreads;
import static org.slf4j.LoggerFactory.getLogger;
/**
* Node connection manager.
*/
public class NodeConnectionManager {
protected final Logger log = getLogger(getClass());
private final ApplicationId appId;
private final NodeId localId;
private final EventuallyConsistentMap<DeviceId, OvsdbNode> nodeStore;
private final MastershipService mastershipService;
private final LeadershipService leadershipService;
private static final int DELAY_SEC = 5;
private ScheduledExecutorService connectionExecutor;
/**
* Creates a new NodeConnectionManager.
*
* @param localId local id
* @param nodeStore node store
* @param mastershipService mastership service
*/
public NodeConnectionManager(ApplicationId appId, NodeId localId,
EventuallyConsistentMap<DeviceId, OvsdbNode> nodeStore,
MastershipService mastershipService,
LeadershipService leadershipService) {
this.appId = appId;
this.localId = localId;
this.nodeStore = nodeStore;
this.mastershipService = mastershipService;
this.leadershipService = leadershipService;
}
/**
* Starts the node connection manager.
*/
public void start() {
connectionExecutor = Executors.newSingleThreadScheduledExecutor(
groupedThreads("onos/cordvtn", "connection-executor"));
connectionExecutor.scheduleWithFixedDelay(() -> nodeStore.values()
.stream()
.filter(node -> localId.equals(getMaster(node)))
.forEach(node -> connectNode(node)), 0, DELAY_SEC, TimeUnit.SECONDS);
}
/**
* Stops the node connection manager.
*/
public void stop() {
connectionExecutor.shutdown();
}
/**
* Adds a new node to the system.
*
* @param ovsdbNode ovsdb node
*/
public void connectNode(OvsdbNode ovsdbNode) {
switch (ovsdbNode.state()) {
case INIT:
case DISCONNECTED:
// TODO: set the node to passive mode
case READY:
// TODO: initiate connection
break;
case CONNECTED:
break;
default:
}
}
/**
* Deletes the ovsdb node.
*
* @param ovsdbNode ovsdb node
*/
public void disconnectNode(OvsdbNode ovsdbNode) {
switch (ovsdbNode.state()) {
case CONNECTED:
// TODO: disconnect
break;
case INIT:
case READY:
case DISCONNECTED:
break;
default:
}
}
private NodeId getMaster(OvsdbNode ovsdbNode) {
// Return the master of the bridge(switch) if it exist or
// return the current leader
if (ovsdbNode.bridgeId() == DeviceId.NONE) {
return leadershipService.getLeader(this.appId.name());
} else {
return mastershipService.getMasterFor(ovsdbNode.bridgeId());
}
}
private void setPassiveMode(OvsdbNode ovsdbNode) {
// TODO: need ovsdb client implementation first
// TODO: set the remove ovsdb server passive mode
// TODO: set the node state READY if it succeed
}
private void connect(OvsdbNode ovsdbNode) {
// TODO: need ovsdb client implementation first
}
private void disconnect(OvsdbNode ovsdbNode) {
// TODO: need ovsdb client implementation first
}
}
|
