Added profinet

.gitignore

@@ -68,7 +68,7 @@ target/
 *.err
 *.log
 *.log*
-*.xml
+# *.xml
 *.pdf
 *.json
 *.cache

examples/swat-s1/physical_process.py

@@ -35,15 +35,15 @@ class RawWaterTank(Tank):
     def pre_loop(self):
 
         # SPHINX_SWAT_TUTORIAL STATE INIT(
-        self.set(MV101, 1)
-        self.set(P101, 0)
-        self.level = self.set(LIT101, 0.800)
+        # self.set(MV101, 1)
+        # self.set(P101, 0)
+        # self.level = self.set(LIT101, 0.800)
         # SPHINX_SWAT_TUTORIAL STATE INIT)
 
         # test underflow
-        # self.set(MV101, 0)
-        # self.set(P101, 1)
-        # self.level = self.set(LIT101, 0.500)
+        self.set(MV101, 0)
+        self.set(P101, 1)
+        self.level = self.set(LIT101, 0.500)
 
     def main_loop(self):
 
@@ -60,7 +60,7 @@ def main_loop(self):
             if int(mv101) == 1:
                 self.set(FIT101, PUMP_FLOWRATE_IN)
                 inflow = PUMP_FLOWRATE_IN * PP_PERIOD_HOURS
-                # print "DEBUG RawWaterTank inflow: ", inflow
+                print "DEBUG RawWaterTank inflow: ", inflow
                 water_volume += inflow
             else:
                 self.set(FIT101, 0.00)
@@ -70,7 +70,7 @@ def main_loop(self):
             if int(p101) == 1:
                 self.set(FIT201, PUMP_FLOWRATE_OUT)
                 outflow = PUMP_FLOWRATE_OUT * PP_PERIOD_HOURS
-                # print "DEBUG RawWaterTank outflow: ", outflow
+                print "DEBUG RawWaterTank outflow: ", outflow
                 water_volume -= outflow
             else:
                 self.set(FIT201, 0.00)

examples/swat-s1/plc1.py

@@ -90,18 +90,18 @@ def main_loop(self):
             print "DEBUG PLC1 - receive lit301: %f" % lit301
             self.send(LIT301_1, lit301, PLC1_ADDR)
 
-            # if fit201 <= FIT_201_THRESH or lit301 >= LIT_301_M['H']:
-            #     # CLOSE p101
-            #     self.set(P101, 0)
-            #     self.send(P101, 0, PLC1_ADDR)
-            #     print "INFO PLC1 - fit201 under FIT_201_THRESH " \
-            #           "or over LIT_301_M['H']: -> close p101."
-
-            # elif lit301 <= LIT_301_M['L']:
-            #     # OPEN p101
-            #     self.set(P101, 1)
-            #     self.send(P101, 1, PLC1_ADDR)
-            #     print "INFO PLC1 - lit301 under LIT_301_M['L'] -> open p101."
+            if fit201 <= FIT_201_THRESH or lit301 >= LIT_301_M['H']:
+                # CLOSE p101
+                self.set(P101, 0)
+                self.send(P101, 0, PLC1_ADDR)
+                print "INFO PLC1 - fit201 under FIT_201_THRESH " \
+                      "or over LIT_301_M['H']: -> close p101."
+
+            elif lit301 <= LIT_301_M['L']:
+                # OPEN p101
+                self.set(P101, 1)
+                self.send(P101, 1, PLC1_ADDR)
+                print "INFO PLC1 - lit301 under LIT_301_M['L'] -> open p101."
 
             time.sleep(PLC_PERIOD_SEC)
             count += 1

examples/swat-s1/run.py

@@ -29,10 +29,10 @@ def __init__(self, name, net):
             'plc1', 'plc2', 'plc3', 's1')
 
         # SPHINX_SWAT_TUTORIAL RUN(
-        plc2.cmd(sys.executable + ' plc2.py &')
-        plc3.cmd(sys.executable + ' plc3.py &')
-        plc1.cmd(sys.executable + ' plc1.py &')
-        s1.cmd(sys.executable + ' physical_process.py &')
+        # plc2.cmd(sys.executable + ' plc2.py &')
+        # plc3.cmd(sys.executable + ' plc3.py &')
+        # plc1.cmd(sys.executable + ' plc1.py &')
+        # s1.cmd(sys.executable + ' physical_process.py &')
         # SPHINX_SWAT_TUTORIAL RUN)
 
         CLI(self.net)

