Removed unnecessary ec_master_sdo_request_t. stable-1.5
authorFlorian Pose <fp@igh-essen.com>
Tue, 04 Dec 2012 13:28:38 +0100
branchstable-1.5
changeset 2461 d2c48550acd0
parent 2460 611e4d745dcd
child 2462 5fc035788a3a
Removed unnecessary ec_master_sdo_request_t.
master/fsm_master.h
master/fsm_slave.c
master/master.c
master/slave.c
--- a/master/fsm_master.h	Tue Dec 04 12:59:15 2012 +0100
+++ b/master/fsm_master.h	Tue Dec 04 13:28:38 2012 +0100
@@ -61,16 +61,6 @@
 
 /*****************************************************************************/
 
-/** Slave/SDO request record for master's SDO request list.
- */
-typedef struct {
-    struct list_head list; /**< List element. */
-    ec_slave_t *slave; /**< Slave. */
-    ec_sdo_request_t req; /**< SDO request. */
-} ec_master_sdo_request_t;
-
-/*****************************************************************************/
-
 /** FoE request.
  */
 typedef struct {
--- a/master/fsm_slave.c	Tue Dec 04 12:59:15 2012 +0100
+++ b/master/fsm_slave.c	Tue Dec 04 13:28:38 2012 +0100
@@ -180,7 +180,7 @@
         )
 {
     ec_slave_t *slave = fsm->slave;
-    ec_master_sdo_request_t *request, *next;
+    ec_sdo_request_t *request, *next;
 
     // search the first external request to be processed
     list_for_each_entry_safe(request, next, &slave->sdo_requests, list) {
@@ -189,7 +189,7 @@
         if (slave->current_state & EC_SLAVE_STATE_ACK_ERR) {
             EC_SLAVE_WARN(slave, "Aborting SDO request,"
                     " slave has error flag set.\n");
-            request->req.state = EC_INT_REQUEST_FAILURE;
+            request->state = EC_INT_REQUEST_FAILURE;
             wake_up(&slave->sdo_queue);
             fsm->sdo_request = NULL;
             fsm->state = ec_fsm_slave_state_idle;
@@ -198,22 +198,22 @@
 
         if (slave->current_state == EC_SLAVE_STATE_INIT) {
             EC_SLAVE_WARN(slave, "Aborting SDO request, slave is in INIT.\n");
-            request->req.state = EC_INT_REQUEST_FAILURE;
+            request->state = EC_INT_REQUEST_FAILURE;
             wake_up(&slave->sdo_queue);
             fsm->sdo_request = NULL;
             fsm->state = ec_fsm_slave_state_idle;
             return 0;
         }
 
-        request->req.state = EC_INT_REQUEST_BUSY;
+        request->state = EC_INT_REQUEST_BUSY;
 
         // Found pending SDO request. Execute it!
         EC_SLAVE_DBG(slave, 1, "Processing SDO request...\n");
 
         // Start SDO transfer
-        fsm->sdo_request = &request->req;
+        fsm->sdo_request = request;
         fsm->state = ec_fsm_slave_state_sdo_request;
-        ec_fsm_coe_transfer(&fsm->fsm_coe, slave, &request->req);
+        ec_fsm_coe_transfer(&fsm->fsm_coe, slave, request);
         ec_fsm_coe_exec(&fsm->fsm_coe); // execute immediately
         ec_master_queue_external_datagram(fsm->slave->master, fsm->datagram);
         return 1;
--- a/master/master.c	Tue Dec 04 12:59:15 2012 +0100
+++ b/master/master.c	Tue Dec 04 13:28:38 2012 +0100
@@ -2665,7 +2665,8 @@
         uint16_t index, uint8_t subindex, uint8_t *data,
         size_t data_size, uint32_t *abort_code)
 {
-    ec_master_sdo_request_t request;
+    ec_sdo_request_t request;
+    ec_slave_t *slave;
 
     EC_MASTER_DBG(master, 1, "%s(master = 0x%p,"
             " slave_position = %u, index = 0x%04X, subindex = 0x%02X,"
@@ -2678,61 +2679,64 @@
         return -EINVAL;
     }
 
-    ec_sdo_request_init(&request.req);
-    ecrt_sdo_request_index(&request.req, index, subindex);
-    if (ec_sdo_request_alloc(&request.req, data_size)) {
-        ec_sdo_request_clear(&request.req);
+    ec_sdo_request_init(&request);
+    ecrt_sdo_request_index(&request, index, subindex);
+    if (ec_sdo_request_alloc(&request, data_size)) {
+        ec_sdo_request_clear(&request);
         return -ENOMEM;
     }
 
-    memcpy(request.req.data, data, data_size);
-    request.req.data_size = data_size;
-    ecrt_sdo_request_write(&request.req);
-
-    if (down_interruptible(&master->master_sem))
+    memcpy(request.data, data, data_size);
+    request.data_size = data_size;
+    ecrt_sdo_request_write(&request);
+
+    if (down_interruptible(&master->master_sem)) {
+        ec_sdo_request_clear(&request);
         return -EINTR;
-
-    if (!(request.slave = ec_master_find_slave(master, 0, slave_position))) {
+    }
+
+    if (!(slave = ec_master_find_slave(master, 0, slave_position))) {
         up(&master->master_sem);
         EC_MASTER_ERR(master, "Slave %u does not exist!\n", slave_position);
-        ec_sdo_request_clear(&request.req);
+        ec_sdo_request_clear(&request);
         return -EINVAL;
     }
 
-    EC_SLAVE_DBG(request.slave, 1, "Schedule SDO download request.\n");
+    EC_SLAVE_DBG(slave, 1, "Schedule SDO download request.\n");
 
     // schedule request.
-    list_add_tail(&request.list, &request.slave->sdo_requests);
+    list_add_tail(&request.list, &slave->sdo_requests);
 
     up(&master->master_sem);
 
     // wait for processing through FSM
-    if (wait_event_interruptible(request.slave->sdo_queue,
-                request.req.state != EC_INT_REQUEST_QUEUED)) {
+    if (wait_event_interruptible(slave->sdo_queue,
+                request.state != EC_INT_REQUEST_QUEUED)) {
         // interrupted by signal
         down(&master->master_sem);
-        if (request.req.state == EC_INT_REQUEST_QUEUED) {
+        if (request.state == EC_INT_REQUEST_QUEUED) {
             list_del(&request.list);
             up(&master->master_sem);
-            ec_sdo_request_clear(&request.req);
+            ec_sdo_request_clear(&request);
             return -EINTR;
         }
         // request already processing: interrupt not possible.
         up(&master->master_sem);
     }
 
+    // FIXME slave may become invalid!
+
     // wait until master FSM has finished processing
-    wait_event(request.slave->sdo_queue,
-            request.req.state != EC_INT_REQUEST_BUSY);
-
-    EC_SLAVE_DBG(request.slave, 1, "Finished SDO download request.\n");
-
-    *abort_code = request.req.abort_code;
-
-    if (request.req.state == EC_INT_REQUEST_SUCCESS) {
+    wait_event(slave->sdo_queue, request.state != EC_INT_REQUEST_BUSY);
+
+    EC_SLAVE_DBG(slave, 1, "Finished SDO download request.\n");
+
+    *abort_code = request.abort_code;
+
+    if (request.state == EC_INT_REQUEST_SUCCESS) {
         return 0;
-    } else if (request.req.errno) {
-        return -request.req.errno;
+    } else if (request.errno) {
+        return -request.errno;
     } else {
         return -EIO;
     }
@@ -2744,7 +2748,8 @@
         uint16_t slave_position, uint16_t index, uint8_t *data,
         size_t data_size, uint32_t *abort_code)
 {
-    ec_master_sdo_request_t request;
+    ec_sdo_request_t request;
+    ec_slave_t *slave;
 
     EC_MASTER_DBG(master, 1, "%s(master = 0x%p,"
             " slave_position = %u, index = 0x%04X,"
@@ -2757,64 +2762,67 @@
         return -EINVAL;
     }
 
-    ec_sdo_request_init(&request.req);
-    ecrt_sdo_request_index(&request.req, index, 0);
-    if (ec_sdo_request_alloc(&request.req, data_size)) {
-        ec_sdo_request_clear(&request.req);
+    ec_sdo_request_init(&request);
+    ecrt_sdo_request_index(&request, index, 0);
+    if (ec_sdo_request_alloc(&request, data_size)) {
+        ec_sdo_request_clear(&request);
         return -ENOMEM;
     }
 
-    request.req.complete_access = 1;
-    memcpy(request.req.data, data, data_size);
-    request.req.data_size = data_size;
-    ecrt_sdo_request_write(&request.req);
-
-    if (down_interruptible(&master->master_sem))
+    request.complete_access = 1;
+    memcpy(request.data, data, data_size);
+    request.data_size = data_size;
+    ecrt_sdo_request_write(&request);
+
+    if (down_interruptible(&master->master_sem)) {
+        ec_sdo_request_clear(&request);
         return -EINTR;
-
-    if (!(request.slave = ec_master_find_slave(master, 0, slave_position))) {
+    }
+
+    if (!(slave = ec_master_find_slave(master, 0, slave_position))) {
         up(&master->master_sem);
         EC_MASTER_ERR(master, "Slave %u does not exist!\n", slave_position);
-        ec_sdo_request_clear(&request.req);
+        ec_sdo_request_clear(&request);
         return -EINVAL;
     }
 
-    EC_SLAVE_DBG(request.slave, 1, "Schedule SDO download request"
+    EC_SLAVE_DBG(slave, 1, "Schedule SDO download request"
             " (complete access).\n");
 
     // schedule request.
-    list_add_tail(&request.list, &request.slave->sdo_requests);
+    list_add_tail(&request.list, &slave->sdo_requests);
 
     up(&master->master_sem);
 
     // wait for processing through FSM
-    if (wait_event_interruptible(request.slave->sdo_queue,
-                request.req.state != EC_INT_REQUEST_QUEUED)) {
+    if (wait_event_interruptible(slave->sdo_queue,
+                request.state != EC_INT_REQUEST_QUEUED)) {
         // interrupted by signal
         down(&master->master_sem);
-        if (request.req.state == EC_INT_REQUEST_QUEUED) {
+        if (request.state == EC_INT_REQUEST_QUEUED) {
             list_del(&request.list);
             up(&master->master_sem);
-            ec_sdo_request_clear(&request.req);
+            ec_sdo_request_clear(&request);
             return -EINTR;
         }
         // request already processing: interrupt not possible.
         up(&master->master_sem);
     }
 
+    // FIXME slave may become invalid!
+
     // wait until master FSM has finished processing
-    wait_event(request.slave->sdo_queue,
-            request.req.state != EC_INT_REQUEST_BUSY);
-
-    EC_SLAVE_DBG(request.slave, 1, "Finished SDO download request"
+    wait_event(slave->sdo_queue, request.state != EC_INT_REQUEST_BUSY);
+
+    EC_SLAVE_DBG(slave, 1, "Finished SDO download request"
             " (complete access).\n");
 
-    *abort_code = request.req.abort_code;
-
-    if (request.req.state == EC_INT_REQUEST_SUCCESS) {
+    *abort_code = request.abort_code;
+
+    if (request.state == EC_INT_REQUEST_SUCCESS) {
         return 0;
-    } else if (request.req.errno) {
-        return -request.req.errno;
+    } else if (request.errno) {
+        return -request.errno;
     } else {
         return -EIO;
     }
@@ -2826,7 +2834,8 @@
         uint16_t index, uint8_t subindex, uint8_t *target,
         size_t target_size, size_t *result_size, uint32_t *abort_code)
 {
-    ec_master_sdo_request_t request;
+    ec_sdo_request_t request;
+    ec_slave_t *slave;
     int retval = 0;
 
     EC_MASTER_DBG(master, 1, "%s(master = 0x%p,"
@@ -2836,69 +2845,71 @@
             __func__, master, slave_position, index, subindex,
             target, target_size, result_size, abort_code);
 
-    ec_sdo_request_init(&request.req);
-    ecrt_sdo_request_index(&request.req, index, subindex);
-    ecrt_sdo_request_read(&request.req);
+    ec_sdo_request_init(&request);
+    ecrt_sdo_request_index(&request, index, subindex);
+    ecrt_sdo_request_read(&request);
 
     if (down_interruptible(&master->master_sem)) {
+        ec_sdo_request_clear(&request);
         return -EINTR;
     }
 
-    if (!(request.slave = ec_master_find_slave(master, 0, slave_position))) {
+    if (!(slave = ec_master_find_slave(master, 0, slave_position))) {
         up(&master->master_sem);
-        ec_sdo_request_clear(&request.req);
+        ec_sdo_request_clear(&request);
         EC_MASTER_ERR(master, "Slave %u does not exist!\n", slave_position);
         return -EINVAL;
     }
 
-    EC_SLAVE_DBG(request.slave, 1, "Schedule SDO upload request.\n");
+    EC_SLAVE_DBG(slave, 1, "Schedule SDO upload request.\n");
 
     // schedule request.
-    list_add_tail(&request.list, &request.slave->sdo_requests);
+    list_add_tail(&request.list, &slave->sdo_requests);
 
     up(&master->master_sem);
 
     // wait for processing through FSM
-    if (wait_event_interruptible(request.slave->sdo_queue,
-                request.req.state != EC_INT_REQUEST_QUEUED)) {
+    if (wait_event_interruptible(slave->sdo_queue,
+                request.state != EC_INT_REQUEST_QUEUED)) {
         // interrupted by signal
         down(&master->master_sem);
-        if (request.req.state == EC_INT_REQUEST_QUEUED) {
+        if (request.state == EC_INT_REQUEST_QUEUED) {
             list_del(&request.list);
             up(&master->master_sem);
-            ec_sdo_request_clear(&request.req);
+            ec_sdo_request_clear(&request);
             return -EINTR;
         }
         // request already processing: interrupt not possible.
         up(&master->master_sem);
     }
 
+    // FIXME slave may become invalid!
+
     // wait until master FSM has finished processing
-    wait_event(request.slave->sdo_queue,
-            request.req.state != EC_INT_REQUEST_BUSY);
-
-    EC_SLAVE_DBG(request.slave, 1, "Finished SDO upload request.\n");
-
-    *abort_code = request.req.abort_code;
-
-    if (request.req.state != EC_INT_REQUEST_SUCCESS) {
+    wait_event(slave->sdo_queue, request.state != EC_INT_REQUEST_BUSY);
+
+    EC_SLAVE_DBG(slave, 1, "Finished SDO upload request.\n");
+
+    *abort_code = request.abort_code;
+
+    if (request.state != EC_INT_REQUEST_SUCCESS) {
         *result_size = 0;
-        if (request.req.errno) {
-            retval = -request.req.errno;
+        if (request.errno) {
+            retval = -request.errno;
         } else {
             retval = -EIO;
         }
     } else {
-        if (request.req.data_size > target_size) {
+        if (request.data_size > target_size) {
             EC_MASTER_ERR(master, "Buffer too small.\n");
-            ec_sdo_request_clear(&request.req);
+            ec_sdo_request_clear(&request);
             return -EOVERFLOW;
         }
-        memcpy(target, request.req.data, request.req.data_size);
-        *result_size = request.req.data_size;
-    }
-
-    ec_sdo_request_clear(&request.req);
+        memcpy(target, request.data, request.data_size);
+        *result_size = request.data_size;
+    }
+
+    ec_sdo_request_clear(&request);
     return retval;
 }
 
--- a/master/slave.c	Tue Dec 04 12:59:15 2012 +0100
+++ b/master/slave.c	Tue Dec 04 13:28:38 2012 +0100
@@ -195,13 +195,12 @@
     // abort all pending requests
 
     while (!list_empty(&slave->sdo_requests)) {
-        ec_master_sdo_request_t *request =
-            list_entry(slave->sdo_requests.next,
-                ec_master_sdo_request_t, list);
+        ec_sdo_request_t *request =
+            list_entry(slave->sdo_requests.next, ec_sdo_request_t, list);
         list_del_init(&request->list); // dequeue
         EC_SLAVE_WARN(slave, "Discarding SDO request,"
                 " slave about to be deleted.\n");
-        request->req.state = EC_INT_REQUEST_FAILURE;
+        request->state = EC_INT_REQUEST_FAILURE;
         wake_up(&slave->sdo_queue);
     }