From 809358b341ff73c2d0b3f82fa4c6d02dc70b0717 Mon Sep 17 00:00:00 2001
From: Vasily Davydov <vasilydavydovmail@yahoo.com>
Date: Wed, 26 Apr 2023 16:54:50 +0300
Subject: [PATCH 1/5] rotary: init task [#9]

---
 source/shoh/.cproject                         | 51 ++++++++++---------
 source/shoh/src/main.cpp                      | 16 +++---
 source/shoh/src/threads/common/ThreadCommon.h |  7 +++
 source/shoh/src/threads/master/Master.cpp     |  2 +-
 source/shoh/src/threads/rotary/Rotary.cpp     | 26 ++++++++++
 source/shoh/src/threads/rotary/Rotary.h       | 26 ++++++++++
 6 files changed, 92 insertions(+), 36 deletions(-)
 create mode 100644 source/shoh/src/threads/rotary/Rotary.cpp
 create mode 100644 source/shoh/src/threads/rotary/Rotary.h

diff --git a/source/shoh/.cproject b/source/shoh/.cproject
index aa180f6..c20b11d 100644
--- a/source/shoh/.cproject
+++ b/source/shoh/.cproject
@@ -50,6 +50,7 @@
 									<listOptionValue builtIn="false" value="&quot;${workspace_loc:/shoh/src/threads}&quot;"/>
 									<listOptionValue builtIn="false" value="&quot;${workspace_loc:/shoh/src/threads/common}&quot;"/>
 									<listOptionValue builtIn="false" value="&quot;${workspace_loc:/shoh/src/threads/master}&quot;"/>
+									<listOptionValue builtIn="false" value="&quot;${workspace_loc:/${ProjName}/src/threads/rotary}&quot;"/>
 									<listOptionValue builtIn="false" value="&quot;${workspace_loc:/shoh/src/peripherals}&quot;"/>
 								</option>
 								<option id="com.crt.advproject.cpp.misc.dialect.4036734" name="Language standard" superClass="com.crt.advproject.cpp.misc.dialect" useByScannerDiscovery="true" value="com.crt.advproject.misc.dialect.cpp17" valueType="enumerated"/>
@@ -303,31 +304,31 @@
 	</storageModule>
 	<storageModule moduleId="org.eclipse.cdt.core.LanguageSettingsProviders"/>
 	<storageModule moduleId="com.crt.config">
-		<projectStorage>&lt;?xml version="1.0" encoding="UTF-8"?&gt;&#13;
-&lt;TargetConfig&gt;&#13;
-&lt;Properties property_2="LPC11U6x_256K.cfx" property_3="NXP" property_4="LPC11U68" property_count="5" version="100300"/&gt;&#13;
-&lt;infoList vendor="NXP"&gt;&#13;
-&lt;info chip="LPC11U68" flash_driver="LPC11U6x_256K.cfx" match_id="0x0" name="LPC11U68" stub="crt_emu_cm3_gen"&gt;&#13;
-&lt;chip&gt;&#13;
-&lt;name&gt;LPC11U68&lt;/name&gt;&#13;
-&lt;family&gt;LPC11U6x&lt;/family&gt;&#13;
-&lt;vendor&gt;NXP (formerly Philips)&lt;/vendor&gt;&#13;
-&lt;reset board="None" core="Real" sys="Real"/&gt;&#13;
-&lt;clock changeable="TRUE" freq="12MHz" is_accurate="TRUE"/&gt;&#13;
-&lt;memory can_program="true" id="Flash" is_ro="true" type="Flash"/&gt;&#13;
-&lt;memory id="RAM" type="RAM"/&gt;&#13;
-&lt;memory id="Periph" is_volatile="true" type="Peripheral"/&gt;&#13;
-&lt;memoryInstance derived_from="Flash" id="MFlash256" location="0x0" size="0x40000"/&gt;&#13;
-&lt;memoryInstance derived_from="RAM" id="Ram0_32" location="0x10000000" size="0x8000"/&gt;&#13;
-&lt;memoryInstance derived_from="RAM" id="Ram1_2" location="0x20000000" size="0x800"/&gt;&#13;
-&lt;memoryInstance derived_from="RAM" id="Ram2USB_2" location="0x20004000" size="0x800"/&gt;&#13;
-&lt;/chip&gt;&#13;
-&lt;processor&gt;&#13;
-&lt;name gcc_name="cortex-m0"&gt;Cortex-M0&lt;/name&gt;&#13;
-&lt;family&gt;Cortex-M&lt;/family&gt;&#13;
-&lt;/processor&gt;&#13;
-&lt;/info&gt;&#13;
-&lt;/infoList&gt;&#13;
+		<projectStorage>&lt;?xml version="1.0" encoding="UTF-8"?&gt;
+&lt;TargetConfig&gt;
+&lt;Properties property_2="LPC11U6x_256K.cfx" property_3="NXP" property_4="LPC11U68" property_count="5" version="100300"/&gt;
+&lt;infoList vendor="NXP"&gt;
+&lt;info chip="LPC11U68" flash_driver="LPC11U6x_256K.cfx" match_id="0x0" name="LPC11U68" stub="crt_emu_cm3_gen"&gt;
+&lt;chip&gt;
+&lt;name&gt;LPC11U68&lt;/name&gt;
+&lt;family&gt;LPC11U6x&lt;/family&gt;
+&lt;vendor&gt;NXP (formerly Philips)&lt;/vendor&gt;
+&lt;reset board="None" core="Real" sys="Real"/&gt;
+&lt;clock changeable="TRUE" freq="12MHz" is_accurate="TRUE"/&gt;
+&lt;memory can_program="true" id="Flash" is_ro="true" type="Flash"/&gt;
+&lt;memory id="RAM" type="RAM"/&gt;
+&lt;memory id="Periph" is_volatile="true" type="Peripheral"/&gt;
+&lt;memoryInstance derived_from="Flash" id="MFlash256" location="0x0" size="0x40000"/&gt;
+&lt;memoryInstance derived_from="RAM" id="Ram0_32" location="0x10000000" size="0x8000"/&gt;
+&lt;memoryInstance derived_from="RAM" id="Ram1_2" location="0x20000000" size="0x800"/&gt;
+&lt;memoryInstance derived_from="RAM" id="Ram2USB_2" location="0x20004000" size="0x800"/&gt;
+&lt;/chip&gt;
+&lt;processor&gt;
+&lt;name gcc_name="cortex-m0"&gt;Cortex-M0&lt;/name&gt;
+&lt;family&gt;Cortex-M&lt;/family&gt;
+&lt;/processor&gt;
+&lt;/info&gt;
+&lt;/infoList&gt;
 &lt;/TargetConfig&gt;</projectStorage>
 	</storageModule>
 	<storageModule moduleId="com.crt.advproject">
diff --git a/source/shoh/src/main.cpp b/source/shoh/src/main.cpp
index bf1f949..91d24cd 100644
--- a/source/shoh/src/main.cpp
+++ b/source/shoh/src/main.cpp
@@ -5,6 +5,7 @@
 #include <cr_section_macros.h>
 #include "ThreadCommon.h"
 #include "Master.h"
+#include "Rotary.h"
 
 
 int main(void)
@@ -17,20 +18,15 @@ int main(void)
   qmanager->createQueue(100,
                         sizeof(Event),
                         ThreadCommon::QueueManager::master_event_all);
-
   //Creating tasks
   manager->createTask(master_thread, "master",
-                     configMINIMAL_STACK_SIZE * 10,tskIDLE_PRIORITY + 1UL,
-                     static_cast<void*>(qmanager));
+                      configMINIMAL_STACK_SIZE * 10,tskIDLE_PRIORITY + 1UL,
+                      static_cast<void*>(qmanager));
+  manager->createTask(rotary_thread, "rotary",
+                      configMINIMAL_STACK_SIZE * 10,tskIDLE_PRIORITY + 1UL,
+                      static_cast<void*>(qmanager));
   
