Merge branch 'python-bindings'
Michael Zillgith
9 years ago
commit
6c306870e9
@ -0,0 +1,23 @@
|
|||||||
|
FIND_PACKAGE(SWIG REQUIRED)
|
||||||
|
INCLUDE(${SWIG_USE_FILE})
|
||||||
|
FIND_PACKAGE(PythonLibs REQUIRED)
|
||||||
|
FIND_PACKAGE ( PythonInterp REQUIRED )
|
||||||
|
INCLUDE_DIRECTORIES(${PYTHON_INCLUDE_PATH})
|
||||||
|
INCLUDE_DIRECTORIES(${CMAKE_CURRENT_SOURCE_DIR})
|
||||||
|
SET(CMAKE_SWIG_FLAGS "")
|
||||||
|
SET_PROPERTY(SOURCE iec61850.i PROPERTY CPLUSPLUS ON)
|
||||||
|
SWIG_ADD_MODULE(iec61850 python iec61850.i)
|
||||||
|
IF(WIN32)
|
||||||
|
SWIG_LINK_LIBRARIES(iec61850 ${PYTHON_LIBRARIES} iec61850 ws2_32)
|
||||||
|
ELSE()
|
||||||
|
SWIG_LINK_LIBRARIES(iec61850 ${PYTHON_LIBRARIES} iec61850-shared)
|
||||||
|
ENDIF(WIN32)
|
||||||
|
EXECUTE_PROCESS ( #Finding python modules install path
|
||||||
|
COMMAND ${PYTHON_EXECUTABLE} -c
|
||||||
|
"import site, sys; sys.stdout.write(site.getsitepackages()[-1])"
|
||||||
|
OUTPUT_VARIABLE PYTHON_SITE_DIR
|
||||||
|
)
|
||||||
|
INSTALL ( FILES ${CMAKE_BINARY_DIR}/iec61850.py DESTINATION ${PYTHON_SITE_DIR})
|
||||||
|
INSTALL ( TARGETS _iec61850 LIBRARY DESTINATION ${PYTHON_SITE_DIR})
|
||||||
|
|
||||||
|
add_test(test_pyiec61850 ${PYTHON_EXECUTABLE} test_pyiec61850.py)
|
||||||
@ -0,0 +1,41 @@
|
|||||||
|
/* File : iec61850.i */
|
||||||
|
%module iec61850
|
||||||
|
%ignore ControlObjectClient_setTestMode(ControlObjectClient self);
|
||||||
|
%ignore CDA_OperBoolean(ModelNode* parent, bool isTImeActivated);
|
||||||
|
%ignore LogicalNode_hasBufferedReports(LogicalNode* node);
|
||||||
|
%ignore LogicalNode_hasUnbufferedReports(LogicalNode* node);
|
||||||
|
%ignore MmsConnection_setIsoConnectionParameters(MmsConnection self, IsoConnectionParameters* params);
|
||||||
|
%include "stdint.i"
|
||||||
|
%{
|
||||||
|
#include <iec61850_client.h>
|
||||||
|
#include <iec61850_model.h>
|
||||||
|
#include <iec61850_server.h>
|
||||||
|
ModelNode* toModelNode(LogicalNode * ln)
|
||||||
|
{
|
||||||
|
return (ModelNode*) ln;
|
||||||
|
}
|
||||||
|
ModelNode* toModelNode(DataObject * DO)
|
||||||
|
{
|
||||||
|
return (ModelNode*) DO;
|
||||||
|
}
|
||||||
|
DataAttribute* toDataAttribute(DataObject * DO)
|
||||||
|
{ return (DataAttribute*)DO;}
|
||||||
|
DataAttribute* toDataAttribute(ModelNode * MN)
|
||||||
|
{ return (DataAttribute*)MN;}
|
||||||
|
%}
|
||||||
|
%apply int *OUTPUT {IedClientError* error};
|
||||||
|
|
||||||
|
%include "iec61850_client.h"
|
||||||
|
%include "iso_connection_parameters.h"
|
||||||
|
%include "mms_client_connection.h"
|
||||||
|
%include "iso_connection_parameters.h"
|
||||||
|
%include "iec61850_common.h"
|
||||||
|
%include "mms_value.h"
|
||||||
|
%include "iec61850_model.h"
|
||||||
|
%include "iec61850_server.h"
|
||||||
|
%include "iec61850_dynamic_model.h"
|
||||||
|
%include "iec61850_cdc.h"
|
||||||
|
ModelNode* toModelNode(LogicalNode *);
|
||||||
|
ModelNode* toModelNode(DataObject *);
|
||||||
|
DataAttribute* toDataAttribute(DataObject *);
|
||||||
|
DataAttribute* toDataAttribute(ModelNode *);
|
||||||
@ -0,0 +1,82 @@
|
|||||||
|
#!/usr/bin/python
|
||||||
|
import sys
|
||||||
|
import time
|
||||||
|
import iec61850
|
||||||
|
import threading
|
||||||
|
import traceback
|
||||||
|
import signal
|
||||||
|
import sys
|
||||||
|
def signal_handler(signal, frame):
|
||||||
|
global running
|
||||||
|
running =0
|
||||||
|
print('You pressed Ctrl+C!')
|
||||||
|
#sys.exit(0)
|
||||||
|
signal.signal(signal.SIGINT, signal_handler)
|
||||||
|
tcpPort = 8102
|
||||||
|
running = 1
|
||||||
|
class myIECServer():
|
||||||
|
def __init__(self):
|
||||||
|
self.__model = iec61850.IedModel_create("testmodel")
|
||||||
|
lDevice1 = iec61850.LogicalDevice_create("SENSORS", self.__model);
|
||||||
|
lln0 = iec61850.LogicalNode_create("LLN0", lDevice1);
|
||||||
|
ttmp1 = iec61850.LogicalNode_create("TTMP1", lDevice1);
|
||||||
|
iec61850.CDC_SAV_create("TmpSv", iec61850.toModelNode(ttmp1), 0, False)
|
||||||
|
iec61850.CDC_ASG_create("TmpSp", iec61850.toModelNode(ttmp1), 0, False)
|
||||||
|
self.__iedServer = iec61850.IedServer_create(self.__model)
|
||||||
|
iec61850.IedServer_start(self.__iedServer, tcpPort);
|
||||||
|
if not(iec61850.IedServer_isRunning(self.__iedServer)) :
|
||||||
|
print("Starting server failed! Exit.\n")
|
||||||
|
iec61850.IedServer_destroy(self.__iedServer)
|
||||||
|
sys.exit(-1)
|
||||||
|
def run(self):
|
||||||
|
global running
|
||||||
|
while running:
|
||||||
|
time.sleep(0.1)
|
||||||
|
self.stop()
|
||||||
|
def stop(self):
|
||||||
|
iec61850.IedServer_stop(self.__iedServer)
|
||||||
|
iec61850.IedServer_destroy(self.__iedServer)
|
||||||
|
iec61850.IedModel_destroy(self.__model)
|
||||||
|
|
||||||
|
def testClient():
|
||||||
|
con = iec61850.IedConnection_create()
|
||||||
|
error = iec61850.IedConnection_connect(con, "localhost", tcpPort)
|
||||||
|
if (error == iec61850.IED_ERROR_OK):
|
||||||
|
# Accessing to SAV values
|
||||||
|
theVal = "testmodelSENSORS/TTMP1.TmpSv.instMag.f"
|
||||||
|
theValType = iec61850.IEC61850_FC_MX
|
||||||
|
temperatureValue = iec61850.IedConnection_readFloatValue(con, theVal, theValType)
|
||||||
|
assert(temperatureValue[1]==0)
|
||||||
|
newValue= temperatureValue[0]+10
|
||||||
|
err = iec61850.IedConnection_writeFloatValue(con, theVal, theValType, newValue)
|
||||||
|
assert(err==21)
|
||||||
|
# Accessing to ASG values
|
||||||
|
theVal = "testmodelSENSORS/TTMP1.TmpSp.setMag.f"
|
||||||
|
theValType = iec61850.IEC61850_FC_SP
|
||||||
|
temperatureSetpoint = iec61850.IedConnection_readFloatValue(con, theVal, theValType)
|
||||||
|
print temperatureSetpoint
|
||||||
|
assert(temperatureValue[1]==0)
|
||||||
|
newValue= temperatureValue[0]+10
|
||||||
|
err = iec61850.IedConnection_writeFloatValue(con, theVal, theValType, newValue)
|
||||||
|
assert(err==0)
|
||||||
|
temperatureSetpoint = iec61850.IedConnection_readFloatValue(con, theVal, theValType)
|
||||||
|
print temperatureSetpoint
|
||||||
|
assert(temperatureSetpoint[0]==newValue)
|
||||||
|
iec61850.IedConnection_close(con)
|
||||||
|
else:
|
||||||
|
print "Connection error"
|
||||||
|
sys.exit(-1)
|
||||||
|
iec61850.IedConnection_destroy(con)
|
||||||
|
print "client ok"
|
||||||
|
try:
|
||||||
|
srv=myIECServer()
|
||||||
|
srvThread = threading.Thread(target = srv.run)
|
||||||
|
srvThread.start()
|
||||||
|
testClient()
|
||||||
|
running = 0
|
||||||
|
#signal.pause()
|
||||||
|
except:
|
||||||
|
running = 0
|
||||||
|
print "Error :"
|
||||||
|
traceback.print_exc(file=sys.stdout)
|
||||||
|
sys.exit(-1)
|
||||||
Loading…
Reference in New Issue