1// SPDX-License-Identifier: GPL-2.0-only
2/*
3 * Copyright 2007-2012 Siemens AG
4 *
5 * Written by:
6 * Dmitry Eremin-Solenikov <dbaryshkov@gmail.com>
7 * Sergey Lapin <slapin@ossfans.org>
8 * Maxim Gorbachyov <maxim.gorbachev@siemens.com>
9 * Alexander Smirnov <alex.bluesman.smirnov@gmail.com>
10 */
11
12#include <linux/netdevice.h>
13#include <linux/if_arp.h>
14#include <linux/crc-ccitt.h>
15#include <asm/unaligned.h>
16
17#include <net/rtnetlink.h>
18#include <net/ieee802154_netdev.h>
19#include <net/mac802154.h>
20#include <net/cfg802154.h>
21
22#include "ieee802154_i.h"
23#include "driver-ops.h"
24
25void ieee802154_xmit_sync_worker(struct work_struct *work)
26{
27 struct ieee802154_local *local =
28 container_of(work, struct ieee802154_local, sync_tx_work);
29 struct sk_buff *skb = local->tx_skb;
30 struct net_device *dev = skb->dev;
31 int res;
32
33 res = drv_xmit_sync(local, skb);
34 if (res)
35 goto err_tx;
36
37 dev->stats.tx_packets++;
38 dev->stats.tx_bytes += skb->len;
39
40 ieee802154_xmit_complete(hw: &local->hw, skb, ifs_handling: false);
41
42 return;
43
44err_tx:
45 /* Restart the netif queue on each sub_if_data object. */
46 ieee802154_release_queue(local);
47 if (atomic_dec_and_test(v: &local->phy->ongoing_txs))
48 wake_up(&local->phy->sync_txq);
49 kfree_skb(skb);
50 netdev_dbg(dev, "transmission failed\n");
51}
52
53static netdev_tx_t
54ieee802154_tx(struct ieee802154_local *local, struct sk_buff *skb)
55{
56 struct net_device *dev = skb->dev;
57 int ret;
58
59 if (!(local->hw.flags & IEEE802154_HW_TX_OMIT_CKSUM)) {
60 struct sk_buff *nskb;
61 u16 crc;
62
63 if (unlikely(skb_tailroom(skb) < IEEE802154_FCS_LEN)) {
64 nskb = skb_copy_expand(skb, newheadroom: 0, IEEE802154_FCS_LEN,
65 GFP_ATOMIC);
66 if (likely(nskb)) {
67 consume_skb(skb);
68 skb = nskb;
69 } else {
70 goto err_free_skb;
71 }
72 }
73
74 crc = crc_ccitt(crc: 0, buffer: skb->data, len: skb->len);
75 put_unaligned_le16(val: crc, p: skb_put(skb, len: 2));
76 }
77
78 /* Stop the netif queue on each sub_if_data object. */
79 ieee802154_hold_queue(local);
80 atomic_inc(v: &local->phy->ongoing_txs);
81
82 /* Drivers should preferably implement the async callback. In some rare
83 * cases they only provide a sync callback which we will use as a
84 * fallback.
85 */
86 if (local->ops->xmit_async) {
87 unsigned int len = skb->len;
88
89 ret = drv_xmit_async(local, skb);
90 if (ret)
91 goto err_wake_netif_queue;
92
93 dev->stats.tx_packets++;
94 dev->stats.tx_bytes += len;
95 } else {
96 local->tx_skb = skb;
97 queue_work(wq: local->workqueue, work: &local->sync_tx_work);
98 }
99
100 return NETDEV_TX_OK;
101
102err_wake_netif_queue:
103 ieee802154_release_queue(local);
104 if (atomic_dec_and_test(v: &local->phy->ongoing_txs))
105 wake_up(&local->phy->sync_txq);
106err_free_skb:
107 kfree_skb(skb);
108 return NETDEV_TX_OK;
109}
110
111static int ieee802154_sync_queue(struct ieee802154_local *local)
112{
113 int ret;
114
115 ieee802154_hold_queue(local);
116 ieee802154_disable_queue(local);
117 wait_event(local->phy->sync_txq, !atomic_read(&local->phy->ongoing_txs));
118 ret = local->tx_result;
119 ieee802154_release_queue(local);
120
121 return ret;
122}
123
124int ieee802154_sync_and_hold_queue(struct ieee802154_local *local)
125{
126 int ret;
127
128 ieee802154_hold_queue(local);
129 ret = ieee802154_sync_queue(local);
130 set_bit(nr: WPAN_PHY_FLAG_STATE_QUEUE_STOPPED, addr: &local->phy->flags);
131
132 return ret;
133}
134
135int ieee802154_mlme_op_pre(struct ieee802154_local *local)
136{
137 return ieee802154_sync_and_hold_queue(local);
138}
139
140int ieee802154_mlme_tx_locked(struct ieee802154_local *local,
141 struct ieee802154_sub_if_data *sdata,
142 struct sk_buff *skb)
143{
144 /* Avoid possible calls to ->ndo_stop() when we asynchronously perform
145 * MLME transmissions.
146 */
147 ASSERT_RTNL();
148
149 /* Ensure the device was not stopped, otherwise error out */
150 if (!local->open_count)
151 return -ENETDOWN;
152
153 /* Warn if the ieee802154 core thinks MLME frames can be sent while the
154 * net interface expects this cannot happen.
155 */
156 if (WARN_ON_ONCE(!netif_running(sdata->dev)))
157 return -ENETDOWN;
158
159 ieee802154_tx(local, skb);
160 return ieee802154_sync_queue(local);
161}
162
163int ieee802154_mlme_tx(struct ieee802154_local *local,
164 struct ieee802154_sub_if_data *sdata,
165 struct sk_buff *skb)
166{
167 int ret;
168
169 rtnl_lock();
170 ret = ieee802154_mlme_tx_locked(local, sdata, skb);
171 rtnl_unlock();
172
173 return ret;
174}
175
176void ieee802154_mlme_op_post(struct ieee802154_local *local)
177{
178 ieee802154_release_queue(local);
179}
180
181int ieee802154_mlme_tx_one(struct ieee802154_local *local,
182 struct ieee802154_sub_if_data *sdata,
183 struct sk_buff *skb)
184{
185 int ret;
186
187 ieee802154_mlme_op_pre(local);
188 ret = ieee802154_mlme_tx(local, sdata, skb);
189 ieee802154_mlme_op_post(local);
190
191 return ret;
192}
193
194int ieee802154_mlme_tx_one_locked(struct ieee802154_local *local,
195 struct ieee802154_sub_if_data *sdata,
196 struct sk_buff *skb)
197{
198 int ret;
199
200 ieee802154_mlme_op_pre(local);
201 ret = ieee802154_mlme_tx_locked(local, sdata, skb);
202 ieee802154_mlme_op_post(local);
203
204 return ret;
205}
206
207static bool ieee802154_queue_is_stopped(struct ieee802154_local *local)
208{
209 return test_bit(WPAN_PHY_FLAG_STATE_QUEUE_STOPPED, &local->phy->flags);
210}
211
212static netdev_tx_t
213ieee802154_hot_tx(struct ieee802154_local *local, struct sk_buff *skb)
214{
215 /* Warn if the net interface tries to transmit frames while the
216 * ieee802154 core assumes the queue is stopped.
217 */
218 WARN_ON_ONCE(ieee802154_queue_is_stopped(local));
219
220 return ieee802154_tx(local, skb);
221}
222
223netdev_tx_t
224ieee802154_monitor_start_xmit(struct sk_buff *skb, struct net_device *dev)
225{
226 struct ieee802154_sub_if_data *sdata = IEEE802154_DEV_TO_SUB_IF(dev);
227
228 skb->skb_iif = dev->ifindex;
229
230 return ieee802154_hot_tx(local: sdata->local, skb);
231}
232
233netdev_tx_t
234ieee802154_subif_start_xmit(struct sk_buff *skb, struct net_device *dev)
235{
236 struct ieee802154_sub_if_data *sdata = IEEE802154_DEV_TO_SUB_IF(dev);
237 int rc;
238
239 /* TODO we should move it to wpan_dev_hard_header and dev_hard_header
240 * functions. The reason is wireshark will show a mac header which is
241 * with security fields but the payload is not encrypted.
242 */
243 rc = mac802154_llsec_encrypt(sec: &sdata->sec, skb);
244 if (rc) {
245 netdev_warn(dev, format: "encryption failed: %i\n", rc);
246 kfree_skb(skb);
247 return NETDEV_TX_OK;
248 }
249
250 skb->skb_iif = dev->ifindex;
251
252 return ieee802154_hot_tx(local: sdata->local, skb);
253}
254

source code of linux/net/mac802154/tx.c