-  //<Queue_test>
-  Event* e = new Event(Event::Rotary, 1);
-
-  qmanager->send<Event>(ThreadCommon::QueueManager::master_event_all, e, 1000);
-  //</Queue_test>
-
   // Start the real time kernel with preemption.
-  //FreeRTOS::Kernel::startScheduler();
   vTaskStartScheduler ();
 
   return 1;
diff --git a/source/shoh/src/threads/common/ThreadCommon.h b/source/shoh/src/threads/common/ThreadCommon.h
index 73a5b72..2e6040b 100644
--- a/source/shoh/src/threads/common/ThreadCommon.h
+++ b/source/shoh/src/threads/common/ThreadCommon.h
@@ -18,6 +18,13 @@
 
 namespace ThreadCommon
 {
+    enum RotaryAction 
+	{
+		Right,
+		Left,
+		Press,
+		Idle
+	};
     class ThreadManager
     {
         public:
diff --git a/source/shoh/src/threads/master/Master.cpp b/source/shoh/src/threads/master/Master.cpp
index 34f86d9..e761e1e 100644
--- a/source/shoh/src/threads/master/Master.cpp
+++ b/source/shoh/src/threads/master/Master.cpp
@@ -18,7 +18,7 @@ void Master::taskFunction() {
 	bool LedState = true;
 	for (;;) {
 		_qm->receive<Event>(ThreadCommon::QueueManager::master_event_all, &data, portMAX_DELAY);
-		if(data.getDataOf(Event::Rotary) == 1){
+		if(data.getDataOf(Event::Rotary) == ThreadCommon::RotaryAction::Idle){
 			Board_LED_Set(led, LedState);
 		}
 	}
diff --git a/source/shoh/src/threads/rotary/Rotary.cpp b/source/shoh/src/threads/rotary/Rotary.cpp
new file mode 100644
index 0000000..9d5e952
--- /dev/null
+++ b/source/shoh/src/threads/rotary/Rotary.cpp
@@ -0,0 +1,26 @@
+/*
+ * Rotary.cpp
+ *
+ *  Created on: 26 Apr 2023
+ *      Author: tylen
+ */
+
+#include "Rotary.h"
+
+Rotary::Rotary(ThreadCommon::QueueManager* qm) : _qm(qm) {}
+
+Rotary::~Rotary() {}
+
+void Rotary::taskFunction()
+{
+Event data(Event::Null, 0);
+	Event* e = new Event(Event::Rotary, ThreadCommon::RotaryAction::Idle);
+	_qm->send<Event>(ThreadCommon::QueueManager::master_event_all, e, 10);
+	for (;;) {}
+}
+
+void rotary_thread(void* pvParams)
+{
+	Rotary r(static_cast<ThreadCommon::QueueManager*>(pvParams));
+	r.taskFunction();
+}
diff --git a/source/shoh/src/threads/rotary/Rotary.h b/source/shoh/src/threads/rotary/Rotary.h
new file mode 100644
index 0000000..4c97f41
--- /dev/null
+++ b/source/shoh/src/threads/rotary/Rotary.h
@@ -0,0 +1,26 @@
+/*
+ * Rotary.h
+ *
+ *  Created on: 26 Apr 2023
+ *      Author: tylen
+ */
+
+#ifndef THREADS_ROTARY_ROTARY_H_
+#define THREADS_ROTARY_ROTARY_H_
+
+#include "Event.h"
+#include "ThreadCommon.h"
+
+class Rotary {
+public:
+	Rotary(ThreadCommon::QueueManager* qm);
+	virtual ~Rotary();
+	void taskFunction();
+private:
+	Event* message;
+	ThreadCommon::QueueManager* _qm;
+};
+
+void rotary_thread(void* pvParams);
+
+#endif /* THREADS_ROTARY_ROTARY_H_ */

From a57f814875d32261597cf308341a8c734ff35bfb Mon Sep 17 00:00:00 2001
From: Vasily Davydov <vasilydavydovmail@yahoo.com>
Date: Wed, 26 Apr 2023 18:19:42 +0300
Subject: [PATCH 2/5] digitalio: add interrupt support and append to rotary

---
 source/shoh/src/peripherals/DigitalIoPin.cpp | 55 +++++++++++++++++++-
 source/shoh/src/peripherals/DigitalIoPin.h   |  4 +-
 source/shoh/src/threads/rotary/Rotary.cpp    | 30 ++++++++++-
 source/shoh/src/threads/rotary/Rotary.h      |  4 ++
 4 files changed, 89 insertions(+), 4 deletions(-)

diff --git a/source/shoh/src/peripherals/DigitalIoPin.cpp b/source/shoh/src/peripherals/DigitalIoPin.cpp
index 8255644..b56c1e0 100644
--- a/source/shoh/src/peripherals/DigitalIoPin.cpp
+++ b/source/shoh/src/peripherals/DigitalIoPin.cpp
@@ -8,7 +8,7 @@
 #include "DigitalIoPin.h"
 
 DigitalIoPin::DigitalIoPin (int port, int pin, bool input, bool pullup,
-                            bool invert)
+                            bool invert, bool isr, IRQn_Type isr_index)
 {
   assert ((port <= UINT8_MAX_VALUE) && (pin <= UINT8_MAX_VALUE));
   _io._port = (uint8_t)port;
@@ -18,7 +18,12 @@ DigitalIoPin::DigitalIoPin (int port, int pin, bool input, bool pullup,
   _io._invert = invert;
   _io.IOCON_mode = IOCON_MODE_INACT;
   _io.IOCON_inv = IOCON_FUNC0;
-  setIoPin ();
+  if (isr){
+    _io.isr_i = isr_index;
+    setIsr();
+  } else {
+    setIoPin ();
+  }
 }
 
 DigitalIoPin::~DigitalIoPin ()
@@ -48,6 +53,52 @@ DigitalIoPin::setIoPin ()
   Chip_GPIO_SetPinDIR (LPC_GPIO, _io._port, _io._pin, direction);
 }
 
+void
+DigitalIoPin::setIsr ()
+{
+  bool direction = true;
+  if (_io._input)
+    {
+      direction = false;
+      _io.IOCON_mode = IOCON_MODE_PULLUP;
+      if (!_io._pullup)
+        {
+          _io.IOCON_mode = IOCON_MODE_PULLDOWN;
+        }
+      if (_io._invert)
+        {
+          _io.IOCON_inv = IOCON_INV_EN;
+        }
+    }
+	/* We'll use an optional IOCON filter (0) with a divider of 64 for the
+	   input pin to be used for PININT */
+	Chip_Clock_SetIOCONFiltClockDiv(0, 64);
+
+  Chip_IOCON_PinMuxSet (LPC_IOCON, _io._port, _io._pin,
+                        (_io.IOCON_mode | _io.DigitalEn 
+                        | _io.IOCON_inv | IOCON_CLKDIV(0) 
+                        | IOCON_S_MODE(3)));
+  /**	False direction equals input */
+  Chip_GPIO_SetPinDIR (LPC_GPIO, _io._port, _io._pin, direction);
+
+  /* Enable PININT clock if it was not enabled before */
+  if ((LPC_SYSCTL->SYSAHBCLKCTRL & (1 << SYSCTL_CLOCK_PINT)) == 0)
+  {
+    Chip_Clock_EnablePeriphClock(SYSCTL_CLOCK_PINT);
+  }
+  /* Configure interrupt channel for the GPIO pin in SysCon block */
+	Chip_SYSCTL_SetPinInterrupt(_io.isr_i, _io._port, _io._pin);
+
+	/* Configure channel interrupt as edge sensitive and falling edge interrupt */
+	Chip_PININT_ClearIntStatus(LPC_PININT, PININTCH(_io.isr_i));
+	Chip_PININT_SetPinModeEdge(LPC_PININT, PININTCH(_io.isr_i));
+	Chip_PININT_EnableIntLow(LPC_PININT, PININTCH(_io.isr_i));
+
+	/* Enable interrupt in the NVIC */
+	NVIC_ClearPendingIRQ(_io.isr_i);
+	NVIC_EnableIRQ(_io.isr_i);
+}
+
 bool
 DigitalIoPin::read ()
 {
diff --git a/source/shoh/src/peripherals/DigitalIoPin.h b/source/shoh/src/peripherals/DigitalIoPin.h
index de004af..19c6c7b 100644
--- a/source/shoh/src/peripherals/DigitalIoPin.h
+++ b/source/shoh/src/peripherals/DigitalIoPin.h
@@ -23,13 +23,14 @@ typedef struct DigitalIOConfigStruct
   uint32_t IOCON_mode;
   uint32_t IOCON_inv;
   uint32_t DigitalEn;
+  IRQn_Type isr_i;
 } DigitalIOConfigStruct;
 
 class DigitalIoPin
 {
 public:
   DigitalIoPin (int port, int pin, bool input = true, bool pullup = true,
-                bool invert = false);
+                bool invert = false, bool isr = false, IRQn_Type isr_index = PIN_INT0_IRQn);
   DigitalIoPin (const DigitalIoPin &) = delete;
   virtual ~DigitalIoPin ();
   bool read ();
@@ -38,6 +39,7 @@ public:
 private:
   DigitalIOConfigStruct _io = { 0, 0, false, false, false, 0, 0, IOCON_DIGMODE_EN};
   void setIoPin ();
+  void setIsr();
 };
 
 #endif /* DIGITALIOPIN_H_ */
diff --git a/source/shoh/src/threads/rotary/Rotary.cpp b/source/shoh/src/threads/rotary/Rotary.cpp
index 9d5e952..9e5d12b 100644
--- a/source/shoh/src/threads/rotary/Rotary.cpp
+++ b/source/shoh/src/threads/rotary/Rotary.cpp
@@ -6,8 +6,36 @@
  */
 
 #include "Rotary.h"
+#include "board.h"
 
-Rotary::Rotary(ThreadCommon::QueueManager* qm) : _qm(qm) {}
+extern "C" 
+{
+  void
+  PIN_INT0_IRQHandler (void)
+  {
+    //portEND_SWITCHING_ISR ();
+  }
+
+  void
+  PIN_INT1_IRQHandler (void)
+  {
+    //portEND_SWITCHING_ISR ();
+  }
+
+  void
+  PIN_INT2_IRQHandler (void)
+  {
+    //portEND_SWITCHING_ISR ();
+  }
+}
+// For example
+#define GPIO_PININT_PIN     1	/* GPIO pin number mapped to PININT */
+#define GPIO_PININT_PORT    0 /* GPIO port number mapped to PININT */
+
+Rotary::Rotary(ThreadCommon::QueueManager* qm) : _qm(qm) 
+{
+
+}
 
 Rotary::~Rotary() {}
 
diff --git a/source/shoh/src/threads/rotary/Rotary.h b/source/shoh/src/threads/rotary/Rotary.h
index 4c97f41..d67bd4a 100644
--- a/source/shoh/src/threads/rotary/Rotary.h
+++ b/source/shoh/src/threads/rotary/Rotary.h
@@ -10,6 +10,7 @@
 
 #include "Event.h"
 #include "ThreadCommon.h"
+#include "DigitalIoPin.h"
 
 class Rotary {
 public:
@@ -19,6 +20,9 @@ public:
 private:
 	Event* message;
 	ThreadCommon::QueueManager* _qm;
+	DigitalIoPin signal[3] = { { 0, 6, true, false, false, true, PIN_INT0_IRQn},
+                               { 0, 5, true, false, false, true, PIN_INT1_IRQn},
+                               { 1, 8, true, false, false, true, PIN_INT2_IRQn} };
 };
 
 void rotary_thread(void* pvParams);

From da50fa4de121e07225b9512c20b6ae002db9e9bf Mon Sep 17 00:00:00 2001
From: Vasily Davydov <vasilydavydovmail@yahoo.com>
Date: Thu, 27 Apr 2023 00:47:32 +0300
Subject: [PATCH 3/5] rotary:[#9] enable interrupts on three pins

---
 source/shoh/src/peripherals/DigitalIoPin.cpp |  8 ++++----
 source/shoh/src/threads/rotary/Rotary.cpp    | 14 +++++++-------
 source/shoh/src/threads/rotary/Rotary.h      |  2 +-
 3 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/source/shoh/src/peripherals/DigitalIoPin.cpp b/source/shoh/src/peripherals/DigitalIoPin.cpp
index b56c1e0..51d4021 100644
--- a/source/shoh/src/peripherals/DigitalIoPin.cpp
+++ b/source/shoh/src/peripherals/DigitalIoPin.cpp
@@ -75,16 +75,16 @@ DigitalIoPin::setIsr ()
 	Chip_Clock_SetIOCONFiltClockDiv(0, 64);
 
   Chip_IOCON_PinMuxSet (LPC_IOCON, _io._port, _io._pin,
-                        (_io.IOCON_mode | _io.DigitalEn 
-                        | _io.IOCON_inv | IOCON_CLKDIV(0) 
-                        | IOCON_S_MODE(3)));
+						(_io.IOCON_mode | _io.DigitalEn
+						| _io.IOCON_inv | IOCON_CLKDIV(0)
+						| IOCON_S_MODE(3)));
   /**	False direction equals input */
   Chip_GPIO_SetPinDIR (LPC_GPIO, _io._port, _io._pin, direction);
 
   /* Enable PININT clock if it was not enabled before */
   if ((LPC_SYSCTL->SYSAHBCLKCTRL & (1 << SYSCTL_CLOCK_PINT)) == 0)
   {
-    Chip_Clock_EnablePeriphClock(SYSCTL_CLOCK_PINT);
+	Chip_Clock_EnablePeriphClock(SYSCTL_CLOCK_PINT);
   }
   /* Configure interrupt channel for the GPIO pin in SysCon block */
 	Chip_SYSCTL_SetPinInterrupt(_io.isr_i, _io._port, _io._pin);
diff --git a/source/shoh/src/threads/rotary/Rotary.cpp b/source/shoh/src/threads/rotary/Rotary.cpp
index 9e5d12b..f35cbd9 100644
--- a/source/shoh/src/threads/rotary/Rotary.cpp
+++ b/source/shoh/src/threads/rotary/Rotary.cpp
@@ -13,24 +13,21 @@ extern "C"
   void
   PIN_INT0_IRQHandler (void)
   {
-    //portEND_SWITCHING_ISR ();
+	Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT0_IRQn));
   }
 
   void
   PIN_INT1_IRQHandler (void)
   {
-    //portEND_SWITCHING_ISR ();
+    Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT1_IRQn));
   }
 
   void
   PIN_INT2_IRQHandler (void)
   {
-    //portEND_SWITCHING_ISR ();
+    Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT2_IRQn));
   }
 }
