Compare commits
No commits in common. 'v1.5' and 'v1.2.2' have entirely different histories.
@ -1,26 +0,0 @@
|
||||
name: CIFuzz
|
||||
on: [pull_request]
|
||||
jobs:
|
||||
Fuzzing:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Build Fuzzers
|
||||
id: build
|
||||
uses: google/oss-fuzz/infra/cifuzz/actions/build_fuzzers@master
|
||||
with:
|
||||
oss-fuzz-project-name: 'libiec61850'
|
||||
dry-run: false
|
||||
language: c
|
||||
- name: Run Fuzzers
|
||||
uses: google/oss-fuzz/infra/cifuzz/actions/run_fuzzers@master
|
||||
with:
|
||||
oss-fuzz-project-name: 'libiec61850'
|
||||
fuzz-seconds: 300
|
||||
dry-run: false
|
||||
language: c
|
||||
- name: Upload Crash
|
||||
uses: actions/upload-artifact@v3
|
||||
if: failure() && steps.build.outcome == 'success'
|
||||
with:
|
||||
name: artifacts
|
||||
path: ./out/artifacts
|
||||
@ -1,12 +0,0 @@
|
||||
name: Greetings
|
||||
|
||||
on: [pull_request, issues]
|
||||
|
||||
jobs:
|
||||
greeting:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/first-interaction@v1
|
||||
with:
|
||||
repo-token: ${{ secrets.GITHUB_TOKEN }}
|
||||
pr-message: 'Push requests and other code contributions can only be accepted from authorized persons that have signed our contributor license agreement(CLA). When in doubt please write to info@libiec61850.com.'
|
||||
@ -1,2 +0,0 @@
|
||||
build/
|
||||
/Debug/
|
||||
@ -1,5 +0,0 @@
|
||||
# Security Policy
|
||||
|
||||
## Reporting a Vulnerability
|
||||
|
||||
Please report security issues to `info@libiec61850.com`
|
||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
@ -1,44 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||
<PropertyGroup>
|
||||
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
|
||||
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
|
||||
<ProjectGuid>{0DA95476-B149-450B-AC36-01CEECFC1A43}</ProjectGuid>
|
||||
<OutputType>Exe</OutputType>
|
||||
<RootNamespace>clientexamplesettinggroup</RootNamespace>
|
||||
<AssemblyName>client-example-setting-group</AssemblyName>
|
||||
<TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
|
||||
</PropertyGroup>
|
||||
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
|
||||
<DebugSymbols>true</DebugSymbols>
|
||||
<DebugType>full</DebugType>
|
||||
<Optimize>false</Optimize>
|
||||
<OutputPath>bin\Debug</OutputPath>
|
||||
<DefineConstants>DEBUG;</DefineConstants>
|
||||
<ErrorReport>prompt</ErrorReport>
|
||||
<WarningLevel>4</WarningLevel>
|
||||
<Externalconsole>true</Externalconsole>
|
||||
</PropertyGroup>
|
||||
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
|
||||
<DebugType>full</DebugType>
|
||||
<Optimize>true</Optimize>
|
||||
<OutputPath>bin\Release</OutputPath>
|
||||
<ErrorReport>prompt</ErrorReport>
|
||||
<WarningLevel>4</WarningLevel>
|
||||
<Externalconsole>true</Externalconsole>
|
||||
</PropertyGroup>
|
||||
<ItemGroup>
|
||||
<Reference Include="System" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<Compile Include="Program.cs" />
|
||||
<Compile Include="Properties\AssemblyInfo.cs" />
|
||||
</ItemGroup>
|
||||
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
|
||||
<ItemGroup>
|
||||
<ProjectReference Include="..\IEC61850forCSharp\IEC61850.NET.csproj">
|
||||
<Project>{C35D624E-5506-4560-8074-1728F1FA1A4D}</Project>
|
||||
<Name>IEC61850.NET</Name>
|
||||
</ProjectReference>
|
||||
</ItemGroup>
|
||||
</Project>
|
||||
@ -1,6 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8" ?>
|
||||
<configuration>
|
||||
<startup>
|
||||
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.6.1" />
|
||||
</startup>
|
||||
</configuration>
|
||||
@ -1,217 +0,0 @@
|
||||
MODEL(simpleIO){
|
||||
LD(GenericIO){
|
||||
LN(LLN0){
|
||||
DO(Mod 0){
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=0;
|
||||
}
|
||||
DO(Beh 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Health 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(NamPlt 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
DA(swRev 0 20 5 0 0);
|
||||
DA(d 0 20 5 0 0);
|
||||
DA(configRev 0 20 5 0 0);
|
||||
DA(ldNs 0 20 11 0 0);
|
||||
}
|
||||
DS(Events){
|
||||
DE(GGIO1$ST$SPCSO1$stVal);
|
||||
DE(GGIO1$ST$SPCSO2$stVal);
|
||||
DE(GGIO1$ST$SPCSO3$stVal);
|
||||
DE(GGIO1$ST$SPCSO4$stVal);
|
||||
}
|
||||
DS(Events2){
|
||||
DE(GGIO1$ST$SPCSO1);
|
||||
DE(GGIO1$ST$SPCSO2);
|
||||
DE(GGIO1$ST$SPCSO3);
|
||||
DE(GGIO1$ST$SPCSO4);
|
||||
}
|
||||
DS(Events3){
|
||||
DE(GGIO1$ST$SPCSO1$stVal);
|
||||
DE(GGIO1$ST$SPCSO1$q);
|
||||
DE(GGIO1$ST$SPCSO2$stVal);
|
||||
DE(GGIO1$ST$SPCSO2$q);
|
||||
DE(GGIO1$ST$SPCSO3$stVal);
|
||||
DE(GGIO1$ST$SPCSO3$q);
|
||||
DE(GGIO1$ST$SPCSO4$stVal);
|
||||
DE(GGIO1$ST$SPCSO4$q);
|
||||
}
|
||||
DS(AnalogValues){
|
||||
DE(GGIO1$MX$AnIn1);
|
||||
DE(GGIO1$MX$AnIn2);
|
||||
DE(GGIO1$MX$AnIn3);
|
||||
DE(GGIO1$MX$AnIn4);
|
||||
}
|
||||
RC(EventsRCB01 Events 0 Events 1 24 175 50 1000);
|
||||
RC(AnalogValuesRCB01 AnalogValues 0 AnalogValues 1 24 175 50 1000);
|
||||
GC(gcbEvents events Events3 2 0 1000 3000 ){
|
||||
PA(4 1 4096 010ccd010001);
|
||||
}
|
||||
GC(gcbAnalogValues analog AnalogValues 2 0 -1 -1 ){
|
||||
PA(4 1 4096 010ccd010001);
|
||||
}
|
||||
}
|
||||
LN(LPHD1){
|
||||
DO(PhyNam 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
}
|
||||
DO(PhyHealth 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Proxy 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
}
|
||||
LN(GGIO1){
|
||||
DO(Mod 0){
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=0;
|
||||
}
|
||||
DO(Beh 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Health 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(NamPlt 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
DA(swRev 0 20 5 0 0);
|
||||
DA(d 0 20 5 0 0);
|
||||
}
|
||||
DO(AnIn1 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn2 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn3 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn4 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(SPCSO1 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(SPCSO2 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(SPCSO3 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(SPCSO4 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind1 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind2 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind3 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind4 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,446 +0,0 @@
|
||||
MODEL(simpleIO){
|
||||
LD(GenericIO){
|
||||
LN(LLN0){
|
||||
DO(Mod 0){
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=0;
|
||||
}
|
||||
DO(Beh 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Health 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(NamPlt 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
DA(swRev 0 20 5 0 0);
|
||||
DA(d 0 20 5 0 0);
|
||||
DA(configRev 0 20 5 0 0);
|
||||
DA(ldNs 0 20 11 0 0);
|
||||
}
|
||||
DO(SetInt1 0){
|
||||
DA(setVal 0 3 2 1 0);
|
||||
}
|
||||
DO(SetInt2 0){
|
||||
DA(setVal 0 3 2 1 0);
|
||||
}
|
||||
DO(SetInt3 0){
|
||||
DA(setVal 0 3 2 1 0);
|
||||
}
|
||||
DO(SetInt4 0){
|
||||
DA(setVal 0 3 2 1 0);
|
||||
}
|
||||
DO(SetBool1 0){
|
||||
DA(setVal 0 0 2 1 0);
|
||||
}
|
||||
DO(SetBool2 0){
|
||||
DA(setVal 0 0 2 1 0);
|
||||
}
|
||||
DO(SetBool3 0){
|
||||
DA(setVal 0 0 2 1 0);
|
||||
}
|
||||
DO(SetBool4 0){
|
||||
DA(setVal 0 0 2 1 0);
|
||||
}
|
||||
DO(Int64 0){
|
||||
DA(stVal 0 4 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(SetAnVal 0){
|
||||
DA(setMag 0 27 2 1 0){
|
||||
DA(f 0 10 2 1 0);
|
||||
}
|
||||
}
|
||||
DS(Events){
|
||||
DE(GGIO1$ST$SPCSO1$stVal);
|
||||
DE(GGIO1$ST$SPCSO2$stVal);
|
||||
DE(GGIO1$ST$SPCSO3$stVal);
|
||||
DE(GGIO1$ST$SPCSO4$stVal);
|
||||
}
|
||||
DS(EventsFCDO){
|
||||
DE(GGIO1$ST$SPCSO1);
|
||||
DE(GGIO1$ST$SPCSO2);
|
||||
DE(GGIO1$ST$SPCSO3);
|
||||
DE(GGIO1$ST$SPCSO4);
|
||||
}
|
||||
DS(Booleans){
|
||||
DE(LLN0$SP$SetBool1$setVal);
|
||||
DE(LLN0$SP$SetBool2$setVal);
|
||||
DE(LLN0$SP$SetBool3$setVal);
|
||||
DE(LLN0$SP$SetBool4$setVal);
|
||||
}
|
||||
DS(Integers){
|
||||
DE(LLN01$SP$SetInt1$setVal);
|
||||
DE(LLN01$SP$SetInt2$setVal);
|
||||
DE(LLN01$SP$SetInt3$setVal);
|
||||
DE(LLN01$SP$SetInt4$setVal);
|
||||
}
|
||||
RC(EventsRCB01 Events1 0 Events 1 24 239 50 1000);
|
||||
RC(EventsRCB02 Events1 0 Events 1 24 239 50 1000);
|
||||
RC(BufferedRCB01 Events1 1 Events 1 24 239 50 1000);
|
||||
RC(BufferedRCB02 Events1 1 Events 1 24 239 50 1000);
|
||||
GC(gcbEvents events Events 1 0 1000 3000 ){
|
||||
PA(4 1 4096 010ccd010001);
|
||||
}
|
||||
}
|
||||
LN(LPHD1){
|
||||
DO(PhyNam 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
}
|
||||
DO(PhyHealth 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Proxy 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
}
|
||||
LN(GGIO1){
|
||||
DO(Mod 0){
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=0;
|
||||
}
|
||||
DO(Beh 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Health 0){
|
||||
DA(stVal 0 3 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(NamPlt 0){
|
||||
DA(vendor 0 20 5 0 0);
|
||||
DA(swRev 0 20 5 0 0);
|
||||
DA(d 0 20 5 0 0);
|
||||
DA(dU 0 21 5 0 0);
|
||||
}
|
||||
DO(AnIn1 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn2 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn3 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(AnIn4 0){
|
||||
DA(mag 0 27 1 1 0){
|
||||
DA(f 0 10 1 1 0);
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DO(SPCSO1 0){
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
}
|
||||
DO(SPCSO2 0){
|
||||
DA(SBO 0 17 12 0 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=2;
|
||||
DA(sboClass 0 12 4 0 0);
|
||||
}
|
||||
DO(SPCSO3 0){
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=3;
|
||||
}
|
||||
DO(SPCSO4 0){
|
||||
DA(SBOw 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=4;
|
||||
}
|
||||
DO(SPCSO5 0){
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=1;
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
}
|
||||
DO(SPCSO6 0){
|
||||
DA(SBO 0 17 12 0 0);
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=2;
|
||||
}
|
||||
DO(SPCSO7 0){
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=3;
|
||||
}
|
||||
DO(SPCSO8 0){
|
||||
DA(SBOw 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Oper 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
DA(Check 0 24 12 0 0);
|
||||
}
|
||||
DA(Cancel 0 27 12 0 0){
|
||||
DA(ctlVal 0 0 12 0 0);
|
||||
DA(operTm 0 22 12 0 0);
|
||||
DA(origin 0 27 12 0 0){
|
||||
DA(orCat 0 12 12 0 0);
|
||||
DA(orIdent 0 13 12 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 12 0 0);
|
||||
DA(T 0 22 12 0 0);
|
||||
DA(Test 0 0 12 0 0);
|
||||
}
|
||||
DA(origin 0 27 0 0 0){
|
||||
DA(orCat 0 12 0 0 0);
|
||||
DA(orIdent 0 13 0 0 0);
|
||||
}
|
||||
DA(ctlNum 0 6 0 0 0);
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
DA(ctlModel 0 12 4 0 0)=4;
|
||||
}
|
||||
DO(Ind1 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind2 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind3 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(Ind4 0){
|
||||
DA(stVal 0 0 0 1 0);
|
||||
DA(q 0 23 0 2 0);
|
||||
DA(t 0 22 0 0 0);
|
||||
}
|
||||
DO(SchdAbsTm 0){
|
||||
DA(val 24 10 2 1 0);
|
||||
}
|
||||
}
|
||||
LN(MHAI1){
|
||||
DO(HA 0){
|
||||
DO(phsAHar 16){
|
||||
DA(cVal 0 27 1 5 0){
|
||||
DA(mag 0 27 1 5 0){
|
||||
DA(f 0 10 1 5 0);
|
||||
}
|
||||
DA(ang 0 27 1 5 0){
|
||||
DA(f 0 10 1 5 0);
|
||||
}
|
||||
}
|
||||
DA(q 0 23 1 2 0);
|
||||
DA(t 0 22 1 0 0);
|
||||
}
|
||||
DA(numHar 0 7 4 1 0)=16;
|
||||
DA(numCyc 0 7 4 1 0);
|
||||
DA(evalTm 0 7 4 1 0);
|
||||
DA(frequency 0 10 4 1 0);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
|
||||
set(goose_observer_SRCS
|
||||
goose_observer.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
|
||||
set_source_files_properties(${goose_observer_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(goose_observer
|
||||
${goose_observer_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(goose_observer
|
||||
iec61850
|
||||
)
|
||||
|
||||
|
||||
@ -1,101 +0,0 @@
|
||||
/*
|
||||
* goose_observer.c
|
||||
*
|
||||
* This is an example for generic GOOSE observer
|
||||
*
|
||||
* Has to be started as root in Linux.
|
||||
*/
|
||||
|
||||
#include "goose_receiver.h"
|
||||
#include "goose_subscriber.h"
|
||||
#include "hal_thread.h"
|
||||
|
||||
#include <signal.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
|
||||
static int running = 1;
|
||||
|
||||
void sigint_handler(int signalId)
|
||||
{
|
||||
running = 0;
|
||||
}
|
||||
|
||||
void
|
||||
gooseListener(GooseSubscriber subscriber, void* parameter)
|
||||
{
|
||||
printf("GOOSE event:\n");
|
||||
printf(" vlanTag: %s\n", GooseSubscriber_isVlanSet(subscriber) ? "found" : "NOT found");
|
||||
if (GooseSubscriber_isVlanSet(subscriber))
|
||||
{
|
||||
printf(" vlanId: %u\n", GooseSubscriber_getVlanId(subscriber));
|
||||
printf(" vlanPrio: %u\n", GooseSubscriber_getVlanPrio(subscriber));
|
||||
}
|
||||
printf(" appId: %d\n", GooseSubscriber_getAppId(subscriber));
|
||||
uint8_t macBuf[6];
|
||||
GooseSubscriber_getSrcMac(subscriber,macBuf);
|
||||
printf(" srcMac: %02X:%02X:%02X:%02X:%02X:%02X\n", macBuf[0],macBuf[1],macBuf[2],macBuf[3],macBuf[4],macBuf[5]);
|
||||
GooseSubscriber_getDstMac(subscriber,macBuf);
|
||||
printf(" dstMac: %02X:%02X:%02X:%02X:%02X:%02X\n", macBuf[0],macBuf[1],macBuf[2],macBuf[3],macBuf[4],macBuf[5]);
|
||||
printf(" goId: %s\n", GooseSubscriber_getGoId(subscriber));
|
||||
printf(" goCbRef: %s\n", GooseSubscriber_getGoCbRef(subscriber));
|
||||
printf(" dataSet: %s\n", GooseSubscriber_getDataSet(subscriber));
|
||||
printf(" confRev: %u\n", GooseSubscriber_getConfRev(subscriber));
|
||||
printf(" ndsCom: %s\n", GooseSubscriber_needsCommission(subscriber) ? "true" : "false");
|
||||
printf(" simul: %s\n", GooseSubscriber_isTest(subscriber) ? "true" : "false");
|
||||
printf(" stNum: %u sqNum: %u\n", GooseSubscriber_getStNum(subscriber),
|
||||
GooseSubscriber_getSqNum(subscriber));
|
||||
printf(" timeToLive: %u\n", GooseSubscriber_getTimeAllowedToLive(subscriber));
|
||||
|
||||
uint64_t timestamp = GooseSubscriber_getTimestamp(subscriber);
|
||||
|
||||
printf(" timestamp: %u.%u\n", (uint32_t) (timestamp / 1000), (uint32_t) (timestamp % 1000));
|
||||
printf(" message is %s\n", GooseSubscriber_isValid(subscriber) ? "valid" : "INVALID");
|
||||
|
||||
MmsValue* values = GooseSubscriber_getDataSetValues(subscriber);
|
||||
|
||||
char buffer[1024];
|
||||
|
||||
MmsValue_printToBuffer(values, buffer, 1024);
|
||||
|
||||
printf(" AllData: %s\n", buffer);
|
||||
}
|
||||
|
||||
int
|
||||
main(int argc, char** argv)
|
||||
{
|
||||
GooseReceiver receiver = GooseReceiver_create();
|
||||
|
||||
if (argc > 1) {
|
||||
printf("Set interface id: %s\n", argv[1]);
|
||||
GooseReceiver_setInterfaceId(receiver, argv[1]);
|
||||
}
|
||||
else {
|
||||
printf("Using interface eth0\n");
|
||||
GooseReceiver_setInterfaceId(receiver, "eth0");
|
||||
}
|
||||
|
||||
GooseSubscriber subscriber = GooseSubscriber_create("", NULL);
|
||||
GooseSubscriber_setObserver(subscriber);
|
||||
GooseSubscriber_setListener(subscriber, gooseListener, NULL);
|
||||
|
||||
GooseReceiver_addSubscriber(receiver, subscriber);
|
||||
|
||||
GooseReceiver_start(receiver);
|
||||
|
||||
if (GooseReceiver_isRunning(receiver)) {
|
||||
signal(SIGINT, sigint_handler);
|
||||
|
||||
while (running) {
|
||||
Thread_sleep(100);
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to start GOOSE subscriber. Reason can be that the Ethernet interface doesn't exist or root permission are required.\n");
|
||||
}
|
||||
|
||||
GooseReceiver_stop(receiver);
|
||||
|
||||
GooseReceiver_destroy(receiver);
|
||||
return 0;
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
|
||||
set(iec61850_client_example3_SRCS
|
||||
client_example3.c
|
||||
)
|
||||
|
||||
IF(WIN32)
|
||||
set_source_files_properties(${iec61850_client_example3_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(WIN32)
|
||||
|
||||
add_executable(iec61850_client_example3
|
||||
${iec61850_client_example3_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(iec61850_client_example3
|
||||
iec61850
|
||||
)
|
||||
@ -1,7 +1,7 @@
|
||||
LIBIEC_HOME=../..
|
||||
|
||||
PROJECT_BINARY_NAME = goose_observer
|
||||
PROJECT_SOURCES = goose_observer.c
|
||||
PROJECT_BINARY_NAME = client_example3
|
||||
PROJECT_SOURCES = client_example3.c
|
||||
|
||||
include $(LIBIEC_HOME)/make/target_system.mk
|
||||
include $(LIBIEC_HOME)/make/stack_includes.mk
|
||||
@ -0,0 +1,219 @@
|
||||
/*
|
||||
* client_example3.c
|
||||
*
|
||||
* How to control a device ... intended to be used with server_example_control
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
#include "hal_thread.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
static void commandTerminationHandler(void *parameter, ControlObjectClient connection)
|
||||
{
|
||||
|
||||
|
||||
LastApplError lastApplError = ControlObjectClient_getLastApplError(connection);
|
||||
|
||||
// if lastApplError.error != 0 this indicates a CommandTermination-
|
||||
if (lastApplError.error != 0) {
|
||||
printf("Received CommandTermination-.\n");
|
||||
printf(" LastApplError: %i\n", lastApplError.error);
|
||||
printf(" addCause: %i\n", lastApplError.addCause);
|
||||
}
|
||||
else
|
||||
printf("Received CommandTermination+.\n");
|
||||
}
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
int tcpPort = 102;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
tcpPort = atoi(argv[2]);
|
||||
|
||||
IedClientError error;
|
||||
|
||||
IedConnection con = IedConnection_create();
|
||||
|
||||
IedConnection_connect(con, &error, hostname, tcpPort);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
|
||||
|
||||
/************************
|
||||
* Direct control
|
||||
***********************/
|
||||
|
||||
ControlObjectClient control
|
||||
= ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO1", con);
|
||||
|
||||
MmsValue* ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
ControlObjectClient_setOrigin(control, NULL, 3);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO1 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO1\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
/* Check if status value has changed */
|
||||
|
||||
MmsValue* stVal = IedConnection_readObject(con, &error, "simpleIOGenericIO/GGIO1.SPCSO1.stVal", IEC61850_FC_ST);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
bool state = MmsValue_getBoolean(stVal);
|
||||
MmsValue_delete(stVal);
|
||||
|
||||
printf("New status of simpleIOGenericIO/GGIO1.SPCSO1.stVal: %i\n", state);
|
||||
}
|
||||
else {
|
||||
printf("Reading status for simpleIOGenericIO/GGIO1.SPCSO1 failed!\n");
|
||||
}
|
||||
|
||||
|
||||
/************************
|
||||
* Select before operate
|
||||
***********************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO2", con);
|
||||
|
||||
if (ControlObjectClient_select(control)) {
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO2 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO2!\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
}
|
||||
else {
|
||||
printf("failed to select simpleIOGenericIO/GGIO1.SPCSO2!\n");
|
||||
}
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
|
||||
/****************************************
|
||||
* Direct control with enhanced security
|
||||
****************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO3", con);
|
||||
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO3 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO3\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
/* Check if status value has changed */
|
||||
|
||||
stVal = IedConnection_readObject(con, &error, "simpleIOGenericIO/GGIO1.SPCSO3.stVal", IEC61850_FC_ST);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
bool state = MmsValue_getBoolean(stVal);
|
||||
|
||||
printf("New status of simpleIOGenericIO/GGIO1.SPCSO3.stVal: %i\n", state);
|
||||
|
||||
MmsValue_delete(stVal);
|
||||
}
|
||||
else {
|
||||
printf("Reading status for simpleIOGenericIO/GGIO1.SPCSO3 failed!\n");
|
||||
}
|
||||
|
||||
/***********************************************
|
||||
* Select before operate with enhanced security
|
||||
***********************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO4", con);
|
||||
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_selectWithValue(control, ctlVal)) {
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO4 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO4!\n");
|
||||
}
|
||||
|
||||
}
|
||||
else {
|
||||
printf("failed to select simpleIOGenericIO/GGIO1.SPCSO4!\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
|
||||
/*********************************************************************
|
||||
* Direct control with enhanced security (expect CommandTermination-)
|
||||
*********************************************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO9", con);
|
||||
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO9 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO9\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
|
||||
IedConnection_close(con);
|
||||
}
|
||||
else {
|
||||
printf("Connection failed!\n");
|
||||
}
|
||||
|
||||
IedConnection_destroy(con);
|
||||
}
|
||||
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
|
||||
set(iec61850_client_example_array_SRCS
|
||||
client_example_array.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
set_source_files_properties(${iec61850_client_example_array_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(iec61850_client_example_array
|
||||
${iec61850_client_example_array_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(iec61850_client_example_array
|
||||
iec61850
|
||||
)
|
||||
@ -1,17 +0,0 @@
|
||||
LIBIEC_HOME=../..
|
||||
|
||||
PROJECT_BINARY_NAME = client_example_array
|
||||
PROJECT_SOURCES = client_example_array.c
|
||||
|
||||
include $(LIBIEC_HOME)/make/target_system.mk
|
||||
include $(LIBIEC_HOME)/make/stack_includes.mk
|
||||
|
||||
all: $(PROJECT_BINARY_NAME)
|
||||
|
||||
include $(LIBIEC_HOME)/make/common_targets.mk
|
||||
|
||||
$(PROJECT_BINARY_NAME): $(PROJECT_SOURCES) $(LIB_NAME)
|
||||
$(CC) $(CFLAGS) $(LDFLAGS) -o $(PROJECT_BINARY_NAME) $(PROJECT_SOURCES) $(INCLUDES) $(LIB_NAME) $(LDLIBS)
|
||||
|
||||
clean:
|
||||
rm -f $(PROJECT_BINARY_NAME)
|
||||
@ -1,100 +0,0 @@
|
||||
/*
|
||||
* client_example_array.c
|
||||
*
|
||||
* SHows how to handle array access from client side
|
||||
*
|
||||
* This example is intended to be used with server_example_complex_array
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
#include "hal_thread.h"
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
int tcpPort = 102;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
tcpPort = atoi(argv[2]);
|
||||
|
||||
IedClientError error;
|
||||
|
||||
IedConnection con = IedConnection_create();
|
||||
|
||||
IedConnection_connect(con, &error, hostname, tcpPort);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
|
||||
/* read complete array */
|
||||
MmsValue* array = IedConnection_readObject(con, &error, "testComplexArray/MHAI1.HA.phsAHar", IEC61850_FC_MX);
|
||||
|
||||
if (array != NULL) {
|
||||
MmsValue_delete(array);
|
||||
}
|
||||
else
|
||||
printf("Failed to read array!\n");
|
||||
|
||||
/* read array element at different component levels */
|
||||
char* arrayElementRef = "testComplexArray/MHAI1.HA.phsAHar(2).cVal.mag.f";
|
||||
|
||||
MmsValue* element = IedConnection_readObject(con, &error, arrayElementRef, IEC61850_FC_MX);
|
||||
|
||||
if (element != NULL) {
|
||||
MmsValue_delete(element);
|
||||
}
|
||||
else
|
||||
printf("Failed to read array element %s!\n", arrayElementRef);
|
||||
|
||||
|
||||
arrayElementRef = "testComplexArray/MHAI1.HA.phsAHar(2).cVal.mag";
|
||||
|
||||
element = IedConnection_readObject(con, &error, arrayElementRef, IEC61850_FC_MX);
|
||||
|
||||
if (element != NULL) {
|
||||
MmsValue_delete(element);
|
||||
}
|
||||
else
|
||||
printf("Failed to read array element %s!\n", arrayElementRef);
|
||||
|
||||
arrayElementRef = "testComplexArray/MHAI1.HA.phsAHar(2).cVal";
|
||||
|
||||
element = IedConnection_readObject(con, &error, arrayElementRef, IEC61850_FC_MX);
|
||||
|
||||
if (element != NULL) {
|
||||
MmsValue_delete(element);
|
||||
}
|
||||
else
|
||||
printf("Failed to read array element %s!\n", arrayElementRef);
|
||||
|
||||
arrayElementRef = "testComplexArray/MHAI1.HA.phsAHar(2)";
|
||||
|
||||
element = IedConnection_readObject(con, &error, arrayElementRef, IEC61850_FC_MX);
|
||||
|
||||
if (element != NULL) {
|
||||
MmsValue_delete(element);
|
||||
}
|
||||
else
|
||||
printf("Failed to read array element %s!\n", arrayElementRef);
|
||||
|
||||
close_connection:
|
||||
|
||||
IedConnection_close(con);
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to %s:%i\n", hostname, tcpPort);
|
||||
}
|
||||
|
||||
IedConnection_destroy(con);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
|
||||
set(iec61850_client_async_SRCS
|
||||
client_example_async.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
set_source_files_properties(${iec61850_client_async_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(iec61850_client_async
|
||||
${iec61850_client_async_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(iec61850_client_async
|
||||
iec61850
|
||||
)
|
||||
@ -1,17 +0,0 @@
|
||||
LIBIEC_HOME=../..
|
||||
|
||||
PROJECT_BINARY_NAME = client_example_async
|
||||
PROJECT_SOURCES = client_example_async.c
|
||||
|
||||
include $(LIBIEC_HOME)/make/target_system.mk
|
||||
include $(LIBIEC_HOME)/make/stack_includes.mk
|
||||
|
||||
all: $(PROJECT_BINARY_NAME)
|
||||
|
||||
include $(LIBIEC_HOME)/make/common_targets.mk
|
||||
|
||||
$(PROJECT_BINARY_NAME): $(PROJECT_SOURCES) $(LIB_NAME)
|
||||
$(CC) $(CFLAGS) $(LDFLAGS) -o $(PROJECT_BINARY_NAME) $(PROJECT_SOURCES) $(INCLUDES) $(LIB_NAME) $(LDLIBS)
|
||||
|
||||
clean:
|
||||
rm -f $(PROJECT_BINARY_NAME)
|
||||
@ -1,322 +0,0 @@
|
||||
/*
|
||||
* client_example_async.c
|
||||
*
|
||||
* Shows how to use the asynchronous client API
|
||||
*
|
||||
* This example is intended to be used with server_example_basic_io.
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
#include "hal_thread.h"
|
||||
|
||||
static ClientDataSet clientDataSet = NULL;
|
||||
|
||||
static void
|
||||
printValue(char* name, MmsValue* value)
|
||||
{
|
||||
char buf[1000];
|
||||
|
||||
MmsValue_printToBuffer(value, buf, 1000);
|
||||
|
||||
printf("%s: %s\n", name, buf);
|
||||
}
|
||||
|
||||
static void
|
||||
readObjectHandler (uint32_t invokeId, void* parameter, IedClientError err, MmsValue* value)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
printValue((char*) parameter, value);
|
||||
|
||||
MmsValue_delete(value);
|
||||
}
|
||||
else {
|
||||
printf("Failed to read object %s (err=%i)\n", (char*) parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
readDataSetHandler(uint32_t invokeId, void* parameter, IedClientError err, ClientDataSet dataSet)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
clientDataSet = dataSet;
|
||||
|
||||
printf("Data set has %d entries\n", ClientDataSet_getDataSetSize(dataSet));
|
||||
|
||||
MmsValue* values = ClientDataSet_getValues(dataSet);
|
||||
|
||||
if (MmsValue_getType(values) == MMS_ARRAY) {
|
||||
int i;
|
||||
for (i = 0; i < MmsValue_getArraySize(values); i++) {
|
||||
printf(" [%i]", i);
|
||||
printValue("", MmsValue_getElement(values, i));
|
||||
}
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to read data set (err=%i)\n", err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
writeDataSetHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList /* <MmsValue*> */accessResults)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
|
||||
if (accessResults) {
|
||||
|
||||
int i = 0;
|
||||
|
||||
LinkedList element = LinkedList_getNext(accessResults);
|
||||
|
||||
while (element) {
|
||||
MmsValue* accessResultValue = (MmsValue*) LinkedList_getData(element);
|
||||
|
||||
printf(" access-result[%i]", i);
|
||||
printValue("", accessResultValue);
|
||||
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
i++;
|
||||
}
|
||||
|
||||
LinkedList_destroyDeep(accessResults, (LinkedListValueDeleteFunction) MmsValue_delete);
|
||||
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to write data set (err=%i)\n", err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
reportCallbackFunction(void* parameter, ClientReport report)
|
||||
{
|
||||
MmsValue* dataSetValues = ClientReport_getDataSetValues(report);
|
||||
|
||||
printf("received report for %s\n", ClientReport_getRcbReference(report));
|
||||
|
||||
int i;
|
||||
for (i = 0; i < 4; i++) {
|
||||
ReasonForInclusion reason = ClientReport_getReasonForInclusion(report, i);
|
||||
|
||||
if (reason != IEC61850_REASON_NOT_INCLUDED) {
|
||||
printf(" GGIO1.SPCSO%i.stVal: %i (included for reason %i)\n", i,
|
||||
MmsValue_getBoolean(MmsValue_getElement(dataSetValues, i)), reason);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getVarSpecHandler (uint32_t invokeId, void* parameter, IedClientError err, MmsVariableSpecification* spec)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
printf("variable: %s has type %d\n", (char*) parameter, MmsVariableSpecification_getType(spec));
|
||||
|
||||
MmsVariableSpecification_destroy(spec);
|
||||
}
|
||||
else {
|
||||
printf("Failed to get variable specification for object %s (err=%i)\n", (char*) parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getNameListHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList nameList, bool moreFollows)
|
||||
{
|
||||
if (err != IED_ERROR_OK) {
|
||||
printf("Get name list error: %d\n", err);
|
||||
}
|
||||
else {
|
||||
|
||||
char* ldName = (char*) parameter;
|
||||
|
||||
LinkedList element = LinkedList_getNext(nameList);
|
||||
|
||||
while (element) {
|
||||
|
||||
char* variableName = (char*) LinkedList_getData(element);
|
||||
|
||||
printf(" %s/%s\n", ldName, variableName);
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
}
|
||||
|
||||
LinkedList_destroy(nameList);
|
||||
|
||||
free(ldName);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getServerDirectoryHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList nameList, bool moreFollows)
|
||||
{
|
||||
IedConnection con = (IedConnection) parameter;
|
||||
|
||||
if (err != IED_ERROR_OK) {
|
||||
printf("Get server directory error: %d\n", err);
|
||||
}
|
||||
else {
|
||||
LinkedList element = LinkedList_getNext(nameList);
|
||||
|
||||
/* Call logical device variables for each logical node */
|
||||
while (element) {
|
||||
|
||||
char* ldName = (char*) LinkedList_getData(element);
|
||||
|
||||
IedClientError cerr;
|
||||
|
||||
printf("LD: %s variables:\n", ldName);
|
||||
|
||||
IedConnection_getLogicalDeviceVariablesAsync(con, &cerr, ldName, NULL, NULL, getNameListHandler, strdup(ldName));
|
||||
|
||||
printf("LD: %s data sets:\n", ldName);
|
||||
|
||||
IedConnection_getLogicalDeviceDataSetsAsync(con, &err, ldName, NULL, NULL, getNameListHandler, strdup(ldName));
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
}
|
||||
|
||||
LinkedList_destroy(nameList);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
controlActionHandler(uint32_t invokeId, void* parameter, IedClientError err, ControlActionType type, bool success)
|
||||
{
|
||||
printf("control: ID: %d type: %i err: %d success: %i\n", invokeId, type, err, success);
|
||||
}
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
int tcpPort = 102;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
tcpPort = atoi(argv[2]);
|
||||
|
||||
IedClientError error;
|
||||
|
||||
IedConnection con = IedConnection_create();
|
||||
|
||||
IedConnection_connectAsync(con, &error, hostname, tcpPort);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
|
||||
bool success = true;
|
||||
|
||||
while (IedConnection_getState(con) != IED_STATE_CONNECTED) {
|
||||
|
||||
if (IedConnection_getState(con) == IED_STATE_CLOSED) {
|
||||
success = false;
|
||||
break;
|
||||
}
|
||||
|
||||
Thread_sleep(10);
|
||||
}
|
||||
|
||||
if (success) {
|
||||
|
||||
IedConnection_getServerDirectoryAsync(con, &error, NULL, NULL, getServerDirectoryHandler, con);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read server directory error %i\n", error);
|
||||
}
|
||||
|
||||
Thread_sleep(1000);
|
||||
|
||||
|
||||
IedConnection_readObjectAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn1.mag.f", IEC61850_FC_MX, readObjectHandler, "simpleIOGenericIO/GGIO1.AnIn1.mag.f");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read object error %i\n", error);
|
||||
}
|
||||
|
||||
IedConnection_readObjectAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn2.mag.f", IEC61850_FC_MX, readObjectHandler, "simpleIOGenericIO/GGIO1.AnIn2.mag.f");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read object error %i\n", error);
|
||||
}
|
||||
|
||||
IedConnection_getVariableSpecificationAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn1", IEC61850_FC_MX, getVarSpecHandler, "simpleIOGenericIO/GGIO1.AnIn1");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("get variable specification error %i\n", error);
|
||||
}
|
||||
|
||||
IedConnection_readDataSetValuesAsync(con, &error, "simpleIOGenericIO/LLN0.Events", NULL, readDataSetHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read data set error %i\n", error);
|
||||
}
|
||||
|
||||
LinkedList values = LinkedList_create();
|
||||
LinkedList_add(values, MmsValue_newBoolean(true));
|
||||
LinkedList_add(values, MmsValue_newBoolean(false));
|
||||
LinkedList_add(values, MmsValue_newBoolean(true));
|
||||
LinkedList_add(values, MmsValue_newBoolean(false));
|
||||
|
||||
IedConnection_writeDataSetValuesAsync(con, &error, "simpleIOGenericIO/LLN0.Events", values, writeDataSetHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("write data set error %i\n", error);
|
||||
}
|
||||
|
||||
LinkedList_destroyDeep(values, (LinkedListValueDeleteFunction) MmsValue_delete);
|
||||
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient controlClient = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO1", con);
|
||||
|
||||
if (controlClient != NULL) {
|
||||
|
||||
ControlObjectClient_setOrigin(controlClient, "test1", CONTROL_ORCAT_AUTOMATIC_REMOTE);
|
||||
|
||||
MmsValue* ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
ControlObjectClient_operateAsync(controlClient, &error, ctlVal, 0, controlActionHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("Failed to send operate %i\n", error);
|
||||
}
|
||||
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to control object\n");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Thread_sleep(1000);
|
||||
|
||||
IedConnection_releaseAsync(con, &error);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("Release returned error: %d\n", error);
|
||||
}
|
||||
else {
|
||||
|
||||
while (IedConnection_getState(con) != IED_STATE_CLOSED) {
|
||||
Thread_sleep(10);
|
||||
}
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to %s:%i\n", hostname, tcpPort);
|
||||
}
|
||||
|
||||
if (clientDataSet)
|
||||
ClientDataSet_destroy(clientDataSet);
|
||||
|
||||
IedConnection_destroy(con);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
|
||||
set(iec61850_client_example_control_SRCS
|
||||
client_example_control.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
set_source_files_properties(${iec61850_client_example_control_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(client_example_control
|
||||
${iec61850_client_example_control_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(client_example_control
|
||||
iec61850
|
||||
)
|
||||
@ -1,17 +0,0 @@
|
||||
LIBIEC_HOME=../..
|
||||
|
||||
PROJECT_BINARY_NAME = client_example_control
|
||||
PROJECT_SOURCES = client_example_control.c
|
||||
|
||||
include $(LIBIEC_HOME)/make/target_system.mk
|
||||
include $(LIBIEC_HOME)/make/stack_includes.mk
|
||||
|
||||
all: $(PROJECT_BINARY_NAME)
|
||||
|
||||
include $(LIBIEC_HOME)/make/common_targets.mk
|
||||
|
||||
$(PROJECT_BINARY_NAME): $(PROJECT_SOURCES) $(LIB_NAME)
|
||||
$(CC) $(CFLAGS) $(LDFLAGS) -o $(PROJECT_BINARY_NAME) $(PROJECT_SOURCES) $(INCLUDES) $(LIB_NAME) $(LDLIBS)
|
||||
|
||||
clean:
|
||||
rm -f $(PROJECT_BINARY_NAME)
|
||||
@ -1,249 +0,0 @@
|
||||
/*
|
||||
* client_example_control.c
|
||||
*
|
||||
* How to control a device ... intended to be used with server_example_control
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
#include "hal_thread.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
static void commandTerminationHandler(void *parameter, ControlObjectClient connection)
|
||||
{
|
||||
|
||||
|
||||
LastApplError lastApplError = ControlObjectClient_getLastApplError(connection);
|
||||
|
||||
/* if lastApplError.error != 0 this indicates a CommandTermination- */
|
||||
if (lastApplError.error != 0) {
|
||||
printf("Received CommandTermination-.\n");
|
||||
printf(" LastApplError: %i\n", lastApplError.error);
|
||||
printf(" addCause: %i\n", lastApplError.addCause);
|
||||
}
|
||||
else
|
||||
printf("Received CommandTermination+.\n");
|
||||
}
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
int tcpPort = 102;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
tcpPort = atoi(argv[2]);
|
||||
|
||||
IedClientError error;
|
||||
|
||||
IedConnection con = IedConnection_create();
|
||||
|
||||
IedConnection_connect(con, &error, hostname, tcpPort);
|
||||
|
||||
if (error == IED_ERROR_OK)
|
||||
{
|
||||
MmsValue* ctlVal = NULL;
|
||||
MmsValue* stVal = NULL;
|
||||
|
||||
/************************
|
||||
* Direct control
|
||||
***********************/
|
||||
|
||||
ControlObjectClient control
|
||||
= ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO1", con);
|
||||
|
||||
if (control)
|
||||
{
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
ControlObjectClient_setOrigin(control, NULL, 3);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO1 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO1\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
/* Check if status value has changed */
|
||||
|
||||
stVal = IedConnection_readObject(con, &error, "simpleIOGenericIO/GGIO1.SPCSO1.stVal", IEC61850_FC_ST);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
bool state = MmsValue_getBoolean(stVal);
|
||||
MmsValue_delete(stVal);
|
||||
|
||||
printf("New status of simpleIOGenericIO/GGIO1.SPCSO1.stVal: %i\n", state);
|
||||
}
|
||||
else {
|
||||
printf("Reading status for simpleIOGenericIO/GGIO1.SPCSO1 failed!\n");
|
||||
}
|
||||
|
||||
}
|
||||
else {
|
||||
printf("Control object simpleIOGenericIO/GGIO1.SPCSO1 not found in server\n");
|
||||
}
|
||||
|
||||
/************************
|
||||
* Select before operate
|
||||
***********************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO2", con);
|
||||
|
||||
if (control)
|
||||
{
|
||||
if (ControlObjectClient_select(control)) {
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO2 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO2!\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
}
|
||||
else {
|
||||
printf("failed to select simpleIOGenericIO/GGIO1.SPCSO2!\n");
|
||||
}
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
}
|
||||
else {
|
||||
printf("Control object simpleIOGenericIO/GGIO1.SPCSO2 not found in server\n");
|
||||
}
|
||||
|
||||
/****************************************
|
||||
* Direct control with enhanced security
|
||||
****************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO3", con);
|
||||
|
||||
if (control)
|
||||
{
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO3 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO3\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
|
||||
/* Check if status value has changed */
|
||||
|
||||
stVal = IedConnection_readObject(con, &error, "simpleIOGenericIO/GGIO1.SPCSO3.stVal", IEC61850_FC_ST);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
bool state = MmsValue_getBoolean(stVal);
|
||||
|
||||
printf("New status of simpleIOGenericIO/GGIO1.SPCSO3.stVal: %i\n", state);
|
||||
|
||||
MmsValue_delete(stVal);
|
||||
}
|
||||
else {
|
||||
printf("Reading status for simpleIOGenericIO/GGIO1.SPCSO3 failed!\n");
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Control object simpleIOGenericIO/GGIO1.SPCSO3 not found in server\n");
|
||||
}
|
||||
|
||||
/***********************************************
|
||||
* Select before operate with enhanced security
|
||||
***********************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO4", con);
|
||||
|
||||
if (control)
|
||||
{
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_selectWithValue(control, ctlVal)) {
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO4 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO4!\n");
|
||||
}
|
||||
|
||||
}
|
||||
else {
|
||||
printf("failed to select simpleIOGenericIO/GGIO1.SPCSO4!\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
}
|
||||
else {
|
||||
printf("Control object simpleIOGenericIO/GGIO1.SPCSO4 not found in server\n");
|
||||
}
|
||||
|
||||
/*********************************************************************
|
||||
* Direct control with enhanced security (expect CommandTermination-)
|
||||
*********************************************************************/
|
||||
|
||||
control = ControlObjectClient_create("simpleIOGenericIO/GGIO1.SPCSO9", con);
|
||||
|
||||
if (control)
|
||||
{
|
||||
ControlObjectClient_setCommandTerminationHandler(control, commandTerminationHandler, NULL);
|
||||
|
||||
ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
if (ControlObjectClient_operate(control, ctlVal, 0 /* operate now */)) {
|
||||
printf("simpleIOGenericIO/GGIO1.SPCSO9 operated successfully\n");
|
||||
}
|
||||
else {
|
||||
printf("failed to operate simpleIOGenericIO/GGIO1.SPCSO9\n");
|
||||
}
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
/* Wait for command termination message */
|
||||
Thread_sleep(1000);
|
||||
|
||||
ControlObjectClient_destroy(control);
|
||||
}
|
||||
else {
|
||||
printf("Control object simpleIOGenericIO/GGIO1.SPCSO9 not found in server\n");
|
||||
}
|
||||
|
||||
IedConnection_close(con);
|
||||
}
|
||||
else {
|
||||
printf("Connection failed!\n");
|
||||
}
|
||||
|
||||
IedConnection_destroy(con);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
|
||||
set(iec61850_client_no_thread_SRCS
|
||||
client_example_no_thread.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
set_source_files_properties(${iec61850_client_no_thread_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(iec61850_client_no_thread
|
||||
${iec61850_client_no_thread_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(iec61850_client_no_thread
|
||||
iec61850
|
||||
)
|
||||
@ -1,17 +0,0 @@
|
||||
LIBIEC_HOME=../..
|
||||
|
||||
PROJECT_BINARY_NAME = client_example_no_thread
|
||||
PROJECT_SOURCES = client_example_no_thread.c
|
||||
|
||||
include $(LIBIEC_HOME)/make/target_system.mk
|
||||
include $(LIBIEC_HOME)/make/stack_includes.mk
|
||||
|
||||
all: $(PROJECT_BINARY_NAME)
|
||||
|
||||
include $(LIBIEC_HOME)/make/common_targets.mk
|
||||
|
||||
$(PROJECT_BINARY_NAME): $(PROJECT_SOURCES) $(LIB_NAME)
|
||||
$(CC) $(CFLAGS) $(LDFLAGS) -o $(PROJECT_BINARY_NAME) $(PROJECT_SOURCES) $(INCLUDES) $(LIB_NAME) $(LDLIBS)
|
||||
|
||||
clean:
|
||||
rm -f $(PROJECT_BINARY_NAME)
|
||||
@ -1,461 +0,0 @@
|
||||
/*
|
||||
* client_example_no_thread.c
|
||||
*
|
||||
* Shows how to use IedConnection in non-thread mode together with the asynchronous client API
|
||||
*
|
||||
* NOTE:
|
||||
* - in non-thread mode only asynchronous service functions can be used!
|
||||
* - the IedConnection_tick function has to be called periodically
|
||||
* - the asynchronous API returns service results by callback functions
|
||||
*
|
||||
* This example is intended to be used with server_example_basic_io.
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
#include "hal_thread.h"
|
||||
|
||||
static ClientDataSet clientDataSet = NULL;
|
||||
|
||||
static void
|
||||
printValue(char* name, MmsValue* value)
|
||||
{
|
||||
char buf[1000];
|
||||
|
||||
MmsValue_printToBuffer(value, buf, 1000);
|
||||
|
||||
printf("%s: %s\n", name, buf);
|
||||
}
|
||||
|
||||
/* callback function for IedConnection_readObjectAsync */
|
||||
static void
|
||||
readObjectHandler (uint32_t invokeId, void* parameter, IedClientError err, MmsValue* value)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
printValue((char*) parameter, value);
|
||||
|
||||
MmsValue_delete(value);
|
||||
}
|
||||
else {
|
||||
printf("Failed to read object %s (err=%i)\n", (char*) parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
/* callback function for IedConnection_readDataSetValuesAsync */
|
||||
static void
|
||||
readDataSetHandler(uint32_t invokeId, void* parameter, IedClientError err, ClientDataSet dataSet)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
clientDataSet = dataSet;
|
||||
|
||||
printf("Data set has %d entries\n", ClientDataSet_getDataSetSize(dataSet));
|
||||
|
||||
MmsValue* values = ClientDataSet_getValues(dataSet);
|
||||
|
||||
if (MmsValue_getType(values) == MMS_ARRAY) {
|
||||
int i;
|
||||
for (i = 0; i < MmsValue_getArraySize(values); i++) {
|
||||
printf(" [%i]", i);
|
||||
printValue("", MmsValue_getElement(values, i));
|
||||
}
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to read data set (err=%i)\n", err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
writeDataSetHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList /* <MmsValue*> */accessResults)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
|
||||
if (accessResults) {
|
||||
|
||||
int i = 0;
|
||||
|
||||
LinkedList element = LinkedList_getNext(accessResults);
|
||||
|
||||
while (element) {
|
||||
MmsValue* accessResultValue = LinkedList_getData(element);
|
||||
|
||||
printf(" access-result[%i]", i);
|
||||
printValue("", accessResultValue);
|
||||
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
i++;
|
||||
}
|
||||
|
||||
LinkedList_destroyDeep(accessResults, (LinkedListValueDeleteFunction) MmsValue_delete);
|
||||
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to write data set (err=%i)\n", err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
reportCallbackFunction(void* parameter, ClientReport report)
|
||||
{
|
||||
MmsValue* dataSetValues = ClientReport_getDataSetValues(report);
|
||||
|
||||
printf("received report for %s\n", ClientReport_getRcbReference(report));
|
||||
|
||||
int i;
|
||||
for (i = 0; i < 4; i++) {
|
||||
ReasonForInclusion reason = ClientReport_getReasonForInclusion(report, i);
|
||||
|
||||
if (reason != IEC61850_REASON_NOT_INCLUDED) {
|
||||
printf(" GGIO1.SPCSO%i.stVal: %i (included for reason %i)\n", i,
|
||||
MmsValue_getBoolean(MmsValue_getElement(dataSetValues, i)), reason);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getControlVariableVarSpecHandler(uint32_t invokeId, void* parameter, IedClientError err, MmsVariableSpecification* spec)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
|
||||
MmsVariableSpecification** ctlVarSpec = (MmsVariableSpecification**)parameter;
|
||||
|
||||
*ctlVarSpec = spec;
|
||||
}
|
||||
else {
|
||||
printf("Failed to get variable specification for object %s (err=%i)\n", (char*) parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getVarSpecHandler (uint32_t invokeId, void* parameter, IedClientError err, MmsVariableSpecification* spec)
|
||||
{
|
||||
if (err == IED_ERROR_OK) {
|
||||
|
||||
printf("variable: %s has type %d\n", (char*) parameter, MmsVariableSpecification_getType(spec));
|
||||
|
||||
MmsVariableSpecification_destroy(spec);
|
||||
}
|
||||
else {
|
||||
printf("Failed to get variable specification for object %s (err=%i)\n", (char*) parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
/* callback function for service functions IedConnection_getLogicalDeviceVariablesAsync, IedConnection_getLogicalDeviceDataSetsAsync */
|
||||
static void
|
||||
getNameListHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList nameList, bool moreFollows)
|
||||
{
|
||||
if (err != IED_ERROR_OK) {
|
||||
printf("Get name list error: %d\n", err);
|
||||
}
|
||||
else {
|
||||
|
||||
char* ldName = (char*) parameter;
|
||||
|
||||
LinkedList element = LinkedList_getNext(nameList);
|
||||
|
||||
while (element) {
|
||||
|
||||
char* variableName = (char*) LinkedList_getData(element);
|
||||
|
||||
printf(" %s/%s\n", ldName, variableName);
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
}
|
||||
|
||||
LinkedList_destroy(nameList);
|
||||
|
||||
free(ldName);
|
||||
}
|
||||
}
|
||||
|
||||
/* callback function for IedConnection_getServerDirectoryAsync */
|
||||
static void
|
||||
getServerDirectoryHandler(uint32_t invokeId, void* parameter, IedClientError err, LinkedList nameList, bool moreFollows)
|
||||
{
|
||||
IedConnection con = (IedConnection) parameter;
|
||||
|
||||
if (err != IED_ERROR_OK) {
|
||||
printf("Get server directory error: %d\n", err);
|
||||
}
|
||||
else {
|
||||
LinkedList element = LinkedList_getNext(nameList);
|
||||
|
||||
/* Call logical device variables for each logical node */
|
||||
while (element) {
|
||||
|
||||
char* ldName = (char*) LinkedList_getData(element);
|
||||
|
||||
printf("LD: %s variables:\n", ldName);
|
||||
|
||||
IedConnection_getLogicalDeviceVariablesAsync(con, &err, ldName, NULL, NULL, getNameListHandler, strdup(ldName));
|
||||
|
||||
printf("LD: %s data sets:\n", ldName);
|
||||
|
||||
IedConnection_getLogicalDeviceDataSetsAsync(con, &err, ldName, NULL, NULL, getNameListHandler, strdup(ldName));
|
||||
|
||||
element = LinkedList_getNext(element);
|
||||
}
|
||||
|
||||
LinkedList_destroy(nameList);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
controlActionHandler(uint32_t invokeId, void* parameter, IedClientError err, ControlActionType type, bool success)
|
||||
{
|
||||
printf("control: ID: %d type: %i err: %d success: %i\n", invokeId, type, err, success);
|
||||
}
|
||||
|
||||
static void
|
||||
stateChangedHandler(void* parameter, IedConnection connection, IedConnectionState newState)
|
||||
{
|
||||
printf("Connection state changed: ");
|
||||
|
||||
switch (newState) {
|
||||
case IED_STATE_CLOSED:
|
||||
printf("CLOSED\n");
|
||||
break;
|
||||
case IED_STATE_CLOSING:
|
||||
printf("CLOSING\n");
|
||||
break;
|
||||
case IED_STATE_CONNECTING:
|
||||
printf("CONNECTING\n");
|
||||
break;
|
||||
case IED_STATE_CONNECTED:
|
||||
printf("CONNECTED\n");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
getRCBValuesHandler (uint32_t invokeId, void* parameter, IedClientError err, ClientReportControlBlock rcb)
|
||||
{
|
||||
if (parameter) {
|
||||
printf("get rcb values handler: %s (error:%i)\n", (char*)parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
genericServiceHandler (uint32_t invokeId, void* parameter, IedClientError err)
|
||||
{
|
||||
if (parameter) {
|
||||
printf("generic service handler: %s (error:%i)\n", (char*)parameter, err);
|
||||
}
|
||||
}
|
||||
|
||||
static void waitWithTick(IedConnection con, int waitMs)
|
||||
{
|
||||
uint64_t startTime = Hal_getTimeInMs();
|
||||
|
||||
while (Hal_getTimeInMs() < (startTime + (uint64_t) waitMs))
|
||||
{
|
||||
if (IedConnection_tick(con) == true)
|
||||
Thread_sleep(10);
|
||||
}
|
||||
}
|
||||
|
||||
int
|
||||
main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
int tcpPort = 102;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
tcpPort = atoi(argv[2]);
|
||||
|
||||
IedClientError error;
|
||||
|
||||
ClientReportControlBlock rcb = NULL;
|
||||
|
||||
/* create new IedConnection with non-thread mode */
|
||||
IedConnection con = IedConnection_createEx(NULL, false);
|
||||
|
||||
/* track connection state change */
|
||||
IedConnection_installStateChangedHandler(con, stateChangedHandler, NULL);
|
||||
|
||||
/* invoke association with server */
|
||||
IedConnection_connectAsync(con, &error, hostname, tcpPort);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
|
||||
bool success = true;
|
||||
|
||||
/* Call IedConnection_tick until state is CONNECTED or CLOSED */
|
||||
while (IedConnection_getState(con) != IED_STATE_CONNECTED) {
|
||||
|
||||
if (IedConnection_getState(con) == IED_STATE_CLOSED) {
|
||||
success = false;
|
||||
break;
|
||||
}
|
||||
|
||||
if (IedConnection_tick(con) == true)
|
||||
Thread_sleep(10);
|
||||
}
|
||||
|
||||
if (success) {
|
||||
|
||||
IedConnection_getServerDirectoryAsync(con, &error, NULL, NULL, getServerDirectoryHandler, con);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read server directory error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
rcb = ClientReportControlBlock_create("simpleIOGenericIO/LLN0.RP.EventsRCB01");
|
||||
|
||||
/* Read RCB values */
|
||||
IedConnection_getRCBValuesAsync(con, &error, "simpleIOGenericIO/LLN0.RP.EventsRCB01", rcb, getRCBValuesHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("getRCBValues service error!\n");
|
||||
}
|
||||
else {
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
/* prepare the parameters of the RCP */
|
||||
ClientReportControlBlock_setResv(rcb, true);
|
||||
ClientReportControlBlock_setDataSetReference(rcb, "simpleIOGenericIO/LLN0$Events"); /* NOTE the "$" instead of "." ! */
|
||||
ClientReportControlBlock_setRptEna(rcb, true);
|
||||
ClientReportControlBlock_setGI(rcb, true);
|
||||
|
||||
/* Configure the report receiver */
|
||||
IedConnection_installReportHandler(con, "simpleIOGenericIO/LLN0.RP.EventsRCB", ClientReportControlBlock_getRptId(rcb), reportCallbackFunction,
|
||||
NULL);
|
||||
|
||||
/* Write RCB parameters and enable report */
|
||||
IedConnection_setRCBValuesAsync(con, &error, rcb, RCB_ELEMENT_RESV | RCB_ELEMENT_DATSET | RCB_ELEMENT_RPT_ENA | RCB_ELEMENT_GI, true, genericServiceHandler, NULL);
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
}
|
||||
|
||||
IedConnection_readObjectAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn1.mag.f", IEC61850_FC_MX, readObjectHandler, "simpleIOGenericIO/GGIO1.AnIn1.mag.f");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read object error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
IedConnection_readObjectAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn2.mag.f", IEC61850_FC_MX, readObjectHandler, "simpleIOGenericIO/GGIO1.AnIn2.mag.f");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read object error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
IedConnection_getVariableSpecificationAsync(con, &error, "simpleIOGenericIO/GGIO1.AnIn1", IEC61850_FC_MX, getVarSpecHandler, "simpleIOGenericIO/GGIO1.AnIn1");
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("get variable specification error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
IedConnection_readDataSetValuesAsync(con, &error, "simpleIOGenericIO/LLN0.Events", NULL, readDataSetHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("read data set error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
LinkedList values = LinkedList_create();
|
||||
LinkedList_add(values, MmsValue_newBoolean(true));
|
||||
LinkedList_add(values, MmsValue_newBoolean(false));
|
||||
LinkedList_add(values, MmsValue_newBoolean(true));
|
||||
LinkedList_add(values, MmsValue_newBoolean(false));
|
||||
|
||||
IedConnection_writeDataSetValuesAsync(con, &error, "simpleIOGenericIO/LLN0.Events", values, writeDataSetHandler, NULL);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("write data set error %i\n", error);
|
||||
}
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
LinkedList_destroyDeep(values, (LinkedListValueDeleteFunction) MmsValue_delete);
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
/* Get the variable specification for the controllable data object by online service */
|
||||
MmsVariableSpecification* ctlVarSpec = NULL;
|
||||
|
||||
IedConnection_getVariableSpecificationAsync(con, &error, "simpleIOGenericIO/GGIO1.SPCSO1", IEC61850_FC_CO,
|
||||
getControlVariableVarSpecHandler, &ctlVarSpec);
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
if (ctlVarSpec != NULL) {
|
||||
|
||||
/* ControlObjectClient_create function cannot be used in non-thread mode - use ControlObjectClient_createEx instead */
|
||||
ControlObjectClient controlClient = ControlObjectClient_createEx("simpleIOGenericIO/GGIO1.SPCSO1", con,
|
||||
CONTROL_MODEL_DIRECT_NORMAL, ctlVarSpec);
|
||||
|
||||
if (controlClient != NULL) {
|
||||
|
||||
ControlObjectClient_setOrigin(controlClient, "test1", CONTROL_ORCAT_AUTOMATIC_REMOTE);
|
||||
|
||||
MmsValue* ctlVal = MmsValue_newBoolean(true);
|
||||
|
||||
ControlObjectClient_operateAsync(controlClient, &error, ctlVal, 0, controlActionHandler, NULL);
|
||||
|
||||
waitWithTick(con, 1000);
|
||||
|
||||
MmsValue_delete(ctlVal);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("Failed to send operate %i\n", error);
|
||||
}
|
||||
|
||||
ControlObjectClient_destroy(controlClient);
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to control object\n");
|
||||
}
|
||||
|
||||
MmsVariableSpecification_destroy(ctlVarSpec);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
IedConnection_releaseAsync(con, &error);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("Release returned error: %d\n", error);
|
||||
}
|
||||
else {
|
||||
|
||||
/* Call IedConnection_tick until state is CLOSED */
|
||||
while (IedConnection_getState(con) != IED_STATE_CLOSED) {
|
||||
if (IedConnection_tick(con) == true)
|
||||
Thread_sleep(10);
|
||||
}
|
||||
}
|
||||
|
||||
if (rcb != NULL)
|
||||
ClientReportControlBlock_destroy(rcb);
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to %s:%i\n", hostname, tcpPort);
|
||||
}
|
||||
|
||||
if (clientDataSet)
|
||||
ClientDataSet_destroy(clientDataSet);
|
||||
|
||||
IedConnection_destroy(con);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
|
||||
set(iec61850_client_file_async_SRCS
|
||||
client_example_async.c
|
||||
)
|
||||
|
||||
IF(MSVC)
|
||||
set_source_files_properties(${iec61850_client_file_async_SRCS}
|
||||
PROPERTIES LANGUAGE CXX)
|
||||
ENDIF(MSVC)
|
||||
|
||||
add_executable(iec61850_client_file_async
|
||||
${iec61850_client_file_async_SRCS}
|
||||
)
|
||||
|
||||
target_link_libraries(iec61850_client_file_async
|
||||
iec61850
|
||||
)
|
||||
@ -1,106 +0,0 @@
|
||||
/*
|
||||
* client_example_async.c
|
||||
*
|
||||
* Shows how to use the asynchronous client API
|
||||
*
|
||||
* This example is intended to be used with server_example_basic_io.
|
||||
*/
|
||||
|
||||
#include "iec61850_client.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
#include "hal_thread.h"
|
||||
|
||||
static bool fileTransferComplete = false;
|
||||
|
||||
static bool
|
||||
getFileAsyncHandler (uint32_t invokeId, void* parameter, IedClientError err, uint32_t originalInvokeId,
|
||||
uint8_t* buffer, uint32_t bytesRead, bool moreFollows)
|
||||
{
|
||||
if ((err != IED_ERROR_OK) || (moreFollows == false)) {
|
||||
|
||||
if (err == IED_ERROR_OK) {
|
||||
printf("Received %d bytes\n", bytesRead);
|
||||
}
|
||||
|
||||
printf("File transfer complete (err:%d)\n", err);
|
||||
fileTransferComplete = true;
|
||||
}
|
||||
else {
|
||||
printf("Received %d bytes\n", bytesRead);
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
|
||||
char* hostname;
|
||||
char* filename = NULL;
|
||||
|
||||
if (argc > 1)
|
||||
hostname = argv[1];
|
||||
else
|
||||
hostname = "localhost";
|
||||
|
||||
if (argc > 2)
|
||||
filename = argv[2];
|
||||
|
||||
IedClientError error;
|
||||
|
||||
IedConnection con = IedConnection_create();
|
||||
|
||||
IedConnection_connectAsync(con, &error, hostname, 102);
|
||||
|
||||
if (error == IED_ERROR_OK) {
|
||||
|
||||
bool success = true;
|
||||
|
||||
while (IedConnection_getState(con) != IED_STATE_CONNECTED) {
|
||||
|
||||
if (IedConnection_getState(con) == IED_STATE_CLOSED) {
|
||||
success = false;
|
||||
break;
|
||||
}
|
||||
|
||||
Thread_sleep(10);
|
||||
}
|
||||
|
||||
if (success) {
|
||||
|
||||
if (filename) {
|
||||
IedConnection_getFileAsync(con, &error, filename, getFileAsyncHandler, NULL);
|
||||
|
||||
printf("Started file download\n");
|
||||
|
||||
while (fileTransferComplete == false)
|
||||
Thread_sleep(10);
|
||||
}
|
||||
}
|
||||
|
||||
Thread_sleep(1000);
|
||||
|
||||
IedConnection_releaseAsync(con, &error);
|
||||
|
||||
if (error != IED_ERROR_OK) {
|
||||
printf("Release returned error: %d\n", error);
|
||||
}
|
||||
else {
|
||||
|
||||
while (IedConnection_getState(con) != IED_STATE_CLOSED) {
|
||||
Thread_sleep(10);
|
||||
}
|
||||
}
|
||||
}
|
||||
else {
|
||||
printf("Failed to connect to %s\n", hostname);
|
||||
}
|
||||
|
||||
|
||||
IedConnection_destroy(con);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue