diff options
author | Thomas Gleixner <tglx@linutronix.de> | 2014-03-18 13:19:09 -0400 |
---|---|---|
committer | Marc Kleine-Budde <mkl@pengutronix.de> | 2014-04-01 05:54:58 -0400 |
commit | 640916db2bf7de7c5ac13a1f470fa959459ccf6d (patch) | |
tree | a2cc8b9df2cec515c2bb8f958d715cbd43cbb671 | |
parent | 5bb9cbaa622a2bbde8e307d4e0528dd2c8212a6a (diff) |
can: c_can: Make it SMP safe
The hardware has two message control interfaces, but the code only uses the
first one. So on SMP the following can be observed:
CPU0 CPU1
rx_poll()
write IF1 xmit()
write IF1
write IF1
That results in corrupted message object configurations. The TX/RX is not
globally serialized it's only serialized on a core.
Simple solution: Let RX use IF1 and TX use IF2 and all is good.
Signed-off-by: Thomas Gleixner <tglx@linutronix.de>
Signed-off-by: Marc Kleine-Budde <mkl@pengutronix.de>
-rw-r--r-- | drivers/net/can/c_can/c_can.c | 36 |
1 files changed, 21 insertions, 15 deletions
diff --git a/drivers/net/can/c_can/c_can.c b/drivers/net/can/c_can/c_can.c index 4d08a32f27ac..38f9adaf15ac 100644 --- a/drivers/net/can/c_can/c_can.c +++ b/drivers/net/can/c_can/c_can.c | |||
@@ -133,6 +133,12 @@ | |||
133 | #define IF_MCONT_DLC_MASK 0xf | 133 | #define IF_MCONT_DLC_MASK 0xf |
134 | 134 | ||
135 | /* | 135 | /* |
136 | * Use IF1 for RX and IF2 for TX | ||
137 | */ | ||
138 | #define IF_RX 0 | ||
139 | #define IF_TX 1 | ||
140 | |||
141 | /* | ||
136 | * IFx register masks: | 142 | * IFx register masks: |
137 | * allow easy operation on 16-bit registers when the | 143 | * allow easy operation on 16-bit registers when the |
138 | * argument is 32-bit instead | 144 | * argument is 32-bit instead |
@@ -420,7 +426,7 @@ static void c_can_handle_lost_msg_obj(struct net_device *dev, | |||
420 | priv->write_reg(priv, C_CAN_IFACE(MSGCTRL_REG, iface), | 426 | priv->write_reg(priv, C_CAN_IFACE(MSGCTRL_REG, iface), |
421 | IF_MCONT_CLR_MSGLST); | 427 | IF_MCONT_CLR_MSGLST); |
422 | 428 | ||
423 | c_can_object_put(dev, 0, objno, IF_COMM_CONTROL); | 429 | c_can_object_put(dev, iface, objno, IF_COMM_CONTROL); |
424 | 430 | ||
425 | /* create an error msg */ | 431 | /* create an error msg */ |
426 | skb = alloc_can_err_skb(dev, &frame); | 432 | skb = alloc_can_err_skb(dev, &frame); |
@@ -551,7 +557,7 @@ static netdev_tx_t c_can_start_xmit(struct sk_buff *skb, | |||
551 | msg_obj_no = get_tx_next_msg_obj(priv); | 557 | msg_obj_no = get_tx_next_msg_obj(priv); |
552 | 558 | ||
553 | /* prepare message object for transmission */ | 559 | /* prepare message object for transmission */ |
554 | c_can_write_msg_object(dev, 0, frame, msg_obj_no); | 560 | c_can_write_msg_object(dev, IF_TX, frame, msg_obj_no); |
555 | can_put_echo_skb(skb, dev, msg_obj_no - C_CAN_MSG_OBJ_TX_FIRST); | 561 | can_put_echo_skb(skb, dev, msg_obj_no - C_CAN_MSG_OBJ_TX_FIRST); |
556 | 562 | ||
557 | /* | 563 | /* |
@@ -634,14 +640,14 @@ static void c_can_configure_msg_objects(struct net_device *dev) | |||
634 | 640 | ||
635 | /* first invalidate all message objects */ | 641 | /* first invalidate all message objects */ |
636 | for (i = C_CAN_MSG_OBJ_RX_FIRST; i <= C_CAN_NO_OF_OBJECTS; i++) | 642 | for (i = C_CAN_MSG_OBJ_RX_FIRST; i <= C_CAN_NO_OF_OBJECTS; i++) |
637 | c_can_inval_msg_object(dev, 0, i); | 643 | c_can_inval_msg_object(dev, IF_RX, i); |
638 | 644 | ||
639 | /* setup receive message objects */ | 645 | /* setup receive message objects */ |
640 | for (i = C_CAN_MSG_OBJ_RX_FIRST; i < C_CAN_MSG_OBJ_RX_LAST; i++) | 646 | for (i = C_CAN_MSG_OBJ_RX_FIRST; i < C_CAN_MSG_OBJ_RX_LAST; i++) |
641 | c_can_setup_receive_object(dev, 0, i, 0, 0, | 647 | c_can_setup_receive_object(dev, IF_RX, i, 0, 0, |
642 | (IF_MCONT_RXIE | IF_MCONT_UMASK) & ~IF_MCONT_EOB); | 648 | (IF_MCONT_RXIE | IF_MCONT_UMASK) & ~IF_MCONT_EOB); |
643 | 649 | ||
644 | c_can_setup_receive_object(dev, 0, C_CAN_MSG_OBJ_RX_LAST, 0, 0, | 650 | c_can_setup_receive_object(dev, IF_RX, C_CAN_MSG_OBJ_RX_LAST, 0, 0, |
645 | IF_MCONT_EOB | IF_MCONT_RXIE | IF_MCONT_UMASK); | 651 | IF_MCONT_EOB | IF_MCONT_RXIE | IF_MCONT_UMASK); |
646 | } | 652 | } |
647 | 653 | ||
@@ -792,13 +798,13 @@ static void c_can_do_tx(struct net_device *dev) | |||
792 | if (!(val & (1 << (msg_obj_no - 1)))) { | 798 | if (!(val & (1 << (msg_obj_no - 1)))) { |
793 | can_get_echo_skb(dev, | 799 | can_get_echo_skb(dev, |
794 | msg_obj_no - C_CAN_MSG_OBJ_TX_FIRST); | 800 | msg_obj_no - C_CAN_MSG_OBJ_TX_FIRST); |
795 | c_can_object_get(dev, 0, msg_obj_no, IF_COMM_ALL); | 801 | c_can_object_get(dev, IF_TX, msg_obj_no, IF_COMM_ALL); |
796 | stats->tx_bytes += priv->read_reg(priv, | 802 | stats->tx_bytes += priv->read_reg(priv, |
797 | C_CAN_IFACE(MSGCTRL_REG, 0)) | 803 | C_CAN_IFACE(MSGCTRL_REG, IF_TX)) |
798 | & IF_MCONT_DLC_MASK; | 804 | & IF_MCONT_DLC_MASK; |
799 | stats->tx_packets++; | 805 | stats->tx_packets++; |
800 | can_led_event(dev, CAN_LED_EVENT_TX); | 806 | can_led_event(dev, CAN_LED_EVENT_TX); |
801 | c_can_inval_msg_object(dev, 0, msg_obj_no); | 807 | c_can_inval_msg_object(dev, IF_TX, msg_obj_no); |
802 | } else { | 808 | } else { |
803 | break; | 809 | break; |
804 | } | 810 | } |
@@ -850,13 +856,13 @@ static int c_can_do_rx_poll(struct net_device *dev, int quota) | |||
850 | while ((msg_obj = ffs(val)) && quota > 0) { | 856 | while ((msg_obj = ffs(val)) && quota > 0) { |
851 | val &= ~BIT(msg_obj - 1); | 857 | val &= ~BIT(msg_obj - 1); |
852 | 858 | ||
853 | c_can_object_get(dev, 0, msg_obj, IF_COMM_ALL & | 859 | c_can_object_get(dev, IF_RX, msg_obj, IF_COMM_ALL & |
854 | ~IF_COMM_TXRQST); | 860 | ~IF_COMM_TXRQST); |
855 | msg_ctrl_save = priv->read_reg(priv, | 861 | msg_ctrl_save = priv->read_reg(priv, |
856 | C_CAN_IFACE(MSGCTRL_REG, 0)); | 862 | C_CAN_IFACE(MSGCTRL_REG, IF_RX)); |
857 | 863 | ||
858 | if (msg_ctrl_save & IF_MCONT_MSGLST) { | 864 | if (msg_ctrl_save & IF_MCONT_MSGLST) { |
859 | c_can_handle_lost_msg_obj(dev, 0, msg_obj); | 865 | c_can_handle_lost_msg_obj(dev, IF_RX, msg_obj); |
860 | num_rx_pkts++; | 866 | num_rx_pkts++; |
861 | quota--; | 867 | quota--; |
862 | continue; | 868 | continue; |
@@ -869,19 +875,19 @@ static int c_can_do_rx_poll(struct net_device *dev, int quota) | |||
869 | continue; | 875 | continue; |
870 | 876 | ||
871 | /* read the data from the message object */ | 877 | /* read the data from the message object */ |
872 | c_can_read_msg_object(dev, 0, msg_ctrl_save); | 878 | c_can_read_msg_object(dev, IF_RX, msg_ctrl_save); |
873 | 879 | ||
874 | if (msg_obj < C_CAN_MSG_RX_LOW_LAST) | 880 | if (msg_obj < C_CAN_MSG_RX_LOW_LAST) |
875 | c_can_mark_rx_msg_obj(dev, 0, | 881 | c_can_mark_rx_msg_obj(dev, IF_RX, |
876 | msg_ctrl_save, msg_obj); | 882 | msg_ctrl_save, msg_obj); |
877 | else if (msg_obj > C_CAN_MSG_RX_LOW_LAST) | 883 | else if (msg_obj > C_CAN_MSG_RX_LOW_LAST) |
878 | /* activate this msg obj */ | 884 | /* activate this msg obj */ |
879 | c_can_activate_rx_msg_obj(dev, 0, | 885 | c_can_activate_rx_msg_obj(dev, IF_RX, |
880 | msg_ctrl_save, msg_obj); | 886 | msg_ctrl_save, msg_obj); |
881 | else if (msg_obj == C_CAN_MSG_RX_LOW_LAST) | 887 | else if (msg_obj == C_CAN_MSG_RX_LOW_LAST) |
882 | /* activate all lower message objects */ | 888 | /* activate all lower message objects */ |
883 | c_can_activate_all_lower_rx_msg_obj(dev, | 889 | c_can_activate_all_lower_rx_msg_obj(dev, |
884 | 0, msg_ctrl_save); | 890 | IF_RX, msg_ctrl_save); |
885 | 891 | ||
886 | num_rx_pkts++; | 892 | num_rx_pkts++; |
887 | quota--; | 893 | quota--; |