-// For example
-#define GPIO_PININT_PIN     1	/* GPIO pin number mapped to PININT */
-#define GPIO_PININT_PORT    0 /* GPIO port number mapped to PININT */
 
 Rotary::Rotary(ThreadCommon::QueueManager* qm) : _qm(qm) 
 {
@@ -44,7 +41,10 @@ void Rotary::taskFunction()
 Event data(Event::Null, 0);
 	Event* e = new Event(Event::Rotary, ThreadCommon::RotaryAction::Idle);
 	_qm->send<Event>(ThreadCommon::QueueManager::master_event_all, e, 10);
-	for (;;) {}
+	for (;;)
+	{
+		vTaskDelay(500);
+	}
 }
 
 void rotary_thread(void* pvParams)
diff --git a/source/shoh/src/threads/rotary/Rotary.h b/source/shoh/src/threads/rotary/Rotary.h
index d67bd4a..b47e38c 100644
--- a/source/shoh/src/threads/rotary/Rotary.h
+++ b/source/shoh/src/threads/rotary/Rotary.h
@@ -20,7 +20,7 @@ public:
 private:
 	Event* message;
 	ThreadCommon::QueueManager* _qm;
-	DigitalIoPin signal[3] = { { 0, 6, true, false, false, true, PIN_INT0_IRQn},
+	DigitalIoPin signal[3] = { { 0, 1, true, true, false, true, PIN_INT0_IRQn},
                                { 0, 5, true, false, false, true, PIN_INT1_IRQn},
                                { 1, 8, true, false, false, true, PIN_INT2_IRQn} };
 };

