新增IEDScout调试工具功能

DELL

2024-02-21 4982b9614516dde101c3e44c60a612b3bfd8d6fe

 iec61850_forFoShanAES_Model/src/org/openmuc/openiec61850/integrationtests/ClientServerITest2.java

@@ -1,241 +1,241 @@
package org.openmuc.openiec61850.integrationtests;

import java.io.IOException;
import java.net.InetAddress;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;

import javax.naming.ConfigurationException;

import org.junit.Assert;
import org.junit.Test;
import org.openmuc.openiec61850.BasicDataAttribute;
import org.openmuc.openiec61850.BdaReasonForInclusion;
import org.openmuc.openiec61850.ClientAssociation;
import org.openmuc.openiec61850.ClientEventListener;
import org.openmuc.openiec61850.ClientSap;
import org.openmuc.openiec61850.Fc;
import org.openmuc.openiec61850.FcModelNode;
import org.openmuc.openiec61850.ModelNode;
import org.openmuc.openiec61850.Report;
import org.openmuc.openiec61850.SclParseException;
import org.openmuc.openiec61850.ServerEventListener;
import org.openmuc.openiec61850.ServerModel;
import org.openmuc.openiec61850.ServerSap;
import org.openmuc.openiec61850.ServiceError;

public class ClientServerITest2 extends Thread implements ServerEventListener, ClientEventListener {

    int port = 54322;
    String host = "127.0.0.1";
    ClientSap clientSap = new ClientSap();
    ServerSap serverSap = null;
    ClientAssociation clientAssociation = null;
    ClientAssociation clientAssociation2 = null;
    ServerModel serversServerModel = null;
    private static int numReports = 0;
    private static int numSuccess = 0;
    private static int numAssociationClosed = 0;

    // Get the Java runtime
    public static Runtime runtime = Runtime.getRuntime();

    @Test
    public void testClientServerCom() throws IOException, ServiceError, ConfigurationException,
            javax.naming.ConfigurationException, SclParseException, InterruptedException {

        clientSap.setTSelRemote(new byte[] { 0, 1 });
        clientSap.setTSelLocal(new byte[] { 0, 0 });
        clientSap.setApTitleCalled(new int[] { 1, 1, 999, 1 });

        runServer("src/test/resources/testModel2.icd", port);
        System.out.println("IED Server is running");

        // -----------------------------------------------------------
        // Client
        // -----------------------------------------------------------

        System.out.println("Attempting to connect to server " + host + " on port " + port);

        clientAssociation = clientSap.associate(InetAddress.getByName(host), port, null, this);

        ServerModel serverModel = clientAssociation.getModelFromSclFile("src/test/resources/testModel2.icd");
        // ServerModel serverModel = clientAssociation.retrieveModel();

        getAllBdas(serverModel);

        // timestamp = (BdaTimestamp) serverModel.findModelNode("ied1lDevice1/MMXU1.TotW.t", Fc.MX);
        // clientAssociation.getDataValues(timestamp);

        clientAssociation.disconnect();

        Thread.sleep(500);
        serverSap.stop();

    }

    private void getAllBdas(ServerModel serverModel) throws ServiceError, IOException {

        for (ModelNode ld : serverModel) {
            for (ModelNode ln : ld) {
                getDataRecursive(ln, clientAssociation);
            }
        }
    }

    private void runServer(String sclFilePath, int port) throws SclParseException, IOException {

        List<ServerSap> serverSaps = null;
        serverSaps = ServerSap.getSapsFromSclFile(sclFilePath);

        serverSap = serverSaps.get(0);
        serverSap.setPort(port);
        serverSap.startListening(this);
        serversServerModel = serverSap.getModelCopy();
        start();
    }

    private static void getDataRecursive(ModelNode modelNode, ClientAssociation clientAssociation)
            throws ServiceError, IOException {
        if (modelNode.getChildren() == null) {
            return;
        }
        for (ModelNode childNode : modelNode) {
            FcModelNode fcChildNode = (FcModelNode) childNode;
            if (fcChildNode.getFc() != Fc.CO) {
                System.out.println("calling GetDataValues(" + childNode.getReference() + ")");
                clientAssociation.getDataValues(fcChildNode);
            }
            // clientAssociation.setDataValues(fcChildNode);
            getDataRecursive(childNode, clientAssociation);
        }
    }

