libiec61850/examples/iec61850_client_example_log/client_example_log.c

/*
 * client_example_log.c
 *
 * This example is intended to be used with server_example_logging
 */

#include "iec61850_client.h"

#include <stdlib.h>
#include <stdio.h>
#include <time.h>

//#include "hal_thread.h"

static void
printJournalEntries(LinkedList journalEntries)
{
    char buf[1024];

    LinkedList journalEntriesElem = LinkedList_getNext(journalEntries);

    while (journalEntriesElem != NULL) {

        MmsJournalEntry journalEntry = (MmsJournalEntry) LinkedList_getData(journalEntriesElem);

        MmsValue_printToBuffer(MmsJournalEntry_getEntryID(journalEntry), buf, 1024);
        printf("EntryID: %s\n", buf);
        MmsValue_printToBuffer(MmsJournalEntry_getOccurenceTime(journalEntry), buf, 1024);
        printf("  occurence time: %s\n", buf);

        LinkedList journalVariableElem = LinkedList_getNext(journalEntry->journalVariables);

        while (journalVariableElem != NULL) {

            MmsJournalVariable journalVariable = (MmsJournalVariable) LinkedList_getData(journalVariableElem);

            printf("   variable-tag: %s\n", MmsJournalVariable_getTag(journalVariable));
            MmsValue_printToBuffer(MmsJournalVariable_getValue(journalVariable), buf, 1024);
            printf("   variable-value: %s\n", buf);

            journalVariableElem = LinkedList_getNext(journalVariableElem);
        }

        journalEntriesElem = LinkedList_getNext(journalEntriesElem);
    }
}

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]);

    char* logRef = "simpleIOGenericIO/LLN0$EventLog";

    IedClientError error;

    IedConnection con = IedConnection_create();

    IedConnection_connect(con, &error, hostname, tcpPort);

    if (error == IED_ERROR_OK) {

        /* read list of logs in LN (optional - if you don't know the existing logs) */
        LinkedList logs = IedConnection_getLogicalNodeDirectory(con, &error, "simpleIOGenericIO/LLN0", ACSI_CLASS_LOG);

        if (error == IED_ERROR_OK) {
            printf("Found log in LN simpleIOGenericIO/LLN0:\n");

            LinkedList log = LinkedList_getNext(logs);

            while (log != NULL) {
                char* logName = (char*) LinkedList_getData(log);

                printf("  %s\n", logName);

                log = LinkedList_getNext(log);
            }

            LinkedList_destroy(logs);
        }

        /* read log control block (using the generic read function) */
        MmsValue* lcbValue = IedConnection_readObject(con, &error, "simpleIOGenericIO/LLN0.EventLog", IEC61850_FC_LG);

        if (error == IED_ERROR_OK) {

            MmsValue* oldEntryTm = MmsValue_getElement(lcbValue, 3);
            MmsValue* oldEntry = MmsValue_getElement(lcbValue, 5);

            uint64_t timestamp = MmsValue_getUtcTimeInMs(oldEntryTm);

            bool moreFollows;

            /*
             * read the log contents. Be aware that the logRef uses the '$' sign as separator between the LN and
             * the log name! This is in contrast to the LCB object reference above.
             */
            LinkedList logEntries = IedConnection_queryLogAfter(con, &error, "simpleIOGenericIO/LLN0$EventLog", oldEntry, timestamp, &moreFollows);

            if (error == IED_ERROR_OK) {
                printJournalEntries(logEntries);

                LinkedList_destroyDeep(logEntries, (LinkedListValueDeleteFunction) MmsJournalEntry_destroy);
            }
            else
                printf("QueryLog failed (error code: %i)!\n", error);

            //TODO handle moreFollows

            MmsValue_delete(lcbValue);
        }
        else
            printf("Read LCB failed!\n");


        IedConnection_abort(con, &error);
    }
    else {
        printf("Failed to connect to %s:%i\n", hostname, tcpPort);
    }

    IedConnection_destroy(con);
}