libiec61850/dotnet/files/FileServicesExample.cs

using System;
using System.Collections.Generic;

using IEC61850.Client;
using IEC61850.Common;
using System.IO;
using System.Threading;

namespace files
{
    /// <summary>
    /// This example connects to an IEC 61850 device, list the available files, and then
    /// tries to read the file "IEDSERVER.BIN" from the server.
    /// </summary>
    class MainClass
    {
        public static void printFiles(IedConnection con, string prefix, string parent)
        {
            bool moreFollows = false;

            List<FileDirectoryEntry> files = con.GetFileDirectoryEx(parent, null, out moreFollows);

            foreach (FileDirectoryEntry file in files)
            {
                Console.WriteLine(prefix + file.GetFileName() + "\t" + file.GetFileSize() + "\t" +
                MmsValue.MsTimeToDateTimeOffset(file.GetLastModified()));

                if (file.GetFileName().EndsWith("/"))
                {
                    printFiles(con, prefix + "  ", parent + file.GetFileName());
                }
            }

            if (moreFollows)
                Console.WriteLine("-- MORE FILES AVAILABLE --");
        }

        static bool getFileHandler(object parameter, byte[] data)
        {
            Console.WriteLine("received " + data.Length + " bytes");

            BinaryWriter binWriter = (BinaryWriter)parameter;

            binWriter.Write(data);

            return true;
        }

        public static void Main(string[] args)
        {
            IedConnection con = new IedConnection();

            string hostname;

            if (args.Length > 0)
                hostname = args[0];
            else
                hostname = "127.0.0.1";

            Console.WriteLine("Connect to " + hostname);

            try
            {
                con.Connect(hostname, 102);

                Console.WriteLine("Files in server root directory:");
                List<string> serverDirectory = con.GetServerDirectory(true);

                foreach (string entry in serverDirectory)
                {
                    Console.WriteLine(entry);
                }

                Console.WriteLine();

                Console.WriteLine("File directory tree at server:");
                printFiles(con, "", "");
                Console.WriteLine();

                string filename = "IEDSERVER.BIN";

                Console.WriteLine("Download file " + filename);

                /* Download file from server and write it to a new local file */
                FileStream fs = new FileStream(filename, FileMode.Create);
                BinaryWriter w = new BinaryWriter(fs);

                bool fileDownloadFinished = false;

                //con.GetFile (filename, new IedConnection.GetFileHandler (getFileHandler), w);

                /// COMMENT SECTION WHEN USING SYNC VERSION -->

                con.GetFileAsync(filename, delegate (UInt32 invokeId, object parameter, IedClientError err, UInt32 originalInvokeId, byte[] buffer, bool moreFollows)
                {
                    if (err == IedClientError.IED_ERROR_OK)
                    {
                        Console.WriteLine("Received new file segment with " + buffer.Length.ToString() + " bytes, more-follows: " + moreFollows.ToString());

                        w.Write(buffer);

                        if (moreFollows == false)
                            fileDownloadFinished = true;
                    }
                    else
                    {
                        Console.WriteLine("File download error: " + err.ToString());
                        fileDownloadFinished = true;
                    }

                    return true;
                }, w);

                while (fileDownloadFinished == false)
                {
                    Thread.Sleep(500);
                }

                /// <-- COMMENT SECTION WHEN USING SYNC VERSION

                fs.Close();

                con.Abort();
            }
            catch (IedConnectionException e)
            {
                Console.WriteLine(e.Message);
            }

            // release all resources - do NOT use the object after this call!!
            con.Dispose();
        }
    }
}