From 2ed0653056a2c22680a07d987573142c09c218bb Mon Sep 17 00:00:00 2001
From: Vasily Davydov <vasilydavydovmail@yahoo.com>
Date: Thu, 27 Apr 2023 01:44:17 +0300
Subject: [PATCH 4/5] rotary:[#9] process interrupts and send to master

---
 source/shoh/src/threads/common/Event.h    |  5 ++++
 source/shoh/src/threads/master/Master.cpp | 17 ++++++++++--
 source/shoh/src/threads/rotary/Rotary.cpp | 34 ++++++++++++++++++++---
 source/shoh/src/threads/rotary/Rotary.h   |  4 +--
 4 files changed, 52 insertions(+), 8 deletions(-)

diff --git a/source/shoh/src/threads/common/Event.h b/source/shoh/src/threads/common/Event.h
index 30c9dea..5577b00 100644
--- a/source/shoh/src/threads/common/Event.h
+++ b/source/shoh/src/threads/common/Event.h
@@ -47,6 +47,11 @@ public:
         return pos->second;
     }
 
+    void inline setDataOf(Event::EventType e, EventRawData data)
+    {
+        events[e] = data;
+    }
+
 private:
     std::map <Event::EventType, EventRawData> events;
 };
diff --git a/source/shoh/src/threads/master/Master.cpp b/source/shoh/src/threads/master/Master.cpp
index e761e1e..70c46bf 100644
--- a/source/shoh/src/threads/master/Master.cpp
+++ b/source/shoh/src/threads/master/Master.cpp
@@ -18,9 +18,22 @@ void Master::taskFunction() {
 	bool LedState = true;
 	for (;;) {
 		_qm->receive<Event>(ThreadCommon::QueueManager::master_event_all, &data, portMAX_DELAY);
-		if(data.getDataOf(Event::Rotary) == ThreadCommon::RotaryAction::Idle){
-			Board_LED_Set(led, LedState);
+		switch(data.getDataOf(Event::Rotary))
+		{
+			case ThreadCommon::RotaryAction::Right:
+				Board_LED_Set(ThreadCommon::RotaryAction::Right, LedState);
+				break;
+			case ThreadCommon::RotaryAction::Left:
+				Board_LED_Set(ThreadCommon::RotaryAction::Left, LedState);
+				break;
+			case ThreadCommon::RotaryAction::Press:
+				Board_LED_Set(ThreadCommon::RotaryAction::Press, LedState);
+				break;
+			case ThreadCommon::RotaryAction::Idle:
+				Board_LED_Set(ThreadCommon::RotaryAction::Right, LedState);
+				break;
 		}
+		LedState = !LedState;
 	}
 }
 
diff --git a/source/shoh/src/threads/rotary/Rotary.cpp b/source/shoh/src/threads/rotary/Rotary.cpp
index f35cbd9..be7e78c 100644
--- a/source/shoh/src/threads/rotary/Rotary.cpp
+++ b/source/shoh/src/threads/rotary/Rotary.cpp
@@ -7,6 +7,9 @@
 
 #include "Rotary.h"
 #include "board.h"
+#include "queue.h"
+
+static QueueHandle_t * p_rotary_isr_q;
 
 extern "C" 
 {
@@ -14,18 +17,30 @@ extern "C"
   PIN_INT0_IRQHandler (void)
   {
 	Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT0_IRQn));
+	portBASE_TYPE xHigherPriorityWoken = pdFALSE;
+	uint8_t data = ThreadCommon::RotaryAction::Right;
+	xQueueSendFromISR (*p_rotary_isr_q, &data,  &xHigherPriorityWoken);
+	portEND_SWITCHING_ISR(xHigherPriorityWoken);
   }
 
   void
   PIN_INT1_IRQHandler (void)
   {
     Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT1_IRQn));
