[2.0.0] Adds the setRXInterrupt #4656
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,77 @@ | ||
| /** Tim Koers - 2021 | ||
| * | ||
| * This sketch shows the usage of a semaphore to receive Serial data. | ||
| * You can safely use this in a FreeRTOS environment and use the semaphore from different tasks on different CPU cores. | ||
| * However, the InterruptQueue example is much more efficient, since it uses less code. | ||
| * This sketch assumes that when Hi is sent, the device returns an 8 byte message. | ||
| * | ||
| */ | ||
|
|
||
| #define BUFFER_SIZE 8 | ||
|
|
||
| // This semaphore is here to handle the interruption of the loop when the interrupt is running. | ||
| SemaphoreHandle_t bufferSemaphore; | ||
|
|
||
| static volatile char inputBuffer[BUFFER_SIZE]; | ||
| static volatile size_t inputBufferLength = 0; | ||
|
|
||
| bool messageSent = false; | ||
|
|
||
| // Please keep in mind, since the ESP32 is dual core, | ||
| // the interrupt will be running on the same core as the setRxInterrupt function was called on. | ||
| static void IRAM_ATTR onSerialRX(uint8_t character, void* user_arg){ | ||
|
|
||
timkoers marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| // Cast the user_arg back to a array | ||
| char* buffer = (char*)user_arg; | ||
|
|
||
| BaseType_t xHighPriorityTaskWoken; | ||
|
|
||
| if(xSemaphoreTakeFromISR(bufferSemaphore, &xHighPriorityTaskWoken) == pdTRUE){ | ||
| if(inputBufferLength < BUFFER_SIZE){ | ||
| buffer[inputBufferLength++] = (char)character; | ||
| } | ||
| xSemaphoreGiveFromISR(bufferSemaphore, &xHighPriorityTaskWoken); | ||
| } | ||
| } | ||
|
|
||
| void setup() | ||
| { | ||
| bufferSemaphore = xSemaphoreCreateBinary(); | ||
|
|
||
| Serial.begin(115200); | ||
| Serial2.begin(115200); | ||
|
|
||
| // The user_arg is expected to be a void pointer (void*), | ||
| // so take the reference of the variable, and it to a void* | ||
| Serial2.setRxInterrupt(onSerialRX, (void*)&inputBuffer); | ||
| } | ||
|
|
||
| void loop() | ||
| { | ||
| if(!messageSent){ | ||
| Serial.println("Hi"); | ||
| messageSent = true; | ||
| } | ||
|
|
||
| // Check if the semaphore can be taken and if the inputBuffer length is long enough. | ||
| // Please keep in mind, since the variable inputBufferLength is also accessed inside the IRQ handler, | ||
| // the semaphore needs to be taken BEFORE you can access that variable. | ||
| if(xSemaphoreTake(bufferSemaphore, portMAX_DELAY) == pdTRUE && inputBufferLength == (BUFFER_SIZE - 1)){ | ||
| for(size_t i = 0; i < inputBufferLength; i++){ | ||
| Serial.write(inputBuffer[i]); | ||
|
|
||
| // Clear the buffer | ||
| inputBuffer[i] = '\0'; | ||
| } | ||
| // Clear the bufferLength | ||
| inputBufferLength = 0; | ||
|
|
||
| // Give back the semaphore | ||
| xSemaphoreGive(bufferSemaphore); | ||
|
|
||
| // Allow the system to request another data set | ||
| messageSent = false; | ||
| } | ||
|
|
||
| delay(10); // Wait for 10ms to allow some data to come in | ||
| } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,59 @@ | ||
| /** Tim Koers - 2021 | ||
| * | ||
| * This sketch shows the usage of an queue, to store and read the characters that are sent to the interrupt. | ||
| * You can safely use this in a FreeRTOS environment and use the queue from different tasks on different CPU cores. | ||
| * This sketch assumes that when Hi is sent, the device returns an 8 byte message. | ||
| * | ||
| */ | ||
|
|
||
| #define BUFFER_SIZE 8 | ||
|
|
||
| // This queue is here to handle the interruption of the loop when the interrupt is running. | ||
| QueueHandle_t bufferQueue; | ||
|
|
||
| bool messageSent = false; | ||
|
|
||
| // Please keep in mind, since the ESP32 is dual core, | ||
| // the interrupt will be running on the same core as the setRxInterrupt function was called on. | ||
| static void IRAM_ATTR onSerialRX(uint8_t character, void* user_arg){ | ||
|
|
||
| BaseType_t xHighPriorityTaskWoken; | ||
|
|
||
| if(xQueueSendFromISR(bufferQueue, &character, &xHighPriorityTaskWoken) != pdTRUE){ | ||
| log_e("IRQ", "Failed to put character onto the queue\n"); | ||
| } | ||
| } | ||
|
|
||
| void setup() | ||
| { | ||
| bufferQueue = xQueueCreate(BUFFER_SIZE * 4, sizeof(char)); // Create a queue that can hold 4 messages of 8-bytes each. | ||
|
|
||
| assert(bufferQueue != NULL); | ||
|
|
||
| Serial.begin(115200); | ||
| Serial2.begin(115200); | ||
|
|
||
| Serial2.setRxInterrupt(onSerialRX, NULL); | ||
|
There was a problem hiding this comment. @timkoers I tested the code and it is working fine. I have only one issue at this point during Setup initilization... it sometimes stop at setrxInterrupt function. When I delete Serial2.begin and Serial2.setRxInterrupt -> upload the code -> then add Serial2.begin and Serial2.setRxInterrupt -> upload the code, everything starts to work fine again... I'm trying to figure out why this is happening... |
||
| } | ||
|
|
||
| void loop() | ||
| { | ||
| if(!messageSent){ | ||
| Serial.println("Hi"); | ||
| messageSent = true; | ||
| } | ||
|
|
||
| // Check if data in the queue and check if there is a complete message (8-bytes) in the queue | ||
| if(!(uxQueueMessagesWaiting(bufferQueue) % BUFFER_SIZE)){ | ||
| char c; | ||
| // Check if the queue is not empty, 0 % 8 returns 0 instead, so does 24 % 8 | ||
| while(uxQueueMessagesWaiting(bufferQueue) > 0){ | ||
| // Get the character from the queue, but don't block if someone else is busy with the queue | ||
| if(xQueueReceive(bufferQueue, &c, 0) == pdTRUE) | ||
| Serial.write(c); | ||
| } | ||
|
|
||
| // Allow the system to request another data set | ||
| messageSent = false; | ||
| } | ||
| } | ||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.