From 513d241d08e6108c22d06eeac9f1da36bea3d614 Mon Sep 17 00:00:00 2001 From: Adema Date: Mon, 17 Feb 2025 09:01:57 +0100 Subject: [PATCH] Upload files to "/" --- eth_tcp_receiv.ino | 24 ++++++++++++++---------- eth_tcp_sender.ino | 27 ++++++++++++++++++++------- 2 files changed, 34 insertions(+), 17 deletions(-) diff --git a/eth_tcp_receiv.ino b/eth_tcp_receiv.ino index 881e04e..c4f56ea 100644 --- a/eth_tcp_receiv.ino +++ b/eth_tcp_receiv.ino @@ -7,10 +7,11 @@ const int localPort = 8888; EthernetServer server(localPort); EthernetClient client; -byte packetBuffer[256]; +#define package_size 1024 +byte packetBuffer[package_size]; void setup() { - Serial.begin(115200); + Serial.begin(921600); //while (!Serial); Serial.println("Initializing Ethernet..."); @@ -41,19 +42,22 @@ void loop() { static int bytesReceived = 0; 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) { bytesReceived += byteRead; } - if (bytesReceived == 256) { // Full packet received - Serial.print("Received full 256-byte packet: "); + if (bytesReceived == package_size) { // Full packet received + //Serial.print("Received packet at: "); + Serial.println(micros()); + //Serial.println(" us"); - for (int i = 0; i < 256; i++) { - Serial.print(packetBuffer[i], DEC); - Serial.print(" "); - } - Serial.println(); + //for (int i = 0; i < package_size; i++) { + //Serial.print(packetBuffer[i], DEC); + //Serial.print(" "); + //if ((i + 1) % 256 == 0) Serial.println(); + //} + //Serial.println(); bytesReceived = 0; // Reset for the next packet } diff --git a/eth_tcp_sender.ino b/eth_tcp_sender.ino index 7ffbbf4..7391c8a 100644 --- a/eth_tcp_sender.ino +++ b/eth_tcp_sender.ino @@ -6,10 +6,11 @@ IPAddress serverIP(192, 168, 1, 101); const int serverPort = 8888; EthernetClient client; -byte buffer[256]; +#define package_size 1024 +byte buffer[package_size]; void setup() { - Serial.begin(115200); + Serial.begin(921600); //while (!Serial); Serial.println("Initializing Ethernet..."); @@ -32,13 +33,25 @@ void setup() { 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) } + send_package(); + send_package(); + send_package(); + send_package(); + send_package(); + delay (3000); + send_package(); + } void loop() { - if (!client.connected()) { + //delay(500); // Small delay to avoid overloading the receiver +} + +void send_package(){ + if (!client.connected()) { Serial.println("Connection lost. Reconnecting..."); client.stop(); delay(1000); @@ -46,7 +59,7 @@ void loop() { return; } - Serial.println("Sending 256-byte packet..."); - client.write(buffer, 256); - //delay(500); // Small delay to avoid overloading the receiver + //Serial.println("Sending packet..."); + client.write(buffer, package_size); + }