    public static int findArray(Byte[] array, Byte[] subArray) {
        return Collections.indexOfSubList(Arrays.asList(array), Arrays.asList(subArray));
    }

    public static String getByteArrayString(byte[] byteArray) {
        StringBuilder builder = new StringBuilder();
        int l = 1;
        for (byte b : byteArray) {
            if ((l != 1) && ((l - 1) % 8 == 0)) {
                builder.append(' ');
            }
            if ((l != 1) && ((l - 1) % 16 == 0)) {
                builder.append('\n');
            }
            l++;
            builder.append("0x");
            String hexString = Integer.toHexString(b & 0xff);
            if (hexString.length() == 1) {
                builder.append(0);
            }
            builder.append(hexString + " ");
        }
        return builder.toString();
    }

    @Override
    public void serverStoppedListening(ServerSap serverSAP) {
        // TODO Auto-generated method stub
    }

    @Override
    public List<ServiceError> write(List<BasicDataAttribute> bdas) {
        System.out.println("DataSource: got write request");
        return null;
    }

    @Override
    public void run() {

        // BdaFloat32 totWMag = (BdaFloat32) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.mag.f", Fc.MX);
        // BdaQuality q = (BdaQuality) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.q", Fc.MX);
        // BdaTimestamp t = (BdaTimestamp) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.t", Fc.MX);
        //
        // List<BasicDataAttribute> totWBdas = new ArrayList<BasicDataAttribute>(3);
        // totWBdas.add(totWMag);
        // totWBdas.add(q);
        // totWBdas.add(t);
        //
        // float totWMagVal = 0.0f;
        // q.setValidity(BdaQuality.Validity.GOOD);
        //
        // // for (int i = 0; i < 500000; i++) {
        //
        // totWMagVal += 1.0;
        //
        // logger.info("setting totWmag to: " + totWMagVal);
        // totWMag.setFloat(totWMagVal);
        // t.setCurrentTime();
        //
        // if (q.getValidity() == Validity.GOOD) {
        // q.setValidity(BdaQuality.Validity.INVALID);
        // }
        // else {
        // q.setValidity(BdaQuality.Validity.GOOD);
        // }
        //
        // try {
        // Thread.sleep(4000);
        // } catch (InterruptedException e) {
        // }
        // serverSap.setValues(totWBdas);

        // // Run the garbage collector
        // runtime.gc();
        // // Calculate the used memory
        // long memory = runtime.totalMemory() - runtime.freeMemory();
        // System.out.println("Used memory is bytes: " + memory);
        // System.out.println("Used memory is megabytes: " + bytesToMegabytes(memory));

        // try {
        // Thread.sleep(2000);
        // } catch (InterruptedException e) {
        // }
        // }

    }

    private static final long MEGABYTE = 1024L * 1024L;

    public static long bytesToMegabytes(long bytes) {
        return bytes / MEGABYTE;
    }

    @Override
    public void newReport(Report report) {
        System.out.println("got report!");
        numReports++;

        if (numReports == 1) {
            List<BdaReasonForInclusion> reasons = report.getReasonCodes();
            Assert.assertEquals(2, reasons.size());
            Assert.assertTrue(reasons.get(0).isGeneralInterrogation());
            Assert.assertFalse(reasons.get(0).isDataUpdate());
        }
        else if (numReports == 2) {
            List<BdaReasonForInclusion> reasons = report.getReasonCodes();
            Assert.assertEquals(1, reasons.size());
            Assert.assertFalse(reasons.get(0).isGeneralInterrogation());
            Assert.assertTrue(reasons.get(0).isDataChange());
        }
        else if (numReports >= 3) {
            List<BdaReasonForInclusion> reasons = report.getReasonCodes();
            Assert.assertEquals(2, reasons.size());
            Assert.assertTrue(reasons.get(0).isIntegrity());
            Assert.assertTrue(reasons.get(1).isIntegrity());
        }

        numSuccess++;

    }