+	portBASE_TYPE xHigherPriorityWoken = pdFALSE;
+	uint8_t data = ThreadCommon::RotaryAction::Left;
+	xQueueSendFromISR (*p_rotary_isr_q, &data,  &xHigherPriorityWoken);
+	portEND_SWITCHING_ISR(xHigherPriorityWoken);
   }
 
   void
   PIN_INT2_IRQHandler (void)
   {
     Chip_PININT_ClearIntStatus (LPC_PININT, PININTCH (PIN_INT2_IRQn));
+	portBASE_TYPE xHigherPriorityWoken = pdFALSE;
+	uint8_t data = ThreadCommon::RotaryAction::Press;
+	xQueueSendFromISR (*p_rotary_isr_q, &data,  &xHigherPriorityWoken);
+	portEND_SWITCHING_ISR(xHigherPriorityWoken);
   }
 }
 
@@ -38,17 +53,28 @@ Rotary::~Rotary() {}
 
 void Rotary::taskFunction()
 {
-Event data(Event::Null, 0);
-	Event* e = new Event(Event::Rotary, ThreadCommon::RotaryAction::Idle);
-	_qm->send<Event>(ThreadCommon::QueueManager::master_event_all, e, 10);
+	auto action_from_rotary_isr = ThreadCommon::RotaryAction::Idle;
+	Event * p_e= new Event(Event::EventType::Rotary, action_from_rotary_isr);
+	
 	for (;;)
 	{
-		vTaskDelay(500);
+		xQueueReceive(*p_rotary_isr_q, &action_from_rotary_isr, portMAX_DELAY);
+		p_e->setDataOf(Event::EventType::Rotary, action_from_rotary_isr);
+		_qm->send<Event>(ThreadCommon::QueueManager::master_event_all, p_e, 10);
 	}
 }
 
 void rotary_thread(void* pvParams)
 {
+	// Special case for ISR
+	QueueHandle_t rotary_isr_q = xQueueCreate(15, sizeof(char));
+	p_rotary_isr_q = &rotary_isr_q;
+
 	Rotary r(static_cast<ThreadCommon::QueueManager*>(pvParams));
 	r.taskFunction();
 }
