empathicqubit/ticables-gdb-bridge
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Get more bytes at a time

Browse source
This commit is contained in:
Empathic Qubit 2023-01-07 21:12:19 +01:00
parent e84ad3ae9e
commit 9160c46066
1 changed files with 27 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
src/tibridge.c
View file

@ -73,6 +73,16 @@ void retry_write_calc(uint8_t* send, int sendCount) {
} }
} }
void retry_read_calc(uint8_t* recv, int getCount) {
int err;
do {
if((err = ticables_cable_recv(cable_handle, recv, getCount))) {
log(LEVEL_ERROR, "error receiving: %d\n", err);
}
} while(err);
log(LEVEL_TRACE, "%.*s", getCount, recv);
}
void ack() { void ack() {
retry_write_calc((uint8_t*)"+", 1); retry_write_calc((uint8_t*)"+", 1);
} }
@ -245,27 +255,25 @@ int main(int argc, char *argv[]) {
while(true) { while(true) {
uint8_t recv[1023]; uint8_t recv[1023];
unsigned char current = 0;
int recvCount = 0; int recvCount = 0;
log(LEVEL_INFO, "<"); log(LEVEL_INFO, "<");
log(LEVEL_DEBUG, "RECEIVE PHASE\n"); log(LEVEL_DEBUG, "RECEIVE PHASE\n");
while(true) { while(true) {
do { int getCount = 1;
if((err = ticables_cable_recv(cable_handle, &recv[recvCount], 1))) { unsigned char *current = NULL;
log(LEVEL_ERROR, "error receiving: %d\n", err); if(recvCount > 0 && memchr(recv, '$', recvCount)) {
getCount = 3;
}
retry_read_calc(&recv[recvCount], getCount);
recvCount += getCount;
if((current = memchr(&recv[recvCount-getCount], '#', getCount))) {
getCount = 2 - ((&recv[recvCount]) - current - 1);
if(getCount > 0) {
retry_read_calc(&recv[recvCount], getCount);
recvCount += getCount;
} }
} while(err);
current = recv[recvCount];
log(LEVEL_TRACE, "%c", current);
recvCount++;
if(current == '#') {
do {
if((err = ticables_cable_recv(cable_handle, &recv[recvCount], 2))) {
log(LEVEL_ERROR, "error receiving: %d\n", err);
}
} while(err);
recvCount += 2;
recv[recvCount] = '\0'; recv[recvCount] = '\0';
@ -302,7 +310,8 @@ int main(int argc, char *argv[]) {
break; break;
} }
else if(recvCount == 1) { else if(recvCount == 1) {
if(current == '-') { current = &recv[recvCount - 1];
if(*current == '-') {
if(!handle_acks) { if(!handle_acks) {
retry_write_host(recv, recvCount); retry_write_host(recv, recvCount);
} }
@ -312,7 +321,7 @@ int main(int argc, char *argv[]) {
recvCount = 0; recvCount = 0;
break; break;
} }
else if(current == '+') { else if(*current == '+') {
continue; continue;
} }
} }
@ -325,6 +334,7 @@ int main(int argc, char *argv[]) {
log(LEVEL_INFO, ">"); log(LEVEL_INFO, ">");
log(LEVEL_DEBUG, "SEND PHASE\n"); log(LEVEL_DEBUG, "SEND PHASE\n");
while(true) { while(true) {
uint8_t current;
uint8_t send[255]; uint8_t send[255];
int sendCount = 0; int sendCount = 0;