    @Override
    public void associationClosed(IOException e) {
        System.out.println("Association closed!");
        numAssociationClosed++;
    }
}
package org.openmuc.openiec61850.integrationtests;



import java.io.IOException;

import java.net.InetAddress;

import java.util.Arrays;

import java.util.Collections;

import java.util.List;



import javax.naming.ConfigurationException;



import org.junit.Assert;

import org.junit.Test;

import org.openmuc.openiec61850.BasicDataAttribute;

import org.openmuc.openiec61850.BdaReasonForInclusion;

import org.openmuc.openiec61850.ClientAssociation;

import org.openmuc.openiec61850.ClientEventListener;

import org.openmuc.openiec61850.ClientSap;

import org.openmuc.openiec61850.Fc;

import org.openmuc.openiec61850.FcModelNode;

import org.openmuc.openiec61850.ModelNode;

import org.openmuc.openiec61850.Report;

import org.openmuc.openiec61850.SclParseException;

import org.openmuc.openiec61850.ServerEventListener;

import org.openmuc.openiec61850.ServerModel;

import org.openmuc.openiec61850.ServerSap;

import org.openmuc.openiec61850.ServiceError;



public class ClientServerITest2 extends Thread implements ServerEventListener, ClientEventListener {



    int port = 54322;

    String host = "127.0.0.1";

    ClientSap clientSap = new ClientSap();

    ServerSap serverSap = null;

    ClientAssociation clientAssociation = null;

    ClientAssociation clientAssociation2 = null;

    ServerModel serversServerModel = null;

    private static int numReports = 0;

    private static int numSuccess = 0;

    private static int numAssociationClosed = 0;



    // Get the Java runtime

    public static Runtime runtime = Runtime.getRuntime();



    @Test

    public void testClientServerCom() throws IOException, ServiceError, ConfigurationException,

            javax.naming.ConfigurationException, SclParseException, InterruptedException {



        clientSap.setTSelRemote(new byte[] { 0, 1 });

        clientSap.setTSelLocal(new byte[] { 0, 0 });

        clientSap.setApTitleCalled(new int[] { 1, 1, 999, 1 });



        runServer("src/test/resources/testModel2.icd", port);

        System.out.println("IED Server is running");



        // -----------------------------------------------------------

        // Client

        // -----------------------------------------------------------



        System.out.println("Attempting to connect to server " + host + " on port " + port);



        clientAssociation = clientSap.associate(InetAddress.getByName(host), port, null, this);



        ServerModel serverModel = clientAssociation.getModelFromSclFile("src/test/resources/testModel2.icd");

        // ServerModel serverModel = clientAssociation.retrieveModel();



        getAllBdas(serverModel);



        // timestamp = (BdaTimestamp) serverModel.findModelNode("ied1lDevice1/MMXU1.TotW.t", Fc.MX);

        // clientAssociation.getDataValues(timestamp);



        clientAssociation.disconnect();



        Thread.sleep(500);

        serverSap.stop();



    }



    private void getAllBdas(ServerModel serverModel) throws ServiceError, IOException {



        for (ModelNode ld : serverModel) {

            for (ModelNode ln : ld) {

                getDataRecursive(ln, clientAssociation);

            }

        }

    }



    private void runServer(String sclFilePath, int port) throws SclParseException, IOException {



        List<ServerSap> serverSaps = null;

        serverSaps = ServerSap.getSapsFromSclFile(sclFilePath);



        serverSap = serverSaps.get(0);

        serverSap.setPort(port);

        serverSap.startListening(this);

        serversServerModel = serverSap.getModelCopy();

        start();

    }



    private static void getDataRecursive(ModelNode modelNode, ClientAssociation clientAssociation)

            throws ServiceError, IOException {

        if (modelNode.getChildren() == null) {

            return;

        }

        for (ModelNode childNode : modelNode) {

            FcModelNode fcChildNode = (FcModelNode) childNode;

            if (fcChildNode.getFc() != Fc.CO) {

                System.out.println("calling GetDataValues(" + childNode.getReference() + ")");

                clientAssociation.getDataValues(fcChildNode);

            }

            // clientAssociation.setDataValues(fcChildNode);

            getDataRecursive(childNode, clientAssociation);

        }

    }