examples/swat-s2/dev1.py

@@ -0,0 +1,77 @@
+"""
+swat-s1 plc1.py
+"""
+
+from minicps.devices import IODevice
+from utils import DEV1_DATA, STATE, DEV1_PROTOCOL
+from utils import PLC_PERIOD_SEC, PLC_SAMPLES
+from utils import IP
+from utils import PUMP_FLOWRATE_IN
+
+import time
+
+PLC1_ADDR = IP['plc1']
+DEV1_ADDR = IP['dev1']
+
+FIT101 = ('FIT101', 4)
+FIT101_PLC = ('FIT101', 1)
+
+MV101 = ('MV101', 5)
+
+
+# SPHINX_SWAT_TUTORIAL PLC1 LOGIC)
+
+# TODO: real value tag where to read/write flow sensor
+class SwatDev1(IODevice):
+
+    def pre_loop(self, sleep=0.1):
+        print 'DEBUG: swat-s2 dev1 enters pre_loop'
+        start_value = 0
+        self.set(FIT101, start_value)
+        self.send(FIT101, start_value, DEV1_ADDR)
+        print
+        time.sleep(45)        
+        time.sleep(sleep)
+
+    def main_loop(self):
+        """fit101 main loop.
+
+            - reads sensors value
+            - updates its enip server
+        """
+
+        print 'DEBUG: swat-s2 dev1 enters main_loop.'
+        print
+
+        count = 0
+        while(count <= PLC_SAMPLES):
+            # TODO: SIMULATE VIRTUAL PROCESS VALUE SHOULD NOT DEPEND FROM MV101 but normal deviations
+            mv101 = float(self.get(MV101))
+            fit101 = float(self.get(FIT101))
+
+            if (mv101 == 1 and fit101 == 0): 
+                # lit101 [meters]
+                self.set(FIT101, PUMP_FLOWRATE_IN)
+            elif mv101 == 0: 
+                self.set(FIT101, 0)
+
+            fit101 = float(self.get(FIT101))
+
+            # print 'DEBUG dev1 fit101: %.5f' % fit101
+            self.send(FIT101, fit101, DEV1_ADDR)
+
+            time.sleep(PLC_PERIOD_SEC)
+            count += 1
+
+        print 'DEBUG swat-s2 dev1 shutdown'
+
+
+if __name__ == "__main__":
+
+    # notice that memory init is different form disk init
+    dev1 = SwatDev1(
+        name='dev1',
+        state=STATE,
+        protocol=DEV1_PROTOCOL,
+        memory=DEV1_DATA,
+        disk=DEV1_DATA)

examples/swat-s2/dev2.py

@@ -0,0 +1,61 @@
+"""
+swat-s1 plc1.py
+"""
+
+from minicps.devices import IODevice
+from utils import DEV2_DATA, STATE, DEV2_PROTOCOL
+from utils import PLC_PERIOD_SEC, PLC_SAMPLES
+from utils import IP
+from utils import PUMP_FLOWRATE_IN
+
+import time
+
+PLC1_ADDR = IP['plc1']
+DEV2_ADDR = IP['dev2']
+
+MV101 = ('MV101', 5)
+MV101_PLC = ('MV101', 1)
+
+# SPHINX_SWAT_TUTORIAL PLC1 LOGIC)
+
+# TODO: real value tag where to read/write flow sensor
+class SwatDev2(IODevice):
+
+    def pre_loop(self, sleep=0.1):
+        print 'DEBUG: swat-s2 dev2 enters pre_loop'
+        start_value = 1
+        self.set(MV101, start_value)
+        time.sleep(sleep)
+        time.sleep(45)
+
+    def main_loop(self):
+        """mv101 main loop.
+
+            - reads sensors value
+            - updates its enip server
+        """
+
+        print 'DEBUG: swat-s2 dev2 enters main_loop.'
+        print
+
+        count = 0
+        while(count <= PLC_SAMPLES):
+            # TODO: SIMULATE VIRTUAL PROCESS
+            mv101_1 = float(self.receive(MV101_PLC, PLC1_ADDR))
+            self.set(MV101, mv101_1)
+
+            time.sleep(PLC_PERIOD_SEC)
+            count += 1
+
+        print 'DEBUG swat-s2 dev2 shutdown'
+
+
+if __name__ == "__main__":
+
+    # notice that memory init is different form disk init
+    dev2 = SwatDev2(
+        name='dev2',
+        state=STATE,
+        protocol=DEV2_PROTOCOL,
+        memory=DEV2_DATA,
+        disk=DEV2_DATA)