+
+static inline void sendActionAndAssertQueue (uint8_t *data, BaseType_t *const pxHPW)
+{
+
+}
diff --git a/source/shoh/src/threads/rotary/Rotary.h b/source/shoh/src/threads/rotary/Rotary.h
index b47e38c..56fdf17 100644
--- a/source/shoh/src/threads/rotary/Rotary.h
+++ b/source/shoh/src/threads/rotary/Rotary.h
@@ -20,8 +20,8 @@ public:
 private:
 	Event* message;
 	ThreadCommon::QueueManager* _qm;
-	DigitalIoPin signal[3] = { { 0, 1, true, true, false, true, PIN_INT0_IRQn},
-                               { 0, 5, true, false, false, true, PIN_INT1_IRQn},
+	DigitalIoPin signal[3] = { { 0, 1, true, true, false, true, PIN_INT0_IRQn}, //SW1
+                               { 0, 16, true, true, false, true, PIN_INT1_IRQn}, //SW2
                                { 1, 8, true, false, false, true, PIN_INT2_IRQn} };
 };
 

From 0c04ccf2e0a2ae23764cab9eb5077afc377967bb Mon Sep 17 00:00:00 2001
From: RedHawk <tadshig@gmail.com>
Date: Thu, 27 Apr 2023 02:08:24 +0300
Subject: [PATCH 5/5] rotary:[#9] small cleanup.

---
 source/shoh/src/threads/master/Master.cpp | 1 -
 source/shoh/src/threads/master/Master.h   | 2 --
 source/shoh/src/threads/rotary/Rotary.cpp | 5 -----
 3 files changed, 8 deletions(-)

diff --git a/source/shoh/src/threads/master/Master.cpp b/source/shoh/src/threads/master/Master.cpp
index 70c46bf..2a7e094 100644
--- a/source/shoh/src/threads/master/Master.cpp
+++ b/source/shoh/src/threads/master/Master.cpp
@@ -14,7 +14,6 @@ Master::Master(ThreadCommon::QueueManager* qm) : _qm(qm)
 
 void Master::taskFunction() {
 	Event data(Event::Null, 0);
-	int led = 0;
 	bool LedState = true;
 	for (;;) {
 		_qm->receive<Event>(ThreadCommon::QueueManager::master_event_all, &data, portMAX_DELAY);
diff --git a/source/shoh/src/threads/master/Master.h b/source/shoh/src/threads/master/Master.h
index aa59969..e5dceae 100644
--- a/source/shoh/src/threads/master/Master.h
+++ b/source/shoh/src/threads/master/Master.h
@@ -21,8 +21,6 @@ public:
 	virtual ~Master() = default;
 	void taskFunction();
 
-	//Master(Master&&) noexcept = default;
-	//Master& operator=(Master&&) noexcept = default;
 private:
 	Event* message;
 	ThreadCommon::QueueManager* _qm;
diff --git a/source/shoh/src/threads/rotary/Rotary.cpp b/source/shoh/src/threads/rotary/Rotary.cpp
index be7e78c..da1d8ed 100644
--- a/source/shoh/src/threads/rotary/Rotary.cpp
+++ b/source/shoh/src/threads/rotary/Rotary.cpp
@@ -73,8 +73,3 @@ void rotary_thread(void* pvParams)
 	Rotary r(static_cast<ThreadCommon::QueueManager*>(pvParams));
 	r.taskFunction();
 }
-
-static inline void sendActionAndAssertQueue (uint8_t *data, BaseType_t *const pxHPW)
-{
-
-}