blob: f87b85e529aa00b84e06e0e01b447fae62ba95ac [file] [log] [blame]
Shad Ansari01b0e652018-04-05 21:02:53 +00001/*
nick7be062f2018-05-25 17:52:56 -04002 Copyright (C) 2018 Open Networking Foundation
Shad Ansari01b0e652018-04-05 21:02:53 +00003
4 This program is free software: you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation, either version 3 of the License, or
7 (at your option) any later version.
8
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
16*/
17
18#include <iostream>
19#include <memory>
20#include <string>
nick7be062f2018-05-25 17:52:56 -040021#include <time.h>
Nicolas Palpacuer0f19b1a2018-06-07 17:29:31 -040022#include <pthread.h>
Shad Ansari01b0e652018-04-05 21:02:53 +000023
24#include "Queue.h"
25#include <iostream>
26#include <sstream>
27
28#include "server.h"
Shad Ansarib7b0ced2018-05-11 21:53:32 +000029#include "core.h"
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -040030#include "state.h"
Shad Ansari01b0e652018-04-05 21:02:53 +000031
Shad Ansarib7b0ced2018-05-11 21:53:32 +000032#include <grpc++/grpc++.h>
Shad Ansari01b0e652018-04-05 21:02:53 +000033#include <openolt.grpc.pb.h>
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -080034#include <tech_profile.grpc.pb.h>
Shad Ansari01b0e652018-04-05 21:02:53 +000035
36using grpc::Server;
37using grpc::ServerBuilder;
38using grpc::ServerContext;
39using grpc::ServerWriter;
Shad Ansarib7b0ced2018-05-11 21:53:32 +000040using grpc::Status;
Shad Ansari01b0e652018-04-05 21:02:53 +000041
42const char *serverPort = "0.0.0.0:9191";
nick7be062f2018-05-25 17:52:56 -040043int signature;
Shad Ansari01b0e652018-04-05 21:02:53 +000044
Shad Ansari627b5782018-08-13 22:49:32 +000045Queue<openolt::Indication> oltIndQ;
46
Shad Ansari01b0e652018-04-05 21:02:53 +000047class OpenoltService final : public openolt::Openolt::Service {
48
Nicolas Palpacuere3fc0d22018-08-02 16:51:05 -040049 Status DisableOlt(
50 ServerContext* context,
51 const openolt::Empty* request,
52 openolt::Empty* response) override {
53 return Disable_();
54 }
55
56 Status ReenableOlt(
57 ServerContext* context,
58 const openolt::Empty* request,
59 openolt::Empty* response) override {
60 return Reenable_();
61 }
62
Shad Ansari01b0e652018-04-05 21:02:53 +000063 Status ActivateOnu(
64 ServerContext* context,
65 const openolt::Onu* request,
66 openolt::Empty* response) override {
67 return ActivateOnu_(
68 request->intf_id(),
69 request->onu_id(),
70 ((request->serial_number()).vendor_id()).c_str(),
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -070071 ((request->serial_number()).vendor_specific()).c_str(), request->pir());
Shad Ansari01b0e652018-04-05 21:02:53 +000072 }
73
Jonathan Davis70c21812018-07-19 15:32:10 -040074 Status DeactivateOnu(
75 ServerContext* context,
76 const openolt::Onu* request,
77 openolt::Empty* response) override {
78 return DeactivateOnu_(
79 request->intf_id(),
80 request->onu_id(),
81 ((request->serial_number()).vendor_id()).c_str(),
82 ((request->serial_number()).vendor_specific()).c_str());
83 }
84
85 Status DeleteOnu(
86 ServerContext* context,
87 const openolt::Onu* request,
88 openolt::Empty* response) override {
89 return DeleteOnu_(
90 request->intf_id(),
91 request->onu_id(),
92 ((request->serial_number()).vendor_id()).c_str(),
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -070093 ((request->serial_number()).vendor_specific()).c_str());
Jonathan Davis70c21812018-07-19 15:32:10 -040094 }
95
Shad Ansari01b0e652018-04-05 21:02:53 +000096 Status OmciMsgOut(
97 ServerContext* context,
98 const openolt::OmciMsg* request,
99 openolt::Empty* response) override {
100 return OmciMsgOut_(
101 request->intf_id(),
102 request->onu_id(),
103 request->pkt());
104 }
105
Shad Ansarif2e27a42018-04-26 22:37:38 +0000106 Status OnuPacketOut(
107 ServerContext* context,
108 const openolt::OnuPacket* request,
109 openolt::Empty* response) override {
110 return OnuPacketOut_(
111 request->intf_id(),
112 request->onu_id(),
Craig Lutgen967a1d02018-11-27 10:41:51 -0600113 request->port_no(),
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800114 request->gemport_id(),
Shad Ansarif2e27a42018-04-26 22:37:38 +0000115 request->pkt());
116 }
117
Nicolas Palpacuerb78def42018-06-07 12:55:26 -0400118 Status UplinkPacketOut(
119 ServerContext* context,
120 const openolt::UplinkPacket* request,
121 openolt::Empty* response) override {
122 return UplinkPacketOut_(
123 request->intf_id(),
124 request->pkt());
125 }
126
Shad Ansari01b0e652018-04-05 21:02:53 +0000127 Status FlowAdd(
128 ServerContext* context,
129 const openolt::Flow* request,
130 openolt::Empty* response) override {
131 return FlowAdd_(
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700132 request->access_intf_id(),
Shad Ansari01b0e652018-04-05 21:02:53 +0000133 request->onu_id(),
Craig Lutgen967a1d02018-11-27 10:41:51 -0600134 request->uni_id(),
135 request->port_no(),
Shad Ansari01b0e652018-04-05 21:02:53 +0000136 request->flow_id(),
137 request->flow_type(),
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700138 request->alloc_id(),
Shad Ansari01b0e652018-04-05 21:02:53 +0000139 request->network_intf_id(),
140 request->gemport_id(),
141 request->classifier(),
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700142 request->action(),
Craig Lutgen967a1d02018-11-27 10:41:51 -0600143 request->priority(),
144 request->cookie());
Shad Ansari01b0e652018-04-05 21:02:53 +0000145 }
146
Nicolas Palpacueredfaa0c2018-07-05 15:05:27 -0400147 Status FlowRemove(
148 ServerContext* context,
149 const openolt::Flow* request,
150 openolt::Empty* response) override {
151 return FlowRemove_(
152 request->flow_id(),
153 request->flow_type());
154 }
155
Shad Ansari01b0e652018-04-05 21:02:53 +0000156 Status EnableIndication(
157 ServerContext* context,
158 const ::openolt::Empty* request,
159 ServerWriter<openolt::Indication>* writer) override {
Shad Ansariedef2132018-08-10 22:14:50 +0000160
nick7be062f2018-05-25 17:52:56 -0400161 std::cout << "Connection to Voltha established. Indications enabled"
162 << std::endl;
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -0400163
Nicolas Palpacuerfbc0d7d2018-08-23 14:46:42 -0400164 if (state.previsouly_connected()) {
165 // Reconciliation / recovery case
Nicolas Palpacuer135ce812018-08-30 09:04:34 -0400166 std::cout << "Reconciliation / Recovery case" << std::endl;
Nicolas Palpacuerfbc0d7d2018-08-23 14:46:42 -0400167 if (state.is_activated()){
168 // Adding extra olt indication of current state
169 openolt::Indication ind;
170 openolt::OltIndication* oltInd = new openolt::OltIndication();
171 if (state.is_activated()) {
172 oltInd->set_oper_state("up");
Nicolas Palpacuer135ce812018-08-30 09:04:34 -0400173 std::cout << "Extra OLT indication up" << std::endl;
Nicolas Palpacuerfbc0d7d2018-08-23 14:46:42 -0400174 } else {
175 oltInd->set_oper_state("down");
Nicolas Palpacuer135ce812018-08-30 09:04:34 -0400176 std::cout << "Extra OLT indication down" << std::endl;
Nicolas Palpacuerfbc0d7d2018-08-23 14:46:42 -0400177 }
178 ind.set_allocated_olt_ind(oltInd);
179 oltIndQ.push(ind);
180 }
181 }
182
Shad Ansariedef2132018-08-10 22:14:50 +0000183 state.connect();
184
185 while (state.is_connected()) {
186 std::pair<openolt::Indication, bool> ind = oltIndQ.pop(COLLECTION_PERIOD);
187 if (ind.second == false) {
188 /* timeout - do lower priority periodic stuff like stats */
189 stats_collection();
190 continue;
191 }
192 openolt::Indication oltInd = ind.first;
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -0400193 bool isConnected = writer->Write(oltInd);
Nicolas Palpacuer58d252c2018-06-06 11:19:04 -0400194 if (!isConnected) {
195 //Lost connectivity to this Voltha instance
196 //Put the indication back in the queue for next connecting instance
197 oltIndQ.push(oltInd);
Shad Ansariedef2132018-08-10 22:14:50 +0000198 state.disconnect();
Nicolas Palpacuer58d252c2018-06-06 11:19:04 -0400199 }
Shad Ansari01b0e652018-04-05 21:02:53 +0000200 //oltInd.release_olt_ind()
201 }
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -0400202
Shad Ansari01b0e652018-04-05 21:02:53 +0000203 return Status::OK;
204 }
nick7be062f2018-05-25 17:52:56 -0400205
206 Status HeartbeatCheck(
207 ServerContext* context,
208 const openolt::Empty* request,
209 openolt::Heartbeat* response) override {
210 response->set_heartbeat_signature(signature);
211
212 return Status::OK;
213 }
Nicolas Palpacuer0f19b1a2018-06-07 17:29:31 -0400214
Nicolas Palpacuer05ea0ea2018-07-06 11:47:21 -0400215 Status EnablePonIf(
216 ServerContext* context,
217 const openolt::Interface* request,
218 openolt::Empty* response) override {
219
220 return EnablePonIf_(request->intf_id());
221 }
222
223 Status DisablePonIf(
224 ServerContext* context,
225 const openolt::Interface* request,
226 openolt::Empty* response) override {
227
228 return DisablePonIf_(request->intf_id());
229 }
Nicolas Palpacuer0f19b1a2018-06-07 17:29:31 -0400230
Nicolas Palpacuer65d04472018-09-06 15:53:37 -0400231 Status CollectStatistics(
232 ServerContext* context,
233 const openolt::Empty* request,
234 openolt::Empty* response) override {
235
236 stats_collection();
237
238 return Status::OK;
239 }
240
Nicolas Palpacuer45180662018-08-02 14:01:51 -0400241 Status Reboot(
242 ServerContext* context,
243 const openolt::Empty* request,
244 openolt::Empty* response) override {
245
246 system("shutdown -r now");
247
248 return Status::OK;
249
250 }
251
Nicolas Palpacuerdff96792018-09-06 14:59:32 -0400252 Status GetDeviceInfo(
253 ServerContext* context,
254 const openolt::Empty* request,
255 openolt::DeviceInfo* response) override {
256
257 GetDeviceInfo_(response);
258
259 return Status::OK;
260
261 }
262
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800263 Status CreateTrafficSchedulers(
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700264 ServerContext* context,
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800265 const tech_profile::TrafficSchedulers* request,
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700266 openolt::Empty* response) override {
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800267 CreateTrafficSchedulers_(request);
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700268 return Status::OK;
269 };
Nicolas Palpacuerdff96792018-09-06 14:59:32 -0400270
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800271 Status RemoveTrafficSchedulers(
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700272 ServerContext* context,
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800273 const tech_profile::TrafficSchedulers* request,
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700274 openolt::Empty* response) override {
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -0800275 RemoveTrafficSchedulers_(request);
276 return Status::OK;
277 };
278
279 Status CreateTrafficQueues(
280 ServerContext* context,
281 const tech_profile::TrafficQueues* request,
282 openolt::Empty* response) override {
283 CreateTrafficQueues_(request);
284 return Status::OK;
285 };
286
287 Status RemoveTrafficQueues(
288 ServerContext* context,
289 const tech_profile::TrafficQueues* request,
290 openolt::Empty* response) override {
291 RemoveTrafficQueues_(request);
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700292 return Status::OK;
293 };
Nicolas Palpacuer45180662018-08-02 14:01:51 -0400294
Shad Ansari01b0e652018-04-05 21:02:53 +0000295};
296
297void RunServer() {
298 OpenoltService service;
299 std::string server_address(serverPort);
300 ServerBuilder builder;
301
302 builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
303 builder.RegisterService(&service);
304
305 std::unique_ptr<Server> server(builder.BuildAndStart());
306
nick7be062f2018-05-25 17:52:56 -0400307 time_t now;
308 time(&now);
309 signature = (int)now;
310
311 std::cout << "Server listening on " << server_address
312 << ", connection signature : " << signature << std::endl;
313
Shad Ansari01b0e652018-04-05 21:02:53 +0000314
315 server->Wait();
316}