examples/swat-s2/dev3.py

@@ -0,0 +1,106 @@
+"""
+swat-s1 plc1.py
+"""
+
+from minicps.devices import IODevice
+from utils import DEV3_DATA, STATE, DEV3_PROTOCOL
+from utils import PLC_PERIOD_SEC, PLC_SAMPLES
+from utils import IP
+from utils import PUMP_FLOWRATE_IN
+from utils import PUMP_FLOWRATE_IN, PUMP_FLOWRATE_OUT
+from utils import TANK_HEIGHT, TANK_SECTION, TANK_DIAMETER
+from utils import LIT_101_M, RWT_INIT_LEVEL
+from utils import STATE, PP_PERIOD_SEC, PP_PERIOD_HOURS, PP_SAMPLES
+
+import time
+
+PLC1_ADDR = IP['plc1']
+DEV3_ADDR = IP['dev3']
+
+LIT101 = ('LIT101', 6)
+LIT101_PLC = ('LIT101', 1)
+
+MV101 = ('MV101', 5)
+P101 = ('P101', 7)
+
+# SPHINX_SWAT_TUTORIAL PLC1 LOGIC)
+
+# TODO: real value tag where to read/write flow sensor
+class SwatDev3(IODevice):
+
+    def pre_loop(self, sleep=0.1):
+        print 'DEBUG: swat-s2 dev2 enters pre_loop'
+        start_level = 0.500
+        time.sleep(45)        
+        self.set(LIT101, start_level)
+        self.send(LIT101, start_level, DEV3_ADDR)
+        time.sleep(sleep)
+
+
+    def main_loop(self):
+        """mv101 main loop.
+
+            - reads sensors value
+            - updates its enip server
+        """
+
+        # print 'DEBUG: swat-s2 dev2 enters main_loop.'
+        print
+
+        count = 0
+        while(count <= PLC_SAMPLES):
+            # TODO: SIMULATE VIRTUAL PROCESS
+            new_level = float(self.get(LIT101))
+
+            water_volume = TANK_SECTION * new_level
+
+            # inflows volumes
+            mv101 = float(self.get(MV101))
+            if int(mv101) == 1:
+                inflow = PUMP_FLOWRATE_IN * PP_PERIOD_HOURS
+                # print "DEBUG RawWaterTank inflow: ", inflow
+                water_volume += inflow
+
+            # outflows volumes
+            p101 = float(self.get(P101))
+            if int(p101) == 1:
+                outflow = PUMP_FLOWRATE_OUT * PP_PERIOD_HOURS
+                # print "DEBUG RawWaterTank outflow: ", outflow
+                water_volume -= outflow
+
+            # compute new water_level
+            new_level = water_volume / TANK_SECTION
+
+            # level cannot be negative
+            if new_level <= 0.0:
+                new_level = 0.0
+
+            # update internal and state water level
+            self.set(LIT101, new_level)
+            self.send(LIT101, new_level, DEV3_ADDR)
+
+            # 988 sec starting from 0.500 m
+            if new_level >= LIT_101_M['HH']:
+                # print 'DEBUG RawWaterTank above HH count: ', count
+                break
+
+            # 367 sec starting from 0.500 m
+            elif new_level <= LIT_101_M['LL']:
+                # print 'DEBUG RawWaterTank below LL count: ', count
+                break
+
+            time.sleep(PLC_PERIOD_SEC)
+            count += 1
+
+        print 'DEBUG swat-s2 dev3 shutdown'
+
+
+if __name__ == "__main__":
+
+    # notice that memory init is different form disk init
+    dev3 = SwatDev3(
+        name='dev3',
+        state=STATE,
+        protocol=DEV3_PROTOCOL,
+        memory=DEV3_DATA,
+        disk=DEV3_DATA)