    public static int findArray(Byte[] array, Byte[] subArray) {

        return Collections.indexOfSubList(Arrays.asList(array), Arrays.asList(subArray));

    }



    public static String getByteArrayString(byte[] byteArray) {

        StringBuilder builder = new StringBuilder();

        int l = 1;

        for (byte b : byteArray) {

            if ((l != 1) && ((l - 1) % 8 == 0)) {

                builder.append(' ');

            }

            if ((l != 1) && ((l - 1) % 16 == 0)) {

                builder.append('\n');

            }

            l++;

            builder.append("0x");

            String hexString = Integer.toHexString(b & 0xff);

            if (hexString.length() == 1) {

                builder.append(0);

            }

            builder.append(hexString + " ");

        }

        return builder.toString();

    }



    @Override

    public void serverStoppedListening(ServerSap serverSAP) {

        // TODO Auto-generated method stub

    }



    @Override

    public List<ServiceError> write(List<BasicDataAttribute> bdas) {

        System.out.println("DataSource: got write request");

        return null;

    }



    @Override

    public void run() {



        // BdaFloat32 totWMag = (BdaFloat32) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.mag.f", Fc.MX);

        // BdaQuality q = (BdaQuality) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.q", Fc.MX);

        // BdaTimestamp t = (BdaTimestamp) serversServerModel.findModelNode("ied1lDevice1/MMXU1.TotW.t", Fc.MX);

        //

        // List<BasicDataAttribute> totWBdas = new ArrayList<BasicDataAttribute>(3);

        // totWBdas.add(totWMag);

        // totWBdas.add(q);

        // totWBdas.add(t);

        //

        // float totWMagVal = 0.0f;

        // q.setValidity(BdaQuality.Validity.GOOD);

        //

        // // for (int i = 0; i < 500000; i++) {

        //

        // totWMagVal += 1.0;

        //

        // logger.info("setting totWmag to: " + totWMagVal);

        // totWMag.setFloat(totWMagVal);

        // t.setCurrentTime();

        //

        // if (q.getValidity() == Validity.GOOD) {

        // q.setValidity(BdaQuality.Validity.INVALID);

        // }

        // else {

        // q.setValidity(BdaQuality.Validity.GOOD);

        // }

        //

        // try {

        // Thread.sleep(4000);

        // } catch (InterruptedException e) {

        // }

        // serverSap.setValues(totWBdas);



        // // Run the garbage collector

        // runtime.gc();

        // // Calculate the used memory

        // long memory = runtime.totalMemory() - runtime.freeMemory();

        // System.out.println("Used memory is bytes: " + memory);

        // System.out.println("Used memory is megabytes: " + bytesToMegabytes(memory));



        // try {

        // Thread.sleep(2000);

        // } catch (InterruptedException e) {

        // }

        // }



    }



    private static final long MEGABYTE = 1024L * 1024L;



    public static long bytesToMegabytes(long bytes) {

        return bytes / MEGABYTE;

    }



    @Override

    public void newReport(Report report) {

        System.out.println("got report!");

        numReports++;



        if (numReports == 1) {

            List<BdaReasonForInclusion> reasons = report.getReasonCodes();

            Assert.assertEquals(2, reasons.size());

            Assert.assertTrue(reasons.get(0).isGeneralInterrogation());

            Assert.assertFalse(reasons.get(0).isDataUpdate());

        }

        else if (numReports == 2) {

            List<BdaReasonForInclusion> reasons = report.getReasonCodes();

            Assert.assertEquals(1, reasons.size());

            Assert.assertFalse(reasons.get(0).isGeneralInterrogation());

            Assert.assertTrue(reasons.get(0).isDataChange());

        }

        else if (numReports >= 3) {

            List<BdaReasonForInclusion> reasons = report.getReasonCodes();

            Assert.assertEquals(2, reasons.size());

            Assert.assertTrue(reasons.get(0).isIntegrity());

            Assert.assertTrue(reasons.get(1).isIntegrity());

        }



        numSuccess++;



    }



    @Override

    public void associationClosed(IOException e) {

        System.out.println("Association closed!");

        numAssociationClosed++;

    }

}