update from LCU

bin/sync.sh

+#!/bin/bash
+rsync -avzh ~/pypcc pi@10.99.0.$1:.
+ssh pi@10.99.0.$1 "cd pypcc;sh install.sh"
\ No newline at end of file

bin/sync_all.sh

+#!/bin/bash
+./sync.sh 100
+./sync.sh 101

install.sh

+#!/bin/bash
+sudo systemctl stop recvtr.service
+sudo systemctl stop apscttr.service
+sudo systemctl stop apsputr.service
+sudo systemctl stop unb2tr.service
+sudo python3 setup.py install
+sudo systemctl start recvtr.service
+sudo systemctl start apscttr.service
+sudo systemctl start apsputr.service
+sudo systemctl start unb2tr.service

pypcc/i2cserv/i2c_array.py

@@ -145,6 +145,7 @@ class i2c_array(i2c_dev):
             print("Check mask length!",len(mask),Step,self.N);
             return;
         else:
+           if not(var1.get('check_value')): 
              for x,enanbled in enumerate(self.enablemask):
                if enanbled: continue;
                for y in range(Step): mask[x*Step+y]=False;
@@ -186,8 +187,8 @@ class i2c_array(i2c_dev):
                res=self.GetVarValue(devreg,width,bitoffset,[],mode=3) #wait if needed
 #            for Vari in range(Step):
 #        else:
-          for RCUi in self.RCUorder:
 #            for Vari in range(Step):
+          for RCUi in self.RCUorder:
                 if not(mask[RCUi*Step+Vari]): continue
                 i0=(RCUi*Step+    Vari)*Step2
                 i1=(RCUi*Step+(Vari+1))*Step2
@@ -209,6 +210,24 @@ class i2c_array(i2c_dev):
                   continue;
                 self.I2Cmask[RCUi]=0;
                 value1[i0:i1]=value2
+        if var1.get('check_value'):
+            check_val=var1.get('check_value')
+            Ncheck=len(check_val);
+            if Ncheck>Step2: Ncheck=Step2;
+            for Vari in range(Step):
+               for RCUi in self.RCUorder:
+                  if not(mask[RCUi*Step+Vari]): continue
+                  i0=(RCUi*Step+    Vari)*Step2
+                  i1=(RCUi*Step+(Vari+1))*Step2
+                  if value1[i0] is None: 
+                           #print(RCUi,'None')
+                           self.enablemask[RCUi]=False;
+                           continue;
+                  for x in range(Ncheck):
+                        #print(RCUi,ord(check_val[x]),value1[i0+x])
+                        if ord(check_val[x])!=value1[i0+x]:
+                           self.enablemask[RCUi]=False;
+            logging.warn(str(("Identify RCUs:",check_val,self.enablemask)))
         return value1,mask
 
     def getstorearray(self,devreg,N=1):