-
Notifications
You must be signed in to change notification settings - Fork 995
/
SerialConsole.cpp
95 lines (83 loc) · 3.38 KB
/
SerialConsole.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
/*
This file is part of Smoothie (http://smoothieware.org/). The motion control part is heavily based on Grbl (https://github.com/simen/grbl).
Smoothie is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
Smoothie is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
You should have received a copy of the GNU General Public License along with Smoothie. If not, see <http://www.gnu.org/licenses/>.
*/
#include <string>
#include <stdarg.h>
using std::string;
#include "libs/Module.h"
#include "libs/Kernel.h"
#include "libs/nuts_bolts.h"
#include "SerialConsole.h"
#include "libs/RingBuffer.h"
#include "libs/SerialMessage.h"
#include "libs/StreamOutput.h"
// Serial reading module
// Treats every received line as a command and passes it ( via event call ) to the command dispatcher.
// The command dispatcher will then ask other modules if they can do something with it
SerialConsole::SerialConsole( PinName rx_pin, PinName tx_pin, int baud_rate ){
this->serial = new mbed::Serial( rx_pin, tx_pin );
this->serial->baud(baud_rate);
}
// Called when the module has just been loaded
void SerialConsole::on_module_loaded() {
// We want to be called every time a new char is received
this->serial->attach(this, &SerialConsole::on_serial_char_received, mbed::Serial::RxIrq);
// We only call the command dispatcher in the main loop, nowhere else
this->register_for_event(ON_MAIN_LOOP);
// Add to the pack of streams kernel can call to, for example for broadcasting
this->kernel->streams->append_stream(this);
}
// Called on Serial::RxIrq interrupt, meaning we have received a char
void SerialConsole::on_serial_char_received(){
while(this->serial->readable()){
char received = this->serial->getc();
// convert CR to NL (for host OSs that don't send NL)
if( received == '\r' ){ received = '\n'; }
this->buffer.push_back(received);
}
}
// Actual event calling must happen in the main loop because if it happens in the interrupt we will loose data
void SerialConsole::on_main_loop(void * argument){
if( this->has_char('\n') ){
string received;
received.reserve(20);
while(1){
char c;
this->buffer.pop_front(c);
if( c == '\n' ){
struct SerialMessage message;
message.message = received;
message.stream = this;
this->kernel->call_event(ON_CONSOLE_LINE_RECEIVED, &message );
return;
}else{
received += c;
}
}
}
}
int SerialConsole::puts(const char* s)
{
return fwrite(s, strlen(s), 1, this->serial->_file);
}
int SerialConsole::_putc(int c)
{
return this->serial->putc(c);
}
int SerialConsole::_getc()
{
return this->serial->getc();
}
bool SerialConsole::has_char(char letter){
int index = this->buffer.head;
while( index != this->buffer.tail ){
if( this->buffer.buffer[index] == letter ){
return true;
}
index = this->buffer.next_block_index(index);
}
return false;
}