Commit 47eb6e2a authored by berge's avatar berge
Browse files

Fixed synchronisation issues

parent ec4c8ae5
Loading
Loading
Loading
Loading
+10 −6
Original line number Diff line number Diff line
@@ -127,7 +127,7 @@ module LibItsGeoNetworking_Functions {
            // Connect            
            connect(p_nodeB:syncPort, self:syncPort);
            connect(p_nodeD:syncPort, self:syncPort);
			connect(self:syncPort, self:syncSendPort);
			connect(self:syncPort, mtc:syncPort);
			activate(a_cf02Down(p_nodeB, p_nodeD));
        
            //Initialze the IUT
@@ -182,7 +182,7 @@ module LibItsGeoNetworking_Functions {
            // Disconnect
            disconnect(p_nodeB:syncPort, self:syncPort);
            disconnect(p_nodeD:syncPort, self:syncPort);
			disconnect(self:syncPort, self:syncSendPort);
			disconnect(self:syncPort, mtc:syncPort);
        
        } // end f_cf02Down
        
@@ -222,7 +222,7 @@ module LibItsGeoNetworking_Functions {
            // Connect
            connect(p_nodeB:syncPort, self:syncPort);
            connect(p_nodeC:syncPort, self:syncPort);
			connect(self:syncPort, self:syncSendPort);
			connect(self:syncPort, mtc:syncPort);
			activate(a_cf03Down(p_nodeB, p_nodeC));

            //Initialze the IUT
@@ -279,7 +279,7 @@ module LibItsGeoNetworking_Functions {
            // Disconnect
            disconnect(p_nodeB:syncPort, self:syncPort);
            disconnect(p_nodeC:syncPort, self:syncPort);
			disconnect(self:syncPort, self:syncSendPort);
			disconnect(self:syncPort, mtc:syncPort);
        
        } // end f_cf03Down

@@ -327,7 +327,7 @@ module LibItsGeoNetworking_Functions {
            connect(p_nodeB:syncPort, self:syncPort);
            connect(p_nodeC:syncPort, self:syncPort);
            connect(p_nodeD:syncPort, self:syncPort);
			connect(self:syncPort, self:syncSendPort);
			connect(self:syncPort, mtc:syncPort);
			activate(a_cf04Down(p_nodeB, p_nodeC, p_nodeD));
            
            //Initialze the IUT
@@ -393,7 +393,7 @@ module LibItsGeoNetworking_Functions {
            disconnect(p_nodeB:syncPort, self:syncPort);
            disconnect(p_nodeC:syncPort, self:syncPort);
            disconnect(p_nodeD:syncPort, self:syncPort);
			disconnect(self:syncPort, self:syncSendPort);
			disconnect(self:syncPort, mtc:syncPort);
        
        } // end f_cf04Down
        
@@ -688,6 +688,10 @@ module LibItsGeoNetworking_Functions {
                log("*** a_default: ERROR: Timeout while awaiting the reception of a message ***");
                f_selfOrClientSyncAndVerdict("error", e_timeout);
            }
            [] a_shutdown() {
                log("*** a_default: INFO: TEST COMPONENT NOW STOPPING ITSELF! ***");
                stop;                 
            }
        }        

        /**