mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-09 00:00:00 +01:00
removed old RT-LAB project
git-svn-id: https://zerberus.eonerc.rwth-aachen.de:8443/svn/s2ss/trunk@158 8ec27952-4edc-4aab-86aa-e87bb2611832
This commit is contained in:
parent
dad3ebecca
commit
03ddf7fe4f
19 changed files with 0 additions and 5899 deletions
|
|
@ -1,12 +0,0 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>test</name>
|
||||
<comment></comment>
|
||||
<projects>
|
||||
</projects>
|
||||
<buildSpec>
|
||||
</buildSpec>
|
||||
<natures>
|
||||
<nature>com.opalrt.rtlab.ui.rtlabnature</nature>
|
||||
</natures>
|
||||
</projectDescription>
|
||||
|
|
@ -1,3 +0,0 @@
|
|||
#Fri May 23 11:58:23 CEST 2014
|
||||
eclipse.preferences.version=1
|
||||
rtprojectfile=01_server2OPAL.llp
|
||||
|
|
@ -1,18 +0,0 @@
|
|||
<?xml version="1.0" ?>
|
||||
<Project>
|
||||
<General>
|
||||
<att_name>test</att_name>
|
||||
<att_description>This is a project!</att_description>
|
||||
<att_autosave>ON</att_autosave>
|
||||
<att_filename>D:\msv\svo\s2ss\clients\opal\01_server2OPAL.llp</att_filename>
|
||||
</General>
|
||||
<Models>
|
||||
<Model>
|
||||
<Path>
|
||||
<Relative>models\AsyncIP_sl\AsyncIP_sl.mdl</Relative>
|
||||
<Absolute>D:\msv\svo\s2ss\clients\opal\models\AsyncIP_sl\AsyncIP_sl.mdl</Absolute>
|
||||
<UNC>D:\msv\svo\s2ss\clients\opal\models\AsyncIP_sl\AsyncIP_sl.mdl</UNC>
|
||||
</Path>
|
||||
</Model>
|
||||
</Models>
|
||||
</Project>
|
||||
|
|
@ -1,101 +0,0 @@
|
|||
[EnvVars]
|
||||
ABORT_COMPILE_WHEN_NO_BITSTREAM=0
|
||||
ACTION_AFTER_N_OVERRUNS=10
|
||||
ACTION_ON_OVERRUNS=0
|
||||
AcquisitionMemory=0,2500,24,100
|
||||
ActiveGroups=7/0/24/25/26/27/28/29/
|
||||
CACHEABLE_DMA_MEMORY_ACCESS=ON
|
||||
COMM_RT=UDP/IP
|
||||
ClockPeriodMode=Free-Clock
|
||||
ClockPeriodTime=10
|
||||
DEBUG=0
|
||||
DETECT_OVERRUNS=ON
|
||||
ENABLE_WATCHDOG=ON
|
||||
EXT_CC_OPTS=
|
||||
EXT_LD_OPTS=
|
||||
EXT_LIB=
|
||||
EXT_LIBPATH=
|
||||
MODEL_PAUSE_TIME=0.000000
|
||||
MODEL_STOP_TIME=0.000000
|
||||
MONITORING=ON
|
||||
MONITORING_BLOCK=OFF
|
||||
MONITORING_DISPLAY=NEVER
|
||||
MSG_PRECISION_FACTOR=0
|
||||
MaxDynamicSignals=2/0/100/24/42/
|
||||
NB_STEP_WITHOUT_OVERRUNS=10
|
||||
OPAL_DEBUG=OFF
|
||||
OP_MATLABR2011B=1
|
||||
OS_COMPILE_RELEASE=2.6.29.6-opalrt-5
|
||||
PRINT_LOG_LEVEL=ALWAYS
|
||||
RESET_IO_MISSING=ON
|
||||
SYSNAME=linux
|
||||
USER_INCS=
|
||||
USER_SRCS=
|
||||
WATCHDOG_TIMEOUT=5000
|
||||
[EnvVars_REDHAWK_DYN_1]
|
||||
INTERNAL_IGN_SOURCE_FILE=sfun_gen_async_ctrl.c sfun_recv_async.c sfun_send_async.c
|
||||
INTERNAL_LIBRARY2=-lOpalAsyncApiR2011b
|
||||
INTERNAL_LIBRARY3=-lOpalAsyncApiCore
|
||||
[ExtraPutFilesComp]
|
||||
s2ss\AsyncIP.mk=Ascii
|
||||
s2ss\include\Interface.h=Ascii
|
||||
s2ss\include\MsgFormat.h=Ascii
|
||||
s2ss\include\Sched.h=Ascii
|
||||
s2ss\include\Socket.h=Ascii
|
||||
s2ss\include\config.h=Ascii
|
||||
s2ss\src\AsyncIP.c=Ascii
|
||||
s2ss\src\Interface.c=Ascii
|
||||
s2ss\src\Sched.c=Ascii
|
||||
s2ss\src\Socket.c=Ascii
|
||||
[ExtraPutFilesComp_1_RT_LAB]
|
||||
C:\OPAL-RT\RT-LAB\v10.5.9.356\common\lib\redhawk\libOpalAsyncApiCore.a=Binary
|
||||
[General]
|
||||
ATT_CHECKSUM1=3303931251
|
||||
ATT_CHECKSUM2=4180788877
|
||||
ATT_CHECKSUM3=2074112130
|
||||
ATT_CHECKSUM4=668397547
|
||||
ATT_CREATED_BY=jwu
|
||||
ATT_CREATED_ON=Thu Apr 15 08:21:54 1999
|
||||
ATT_ENABLE_PTA=OFF
|
||||
ATT_HANDLE_CONSOLE=ON
|
||||
ATT_LAST_SAVED_BY=ACS
|
||||
ATT_LAST_SAVED_ON=Mon Jul 14 19:24:22 2014
|
||||
ATT_REVISION=1.429
|
||||
AutoRetrieveFiles=ON
|
||||
AutoRetrieveRtlab=ON
|
||||
CompilerVersion=AUTOMATIC
|
||||
DESCRIPTION=Simple ping pong test between S2SS and OPAL$%CR%$$%CR%$Using sine waves to measure round trip time.
|
||||
DinamoFlag=OFF
|
||||
FILENAME=D:\msv\svo\s2ss\clients\opal\models\AsyncIP_sl\AsyncIP_sl.mdl
|
||||
FORCE_RECOMPILE=0
|
||||
IMPORTED_GLOBAL_VARIABLES=1
|
||||
LastCompileRtlabVersion=v10.5.9.356
|
||||
LastMatlabUsed=21
|
||||
LastMatlabUsedName=v7.13
|
||||
MATLAB_USED_IN_MODEL=21
|
||||
Name=AsyncIP_sl
|
||||
PRINT_CYCLE=OFF
|
||||
PostBuildCmd=
|
||||
PreBuildCmd=
|
||||
QNX_LAST_COMPILE_VERSION=
|
||||
RH64_LAST_COMPILE_VERSION=
|
||||
RH_LAST_COMPILE_VERSION=2.6.29.6-opalrt-5
|
||||
ReportFileId=
|
||||
RetrieveBuildTree=ON
|
||||
RetrieveRootDir=
|
||||
SimulationMode=2
|
||||
TLC=Automatic
|
||||
TMF=Automatic
|
||||
TRANSFERFILE_AT_LOAD=ON
|
||||
TargetCompileCmd=make -f /usr/opalrt/common/bin/opalmodelmk
|
||||
TargetPlatform=REDHAWK
|
||||
TimeFactor=1.000000000000000
|
||||
TimeStep=0.000050000000000
|
||||
sc_consoleTimeStep=-1.000000000000000
|
||||
sm_ip_testTimeStep=0.000049999998737
|
||||
[NodeMapping]
|
||||
sm_ip_test=ACS_OPAL_RT
|
||||
sm_ip_test_CORE_ASSIGNATION=1
|
||||
sm_ip_test_CPU=-1
|
||||
sm_ip_test_DEBUG=OFF
|
||||
sm_ip_test_XHP_ENABLE=FALSE
|
||||
File diff suppressed because it is too large
Load diff
File diff suppressed because it is too large
Load diff
|
|
@ -1,59 +0,0 @@
|
|||
[General]
|
||||
ATT_VERSION=6
|
||||
numClientsProbe=0
|
||||
fileVersion=6
|
||||
[Group_1]
|
||||
maxDynSignals=100
|
||||
fixSignalsList=13|1|2|3|4|5|6|7|8|9|10|11|12|13
|
||||
dynSignalsList=0
|
||||
signalName=
|
||||
trigSignalName=
|
||||
level=0.000000
|
||||
offset=0
|
||||
condition=0
|
||||
triggerEnabled=0
|
||||
trigType=0
|
||||
sigNameId=800
|
||||
trigSigNameId=0
|
||||
nodeId=0
|
||||
decimationFactor=1
|
||||
valueType=0
|
||||
numValues=200
|
||||
duration=0.010000
|
||||
newMemSize=2500
|
||||
triggerState=0
|
||||
repetitive=1
|
||||
rearmDelay=0.000000
|
||||
triggerButton=2
|
||||
writeEnabled=0
|
||||
writeFileName=
|
||||
writeFileVarName=
|
||||
fileLimit=1000000
|
||||
[Group_25]
|
||||
maxDynSignals=42
|
||||
signalName=
|
||||
trigSignalName=
|
||||
level=0.000000
|
||||
offset=0
|
||||
condition=0
|
||||
triggerEnabled=0
|
||||
trigType=0
|
||||
sigNameId=2033149028
|
||||
trigSigNameId=1684275321
|
||||
nodeId=539780196
|
||||
decimationFactor=1
|
||||
valueType=0
|
||||
numValues=100
|
||||
duration=0.005000
|
||||
newMemSize=100
|
||||
triggerState=0
|
||||
repetitive=1
|
||||
rearmDelay=0.000000
|
||||
triggerButton=2
|
||||
writeEnabled=0
|
||||
writeFileName=
|
||||
writeFileVarName=
|
||||
fileLimit=0
|
||||
dynSignalsList=0
|
||||
[DynGroup_1]
|
||||
[DynGroup_25]
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
function lic = actxlicense(progid)
|
||||
|
||||
if strcmpi(progid, 'air.airctrl.1')
|
||||
lic = 'Copyright (c) 1996 ';
|
||||
return;
|
||||
end
|
||||
File diff suppressed because it is too large
Load diff
|
|
@ -1,75 +0,0 @@
|
|||
# Specify program name
|
||||
PROGRAM = AsyncIP
|
||||
|
||||
# Specify default values if we are not compiling from RT-LAB
|
||||
TARGET_OPALRT_ROOT = /usr/opalrt
|
||||
|
||||
# QNX v6.x
|
||||
ifeq "$(SYSNAME)" "nto"
|
||||
CC = gcc
|
||||
LD = $(CC)
|
||||
TARGET_LIB = -lsocket
|
||||
endif
|
||||
|
||||
# RedHawk Linux
|
||||
ifeq "$(shell uname)" "Linux"
|
||||
RTLAB_INTEL_COMPILER ?= 1
|
||||
|
||||
# Intel Compiler support
|
||||
ifeq ($(RTLAB_INTEL_COMPILER),1)
|
||||
CC = opicc
|
||||
LD = opicpc
|
||||
# Gnu Compiler support
|
||||
else
|
||||
CC = gcc
|
||||
LD = g++
|
||||
INTEL_LIBS = -limf -lirc
|
||||
endif
|
||||
|
||||
# RedHat or RedHawk
|
||||
LINUX_FLAVOR = $(shell uname -r | grep RedHawk)
|
||||
ifneq "$(LINUX_FLAVOR) " " " ### Linux (RedHat)
|
||||
RH_FLAGS = -D_GNU_SOURCE -D__redhawk__
|
||||
RH_LIBS = -lccur_rt
|
||||
else
|
||||
RH_FLAGS = -D_GNU_SOURCE
|
||||
endif
|
||||
|
||||
TARGET_LIB = -lpthread -lm -ldl -lutil -lrt $(RH_LIBS) $(INTEL_LIBS)
|
||||
endif
|
||||
|
||||
# Support for debugging symbols
|
||||
ifeq ($(DEBUG),1)
|
||||
CC_DEBUG_OPTS=-g -D_DEBUG
|
||||
LD_DEBUG_OPTS=-g
|
||||
else
|
||||
CC_DEBUG_OPTS=-O
|
||||
LD_DEBUG_OPTS=
|
||||
endif
|
||||
|
||||
INCLUDES = -I.
|
||||
LIBPATH = -L.
|
||||
CC_OPTS =
|
||||
LD_OPTS =
|
||||
OBJS = ${PROGRAM}.o Sched.o Interface.o Socket.o
|
||||
|
||||
ADDLIB = -lOpalCore -lOpalUtils
|
||||
LIBS = -lOpalAsyncApiCore $(ADDLIB) $(TARGET_LIB)
|
||||
|
||||
CFLAGS = -c $(CC_OPTS) $(CC_DEBUG_OPTS) $(RH_FLAGS) $(INCLUDES)
|
||||
LDFLAGS = $(LD_OPTS) $(LD_DEBUG_OPTS) $(LIBPATH)
|
||||
|
||||
all: $(PROGRAM)
|
||||
|
||||
install:
|
||||
\mkdir -p $(TARGET_OPALRT_ROOT)/local
|
||||
\chmod 755 $(TARGET_OPALRT_ROOT)/local
|
||||
\cp -f $(PROGRAM) $(TARGET_OPALRT_ROOT)/local
|
||||
|
||||
clean:
|
||||
\rm -f $(OBJS) $(PROGRAM)
|
||||
|
||||
$(PROGRAM): $(OBJS)
|
||||
$(LD) $(LDFLAGS) -o $@ $(OBJS) $(LIBS)
|
||||
chmod 777 $@
|
||||
@echo "### Created executable: $(PROGRAM)"
|
||||
|
|
@ -1,13 +0,0 @@
|
|||
/** OPAL Interface setup
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @file
|
||||
*/
|
||||
|
||||
#ifndef _INTERFACE_H_
|
||||
#define _INTERFACE_H_
|
||||
|
||||
int if_setup(const char *op, const char *iface, const char *addr);
|
||||
|
||||
#endif /* _INTERFACE_H_ */
|
||||
|
|
@ -1,51 +0,0 @@
|
|||
/** Message format
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @file
|
||||
*/
|
||||
|
||||
#ifndef _MSG_FORMAT_H_
|
||||
#define _MSG_FORMAT_H_
|
||||
|
||||
#include <stdint.h>
|
||||
|
||||
/** Maximum number of dword values in a message */
|
||||
#define MSG_VALUES 16
|
||||
/** The current version number for the message format */
|
||||
#define MSG_VERSION 0
|
||||
|
||||
/** @todo Implement more message types */
|
||||
#define MSG_TYPE_DATA 0
|
||||
#define MSG_TYPE_START 1
|
||||
#define MSG_TYPE_STOP 2
|
||||
|
||||
/** Initialize a message */
|
||||
#define MSG_INIT(i) { \
|
||||
.version = MSG_VERSION, \
|
||||
.type = MSG_TYPE_DATA, \
|
||||
.length = i, \
|
||||
.sequence = 0 \
|
||||
}
|
||||
|
||||
/** This message format is used by all clients
|
||||
*
|
||||
* @diafile msg_format.dia
|
||||
**/
|
||||
struct msg
|
||||
{
|
||||
/** The version specifies the format of the remaining message */
|
||||
unsigned version : 4;
|
||||
/** Data or control message */
|
||||
unsigned type : 2;
|
||||
/** These bits are reserved for future extensions */
|
||||
unsigned __padding : 2;
|
||||
/** Number of valid dword values in msg::data[] */
|
||||
uint8_t length;
|
||||
/** The sequence number gets incremented by one for consecutive messages */
|
||||
uint16_t sequence;
|
||||
/** The message payload */
|
||||
float data[MSG_VALUES];
|
||||
} __attribute__((packed));
|
||||
|
||||
#endif /* _MSG_FORMAT_H_ */
|
||||
|
|
@ -1,17 +0,0 @@
|
|||
/** Configure Scheduler
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @author Mathieu Dubé-Dallaire
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @copyright 2003, OPAL-RT Technologies inc
|
||||
* @file
|
||||
*/
|
||||
|
||||
#ifndef _SCHED_H_
|
||||
#define _SCHED_H_
|
||||
|
||||
#define EOK 0
|
||||
|
||||
int AssignProcToCpu0(void);
|
||||
|
||||
#endif /* _SCHED_H_ */
|
||||
|
|
@ -1,33 +0,0 @@
|
|||
/** Helper functions for socket
|
||||
*
|
||||
* Code example of an asynchronous program. This program is started
|
||||
* by the asynchronous controller and demonstrates how to send and
|
||||
* receive data to and from the asynchronous icons and a UDP or TCP
|
||||
* port.
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @author Mathieu Dubé-Dallaire
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @copyright 2003, OPAL-RT Technologies inc
|
||||
* @file
|
||||
*/
|
||||
|
||||
#ifndef _SOCKET_H_
|
||||
#define _SOCKET_H_
|
||||
|
||||
#define RT
|
||||
#include "OpalGenAsyncParamCtrl.h"
|
||||
|
||||
#define UDP_PROTOCOL 1
|
||||
#define TCP_PROTOCOL 2
|
||||
#define EOK 0
|
||||
|
||||
int InitSocket(Opal_GenAsyncParam_Ctrl IconCtrlStruct);
|
||||
|
||||
int SendPacket(char* DataSend, int datalength);
|
||||
|
||||
int RecvPacket(char* DataRecv, int datalength, double timeout);
|
||||
|
||||
int CloseSocket(Opal_GenAsyncParam_Ctrl IconCtrlStruct);
|
||||
|
||||
#endif /* _SOCKET_H_ */
|
||||
|
|
@ -1,294 +0,0 @@
|
|||
/** AsyncIP
|
||||
*
|
||||
* Code example of an asynchronous program. This program is started
|
||||
* by the asynchronous controller and demonstrates how to send and
|
||||
* receive data to and from the asynchronous icons and a UDP or TCP
|
||||
* port.
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @author Mathieu Dubé-Dallaire
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @copyright 2003, OPAL-RT Technologies inc
|
||||
* @file
|
||||
*/
|
||||
|
||||
/* Standard ANSI C headers needed for this program */
|
||||
#include <errno.h>
|
||||
#include <fcntl.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <sys/wait.h>
|
||||
#include <termios.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#if defined(__QNXNTO__)
|
||||
# include <process.h>
|
||||
# include <pthread.h>
|
||||
# include <devctl.h>
|
||||
# include <sys/dcmd_chr.h>
|
||||
#elif defined(__linux__)
|
||||
# define _GNU_SOURCE 1
|
||||
#endif
|
||||
|
||||
/* Define RTLAB before including OpalPrint.h for messages to be sent
|
||||
* to the OpalDisplay. Otherwise stdout will be used. */
|
||||
#define RTLAB
|
||||
#include "OpalPrint.h"
|
||||
#include "AsyncApi.h"
|
||||
|
||||
/* This is the message format */
|
||||
#include "config.h"
|
||||
#include "MsgFormat.h"
|
||||
#include "Socket.h"
|
||||
#include "Interface.h"
|
||||
|
||||
/* This is just for initializing the shared memory access to communicate
|
||||
* with the RT-LAB model. It's easier to remember the arguments like this */
|
||||
#define ASYNC_SHMEM_NAME argv[1]
|
||||
#define ASYNC_SHMEM_SIZE atoi(argv[2])
|
||||
#define PRINT_SHMEM_NAME argv[3]
|
||||
|
||||
static void *SendToIPPort(void *arg)
|
||||
{
|
||||
unsigned SendID = 1;
|
||||
unsigned i, n;
|
||||
int nbSend = 0;
|
||||
unsigned ModelState;
|
||||
|
||||
/* Data from OPAL-RT model */
|
||||
double mdldata[MSG_VALUES];
|
||||
int mdldata_size;
|
||||
|
||||
/* Data from the S2SS server */
|
||||
struct msg msg = MSG_INIT(0);
|
||||
int msg_size;
|
||||
|
||||
OpalPrint("%s: SendToIPPort thread started\n", PROGNAME);
|
||||
|
||||
OpalGetNbAsyncSendIcon(&nbSend);
|
||||
if (nbSend >= 1) {
|
||||
do {
|
||||
/* This call unblocks when the 'Data Ready' line of a send icon is asserted. */
|
||||
if ((n = OpalWaitForAsyncSendRequest(&SendID)) != EOK) {
|
||||
ModelState = OpalGetAsyncModelState();
|
||||
if ((ModelState != STATE_RESET) && (ModelState != STATE_STOP)) {
|
||||
OpalSetAsyncSendIconError(n, SendID);
|
||||
OpalPrint("%s: OpalWaitForAsyncSendRequest(), errno %d\n", PROGNAME, n);
|
||||
}
|
||||
|
||||
continue;
|
||||
}
|
||||
|
||||
/* No errors encountered yet */
|
||||
OpalSetAsyncSendIconError(0, SendID);
|
||||
|
||||
/* Get the size of the data being sent by the unblocking SendID */
|
||||
OpalGetAsyncSendIconDataLength(&mdldata_size, SendID);
|
||||
if (mdldata_size / sizeof(double) > MSG_VALUES) {
|
||||
OpalPrint("%s: Number of signals for SendID=%d exceeds allowed maximum (%d)\n",
|
||||
PROGNAME, SendID, MSG_VALUES);
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
/* Read data from the model */
|
||||
OpalGetAsyncSendIconData(mdldata, mdldata_size, SendID);
|
||||
|
||||
/******* FORMAT TO SPECIFIC PROTOCOL HERE *****************************/
|
||||
// msg.dev_id = SendID; /* Use the SendID as a device ID here */
|
||||
msg.sequence++;
|
||||
msg.length = mdldata_size / sizeof(double);
|
||||
|
||||
for (i = 0; i < msg.length; i++)
|
||||
msg.data[i] = (float) mdldata[i];
|
||||
|
||||
msg_size = 4 * (msg.length + 1);
|
||||
/**********************************************************************/
|
||||
|
||||
/* Perform the actual write to the ip port */
|
||||
if (SendPacket((char *) &msg, msg_size) < 0)
|
||||
OpalSetAsyncSendIconError(errno, SendID);
|
||||
else
|
||||
OpalSetAsyncSendIconError(0, SendID);
|
||||
|
||||
/* This next call allows the execution of the "asynchronous" process
|
||||
* to actually be synchronous with the model. To achieve this, you
|
||||
* should set the "Sending Mode" in the Async_Send block to
|
||||
* NEED_REPLY_BEFORE_NEXT_SEND or NEED_REPLY_NOW. This will force
|
||||
* the model to wait for this process to call this
|
||||
* OpalAsyncSendRequestDone function before continuing. */
|
||||
OpalAsyncSendRequestDone(SendID);
|
||||
|
||||
/* Before continuing, we make sure that the real-time model
|
||||
* has not been stopped. If it has, we quit. */
|
||||
ModelState = OpalGetAsyncModelState();
|
||||
} while ((ModelState != STATE_RESET) && (ModelState != STATE_STOP));
|
||||
|
||||
OpalPrint("%s: SendToIPPort: Finished\n", PROGNAME);
|
||||
}
|
||||
else {
|
||||
OpalPrint("%s: SendToIPPort: No transimission block for this controller. Stopping thread.\n", PROGNAME);
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static void *RecvFromIPPort(void *arg)
|
||||
{
|
||||
unsigned RecvID = 1;
|
||||
unsigned i, n;
|
||||
int nbRecv = 0;
|
||||
unsigned ModelState;
|
||||
|
||||
/* Data from OPAL-RT model */
|
||||
double mdldata[MSG_VALUES];
|
||||
int mdldata_size;
|
||||
|
||||
/* Data from the S2SS server */
|
||||
struct msg msg = MSG_INIT(0);
|
||||
unsigned msg_size;
|
||||
|
||||
OpalPrint("%s: RecvFromIPPort thread started\n", PROGNAME);
|
||||
|
||||
OpalGetNbAsyncRecvIcon(&nbRecv);
|
||||
if (nbRecv >= 1) {
|
||||
do {
|
||||
|
||||
/******* FORMAT TO SPECIFIC PROTOCOL HERE ******************************/
|
||||
msg_size = sizeof(msg);
|
||||
n = RecvPacket((char *) &msg, msg_size, 1.0);
|
||||
|
||||
if (msg.version != MSG_VERSION) {
|
||||
OpalPrint("%s: Received message with unknown version. Skipping..\n", PROGNAME);
|
||||
continue;
|
||||
}
|
||||
|
||||
if (msg.type != MSG_TYPE_DATA) {
|
||||
OpalPrint("%s: Received no data. Skipping..\n", PROGNAME);
|
||||
continue;
|
||||
}
|
||||
|
||||
msg_size = 4 * (msg.length + 1);
|
||||
/***********************************************************************/
|
||||
|
||||
if (n < 1) {
|
||||
ModelState = OpalGetAsyncModelState();
|
||||
if ((ModelState != STATE_RESET) && (ModelState != STATE_STOP)) {
|
||||
// n == 0 means timeout, so we continue silently
|
||||
//if (n == 0)
|
||||
// OpalPrint("%s: Timeout while waiting for data\n", PROGNAME, errno);
|
||||
// n == -1 means a more serious error, so we print it
|
||||
if (n == -1)
|
||||
OpalPrint("%s: Error %d while waiting for data\n", PROGNAME, errno);
|
||||
continue;
|
||||
}
|
||||
break;
|
||||
}
|
||||
else if (n != msg_size) {
|
||||
OpalPrint("%s: Received incoherent packet (size: %d, complete: %d)\n", PROGNAME, n, msg_size);
|
||||
continue;
|
||||
}
|
||||
|
||||
/******* FORMAT TO SPECIFIC PROTOCOL HERE *******************************/
|
||||
OpalSetAsyncRecvIconStatus(msg.sequence, RecvID); /* Set the Status to the message ID */
|
||||
OpalSetAsyncRecvIconError(0, RecvID); /* Set the Error to 0 */
|
||||
|
||||
/* Get the number of signals to send back to the model */
|
||||
OpalGetAsyncRecvIconDataLength(&mdldata_size, RecvID);
|
||||
|
||||
if (mdldata_size / sizeof(double) > MSG_VALUES) {
|
||||
OpalPrint("%s: Number of signals for RecvID=%d (%d) exceeds allowed maximum (%d)\n",
|
||||
PROGNAME, RecvID, mdldata_size / sizeof(double), MSG_VALUES);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
if (mdldata_size / sizeof(double) > msg.length) {
|
||||
OpalPrint("%s: Number of signals for RecvID=%d (%d) exceeds what was received (%d)\n",
|
||||
PROGNAME, RecvID, mdldata_size / sizeof(double), msg.length);
|
||||
}
|
||||
|
||||
for (i = 0; i < msg.length; i++)
|
||||
mdldata[i] = (double) msg.data[i];
|
||||
/************************************************************************/
|
||||
|
||||
OpalSetAsyncRecvIconData(mdldata, mdldata_size, RecvID);
|
||||
|
||||
/* Before continuing, we make sure that the real-time model
|
||||
* has not been stopped. If it has, we quit. */
|
||||
ModelState = OpalGetAsyncModelState();
|
||||
} while ((ModelState != STATE_RESET) && (ModelState != STATE_STOP));
|
||||
|
||||
OpalPrint("%s: RecvFromIPPort: Finished\n", PROGNAME);
|
||||
}
|
||||
else {
|
||||
OpalPrint("%s: RecvFromIPPort: No reception block for this controller. Stopping thread.\n", PROGNAME);
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
int err;
|
||||
|
||||
Opal_GenAsyncParam_Ctrl IconCtrlStruct;
|
||||
|
||||
pthread_t tid_send, tid_recv;
|
||||
pthread_attr_t attr_send, attr_recv;
|
||||
|
||||
OpalPrint("%s: This is a S2SS client\n", PROGNAME);
|
||||
|
||||
/* Check for the proper arguments to the program */
|
||||
if (argc < 4) {
|
||||
printf("Invalid Arguments: 1-AsyncShmemName 2-AsyncShmemSize 3-PrintShmemName\n");
|
||||
exit(0);
|
||||
}
|
||||
|
||||
/* Enable the OpalPrint function. This prints to the OpalDisplay. */
|
||||
if (OpalSystemCtrl_Register(PRINT_SHMEM_NAME) != EOK) {
|
||||
printf("%s: ERROR: OpalPrint() access not available\n", PROGNAME);
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
/* Open Share Memory created by the model. */
|
||||
if ((OpalOpenAsyncMem(ASYNC_SHMEM_SIZE, ASYNC_SHMEM_NAME)) != EOK) {
|
||||
OpalPrint("%s: ERROR: Model shared memory not available\n", PROGNAME);
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
/* For Redhawk, Assign this process to CPU 0 in order to support partial XHP */
|
||||
AssignProcToCpu0();
|
||||
|
||||
/* Get IP Controler Parameters (ie: ip address, port number...) and
|
||||
* initialize the device on the QNX node. */
|
||||
memset(&IconCtrlStruct, 0, sizeof(IconCtrlStruct));
|
||||
if ((err = OpalGetAsyncCtrlParameters(&IconCtrlStruct, sizeof(IconCtrlStruct))) != EOK) {
|
||||
OpalPrint("%s: ERROR: Could not get controller parameters (%d).\n", PROGNAME, err);
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
if (InitSocket(IconCtrlStruct) != EOK) {
|
||||
OpalPrint("%s: ERROR: Initialization failed.\n", PROGNAME);
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
/* Start send/receive threads */
|
||||
if ((pthread_create(&tid_send, NULL, SendToIPPort, NULL)) == -1)
|
||||
OpalPrint("%s: ERROR: Could not create thread (SendToIPPort), errno %d\n", PROGNAME, errno);
|
||||
if ((pthread_create(&tid_recv, NULL, RecvFromIPPort, NULL)) == -1)
|
||||
OpalPrint("%s: ERROR: Could not create thread (RecvFromIPPort), errno %d\n", PROGNAME, errno);
|
||||
|
||||
/* Wait for both threads to finish */
|
||||
if ((err = pthread_join(tid_send, NULL)) != 0)
|
||||
OpalPrint("%s: ERROR: pthread_join (SendToIPPort), errno %d\n", PROGNAME, err);
|
||||
if ((err = pthread_join(tid_recv, NULL)) != 0)
|
||||
OpalPrint("%s: ERROR: pthread_join (RecvFromIPPort), errno %d\n", PROGNAME, err);
|
||||
|
||||
/* Close the ip port and shared memories */
|
||||
CloseSocket(IconCtrlStruct);
|
||||
OpalCloseAsyncMem (ASYNC_SHMEM_SIZE, ASYNC_SHMEM_NAME);
|
||||
OpalSystemCtrl_UnRegister(PRINT_SHMEM_NAME);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
|
@ -1,26 +0,0 @@
|
|||
/** OPAL Interface setup
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @file
|
||||
*/
|
||||
|
||||
#include "config.h"
|
||||
#include "Interface.h"
|
||||
|
||||
int if_setup(const char *op, const char *iface, const char *addr)
|
||||
{
|
||||
char cmd[256];
|
||||
|
||||
/* Setup remote address */
|
||||
snprintf(cmd, 256, "ip addr %s %s/32 dev %s", op, addr, iface);
|
||||
if (system(cmd))
|
||||
OpalPrint("Failed to add local address to interface");
|
||||
|
||||
/* Setup route for single IP address */
|
||||
snprintf(cmd, 256, "ip route %s %s/32 dev %s", op, addr, iface);
|
||||
if (system(cmd))
|
||||
OpalPrint("Failed to add route for remote address");
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
|
@ -1,74 +0,0 @@
|
|||
/** Configure Scheduler
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @author Mathieu Dubé-Dallaire
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @copyright 2003, OPAL-RT Technologies inc
|
||||
* @file
|
||||
*/
|
||||
|
||||
#include <errno.h>
|
||||
|
||||
/* Define RTLAB before including OpalPrint.h for messages to be sent
|
||||
* to the OpalDisplay. Otherwise stdout will be used. */
|
||||
#define RTLAB
|
||||
#include "OpalPrint.h"
|
||||
|
||||
#include "config.h"
|
||||
#include "Sched.h"
|
||||
|
||||
#if defined(__QNXNTO__)
|
||||
# include <process.h>
|
||||
# include <sys/sched.h>
|
||||
# include <devctl.h>
|
||||
# include <sys/dcmd_chr.h>
|
||||
#elif defined(__linux__)
|
||||
# define _GNU_SOURCE 1
|
||||
# include <sched.h>
|
||||
# if defined(__redhawk__)
|
||||
# include <cpuset.h>
|
||||
# include <mpadvise.h>
|
||||
# endif
|
||||
#endif
|
||||
|
||||
int AssignProcToCpu0(void)
|
||||
{
|
||||
#if defined(__linux__)
|
||||
#if defined(__redhawk__)
|
||||
int rc;
|
||||
pid_t pid = getpid();
|
||||
cpuset_t *pCpuset;
|
||||
|
||||
pCpuset = cpuset_alloc();
|
||||
if (NULL == pCpuset) {
|
||||
OpalPrint("Error allocating a cpuset\n");
|
||||
return ENOMEM;
|
||||
}
|
||||
|
||||
cpuset_init(pCpuset);
|
||||
cpuset_set_cpu(pCpuset, 0, 1);
|
||||
|
||||
rc = mpadvise(MPA_PRC_SETBIAS, MPA_TID, pid, pCpuset);
|
||||
if (MPA_FAILURE == rc) {
|
||||
rc = errno;
|
||||
OpalPrint("Error from mpadvise, %d %s, for pid %d\n", errno, strerror(errno), pid);
|
||||
cpuset_free(pCpuset);
|
||||
return rc;
|
||||
}
|
||||
|
||||
cpuset_free(pCpuset);
|
||||
#else
|
||||
cpu_set_t bindSet;
|
||||
CPU_ZERO(&bindSet);
|
||||
CPU_SET(0, &bindSet);
|
||||
|
||||
/* changing process cpu affinity */
|
||||
if (sched_setaffinity(0, sizeof(cpu_set_t), &bindSet) != 0) {
|
||||
OpalPrint("Unable to bind the process to CPU 0. (sched_setaffinity errno %d)\n", errno);
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
#endif
|
||||
return EOK;
|
||||
#endif /* __linux__ */
|
||||
}
|
||||
|
|
@ -1,223 +0,0 @@
|
|||
/** Helper functions for socket
|
||||
*
|
||||
* Code example of an asynchronous program. This program is started
|
||||
* by the asynchronous controller and demonstrates how to send and
|
||||
* receive data to and from the asynchronous icons and a UDP or TCP
|
||||
* port.
|
||||
*
|
||||
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
||||
* @author Mathieu Dubé-Dallaire
|
||||
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
||||
* @copyright 2003, OPAL-RT Technologies inc
|
||||
* @file
|
||||
*/
|
||||
|
||||
#include <errno.h>
|
||||
#include <unistd.h>
|
||||
#include <stdlib.h>
|
||||
#include <fcntl.h>
|
||||
#include <sys/time.h>
|
||||
#include <sys/socket.h>
|
||||
#include <netinet/in.h>
|
||||
|
||||
/* Define RTLAB before including OpalPrint.h for messages to be sent
|
||||
* to the OpalDisplay. Otherwise stdout will be used. */
|
||||
#define RTLAB
|
||||
#include "OpalPrint.h"
|
||||
#include "AsyncApi.h"
|
||||
|
||||
#include "config.h"
|
||||
#include "Socket.h"
|
||||
|
||||
/* Globals variables */
|
||||
struct sockaddr_in send_ad; /* Send address */
|
||||
struct sockaddr_in recv_ad; /* Receive address */
|
||||
int sd = -1; /* socket descriptor */
|
||||
int proto = UDP_PROTOCOL;
|
||||
|
||||
int InitSocket(Opal_GenAsyncParam_Ctrl IconCtrlStruct)
|
||||
{
|
||||
struct ip_mreq mreq; /* Multicast group structure */
|
||||
int socket_type;
|
||||
int socket_proto;
|
||||
unsigned char TTL = 1;
|
||||
unsigned char LOOP = 0;
|
||||
int rc;
|
||||
|
||||
proto = (int) IconCtrlStruct.FloatParam[0];
|
||||
OpalPrint("%s: Version : %s\n", PROGNAME, VERSION);
|
||||
|
||||
switch (proto) {
|
||||
case UDP_PROTOCOL: /* Communication using UDP/IP protocol */
|
||||
socket_proto = IPPROTO_UDP;
|
||||
socket_type = SOCK_DGRAM;
|
||||
OpalPrint("%s: Protocol : UDP/IP\n", PROGNAME);
|
||||
break;
|
||||
|
||||
case TCP_PROTOCOL: /* Communication using TCP/IP protocol */
|
||||
socket_proto = IPPROTO_IP;
|
||||
socket_type = SOCK_STREAM;
|
||||
OpalPrint("%s: Protocol : TCP/IP\n", PROGNAME);
|
||||
break;
|
||||
|
||||
default: /* Protocol is not recognized */
|
||||
OpalPrint("%s: ERROR: Protocol (%d) not supported!\n", PROGNAME, proto);
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
OpalPrint("%s: Remote Address : %s\n", PROGNAME, IconCtrlStruct.StringParam[0]);
|
||||
OpalPrint("%s: Remote Port : %d\n", PROGNAME, (int) IconCtrlStruct.FloatParam[1]);
|
||||
|
||||
/* Initialize the socket */
|
||||
if ((sd = socket(AF_INET, socket_type, socket_proto)) < 0) {
|
||||
OpalPrint("%s: ERROR: Could not open socket\n", PROGNAME);
|
||||
return EIO;
|
||||
}
|
||||
|
||||
/* Set the structure for the remote port and address */
|
||||
memset(&send_ad, 0, sizeof(send_ad));
|
||||
send_ad.sin_family = AF_INET;
|
||||
send_ad.sin_addr.s_addr = inet_addr(IconCtrlStruct.StringParam[0]);
|
||||
send_ad.sin_port = htons((u_short)IconCtrlStruct.FloatParam[1]);
|
||||
|
||||
/* Set the structure for the local port and address */
|
||||
memset(&recv_ad, 0, sizeof(recv_ad));
|
||||
recv_ad.sin_family = AF_INET;
|
||||
recv_ad.sin_addr.s_addr = INADDR_ANY;
|
||||
recv_ad.sin_port = htons((u_short)IconCtrlStruct.FloatParam[2]);
|
||||
|
||||
/* Bind local port and address to socket. */
|
||||
if (bind(sd, (struct sockaddr *) &recv_ad, sizeof(struct sockaddr_in)) == -1) {
|
||||
OpalPrint("%s: ERROR: Could not bind local port to socket\n", PROGNAME);
|
||||
return EIO;
|
||||
}
|
||||
else
|
||||
OpalPrint("%s: Local Port : %d\n", PROGNAME, (int) IconCtrlStruct.FloatParam[2]);
|
||||
|
||||
switch (proto) {
|
||||
case UDP_PROTOCOL: /* Communication using UDP/IP protocol */
|
||||
/* If sending to a multicast address */
|
||||
if ((inet_addr(IconCtrlStruct.StringParam[0]) & inet_addr("240.0.0.0")) == inet_addr("224.0.0.0")) {
|
||||
if (setsockopt(sd, IPPROTO_IP, IP_MULTICAST_TTL, (char *) &TTL, sizeof(TTL)) == -1) {
|
||||
OpalPrint("%s: ERROR: Could not set TTL for multicast send (%d)\n", PROGNAME, errno);
|
||||
return EIO;
|
||||
}
|
||||
if (setsockopt(sd, IPPROTO_IP, IP_MULTICAST_LOOP, (char *)&LOOP, sizeof(LOOP)) == -1) {
|
||||
OpalPrint("%s: ERROR: Could not set loopback for multicast send (%d)\n", PROGNAME, errno);
|
||||
return EIO;
|
||||
}
|
||||
|
||||
OpalPrint("%s: Configured socket for sending to multicast address\n", PROGNAME);
|
||||
}
|
||||
|
||||
/* If receiving from a multicast group, register for it. */
|
||||
if (inet_addr(IconCtrlStruct.StringParam[1]) > 0) {
|
||||
if ((inet_addr(IconCtrlStruct.StringParam[1]) & inet_addr("240.0.0.0")) == inet_addr("224.0.0.0")) {
|
||||
mreq.imr_multiaddr.s_addr = inet_addr(IconCtrlStruct.StringParam[1]);
|
||||
mreq.imr_interface.s_addr = INADDR_ANY;
|
||||
|
||||
/* Have the multicast socket join the multicast group */
|
||||
if (setsockopt(sd, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *) &mreq, sizeof(mreq)) == -1) {
|
||||
OpalPrint("%s: ERROR: Could not join multicast group (%d)\n", PROGNAME, errno);
|
||||
return EIO;
|
||||
}
|
||||
|
||||
OpalPrint("%s: Added process to multicast group (%s)\n",
|
||||
PROGNAME, IconCtrlStruct.StringParam[1]);
|
||||
}
|
||||
else {
|
||||
OpalPrint("%s: WARNING: IP address for multicast group is not in multicast range. Ignored\n",
|
||||
PROGNAME);
|
||||
}
|
||||
}
|
||||
break;
|
||||
|
||||
case TCP_PROTOCOL: /* Communication using TCP/IP protocol */
|
||||
OpalPrint("%s: Calling connect()\n", PROGNAME);
|
||||
|
||||
/* Connect to server to start data transmission */
|
||||
rc = connect(sd, (struct sockaddr *) &send_ad, sizeof(send_ad));
|
||||
if (rc < 0) {
|
||||
OpalPrint("%s: ERROR: Call to connect() failed\n", PROGNAME);
|
||||
return EIO;
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
return EOK;
|
||||
}
|
||||
|
||||
int SendPacket(char* DataSend, int datalength)
|
||||
{
|
||||
int err;
|
||||
|
||||
if(sd < 0)
|
||||
return -1;
|
||||
|
||||
/* Send the packet */
|
||||
if (proto == TCP_PROTOCOL)
|
||||
err = send(sd, DataSend, datalength, 0);
|
||||
else
|
||||
err = sendto(sd, DataSend, datalength, 0, (struct sockaddr *)&send_ad, sizeof(send_ad));
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
int RecvPacket(char* DataRecv, int datalength, double timeout)
|
||||
{
|
||||
int len;
|
||||
struct sockaddr_in client_ad;
|
||||
socklen_t client_ad_size = sizeof(client_ad);
|
||||
fd_set sd_set;
|
||||
struct timeval tv;
|
||||
|
||||
if (sd < 0)
|
||||
return -1;
|
||||
|
||||
/* Set the descriptor set for the select() call */
|
||||
FD_ZERO(&sd_set);
|
||||
FD_SET(sd, &sd_set);
|
||||
|
||||
/* Set the tv structure to the correct timeout value */
|
||||
tv.tv_sec = (int) timeout;
|
||||
tv.tv_usec = (int) ((timeout - tv.tv_sec) * 1000000);
|
||||
|
||||
/* Wait for a packet. We use select() to have a timeout. This is
|
||||
* necessary when reseting the model so we don't wait indefinitely
|
||||
* and prevent the process from exiting and freeing the port for
|
||||
* a future instance (model load). */
|
||||
switch (select(sd+1, &sd_set, (fd_set *) 0, (fd_set *) 0, &tv)) {
|
||||
case -1: /* Error */
|
||||
return -1;
|
||||
case 0: /* We hit the timeout */
|
||||
return 0;
|
||||
default:
|
||||
if (!(FD_ISSET(sd, &sd_set))) {
|
||||
/* We received something, but it's not on "sd". Since sd is the only
|
||||
* descriptor in the set... */
|
||||
OpalPrint("%s: RecvPacket: God, is that You trying to reach me?\n", PROGNAME);
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
|
||||
/* Clear the DataRecv array (in case we receive an incomplete packet) */
|
||||
memset(DataRecv, 0, datalength);
|
||||
|
||||
/* Perform the reception */
|
||||
if (proto == TCP_PROTOCOL)
|
||||
len = recv(sd, DataRecv, datalength, 0);
|
||||
else
|
||||
len = recvfrom(sd, DataRecv, datalength, 0, (struct sockaddr *) &client_ad, &client_ad_size);
|
||||
|
||||
return len;
|
||||
}
|
||||
|
||||
int CloseSocket(Opal_GenAsyncParam_Ctrl IconCtrlStruct)
|
||||
{
|
||||
if (sd < 0) {
|
||||
shutdown(sd, SHUT_RDWR);
|
||||
close(sd);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
|
@ -1,90 +0,0 @@
|
|||
<?xml version="1.0" ?>
|
||||
<tm>
|
||||
<child attributes="[]" type="'TestFile'">
|
||||
<modelname>'AsyncIP_sl.mdl'</modelname>
|
||||
<name>'Execute'</name>
|
||||
<rtlabInfo attributes="['paramIn','paramOut']">{"modelName": ''}</rtlabInfo>
|
||||
<platformList attributes="['paramIn']">''</platformList>
|
||||
<targetList attributes="['paramIn']">''</targetList>
|
||||
<compilState attributes="['paramIn']">''</compilState>
|
||||
<preExpression>'variables.testFile.name="Execute " + variables.testFile.modelname + " model";variables.testFile.rtlabInfo["modelName"] = variables.testFile.filePath + "/../models/Simulink/" + variables.testFile.modelname'</preExpression>
|
||||
<result><platformResult>['', '', '', '']</platformResult></result>
|
||||
<targetIdx>0</targetIdx>
|
||||
|
||||
<child type="'Loop'">
|
||||
<name>'Platform Loop'</name>
|
||||
<initExpression>'global platformIndex;platformIndex=0'</initExpression>
|
||||
<conditionExpression>'platformIndex<len(variables.testFile.platformList)'</conditionExpression>
|
||||
<incrementExpression>'platformIndex+=1'</incrementExpression>
|
||||
|
||||
<child type="'Test'">
|
||||
<name>'Test - Execute example sequences'</name>
|
||||
<preCondition>'variables.testFile.platformList[platformIndex] == 1'</preCondition>
|
||||
<postExpression>'variables.testFile.targetIdx += 1'</postExpression>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'step setplatform'</name>
|
||||
<type>'RT-LAB/SetConfiguration'</type>
|
||||
<preCondition>'True'</preCondition>
|
||||
<configuration>{'TargetPlatform': -1}</configuration>
|
||||
<preExpression>'variables.step.configuration["TargetPlatform"]=variables.root.platformListName[platformIndex]'</preExpression>
|
||||
<paramIn>'variables.testFile.rtlabInfo, variables.step.configuration'</paramIn>
|
||||
<paramOut>'variables.testFile.rtlabInfo'</paramOut>
|
||||
</child>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'step async. proc. compilation command'</name>
|
||||
<type>'RT-LAB/SetConfiguration'</type>
|
||||
<commandListPerPlatform>["","make -f /usr/opalrt/common/bin/opalmodelmk","/usr/bin/make -f /usr/opalrt/common/bin/opalmodelmk",""]</commandListPerPlatform>
|
||||
<postCondition>'True'</postCondition>
|
||||
<configuration>{'TargetCompileCmd': -1}</configuration>
|
||||
<preExpression>'variables.step.configuration["TargetCompileCmd"]=variables.step.commandListPerPlatform[platformIndex]'</preExpression>
|
||||
<paramIn>'variables.testFile.rtlabInfo, variables.step.configuration'</paramIn>
|
||||
<paramOut>'variables.testFile.rtlabInfo'</paramOut>
|
||||
</child>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'Run CompileModel sequence'</name>
|
||||
<preCondition>'variables.root.platformListName[platformIndex] != RtlabApi.REDHAWK64_TARGET'</preCondition>
|
||||
<type>'SequenceCall'</type>
|
||||
<mode>'dynamic'</mode>
|
||||
<preExpression>''</preExpression>
|
||||
<sequenceFilename>'variables.root.testPath + "/utils/sequence/compileModel.tms"'</sequenceFilename>
|
||||
<paramIn>'variables.testFile.rtlabInfo,variables.testFile.compilState'</paramIn>
|
||||
<paramOut>'variables.testFile.rtlabInfo'</paramOut>
|
||||
<postExpression>''</postExpression>
|
||||
</child>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'Run testCompileModel sequence'</name>
|
||||
<preCondition>'variables.root.platformListName[platformIndex] == RtlabApi.REDHAWK64_TARGET'</preCondition>
|
||||
<type>'SequenceCall'</type>
|
||||
<mode>'dynamic'</mode>
|
||||
<sequenceFilename>'variables.root.testPath + "/utils/sequence/testCompileModel.tms"'</sequenceFilename>
|
||||
<paramIn>'variables.testFile.rtlabInfo'</paramIn>
|
||||
<paramOut>'variables.testFile.rtlabInfo'</paramOut>
|
||||
<postExpression>''</postExpression>
|
||||
</child>
|
||||
</child>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'Validation'</name>
|
||||
<type>'Expression'</type>
|
||||
<group>'cleanup'</group>
|
||||
<paramIn>''</paramIn>
|
||||
<paramOut>''</paramOut>
|
||||
<preExpression>'variables.testFile.result.platformResult[platformIndex] = variables.step._getParent().children["Test - Execute example sequences"].result.status'</preExpression>
|
||||
</child>
|
||||
</child>
|
||||
|
||||
<child type="'Step'">
|
||||
<name>'Test loop result'</name>
|
||||
<type>'Expression'</type>
|
||||
<group>'cleanup'</group>
|
||||
<paramIn>''</paramIn>
|
||||
<paramOut>''</paramOut>
|
||||
<preExpression>''</preExpression>
|
||||
<postExpression>'variables.root.result.TestDetail.append(variables.testFile.result.platformResult)'</postExpression>
|
||||
</child>
|
||||
</child>
|
||||
</tm>
|
||||
Loading…
Add table
Reference in a new issue