Skip to content

Ethernet Changes #373

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
bjackson312006 merged 2 commits into from
Feb 27, 2026
Merged

Ethernet Changes #373

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
30d2aa1
changes when testing ethernet
bjackson312006 Feb 27, 2026
68afe6c
one or two more changes
bjackson312006 Feb 27, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions NetX/inc/u_nx_ethernet.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@

/* CONFIG */
#define ETH_UDP_PORT 2006 /* UDP port for communication */
#define ETH_MESSAGE_SIZE 8 /* Maximum ethernet message size in bytes. */
#define ETH_MESSAGE_SIZE 60 /* Maximum ethernet message size in bytes. */
#define ETH_MAX_PACKETS 10 /* Maximum number of packets we wanna handle simultaneously */
#define ETH_NUMBER_OF_NODES 8 /* Number of nodes in the network. */

Expand Down Expand Up @@ -51,7 +51,7 @@ typedef enum {
} plca_node_id_t;
/* END CONFIG */

typedef struct {
typedef struct __attribute__((__packed__)) {
uint8_t sender_id;
uint8_t recipient_id;
uint8_t message_id;
Expand Down
18 changes: 7 additions & 11 deletions NetX/src/u_nx_ethernet.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
#include "nxd_ptp_client.h"
#include "u_nx_debug.h"
#include "u_tx_debug.h"
#include "c_utils.h"
#include "nx_api.h"
#include <string.h>
#include <stdio.h>
Expand Down Expand Up @@ -113,20 +114,15 @@ static void _receive_message(NX_UDP_SOCKET *socket) {
}

/* Extract message from packet */
status = nx_packet_data_extract_offset(
packet, // Packet to extract from
0, // Offset (start of packet)
&message, // Message buffer
sizeof(ethernet_message_t), // Size to extract
&bytes_copied // Stores how many bytes were actually copied to &message
);
if(bytes_copied < sizeof(ethernet_message_t)) {
PRINTLN_WARNING("Received ethernet message was smaller than expected (only received %lu of %u expected bytes).", bytes_copied, sizeof(ethernet_message_t));
ULONG bytes_copied = 0;
status = nx_packet_data_retrieve(packet, &message, &bytes_copied);
if(status != NX_SUCCESS) {
PRINTLN_ERROR("Failed to call nx_packet_data_retrieve() (Status: %d/%s).", status, nx_status_toString(status));
}

/* Process received message */
if(status == NX_SUCCESS) {
PRINTLN_INFO("Received ethernet message! (Sender ID: %d, Message ID: %d).", message.sender_id, message.message_id);
PRINTLN_INFO("Received ethernet message! (Sender ID: %d, Message ID: %d, bytes_copied: %d).", message.sender_id, message.message_id, bytes_copied);
device.on_recieve(message);
}
}
Expand Down Expand Up @@ -356,7 +352,7 @@ uint8_t ethernet_send_message(ethernet_message_t *message) {
/* Append message data to packet */
status = nx_packet_data_append(
packet, // Packet
&message, // Data to append
message, // Data to append
sizeof(ethernet_message_t), // Size of data
&device.packet_pool, // Packet pool
TX_WAIT_FOREVER // Wait indefinitely
Expand Down