wip

serialstep/serialstep.4.multi.py

@@ -94,7 +94,7 @@ def worker3(id,count):
          elif ((localcount >= 4*maxcount/7) and (localcount < 5*maxcount/7)):
             ports[id].write(forward)
          elif ((localcount >= 5*maxcount/7) and (localcount%5 == 0)):
-            ports[id].write(reserve)
+            ports[id].write(reverse)
 #
 # alarm event handler
 #

serialstep/serialstep.4.seq.py

@@ -33,7 +33,6 @@ print('open '+device2+' at '+str(baud)+' delay '+str(delay))
 port2 = serial.Serial(device2,baudrate=baud,timeout=0)
 print('open '+device3+' at '+str(baud)+' delay '+str(delay))
 port3 = serial.Serial(device3,baudrate=baud,timeout=0)
-count = 0;
 #
 # global variables 
 #
@@ -45,7 +44,8 @@ reverse = b'r'
 # alarm event handler
 #
 def alarm(signum,stack):
-   count.value += 1
+   global count
+   count += 1
    if (count < maxcount/7):
       port0.write(forward)
    elif ((count >= 1*maxcount/7) and (count < 2*maxcount/7)):
@@ -59,7 +59,7 @@ def alarm(signum,stack):
       port1.write(forward)
       port2.write(reverse)
       port3.write(forward)
-   elif (count >= 5*maxcount/7)):
+   elif (count >= 5*maxcount/7):
       if (count%2 == 0):
          port0.write(forward)
       if (count%3 == 0):
@@ -68,17 +68,8 @@ def alarm(signum,stack):
          port2.write(forward)
       if (count%5 == 0):
          port3.write(reverse)
-#
-# start workers
-#
-p0 = multiprocessing.Process(target=worker0,args=(0,count))
-p0.start()
-p1 = multiprocessing.Process(target=worker1,args=(1,count))
-p1.start()
-p2 = multiprocessing.Process(target=worker2,args=(2,count))
-p2.start()
-p3 = multiprocessing.Process(target=worker3,args=(3,count))
-p3.start()
+   if (count > maxcount):
+      count = 0
 #
 # start alarm
 #