Skeleton code for Omci go routine
Change-Id: Ida34470b465c40f2e0bdaf47b0d1b38b4e8396b5
diff --git a/core/mediator.go b/core/mediator.go
index ee25264..0ad0696 100644
--- a/core/mediator.go
+++ b/core/mediator.go
@@ -125,7 +125,10 @@
func (m *mediator) Start() {
var wg sync.WaitGroup
opt := m.opt
- server := NewCore(opt)
+ omciOut := make(chan OmciMsg, 8)
+ omciIn := make(chan OmciMsg, 8)
+ go OmciRun(omciOut, omciIn)
+ server := NewCore(opt, omciOut, omciIn)
wg.Add(1)
go func() {
if err := server.Start(); err != nil { //Blocking