Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(559)

Side by Side Diff: platforms/stm/disco_dartino/src/uart.cc

Issue 1659163007: Rename fletch -> dartino (Closed) Base URL: https://github.com/dartino/sdk.git@master
Patch Set: address comments Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2015, the Dartino project authors. Please see the AUTHORS file 1 // Copyright (c) 2015, the Dartino project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE.md file. 3 // BSD-style license that can be found in the LICENSE.md file.
4 4
5 #include "platforms/stm/disco_fletch/src/uart.h" 5 #include "platforms/stm/disco_dartino/src/uart.h"
6 6
7 #include <stdlib.h> 7 #include <stdlib.h>
8 8
9 #include <stm32f7xx_hal.h> 9 #include <stm32f7xx_hal.h>
10 10
11 #include "src/shared/atomic.h" 11 #include "src/shared/atomic.h"
12 #include "src/shared/utils.h" 12 #include "src/shared/utils.h"
13 13
14 // Reference to the instance in the code generated by STM32CubeMX. 14 // Reference to the instance in the code generated by STM32CubeMX.
15 extern UART_HandleTypeDef huart1; 15 extern UART_HandleTypeDef huart1;
16 16
17 // TODO(sgjesse): Get rid of these global variables. These global 17 // TODO(sgjesse): Get rid of these global variables. These global
18 // variables are accessed from the interrupt handlers. 18 // variables are accessed from the interrupt handlers.
19 static osSemaphoreId sem_; 19 static osSemaphoreId sem_;
20 static uint32_t error = 0; 20 static uint32_t error = 0;
21 21
22 // Bits set from interrupt handlers. 22 // Bits set from interrupt handlers.
23 const int kReceivedBit = 1 << 0; 23 const int kReceivedBit = 1 << 0;
24 const int kTransmittedBit = 1 << 1; 24 const int kTransmittedBit = 1 << 1;
25 const int kErrorBit = 1 << 2; 25 const int kErrorBit = 1 << 2;
26 static fletch::Atomic<uint32_t> interrupt_flags; 26 static dartino::Atomic<uint32_t> interrupt_flags;
27 27
28 const int kRxBufferSize = 511; 28 const int kRxBufferSize = 511;
29 const int kTxBufferSize = 511; 29 const int kTxBufferSize = 511;
30 30
31 // C trampoline for the interrupt handling thread. 31 // C trampoline for the interrupt handling thread.
32 void __UartTask(void const* argument) { 32 void __UartTask(void const* argument) {
33 Uart* uart = const_cast<Uart*>(reinterpret_cast<const Uart*>(argument)); 33 Uart* uart = const_cast<Uart*>(reinterpret_cast<const Uart*>(argument));
34 uart->Task(); 34 uart->Task();
35 } 35 }
36 36
37 Uart::Uart() { 37 Uart::Uart() {
38 uart_ = &huart1; 38 uart_ = &huart1;
39 rx_buffer_ = new CircularBuffer(kRxBufferSize); 39 rx_buffer_ = new CircularBuffer(kRxBufferSize);
40 tx_mutex_ = fletch::Platform::CreateMutex(); 40 tx_mutex_ = dartino::Platform::CreateMutex();
41 tx_buffer_ = new CircularBuffer(kTxBufferSize); 41 tx_buffer_ = new CircularBuffer(kTxBufferSize);
42 tx_pending_ = false; 42 tx_pending_ = false;
43 error_count_ = 0; 43 error_count_ = 0;
44 44
45 // Semaphore for signaling from interrupt handlers. A maximum of 45 // Semaphore for signaling from interrupt handlers. A maximum of
46 // three tokens - one for data received and one for data transmitted 46 // three tokens - one for data received and one for data transmitted
47 // and one for error. 47 // and one for error.
48 semaphore_ = osSemaphoreCreate(osSemaphore(semaphore_def_), 3); 48 semaphore_ = osSemaphoreCreate(osSemaphore(semaphore_def_), 3);
49 // Store in global variable for access from interrupt handlers. 49 // Store in global variable for access from interrupt handlers.
50 sem_ = semaphore_; 50 sem_ = semaphore_;
51 } 51 }
52 52
53 void Uart::Start() { 53 void Uart::Start() {
54 // Start thread for handling interrupts. 54 // Start thread for handling interrupts.
55 osThreadDef(UART_TASK, __UartTask, osPriorityHigh, 0, 1024); 55 osThreadDef(UART_TASK, __UartTask, osPriorityHigh, 0, 1024);
56 osThreadCreate(osThread(UART_TASK), this); 56 osThreadCreate(osThread(UART_TASK), this);
57 57
58 // Start receiving. 58 // Start receiving.
59 HAL_UART_Receive_IT(uart_, &rx_data_, 1); 59 HAL_UART_Receive_IT(uart_, &rx_data_, 1);
60 } 60 }
61 61
62 size_t Uart::Read(uint8_t* buffer, size_t count) { 62 size_t Uart::Read(uint8_t* buffer, size_t count) {
63 return rx_buffer_->Read(buffer, count, CircularBuffer::kBlock); 63 return rx_buffer_->Read(buffer, count, CircularBuffer::kBlock);
64 } 64 }
65 65
66 size_t Uart::Write(const uint8_t* buffer, size_t count) { 66 size_t Uart::Write(const uint8_t* buffer, size_t count) {
67 size_t written = tx_buffer_->Write(buffer, count, CircularBuffer::kBlock); 67 size_t written = tx_buffer_->Write(buffer, count, CircularBuffer::kBlock);
68 68
69 fletch::ScopedLock lock(tx_mutex_); 69 dartino::ScopedLock lock(tx_mutex_);
70 EnsureTransmission(); 70 EnsureTransmission();
71 return written; 71 return written;
72 } 72 }
73 73
74 void Uart::Task() { 74 void Uart::Task() {
75 // Process notifications from the interrupt handlers. 75 // Process notifications from the interrupt handlers.
76 for (;;) { 76 for (;;) {
77 // Wait for an interrupt to be processed. 77 // Wait for an interrupt to be processed.
78 osSemaphoreWait(semaphore_, osWaitForever); 78 osSemaphoreWait(semaphore_, osWaitForever);
79 // Read the flags and set them to zero. 79 // Read the flags and set them to zero.
80 uint32_t flags = interrupt_flags.exchange(0); 80 uint32_t flags = interrupt_flags.exchange(0);
81 81
82 if ((flags & kReceivedBit) != 0) { 82 if ((flags & kReceivedBit) != 0) {
83 // Don't block when writing to the buffer. Buffer overrun will 83 // Don't block when writing to the buffer. Buffer overrun will
84 // cause lost data. 84 // cause lost data.
85 rx_buffer_->Write(&rx_data_, 1, CircularBuffer::kDontBlock); 85 rx_buffer_->Write(&rx_data_, 1, CircularBuffer::kDontBlock);
86 86
87 // Start receiving of next byte. 87 // Start receiving of next byte.
88 HAL_StatusTypeDef status = HAL_UART_Receive_IT(uart_, &rx_data_, 1); 88 HAL_StatusTypeDef status = HAL_UART_Receive_IT(uart_, &rx_data_, 1);
89 if (status != HAL_OK) { 89 if (status != HAL_OK) {
90 fletch::Print::Error("HAL_UART_Receive_IT returned %d\n", status); 90 dartino::Print::Error("HAL_UART_Receive_IT returned %d\n", status);
91 } 91 }
92 } 92 }
93 93
94 if ((flags & kTransmittedBit) != 0) { 94 if ((flags & kTransmittedBit) != 0) {
95 fletch::ScopedLock lock(tx_mutex_); 95 dartino::ScopedLock lock(tx_mutex_);
96 tx_pending_ = false; 96 tx_pending_ = false;
97 EnsureTransmission(); 97 EnsureTransmission();
98 } 98 }
99 99
100 if ((flags & kErrorBit) != 0) { 100 if ((flags & kErrorBit) != 0) {
101 // Ignore errors for now. 101 // Ignore errors for now.
102 error_count_++; 102 error_count_++;
103 error = 0; 103 error = 0;
104 // Setup interrupt for next byte. 104 // Setup interrupt for next byte.
105 HAL_StatusTypeDef status = HAL_UART_Receive_IT(uart_, &rx_data_, 1); 105 HAL_StatusTypeDef status = HAL_UART_Receive_IT(uart_, &rx_data_, 1);
106 if (status != HAL_OK) { 106 if (status != HAL_OK) {
107 fletch::Print::Error("HAL_UART_Receive_IT returned %d\n", status); 107 dartino::Print::Error("HAL_UART_Receive_IT returned %d\n", status);
108 } 108 }
109 } 109 }
110 } 110 }
111 } 111 }
112 112
113 void Uart::EnsureTransmission() { 113 void Uart::EnsureTransmission() {
114 if (!tx_pending_) { 114 if (!tx_pending_) {
115 // Don't block when there is nothing to send. 115 // Don't block when there is nothing to send.
116 int bytes = tx_buffer_->Read( 116 int bytes = tx_buffer_->Read(
117 tx_data_, kTxBlockSize, CircularBuffer::kDontBlock); 117 tx_data_, kTxBlockSize, CircularBuffer::kDontBlock);
118 if (bytes > 0) { 118 if (bytes > 0) {
119 HAL_StatusTypeDef status = HAL_UART_Transmit_IT(uart_, tx_data_, bytes); 119 HAL_StatusTypeDef status = HAL_UART_Transmit_IT(uart_, tx_data_, bytes);
120 if (status != HAL_OK) { 120 if (status != HAL_OK) {
121 fletch::Print::Error("HAL_UART_Transmit_IT returned %d\n", status); 121 dartino::Print::Error("HAL_UART_Transmit_IT returned %d\n", status);
122 } 122 }
123 tx_pending_ = true; 123 tx_pending_ = true;
124 } 124 }
125 } 125 }
126 } 126 }
127 127
128 // Shared return from interrupt handler. Will set the specified flag 128 // Shared return from interrupt handler. Will set the specified flag
129 // and transfer control to the thread handling interrupts. 129 // and transfer control to the thread handling interrupts.
130 static void ReturnFromInterrupt(UART_HandleTypeDef *huart, uint32_t flag) { 130 static void ReturnFromInterrupt(UART_HandleTypeDef *huart, uint32_t flag) {
131 // Set the requested bit. 131 // Set the requested bit.
(...skipping 23 matching lines...) Expand all
155 error = HAL_UART_GetError(huart); 155 error = HAL_UART_GetError(huart);
156 156
157 // Clear all errors. 157 // Clear all errors.
158 __HAL_UART_CLEAR_OREFLAG(&huart1); 158 __HAL_UART_CLEAR_OREFLAG(&huart1);
159 __HAL_UART_CLEAR_FEFLAG(&huart1); 159 __HAL_UART_CLEAR_FEFLAG(&huart1);
160 __HAL_UART_CLEAR_PEFLAG(&huart1); 160 __HAL_UART_CLEAR_PEFLAG(&huart1);
161 __HAL_UART_CLEAR_NEFLAG(&huart1); 161 __HAL_UART_CLEAR_NEFLAG(&huart1);
162 162
163 ReturnFromInterrupt(huart, kErrorBit); 163 ReturnFromInterrupt(huart, kErrorBit);
164 } 164 }
OLDNEW
« no previous file with comments | « platforms/stm/disco_dartino/src/uart.h ('k') | platforms/stm/disco_dartino/template/startup_stm32f746xx.s » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698