ThingWorx Edge .NET SDK Crashing

It's running on a PC running Windows 2008. I don't think it's running out of memory, although the machines we're running it on don't have much, only 2 gigs of RAM. I don't see any other programs that are running on it having memory errors.

I don't know if I would say it is time based. It seems pretty random. We have it run on 14 different machines that are restarted each evening and it seems like there will usually be one or two instances of the Edge server that crash during the day.

Its basic activity is to communicate with a Python program that we run tests with, then update a Thingworx mashup with the test's status.

Here's a snippet with most of the changes that were made to the steam sensor example. I don't think it does anything too different from the steam sensor example:

TestMonitorThing.cs:

using com.thingworx.common;

using com.thingworx.common.exceptions;

using com.thingworx.communications.client;

using com.thingworx.communications.client.things;

using com.thingworx.metadata;

using com.thingworx.metadata.annotations;

using com.thingworx.metadata.collections;

using com.thingworx.types;

using com.thingworx.types.collections;

using com.thingworx.types.constants;

using com.thingworx.types.primitives;

using System;

using System.Collections.Specialized;

using System.Linq;

using System.Text;

using System.Threading;

using System.Globalization;

using Microsoft.Win32.TaskScheduler;

using System.Collections;

using log4net;

namespace TestMonitor

{

    // Property Definitions

    [ThingworxPropertyDefinition(name = "TestBaselineTask", description = "Baseline Task", baseType = "STRING", category = "Status", aspects = new string[] { "isReadOnly:true" })]

    [ThingworxPropertyDefinition(name = "TestTask", description = "Test Task", baseType = "STRING", category = "Status", aspects = new string[] { "isReadOnly:true" })]

    class TestMonitorThing : VirtualThing

    {

        private static readonly ILog logger = LogManager.GetLogger(typeof(TestMonitorThing));

        private static String TEST_NAME = "TestName";

        private static String TEST_STATUS = "TestStatus";

        // Lock and bool field used to keep the shutdown logic from occuring multiple times before the actual shutdown

        private object _shutdownLock = new object();

        private bool _shuttingDown = false;

        private TestMonitor.TestCommunicator _testCommunicator;

        public TestMonitorThing(string name, string description, string identifier, ConnectedThingClient client, TestMonitor.TestCommunicator testCommunicator)

            : base(name, description, identifier, client)

        {

            //Data shape definition that is used by the GetSteamSensorReadings service

            FieldDefinitionCollection readingfields = new FieldDefinitionCollection();

            readingfields.addFieldDefinition(new FieldDefinition(TEST_NAME, BaseTypes.STRING));

            readingfields.addFieldDefinition(new FieldDefinition(TEST_STATUS, BaseTypes.STRING));

            defineDataShapeDefinition("SteamSensorReadings", readingfields);

            // Populate the thing shape with the properties, services, and events that are annotated in this code

            base.initializeFromAnnotations();

            _testCommunicator = testCommunicator;

        }

        // From the VirtualThing class

        // This method will get called when a connect or reconnect happens

        // Need to send the values when this happens

        // This is more important for a solution that does not send its properties on a regular basis

        public override void synchronizeState()

        {

            // Be sure to call the base class

            base.synchronizeState();

            // Send the property values to Thingworx when a synchronization is required

            base.syncProperties();

        }

        // The processScanRequest is called by the SteamSensorClient every scan cycle

        public override void processScanRequest()

        {

            // Be sure to call the base classes scan request

            base.processScanRequest();

            // Execute the code for this simulation every scan

            this.scanDevice();

        }

        private Task getTestTask()

        {

            Task kickoffTask;

            using (TaskService ts = new TaskService())

            {

                kickoffTask = ts.GetTask("Kickoff");

            }

            return kickoffTask;

        }

        private Task getTestBaselineTask()

        {

            Task kickoffBaselineTask;

            using (TaskService ts = new TaskService())

            {

                kickoffBaselineTask = ts.GetTask("Kickoffbaseline");

            }

            return kickoffBaselineTask;

        }

        // Performs the logic for the steam sensor, occurs every scan cycle

        public void scanDevice()

