public override void Start()
        {
            foreach (var potentialSensor in KinectSensor.KinectSensors)
            {
                if (potentialSensor.Status == KinectStatus.Connected)
                {
                    this.sensor = potentialSensor;
                    break;
                }
            }

            //Create a new port on the platform.
            string kinectStr = moduleInfo.Args()[0];
            VPortInfo pInfo = GetPortInfoFromPlatform("kinect" + kinectStr);
            List<VRole> roles = new List<VRole>() { RoleCamera.Instance, RoleDepthCam.Instance, RoleMicrophone.Instance, RoleSkeletonTracker.Instance };

            kinectPort = InitPort(pInfo);
            BindRoles(kinectPort, roles, OnOperationInvoke);

            RegisterPortWithPlatform(kinectPort);

            /*            sensor.ColorStream.Enable();
            sensor.DepthStream.Enable();
            sensor.SkeletonStream.Enable();*/

            logger.Log("Kinect Sensor Rigistered.");
            StartKinect();
        }

        private static void Run(int n, int threadCount)
        {
            Dispatcher d = new Dispatcher(threadCount, "ccr pool");
            DispatcherQueue dq = new DispatcherQueue("disp", d);
            Port<int> p1 = new Port<int>(),  p2 = new Port<int>();
            EventWaitHandle done1 = new AutoResetEvent(false), done2 = new AutoResetEvent(false);

            PingPonger pp1 = new PingPonger(done1, n, p2),
                pp2 = new PingPonger(done2, n, p1);

            Arbiter.Activate(dq, Arbiter.Interleave(
                new TeardownReceiverGroup(),
                new ExclusiveReceiverGroup(Arbiter.Receive(true, p1, pp1.Update)),
                new ConcurrentReceiverGroup()));

            Arbiter.Activate(dq, Arbiter.Interleave(
                new TeardownReceiverGroup(),
                new ExclusiveReceiverGroup(Arbiter.Receive(true, p2, pp2.Update)),
                new ConcurrentReceiverGroup()));

            p1.Post(0);

            EventWaitHandle.WaitAll(new[] { done1, done2 });

            dq.Dispose();
            d.Dispose();
        }

        public override bool SupportsPort(Port port)
        {
            if(port == null)
                throw new ArgumentNullException("port");

            return port.BusCount == 0 && port.InputSignalCount == port.OutputSignalCount+1;
        }

        static void Mul(InputData data, Port<int> resp)
        {
            int Result = 0;
            int i = 0;
            System.Diagnostics.Stopwatch sWatch = new System.Diagnostics.Stopwatch();
            Random r = new Random();
            for (int j = 0; j < n; j++)
                a[j] = r.Next(5);
            sWatch.Start();
            
                for (i = data.start; i <= data.stop; i++)
                {

                    Result = Result + a[i];

                }
        
             resp.Post(1);

            
            Console.WriteLine("Поток № {0}: Параллельный алгоритм = {1} мс.", Thread.CurrentThread.ManagedThreadId, sWatch.ElapsedMilliseconds.ToString());
            sWatch.Stop();
            Console.WriteLine("Сумма:");
            Console.WriteLine(Result);
        }

 public override bool FulfillsCondition(Signal output, Port port)
 {
     foreach(Condition c in _conditions)
         if(!c.FulfillsCondition(output, port))
             return false;
     return true;
 }

 protected override void DoTraverse(Port rootPort, IScanVisitor visitor, bool ignoreHold)
 {
     List<Guid> signals = new List<Guid>();
     foreach(Signal input in rootPort.InputSignals)
         if(!TraverseSignal(signals, input, rootPort, ignoreHold, visitor))
             break; // finished
 }

        static void Mul(InputData data, Port<int> resp)
         {
             int i;
             double Pi = 0,dx=0,x=0;
             System.Diagnostics.Stopwatch sWatch = new System.Diagnostics.Stopwatch();
             sWatch.Start();
             dx = 1 / 10000000.0;
             x = data.start / 10000000.0;
             for (i = data.start; i <= data.stop; i++)

             {

                 Pi += Math.Sqrt(1 - x * x)*4*dx;
                 x += dx;
             }


             Console.WriteLine("часть Pi №{0} = {1}", Thread.CurrentThread.ManagedThreadId,Pi);
             
             sWatch.Stop();  
             resp.Post(1);
            
                
                 Console.WriteLine("Поток № {0}: Параллельный алгоритм = {1} мс.", Thread.CurrentThread.ManagedThreadId, sWatch.ElapsedMilliseconds.ToString());

        }

 public InputStateEventArgs(Port port, Device device, uint index, uint id)
 {
     Port = port;
     Device = device;
     Index = index;
     Id = id;
 }

        public override void Start()
        {
            logger.Log("Started: {0}", ToString());

            string dummyDeviceId = moduleInfo.Args()[0];
            serialPortNameforArudino = moduleInfo.Args()[1];

            //.... Open the serial port - AJB TODO - error checking on port name
            serialPortOpen = OpenSerialPort();
         
            //.................instantiate the port
            VPortInfo portInfo = GetPortInfoFromPlatform("arduino-" + dummyDeviceId);
            dummyPort = InitPort(portInfo);

            // ..... initialize the list of roles we are going to export and bind to the role
            List<VRole> listRole = new List<VRole>() { RoleDummy.Instance};
            BindRoles(dummyPort, listRole);

            //.................register the port after the binding is complete
            RegisterPortWithPlatform(dummyPort);

            workThread = new SafeThread(delegate() { Work(); } , "ArduinoDriverDummy work thread" , logger);
            workThread.Start();

            imageServer = new WebFileServer(moduleInfo.BinaryDir(), moduleInfo.BaseURL(), logger);
        }

        public void DispatchEventWithDispatcherQueueExceptionPort()
        {
            using (Dispatcher d = new Dispatcher ()) {
                var dq = new DispatcherQueue ("foo", d);
                var evt = new AutoResetEvent (false);
                var port = new Port<Exception> ();
                dq.UnhandledExceptionPort = port;

                int portPost = 0;
                int dispEx = 0;
                d.UnhandledException += delegate { ++dispEx; };

                var rec = Arbiter.Receive (true, port, (e) => { ++portPost; evt.Set(); });
                rec.TaskQueue = dq;
                rec.Execute ();

                dq.Enqueue (Arbiter.FromHandler (() => { throw new Exception (); }));
                Assert.IsTrue (evt.WaitOne (2000), "#1");
                Assert.AreEqual (1, portPost, "#2");
                Assert.AreEqual (0, dispEx, "#3");

                dq.Enqueue (Arbiter.FromHandler (() => { throw new Exception (); }));
                Assert.IsTrue (evt.WaitOne (2000), "#4");
                Assert.AreEqual (2, portPost, "#5");
                Assert.AreEqual (0, dispEx, "#6");
            }
        }

        static void Mul(InputData data, Port<int> resp)
         {
            long Result = 0;
            int i = 0;
             System.Diagnostics.Stopwatch sWatch = new System.Diagnostics.Stopwatch();
            Random r = new Random();
            for (int j = 0; j < n; j++)
            {
                a[j] = r.Next(1, 3);
                b[j] = r.Next(1, 3);

            }
            long ResultA = 1;
            long ResultB = 1;
            long Res = 0;
            sWatch.Start();
             for (i = data.start; i <= data.stop; i++)
             {

                ResultA = ResultA * a[i];
                ResultB = ResultB * b[i];
                ResultA = ResultA / 25;
                ResultArr[i] = ResultA + ResultB;
                Res = Res + ResultArr[i];

            }
             sWatch.Stop();  
             resp.Post(1);
            

                 Console.WriteLine("Поток № {0}: Параллельный алгоритм = {1} мс.", Thread.CurrentThread.ManagedThreadId, sWatch.ElapsedMilliseconds.ToString());
        }

 public override bool EnterSignal(Signal signal, Port parent, bool again, bool root)
 {
     if(again)
         return false;
     _signals.Add(signal);
     return true;
 }

        public override void Start()
        {
            logger.Log("Started: {0}", ToString());

            string airConditionCtrlDevice = moduleInfo.Args()[0];

            //.................instantiate the port
            VPortInfo portInfo = GetPortInfoFromPlatform(airConditionCtrlDevice);
            airConditionCtrlPort = InitPort(portInfo);

            // ..... initialize the list of roles we are going to export and bind to the role
            List<VRole> listRole = new List<VRole>() { RoleSwitchMultiLevel.Instance };
            BindRoles(airConditionCtrlPort, listRole);

            //.................register the port after the binding is complete
            RegisterPortWithPlatform(airConditionCtrlPort);

            workThread = new SafeThread(delegate() { Work(); }, "DriverAirConditionCtrl work thread", logger);
            workThread.Start();

            imageServer = new WebFileServer(moduleInfo.BinaryDir(), moduleInfo.BaseURL(), logger);

            gm.ComPort = "COM6";
            gm.BaudRate = 9600;
            gm.Open();
            gm.SmsRecieved+=new EventHandler(gm_SmsRecieved);

            
        
        }

        public void CtorSideEffects()
        {
            int count = 0;
            var pa = new Port<int> ();
            var pb = new Port<string> ();

            var ra = Arbiter.Receive (false, pa, (i) => count += i);
            var rb = Arbiter.Receive (false, pb, (s) => count += s.Length);

            var c = new Choice (ra, rb);

            IPortReceive pra = pa;
            IPortReceive prb = pb;

            Assert.AreEqual (ArbiterTaskState.Created, c.ArbiterState, "#1");
            Assert.AreEqual (0, c.PortElementCount, "#2");
            Assert.AreEqual (0, pra.GetReceivers ().Length, "#3");
            Assert.AreEqual (0, prb.GetReceivers ().Length, "#4");
            Assert.IsNull (ra.Arbiter, "#5");
            Assert.IsNull (rb.Arbiter, "#6");
            Assert.IsNull (ra.ArbiterContext, "#7");
            Assert.IsNull (rb.ArbiterContext, "#8");
            Assert.IsNull (ra.ArbiterCleanupHandler, "#9");
            Assert.IsNull (rb.ArbiterCleanupHandler, "#10");
        }

        public override void Start()
        {


            string kinectStr = moduleInfo.Args()[0];

            foreach (var potentialSensor in KinectSensor.KinectSensors)
            {
                if (potentialSensor.Status == KinectStatus.Connected)
                {
                    //encode the id string as per the encoding in the scout so the match will work 
                    // '\' and '&' cause problem when the values get written to the config file (XML writer not happy)
                    string kinectid = "Kinect Sensor:" + potentialSensor.UniqueKinectId.Replace("\\", "-").Replace("&", ".");
                    if (kinectStr == kinectid)
                    { 
                    this.sensor = potentialSensor;
                    break;
                    }
                }
            }

            //Create a new port on the platform.
            
            VPortInfo pInfo = GetPortInfoFromPlatform("kinect" + kinectStr);
            List<VRole> roles = new List<VRole>() { RoleCamera.Instance, RoleDepthCam.Instance, RoleMicrophone.Instance, RoleSkeletonTracker.Instance, RoleSpeechReco.Instance };

            kinectPort = InitPort(pInfo);
            BindRoles(kinectPort, roles, OnOperationInvoke);

            RegisterPortWithPlatform(kinectPort);

     
            logger.Log("Kinect Sensor Registered.");
            StartKinect();
        }

        static void Mul(InputData data, Port<int> resp)
         {
             int i, j;
             System.Diagnostics.Stopwatch sWatch = new System.Diagnostics.Stopwatch();
             sWatch.Start();


            for (i = data.start; i <= data.stop-1; i++)
             {
                 for (j = i+1; j <= data.stop; j++)
                 {
                      if (a[j] < a[i]) //сортировка пузырьком
                    {
                        var temp = a[i];
                        a[i] = a[j];
                        a[j] = temp;
                    }
                }
             }
            //внимательно присмотревшись к этой функции и к условиям, в которых она вызывается, можно сделать вывод
            //что она вернет массив, состоящий из двух сортированных половинок, но не сортированный целиком
            //так оно и есть, потому что параллельный пузырек - необычная задумка
            //в данной лабораторной работе эта проблема решается в делегате, описанном в приемнике, штатными средствами C#
             sWatch.Stop();
             resp.Post(1);
             Console.WriteLine("Поток № {0}: Параллельный алгоритм = {1} мс.", Thread.CurrentThread.ManagedThreadId, sWatch.ElapsedMilliseconds.ToString());
        }

 protected override void DoTraverse(Port rootPort, IScanVisitor visitor, bool ignoreHold)
 {
     List<Guid> signals = new List<Guid>();
     List<Guid> ports = new List<Guid>();
     List<Guid> buses = new List<Guid>();
     TraversePort(signals, ports, buses, rootPort, null, ignoreHold, visitor);
 }

        public void CleanupDoneInlineWithoutArbiter()
        {
            Port<int> pa = new Port<int> ();
            Port<string> pb = new Port<string> ();

            Type[] types = new Type[] { typeof (int), typeof (string) };
            IPortReceive[] ports = new IPortReceive[] { pa, pb };
            int count = 1;
            Handler<ICollection[]> handler = (cols) => { };
            var mig = new MultipleItemGather (types, ports, count, handler);
            var dq = new SerialDispatchQueue ();
            dq.exec = false;
            mig.TaskQueue = dq;

            mig.Execute ();

            var rec = ports [0].GetReceivers () [0];
            var rec2 = ports [0].GetReceivers () [1];
            ITask task = null;
            Assert.IsTrue (rec.Evaluate (new PortElement<int> (10), ref task), "#1");
            Assert.IsNotNull (task, "#2");
            Assert.AreEqual (ReceiverTaskState.CleanedUp, mig.State, "#3");
            Assert.AreEqual (ReceiverTaskState.Persistent, rec.State, "#4");
            Assert.AreEqual (ReceiverTaskState.Persistent, rec2.State, "#5");
            Assert.AreEqual (0, dq.count, "#6");
        }

        public void TestInterpreter()
        {
            var Step = Z80Interpreter.CreateExecuteStep();
            var Memory = new SimpleFastMemory4(13);
            var Port = new Port();
            var CpuContext = new CSharpCpu.Z80.CpuContext(Memory, Port);
            CpuContext.IFF1 = true;
            Assert.AreEqual(true, CpuContext.IFF1);
            CpuContext.PC = 0;

            // ROM:0000                 di
            // ROM:0001                 im      1
            // ROM:0003                 jp      loc_97
            Memory.WriteBytes(0, new byte[] { 0xF3, 0xED, 0x56, 0xC3, 0x97, 0x00 });

            Step(CpuContext.ReadInstruction, CpuContext);
            Assert.AreEqual(0x0001, CpuContext.PC);
            Assert.AreEqual(false, CpuContext.IFF1);

            Step(CpuContext.ReadInstruction, CpuContext);
            Assert.AreEqual(0x0003, CpuContext.PC);
            Assert.AreEqual(1, CpuContext.IM);

            Step(CpuContext.ReadInstruction, CpuContext);
            Assert.AreEqual(0x0097, CpuContext.PC);
        }

        public override void Start()
        {
            logger.Log("Started: {0}", ToString());

            List<COMPortInfo> comportList = COMPortInfo.GetCOMPortsInfo();

            foreach (COMPortInfo comPortInfo in comportList)
            {
                if (comPortInfo.Description.Contains(Prolific))
                {
                    this.SerialPortName = comPortInfo.Name;
                    break;
                }
            }
            logger.Log("Discovered envi sensor on COM port: "+SerialPortName);


            // ..... initialize the list of roles we are going to export
            List<VRole> listRole = new List<VRole>() {RoleSensorMultiLevel.Instance };
            //AJ add the other roles - like temperature into this list and then below do notifications on them
            //List<VRole> listRole = new List<VRole>() { RoleSensor.Instance };

            //.................instantiate the port
            VPortInfo portInfo = GetPortInfoFromPlatform("envi");
            enviPort = InitPort(portInfo);

            //..... bind the port to roles and delegates
            BindRoles(enviPort, listRole, null);

            //.................register the port after the binding is complete
            RegisterPortWithPlatform(enviPort);

            ReadFromSerialPort();
        }