mirror of
https://github.com/DCC-EX/CommandStation-EX.git
synced 2024-12-23 12:51:24 +01:00
send whole outbuffer
This commit is contained in:
parent
690c629e6d
commit
127f3acce5
@ -209,6 +209,7 @@ void EthernetInterface::loop2() {
|
||||
if (Diag::ETHERNET) DIAG(F("Ethernet: available socket=%d,avail=%d"), socket, available);
|
||||
// read bytes from a client
|
||||
int count = clients[socket].read(buffer, MAX_ETH_BUFFER);
|
||||
looptimer(8000, F("Ethloop2 read"));
|
||||
buffer[count] = '\0'; // terminate the string properly
|
||||
if (Diag::ETHERNET) DIAG(F(",count=%d:%e"), count, buffer);
|
||||
// execute with data going directly back
|
||||
@ -239,7 +240,14 @@ void EthernetInterface::loop2() {
|
||||
} else if (socketOut >= 0) {
|
||||
int count=outboundRing->count();
|
||||
if (Diag::ETHERNET) DIAG(F("Ethernet reply socket=%d, count=:%d"), socketOut,count);
|
||||
for(;count>0;count--) clients[socketOut].write(outboundRing->read());
|
||||
{
|
||||
char buffer[count+1]; // one extra for '\0'
|
||||
for(int i=0;i<count;i++) {
|
||||
buffer[i] = outboundRing->read();
|
||||
}
|
||||
buffer[count]=0;
|
||||
clients[socketOut].write(buffer,count);
|
||||
}
|
||||
clients[socketOut].flush(); //maybe
|
||||
}
|
||||
looptimer(8000, F("Ethloop after outbound"));
|
||||
|
@ -1 +1 @@
|
||||
#define GITHUB_SHA "devel-fozzie-202408080852Z"
|
||||
#define GITHUB_SHA "devel-fozzie-202408090945Z"
|
||||
|
Loading…
Reference in New Issue
Block a user