        {

            Random random = new Random();

            Task testTask = getTestTask();

            Task baselineTask = getTestBaselineTask();

            string testTaskStatus = testTask.Name + " - " + testTask.State.ToString();

            string testBaselineTaskStatus = baselineTask.Name + " - " + baselineTask.State.ToString();

            // Set the property values

            base.setProperty("TestTask", testTaskStatus);

            base.setProperty("TestBaselineTask", testBaselineTaskStatus);

            try

            {

                // Update the subscribed properties and events to send any updates to Thingworx

                // Without calling these methods, the property and event updates will not be sent

                // The numbers are timeouts in milliseconds.

                base.updateSubscribedProperties(15000);

                base.updateSubscribedEvents(60000);

            }

            catch (Exception ex)

            {

                // handle exception as appropriate

                logger.Error("Error in scanDevice!");

            }

        }

        [method: ThingworxServiceDefinition(name = "LaunchTest", description = "Launch test.")]

        [return: ThingworxServiceResult(name = CommonPropertyNames.PROP_RESULT, description = "Result", baseType = "STRING")]

        public string LaunchTest()

        {

            getTestTask().Run();

            return "Success";

        }

        [method: ThingworxServiceDefinition(name = "StopTest", description = "Stop test.")]

        [return: ThingworxServiceResult(name = CommonPropertyNames.PROP_RESULT, description = "Result", baseType = "STRING")]

        public string StopTest()

        {

            getTestTask().Stop();

            return "Success";

        }

        [method: ThingworxServiceDefinition(name = "LaunchBaselineTest", description = "Launch baseline test.")]

        [return: ThingworxServiceResult(name = CommonPropertyNames.PROP_RESULT, description = "Result", baseType = "STRING")]

        public string LaunchBaselineTest()

        {

            getTestBaselineTask().Run();

            return "Success";

        }

        [method: ThingworxServiceDefinition(name = "GetTestState", description = "Get the state of tests that run on this machine.")]

        [return: ThingworxServiceResult(name = CommonPropertyNames.PROP_RESULT, description = "Result", baseType = "INFOTABLE", aspects = new string[] { "dataShape:SteamSensorReadings" })]

        public InfoTable GetTestState()

        {

            var table = new InfoTable(getDataShapeDefinition("SteamSensorReadings"));

            try

            {

                OrderedDictionary testStatuses = _testCommunicator.GetTestStatuses();

                foreach (DictionaryEntry de in testStatuses)

                {

                    string currentTestName = (string)de.Key;

                    string currentTestStatus = (string)de.Value;

                    var entry = new ValueCollection();

                    entry.SetStringValue(TEST_NAME, currentTestName);

                    entry.SetStringValue(TEST_STATUS, currentTestStatus);

                    table.addRow(entry);

                }

            }

            catch (Exception e)

            {

                // handle exception as appropriate

                logger.Error("Error in GetTestState!");

            }

            return table;

        }

        [method: ThingworxServiceDefinition(name = "Shutdown", description = "Shutdown the client")]

        [return: ThingworxServiceResult(name = CommonPropertyNames.PROP_RESULT, description = "", baseType = "NOTHING")]

        public void Shutdown()

        {

            // Highly unlikely that this service could be called more than once, but guard against it anyway

            lock (this._shutdownLock)

            {

                if (!this._shuttingDown)

                {

                    // Start a thread to begin the shutdown or the shutdown could happen before the service returns

                    ThreadPool.QueueUserWorkItem(new WaitCallback(this.shutdownThread));

                }

                this._shuttingDown = true;

            }

        }

        private void shutdownThread(object state)

        {

            try

            {

                // Delay for a period to verify that the Shutdown service will return

                Thread.Sleep(1000);

                // Shutdown the client

                this.getClient().shutdown();

            }

            catch

            {

                logger.Error("Error in shutdownThread!");

                // Not much can be done if there is an exception here

                // In the case of production code should at least log the error

            }

        }

    }

}

I've managed to open up the crash dumps in Visual Studio, and I'm seeing that it seems to have crashed on line 77 of the C Edge SDK file src\messaging\twMessaging.c:

if (msgHandlerSingleton && msgHandlerSingleton->incomingRequestCallbacks) {

I'm not sure, but it looks like the msgHandlerSingleton variable may be invalid when it is referenced on that line.