Mirrors_Framework/ethercat
1
0
Fork 0
mirror of https://gitlab.com/etherlab.org/ethercat.git synced 2026-08-17 08:41:43 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improved smp_store positions.

Browse Source
This commit is contained in:
Florian Pose
2026-07-15 13:45:50 +02:00
parent b4217e93b0
commit 754d0e548a
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
master/master.c
+6 -6
View File
@@ -1100,12 +1100,12 @@ void ec_master_send_datagrams(
// set datagram states and sending timestamps
list_for_each_entry_safe(datagram, next, &sent_datagrams, sent) {
smp_store_release(&datagram->state, EC_DATAGRAM_SENT);
#ifdef EC_HAVE_CYCLES
datagram->cycles_sent = cycles_sent;
#endif
datagram->jiffies_sent = jiffies_sent;
list_del_init(&datagram->sent); // empty list of sent datagrams
list_del_init(&datagram->sent); // remove from sent queue
smp_store_release(&datagram->state, EC_DATAGRAM_SENT);
}
frame_count++;
@@ -1257,11 +1257,11 @@ void ec_master_receive_datagrams(
datagram->jiffies_received =
master->devices[EC_DEVICE_MAIN].jiffies_poll;
// set the state with a barrier
smp_store_release(&datagram->state, EC_DATAGRAM_RECEIVED);
// dequeue the received datagram
list_del_init(&datagram->queue);
// set the state (with a barrier)
smp_store_release(&datagram->state, EC_DATAGRAM_RECEIVED);
}
}
@@ -2466,8 +2466,8 @@ int ecrt_master_send(ec_master_t *master)
list_for_each_entry_safe(datagram, n,
&master->datagram_queue, queue) {
if (datagram->device_index == dev_idx) {
smp_store_release(&datagram->state, EC_DATAGRAM_ERROR);
list_del_init(&datagram->queue);
smp_store_release(&datagram->state, EC_DATAGRAM_ERROR);
}
}