p268786/t41_to_t41_comm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Upload files to "/"

Browse Source
This commit is contained in:
Adema 2025-02-17 09:01:57 +01:00
parent 9e91df209a
commit 513d241d08
2 changed files with 34 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
eth_tcp_receiv.ino
View File

@ -7,10 +7,11 @@ const int localPort = 8888;
EthernetServer server(localPort); EthernetServer server(localPort);
EthernetClient client; EthernetClient client;
byte packetBuffer[256]; #define package_size 1024
byte packetBuffer[package_size];
void setup() { void setup() {
Serial.begin(115200); Serial.begin(921600);
//while (!Serial); //while (!Serial);
Serial.println("Initializing Ethernet..."); Serial.println("Initializing Ethernet...");
@ -41,19 +42,22 @@ void loop() {
static int bytesReceived = 0; static int bytesReceived = 0;
while (client.available()) { // Keep reading while data is available while (client.available()) { // Keep reading while data is available
int byteRead = client.read(packetBuffer + bytesReceived, 256 - bytesReceived); int byteRead = client.read(packetBuffer + bytesReceived, package_size - bytesReceived);
if (byteRead > 0) { if (byteRead > 0) {
bytesReceived += byteRead; bytesReceived += byteRead;
} }
if (bytesReceived == 256) { // Full packet received if (bytesReceived == package_size) { // Full packet received
Serial.print("Received full 256-byte packet: "); //Serial.print("Received packet at: ");
Serial.println(micros());
//Serial.println(" us");
for (int i = 0; i < 256; i++) { //for (int i = 0; i < package_size; i++) {
Serial.print(packetBuffer[i], DEC); //Serial.print(packetBuffer[i], DEC);
Serial.print(" "); //Serial.print(" ");
} //if ((i + 1) % 256 == 0) Serial.println();
Serial.println(); //}
//Serial.println();
bytesReceived = 0; // Reset for the next packet bytesReceived = 0; // Reset for the next packet
} }

25
eth_tcp_sender.ino
View File

@ -6,10 +6,11 @@ IPAddress serverIP(192, 168, 1, 101);
const int serverPort = 8888; const int serverPort = 8888;
EthernetClient client; EthernetClient client;
byte buffer[256]; #define package_size 1024
byte buffer[package_size];
void setup() { void setup() {
Serial.begin(115200); Serial.begin(921600);
//while (!Serial); //while (!Serial);
Serial.println("Initializing Ethernet..."); Serial.println("Initializing Ethernet...");
@ -32,12 +33,24 @@ void setup() {
Serial.println("Connection failed."); Serial.println("Connection failed.");
} }
for (int i = 0; i < 256; i++) { for (int i = 0; i < package_size; i++) {
buffer[i] = i; // Fill buffer with sample data (0-255) buffer[i] = i; // Fill buffer with sample data (0-255)
} }
send_package();
send_package();
send_package();
send_package();
send_package();
delay (3000);
send_package();
} }
void loop() { void loop() {
//delay(500); // Small delay to avoid overloading the receiver
}
void send_package(){
if (!client.connected()) { if (!client.connected()) {
Serial.println("Connection lost. Reconnecting..."); Serial.println("Connection lost. Reconnecting...");
client.stop(); client.stop();
@ -46,7 +59,7 @@ void loop() {
return; return;
} }
Serial.println("Sending 256-byte packet..."); //Serial.println("Sending packet...");
client.write(buffer, 256); client.write(buffer, package_size);
//delay(500); // Small delay to avoid overloading the receiver
} }