Merge branch 'L2SS-2374' into 'master'

L2SS-2374: Use more portable multiprocessing queue

Closes L2SS-2374

See merge request !27

pypcc/opcuaserv/i2client.py

 #This is the OPC-UA side of the pipes to I2Cserver
 
-from multiprocessing import Queue
+from multiprocessing import Queue, Manager
 from pypcc.queuetypes import *
 
 
 class i2client():
     def __init__(self,name='RCU'):
-        self.Qin=Queue() 
-        self.Qout=Queue()
-        self.name=name;
+        self.mp_manager = Manager()
+        self.Qin=self.mp_manager.Queue()
+        self.Qout=self.mp_manager.Queue()
+        self.name=name
 
     def GetInfo(self):
         return self.Qin,self.Qout,self.name
 
     def stop(self):
-        self.Qout.put(None);
-        self.Qin.put(None);
+        self.Qout.put(None)
+        self.Qin.put(None)
 #        self.thread1.join();
 #        os.close(self.Output)
 #        self.Input.close()
     def restart(self):
         self.stop()
-        self.Qin=Queue()
-        self.Qout=Queue()
+        self.Qin=self.mp_manager.Queue()
+        self.Qout=self.mp_manager.Queue()
 
     def readvar(self,id1,mask=[]):
         Data=OPCUAset(id1,InstType.varRead,[],mask.copy())
-        self.Qout.put(Data);
+        self.Qout.put(Data)
 
     def setvar(self,id1,data=[],mask=[]):
         Data=OPCUAset(id1,InstType.varSet,data.copy(),mask.copy())
-        self.Qout.put(Data);
+        self.Qout.put(Data)
 
     def QoutLength(self):
         return self.Qout.qsize()
@@ -40,7 +41,7 @@ class i2client():
         self.Qout.put(Data);
 
     def data_waiting(self):
-        return (self.Qin.qsize()>0);
+        return (self.Qin.qsize()>0)
 
     def readdata(self):
         message=self.Qin.get()