Stf531 non blocking

LibOneM2M/OneM2M_Functions.ttcn

@@ -1566,6 +1566,41 @@ module OneM2M_Functions {
}
} //end f_cse_notifyProcedure_representationHandler
+				
+				/**
+				 * @desc Handling message exchange for the notification procedure
+				 * @param p_responsePrimitive Expected responsePrimitive in the notification
+				 * @verdict 
+				 */
+				function f_cse_notifyProcedure_responsePrimitiveHandler(template ResponsePrimitive p_responsePrimitive) runs on AeSimu {
+					// Local variables
+					var ResponsePrimitive v_responsePrimitive;
+	
+					//Activate defaults when running on a PTC
+					f_cse_activateDefaults_ae();							
+	
+					tc_ac.start;
+					alt {
+						[] mcaPortIn.receive(mw_request(mw_notifyResponsePrimitive(p_responsePrimitive))) -> value vc_request {
+							tc_ac.stop;
+							setverdict(pass, __SCOPE__ & ":INFO: Notification received with the expected content");
+							v_responsePrimitive := valueof(m_responseNotification(int2001, omit));
+							v_responsePrimitive.requestIdentifier := vc_request.primitive.requestPrimitive.requestIdentifier;
+							mcaPortIn.send(m_response(v_responsePrimitive));
+						}
+						[] mcaPortIn.receive(mw_request(mw_notifyResponsePrimitive(?))) -> value vc_request {
+							tc_ac.stop;
+							setverdict(fail, __SCOPE__ & ":ERROR: Notification received but the content doesn't match");
+							v_responsePrimitive := valueof(m_responseNotification(int2001, omit));
+							v_responsePrimitive.requestIdentifier := vc_request.primitive.requestPrimitive.requestIdentifier;
+							mcaPortIn.send(m_response(v_responsePrimitive));
+						}
+						[] tc_ac.timeout {
+							setverdict(fail, __SCOPE__ & ":ERROR: No notification received");
+						}
+					}
+    	
+				} //end f_cse_notifyProcedure_representationHandler
/**
* @desc Handling message exchange for the notification procedure (aggregatedNotification)