QMesh
/
QMesh-ESP32
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Added in much deeper buffering, ZMODEM and YMODEM seem to work now

main
Dan 2021-05-05 21:43:12 -06:00
parent 9b752266c0
commit 7052e6893f
1 changed files with 57 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
qmesh_interface/qmesh_interface.ino
View File

@ -5,26 +5,77 @@
//and also demonstrate that SerialBT have the same functionalities of a normal Serial
#include "BluetoothSerial.h"
#include <deque>
#if !defined(CONFIG_BT_ENABLED) || !defined(CONFIG_BLUEDROID_ENABLED)
#error Bluetooth is not enabled! Please run `make menuconfig` to and enable it
#endif
BluetoothSerial SerialBT;
//HardwareSerial Serial;
void setup() {
Serial.begin(115200);
Serial.setRxBufferSize(16384);
Serial.setRxBufferSize(4096);
SerialBT.begin("ESP32test"); //Bluetooth device name
Serial.println("The device started, now you can pair it with bluetooth!");
}
uint8_t bt_buf[256];
#define MAX_DEQUE_SIZE 65536
#define MAX_WRITE_BYTES 16
std::deque<uint8_t> rx_serial, rx_btserial;
void loop() {
if (Serial.available()) {
SerialBT.write(Serial.read());
// First, store any received data
if(Serial.available()) {
while(Serial.available()) {
rx_serial.push_front(Serial.read());
if(rx_serial.size() > MAX_DEQUE_SIZE) {
rx_serial.clear();
}
}
}
if (SerialBT.available()) {
Serial.write(SerialBT.read());
if(SerialBT.available()) {
while(SerialBT.available()) {
rx_btserial.push_front(SerialBT.read());
if(rx_btserial.size() > MAX_DEQUE_SIZE) {
rx_btserial.clear();
}
}
}
delay(1);
// Next, send out the buffer data
if(rx_btserial.size() > 0) {
std::vector<uint8_t> write_bytes;
size_t num_write_bytes = Serial.availableForWrite();
if(num_write_bytes > MAX_DEQUE_SIZE) {
num_write_bytes = MAX_DEQUE_SIZE;
}
if(num_write_bytes > rx_btserial.size()) {
num_write_bytes = rx_btserial.size();
}
for(size_t i = 0; i < num_write_bytes; i++) {
write_bytes.push_back(rx_btserial.back());
rx_btserial.pop_back();
}
Serial.write(write_bytes.data(), write_bytes.size());
}
if(rx_serial.size() > 0) {
std::vector<uint8_t> write_bytes;
size_t num_write_bytes = rx_serial.size();
if(num_write_bytes > MAX_DEQUE_SIZE) {
num_write_bytes = MAX_DEQUE_SIZE;
}
std::deque<uint8_t>::iterator iter = rx_serial.end();
for(size_t i = 0; i < num_write_bytes; i++) {
write_bytes.push_back(*--iter);
}
if(SerialBT.write(write_bytes.data(), write_bytes.size())) {
rx_serial.erase(iter, rx_serial.end());
}
}
}