Quellcodebibliothek Statistik Leitseite products/sources/formale Sprachen/C/Linux/drivers/net/wireless/virtual/   (Open Source Betriebssystem Version 6.17.9©)  Datei vom 24.10.2025 mit Größe 194 kB image not shown  

Quelle  mac80211_hwsim.c   Sprache: C

 
// SPDX-License-Identifier: GPL-2.0-only
/*
 * mac80211_hwsim - software simulator of 802.11 radio(s) for mac80211
 * Copyright (c) 2008, Jouni Malinen <j@w1.fi>
 * Copyright (c) 2011, Javier Lopez <jlopex@gmail.com>
 * Copyright (c) 2016 - 2017 Intel Deutschland GmbH
 * Copyright (C) 2018 - 2025 Intel Corporation
 */


/*
 * TODO:
 * - Add TSF sync and fix IBSS beacon transmission by adding
 *   competition for "air time" at TBTT
 * - RX filtering based on filter configuration (data->rx_filter)
 */


#include <linux/list.h>
#include <linux/slab.h>
#include <linux/spinlock.h>
#include <net/dst.h>
#include <net/xfrm.h>
#include <net/mac80211.h>
#include <net/ieee80211_radiotap.h>
#include <linux/if_arp.h>
#include <linux/rtnetlink.h>
#include <linux/etherdevice.h>
#include <linux/platform_device.h>
#include <linux/debugfs.h>
#include <linux/module.h>
#include <linux/ktime.h>
#include <net/genetlink.h>
#include <net/net_namespace.h>
#include <net/netns/generic.h>
#include <linux/rhashtable.h>
#include <linux/nospec.h>
#include <linux/virtio.h>
#include <linux/virtio_ids.h>
#include <linux/virtio_config.h>
#include "mac80211_hwsim.h"

#define WARN_QUEUE 100
#define MAX_QUEUE 200

MODULE_AUTHOR("Jouni Malinen");
MODULE_DESCRIPTION("Software simulator of 802.11 radio(s) for mac80211");
MODULE_LICENSE("GPL");

static int radios = 2;
module_param(radios, int, 0444);
MODULE_PARM_DESC(radios, "Number of simulated radios");

static int channels = 1;
module_param(channels, int, 0444);
MODULE_PARM_DESC(channels, "Number of concurrent channels");

static bool paged_rx = false;
module_param(paged_rx, bool, 0644);
MODULE_PARM_DESC(paged_rx, "Use paged SKBs for RX instead of linear ones");

static bool rctbl = false;
module_param(rctbl, bool, 0444);
MODULE_PARM_DESC(rctbl, "Handle rate control table");

static bool support_p2p_device = true;
module_param(support_p2p_device, bool, 0444);
MODULE_PARM_DESC(support_p2p_device, "Support P2P-Device interface type");

static bool mlo;
module_param(mlo, bool, 0444);
MODULE_PARM_DESC(mlo, "Support MLO");

static bool multi_radio;
module_param(multi_radio, bool, 0444);
MODULE_PARM_DESC(multi_radio, "Support Multiple Radios per wiphy");

/**
 * enum hwsim_regtest - the type of regulatory tests we offer
 *
 * @HWSIM_REGTEST_DISABLED: No regulatory tests are performed,
 *  this is the default value.
 * @HWSIM_REGTEST_DRIVER_REG_FOLLOW: Used for testing the driver regulatory
 * hint, only one driver regulatory hint will be sent as such the
 *  secondary radios are expected to follow.
 * @HWSIM_REGTEST_DRIVER_REG_ALL: Used for testing the driver regulatory
 *  request with all radios reporting the same regulatory domain.
 * @HWSIM_REGTEST_DIFF_COUNTRY: Used for testing the drivers calling
 *  different regulatory domains requests. Expected behaviour is for
 *  an intersection to occur but each device will still use their
 *  respective regulatory requested domains. Subsequent radios will
 *  use the resulting intersection.
 * @HWSIM_REGTEST_WORLD_ROAM: Used for testing the world roaming. We accomplish
 * this by using a custom beacon-capable regulatory domain for the first
 * radio. All other device world roam.
 * @HWSIM_REGTEST_CUSTOM_WORLD: Used for testing the custom world regulatory
 *  domain requests. All radios will adhere to this custom world regulatory
 *  domain.
 * @HWSIM_REGTEST_CUSTOM_WORLD_2: Used for testing 2 custom world regulatory
 *  domain requests. The first radio will adhere to the first custom world
 *  regulatory domain, the second one to the second custom world regulatory
 *  domain. All other devices will world roam.
 * @HWSIM_REGTEST_STRICT_FOLLOW: Used for testing strict regulatory domain
 * settings, only the first radio will send a regulatory domain request
 * and use strict settings. The rest of the radios are expected to follow.
 * @HWSIM_REGTEST_STRICT_ALL: Used for testing strict regulatory domain
 * settings. All radios will adhere to this.
 * @HWSIM_REGTEST_STRICT_AND_DRIVER_REG: Used for testing strict regulatory
 * domain settings, combined with secondary driver regulatory domain
 * settings. The first radio will get a strict regulatory domain setting
 * using the first driver regulatory request and the second radio will use
 * non-strict settings using the second driver regulatory request. All
 * other devices should follow the intersection created between the
 * first two.
 * @HWSIM_REGTEST_ALL: Used for testing every possible mix. You will need
 *  at least 6 radios for a complete test. We will test in this order:
 *  1 - driver custom world regulatory domain
 *  2 - second custom world regulatory domain
 *  3 - first driver regulatory domain request
 *  4 - second driver regulatory domain request
 *  5 - strict regulatory domain settings using the third driver regulatory
 *      domain request
 *  6 and on - should follow the intersection of the 3rd, 4rth and 5th radio
 *             regulatory requests.
 *
 * These are the different values you can use for the regtest
 * module parameter. This is useful to help test world roaming
 * and the driver regulatory_hint() call and combinations of these.
 * If you want to do specific alpha2 regulatory domain tests simply
 * use the userspace regulatory request as that will be respected as
 * well without the need of this module parameter. This is designed
 * only for testing the driver regulatory request, world roaming
 * and all possible combinations.
 */

enum hwsim_regtest {
 HWSIM_REGTEST_DISABLED = 0,
 HWSIM_REGTEST_DRIVER_REG_FOLLOW = 1,
 HWSIM_REGTEST_DRIVER_REG_ALL = 2,
 HWSIM_REGTEST_DIFF_COUNTRY = 3,
 HWSIM_REGTEST_WORLD_ROAM = 4,
 HWSIM_REGTEST_CUSTOM_WORLD = 5,
 HWSIM_REGTEST_CUSTOM_WORLD_2 = 6,
 HWSIM_REGTEST_STRICT_FOLLOW = 7,
 HWSIM_REGTEST_STRICT_ALL = 8,
 HWSIM_REGTEST_STRICT_AND_DRIVER_REG = 9,
 HWSIM_REGTEST_ALL = 10,
};

/* Set to one of the HWSIM_REGTEST_* values above */
static int regtest = HWSIM_REGTEST_DISABLED;
module_param(regtest, int, 0444);
MODULE_PARM_DESC(regtest, "The type of regulatory test we want to run");

static const char *hwsim_alpha2s[] = {
 "FI",
 "AL",
 "US",
 "DE",
 "JP",
 "AL",
};

static const struct ieee80211_regdomain hwsim_world_regdom_custom_01 = {
 .n_reg_rules = 5,
 .alpha2 =  "99",
 .reg_rules = {
  REG_RULE(2412-10, 2462+10, 40, 0, 20, 0),
  REG_RULE(2484-10, 2484+10, 40, 0, 20, 0),
  REG_RULE(5150-10, 5240+10, 40, 0, 30, 0),
  REG_RULE(5745-10, 5825+10, 40, 0, 30, 0),
  REG_RULE(5855-10, 5925+10, 40, 0, 33, 0),
 }
};

static const struct ieee80211_regdomain hwsim_world_regdom_custom_02 = {
 .n_reg_rules = 3,
 .alpha2 =  "99",
 .reg_rules = {
  REG_RULE(2412-10, 2462+10, 40, 0, 20, 0),
  REG_RULE(5725-10, 5850+10, 40, 0, 30,
    NL80211_RRF_NO_IR),
  REG_RULE(5855-10, 5925+10, 40, 0, 33, 0),
 }
};

static const struct ieee80211_regdomain hwsim_world_regdom_custom_03 = {
 .n_reg_rules = 6,
 .alpha2 =  "99",
 .reg_rules = {
  REG_RULE(2412 - 10, 2462 + 10, 40, 0, 20, 0),
  REG_RULE(2484 - 10, 2484 + 10, 40, 0, 20, 0),
  REG_RULE(5150 - 10, 5240 + 10, 40, 0, 30, 0),
  REG_RULE(5745 - 10, 5825 + 10, 40, 0, 30, 0),
  REG_RULE(5855 - 10, 5925 + 10, 40, 0, 33, 0),
  REG_RULE(5955 - 10, 7125 + 10, 320, 0, 33, 0),
 }
};

static const struct ieee80211_regdomain hwsim_world_regdom_custom_04 = {
 .n_reg_rules = 6,
 .alpha2 =  "99",
 .reg_rules = {
  REG_RULE(2412 - 10, 2462 + 10, 40, 0, 20, 0),
  REG_RULE(2484 - 10, 2484 + 10, 40, 0, 20, 0),
  REG_RULE(5150 - 10, 5240 + 10, 80, 0, 30, NL80211_RRF_AUTO_BW),
  REG_RULE(5260 - 10, 5320 + 10, 80, 0, 30,
    NL80211_RRF_DFS_CONCURRENT | NL80211_RRF_DFS |
    NL80211_RRF_AUTO_BW),
  REG_RULE(5500 - 10, 5720 + 10, 160, 0, 30,
    NL80211_RRF_DFS_CONCURRENT | NL80211_RRF_DFS),
  REG_RULE(5745 - 10, 5825 + 10, 80, 0, 30, 0),
  REG_RULE(5855 - 10, 5925 + 10, 80, 0, 33, 0),
 }
};

static const struct ieee80211_regdomain *hwsim_world_regdom_custom[] = {
 &hwsim_world_regdom_custom_01,
 &hwsim_world_regdom_custom_02,
 &hwsim_world_regdom_custom_03,
 &hwsim_world_regdom_custom_04,
};

struct hwsim_vif_priv {
 u32 magic;
 u32 skip_beacons[IEEE80211_MLD_MAX_NUM_LINKS];
 u8 bssid[ETH_ALEN];
 bool assoc;
 bool bcn_en;
 u16 aid;
};

#define HWSIM_VIF_MAGIC 0x69537748

static inline void hwsim_check_magic(struct ieee80211_vif *vif)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 WARN(vp->magic != HWSIM_VIF_MAGIC,
      "Invalid VIF (%p) magic %#x, %pM, %d/%d\n",
      vif, vp->magic, vif->addr, vif->type, vif->p2p);
}

static inline void hwsim_set_magic(struct ieee80211_vif *vif)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 vp->magic = HWSIM_VIF_MAGIC;
}

static inline void hwsim_clear_magic(struct ieee80211_vif *vif)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 vp->magic = 0;
}

struct hwsim_sta_priv {
 u32 magic;
 unsigned int last_link;
 u16 active_links_rx;
};

#define HWSIM_STA_MAGIC 0x6d537749

static inline void hwsim_check_sta_magic(struct ieee80211_sta *sta)
{
 struct hwsim_sta_priv *sp = (void *)sta->drv_priv;
 WARN_ON(sp->magic != HWSIM_STA_MAGIC);
}

static inline void hwsim_set_sta_magic(struct ieee80211_sta *sta)
{
 struct hwsim_sta_priv *sp = (void *)sta->drv_priv;
 sp->magic = HWSIM_STA_MAGIC;
}

static inline void hwsim_clear_sta_magic(struct ieee80211_sta *sta)
{
 struct hwsim_sta_priv *sp = (void *)sta->drv_priv;
 sp->magic = 0;
}

struct hwsim_chanctx_priv {
 u32 magic;
};

#define HWSIM_CHANCTX_MAGIC 0x6d53774a

static inline void hwsim_check_chanctx_magic(struct ieee80211_chanctx_conf *c)
{
 struct hwsim_chanctx_priv *cp = (void *)c->drv_priv;
 WARN_ON(cp->magic != HWSIM_CHANCTX_MAGIC);
}

static inline void hwsim_set_chanctx_magic(struct ieee80211_chanctx_conf *c)
{
 struct hwsim_chanctx_priv *cp = (void *)c->drv_priv;
 cp->magic = HWSIM_CHANCTX_MAGIC;
}

static inline void hwsim_clear_chanctx_magic(struct ieee80211_chanctx_conf *c)
{
 struct hwsim_chanctx_priv *cp = (void *)c->drv_priv;
 cp->magic = 0;
}

static unsigned int hwsim_net_id;

static DEFINE_IDA(hwsim_netgroup_ida);

struct hwsim_net {
 int netgroup;
 u32 wmediumd;
};

static inline int hwsim_net_get_netgroup(struct net *net)
{
 struct hwsim_net *hwsim_net = net_generic(net, hwsim_net_id);

 return hwsim_net->netgroup;
}

static inline int hwsim_net_set_netgroup(struct net *net)
{
 struct hwsim_net *hwsim_net = net_generic(net, hwsim_net_id);

 hwsim_net->netgroup = ida_alloc(&hwsim_netgroup_ida, GFP_KERNEL);
 return hwsim_net->netgroup >= 0 ? 0 : -ENOMEM;
}

static inline u32 hwsim_net_get_wmediumd(struct net *net)
{
 struct hwsim_net *hwsim_net = net_generic(net, hwsim_net_id);

 return hwsim_net->wmediumd;
}

static inline void hwsim_net_set_wmediumd(struct net *net, u32 portid)
{
 struct hwsim_net *hwsim_net = net_generic(net, hwsim_net_id);

 hwsim_net->wmediumd = portid;
}

static struct class *hwsim_class;

static struct net_device *hwsim_mon; /* global monitor netdev */

#define CHAN2G(_freq)  { \
 .band = NL80211_BAND_2GHZ, \
 .center_freq = (_freq), \
 .hw_value = (_freq), \
}

#define CHAN5G(_freq) { \
 .band = NL80211_BAND_5GHZ, \
 .center_freq = (_freq), \
 .hw_value = (_freq), \
}

#define CHAN6G(_freq) { \
 .band = NL80211_BAND_6GHZ, \
 .center_freq = (_freq), \
 .hw_value = (_freq), \
}

static const struct ieee80211_channel hwsim_channels_2ghz[] = {
 CHAN2G(2412), /* Channel 1 */
 CHAN2G(2417), /* Channel 2 */
 CHAN2G(2422), /* Channel 3 */
 CHAN2G(2427), /* Channel 4 */
 CHAN2G(2432), /* Channel 5 */
 CHAN2G(2437), /* Channel 6 */
 CHAN2G(2442), /* Channel 7 */
 CHAN2G(2447), /* Channel 8 */
 CHAN2G(2452), /* Channel 9 */
 CHAN2G(2457), /* Channel 10 */
 CHAN2G(2462), /* Channel 11 */
 CHAN2G(2467), /* Channel 12 */
 CHAN2G(2472), /* Channel 13 */
 CHAN2G(2484), /* Channel 14 */
};

static const struct ieee80211_channel hwsim_channels_5ghz[] = {
 CHAN5G(5180), /* Channel 36 */
 CHAN5G(5200), /* Channel 40 */
 CHAN5G(5220), /* Channel 44 */
 CHAN5G(5240), /* Channel 48 */

 CHAN5G(5260), /* Channel 52 */
 CHAN5G(5280), /* Channel 56 */
 CHAN5G(5300), /* Channel 60 */
 CHAN5G(5320), /* Channel 64 */

 CHAN5G(5500), /* Channel 100 */
 CHAN5G(5520), /* Channel 104 */
 CHAN5G(5540), /* Channel 108 */
 CHAN5G(5560), /* Channel 112 */
 CHAN5G(5580), /* Channel 116 */
 CHAN5G(5600), /* Channel 120 */
 CHAN5G(5620), /* Channel 124 */
 CHAN5G(5640), /* Channel 128 */
 CHAN5G(5660), /* Channel 132 */
 CHAN5G(5680), /* Channel 136 */
 CHAN5G(5700), /* Channel 140 */

 CHAN5G(5745), /* Channel 149 */
 CHAN5G(5765), /* Channel 153 */
 CHAN5G(5785), /* Channel 157 */
 CHAN5G(5805), /* Channel 161 */
 CHAN5G(5825), /* Channel 165 */
 CHAN5G(5845), /* Channel 169 */

 CHAN5G(5855), /* Channel 171 */
 CHAN5G(5860), /* Channel 172 */
 CHAN5G(5865), /* Channel 173 */
 CHAN5G(5870), /* Channel 174 */

 CHAN5G(5875), /* Channel 175 */
 CHAN5G(5880), /* Channel 176 */
 CHAN5G(5885), /* Channel 177 */
 CHAN5G(5890), /* Channel 178 */
 CHAN5G(5895), /* Channel 179 */
 CHAN5G(5900), /* Channel 180 */
 CHAN5G(5905), /* Channel 181 */

 CHAN5G(5910), /* Channel 182 */
 CHAN5G(5915), /* Channel 183 */
 CHAN5G(5920), /* Channel 184 */
 CHAN5G(5925), /* Channel 185 */
};

static const struct ieee80211_channel hwsim_channels_6ghz[] = {
 CHAN6G(5955), /* Channel 1 */
 CHAN6G(5975), /* Channel 5 */
 CHAN6G(5995), /* Channel 9 */
 CHAN6G(6015), /* Channel 13 */
 CHAN6G(6035), /* Channel 17 */
 CHAN6G(6055), /* Channel 21 */
 CHAN6G(6075), /* Channel 25 */
 CHAN6G(6095), /* Channel 29 */
 CHAN6G(6115), /* Channel 33 */
 CHAN6G(6135), /* Channel 37 */
 CHAN6G(6155), /* Channel 41 */
 CHAN6G(6175), /* Channel 45 */
 CHAN6G(6195), /* Channel 49 */
 CHAN6G(6215), /* Channel 53 */
 CHAN6G(6235), /* Channel 57 */
 CHAN6G(6255), /* Channel 61 */
 CHAN6G(6275), /* Channel 65 */
 CHAN6G(6295), /* Channel 69 */
 CHAN6G(6315), /* Channel 73 */
 CHAN6G(6335), /* Channel 77 */
 CHAN6G(6355), /* Channel 81 */
 CHAN6G(6375), /* Channel 85 */
 CHAN6G(6395), /* Channel 89 */
 CHAN6G(6415), /* Channel 93 */
 CHAN6G(6435), /* Channel 97 */
 CHAN6G(6455), /* Channel 181 */
 CHAN6G(6475), /* Channel 105 */
 CHAN6G(6495), /* Channel 109 */
 CHAN6G(6515), /* Channel 113 */
 CHAN6G(6535), /* Channel 117 */
 CHAN6G(6555), /* Channel 121 */
 CHAN6G(6575), /* Channel 125 */
 CHAN6G(6595), /* Channel 129 */
 CHAN6G(6615), /* Channel 133 */
 CHAN6G(6635), /* Channel 137 */
 CHAN6G(6655), /* Channel 141 */
 CHAN6G(6675), /* Channel 145 */
 CHAN6G(6695), /* Channel 149 */
 CHAN6G(6715), /* Channel 153 */
 CHAN6G(6735), /* Channel 157 */
 CHAN6G(6755), /* Channel 161 */
 CHAN6G(6775), /* Channel 165 */
 CHAN6G(6795), /* Channel 169 */
 CHAN6G(6815), /* Channel 173 */
 CHAN6G(6835), /* Channel 177 */
 CHAN6G(6855), /* Channel 181 */
 CHAN6G(6875), /* Channel 185 */
 CHAN6G(6895), /* Channel 189 */
 CHAN6G(6915), /* Channel 193 */
 CHAN6G(6935), /* Channel 197 */
 CHAN6G(6955), /* Channel 201 */
 CHAN6G(6975), /* Channel 205 */
 CHAN6G(6995), /* Channel 209 */
 CHAN6G(7015), /* Channel 213 */
 CHAN6G(7035), /* Channel 217 */
 CHAN6G(7055), /* Channel 221 */
 CHAN6G(7075), /* Channel 225 */
 CHAN6G(7095), /* Channel 229 */
 CHAN6G(7115), /* Channel 233 */
};

#define NUM_S1G_CHANS_US 51
static struct ieee80211_channel hwsim_channels_s1g[NUM_S1G_CHANS_US];

static const struct ieee80211_sta_s1g_cap hwsim_s1g_cap = {
 .s1g = true,
 .cap = { S1G_CAP0_SGI_1MHZ | S1G_CAP0_SGI_2MHZ,
   0,
   0,
   S1G_CAP3_MAX_MPDU_LEN,
   0,
   S1G_CAP5_AMPDU,
   0,
   S1G_CAP7_DUP_1MHZ,
   S1G_CAP8_TWT_RESPOND | S1G_CAP8_TWT_REQUEST,
   0},
 .nss_mcs = { 0xfc | 1, /* MCS 7 for 1 SS */
 /* RX Highest Supported Long GI Data Rate 0:7 */
       0,
 /* RX Highest Supported Long GI Data Rate 0:7 */
 /* TX S1G MCS Map 0:6 */
       0xfa,
 /* TX S1G MCS Map :7 */
 /* TX Highest Supported Long GI Data Rate 0:6 */
       0x80,
 /* TX Highest Supported Long GI Data Rate 7:8 */
 /* Rx Single spatial stream and S1G-MCS Map for 1MHz */
 /* Tx Single spatial stream and S1G-MCS Map for 1MHz */
       0 },
};

static void hwsim_init_s1g_channels(struct ieee80211_channel *chans)
{
 int ch, freq;

 for (ch = 0; ch < NUM_S1G_CHANS_US; ch++) {
  freq = 902000 + (ch + 1) * 500;
  chans[ch].band = NL80211_BAND_S1GHZ;
  chans[ch].center_freq = KHZ_TO_MHZ(freq);
  chans[ch].freq_offset = freq % 1000;
  chans[ch].hw_value = ch + 1;
 }
}

static const struct ieee80211_rate hwsim_rates[] = {
 { .bitrate = 10 },
 { .bitrate = 20, .flags = IEEE80211_RATE_SHORT_PREAMBLE },
 { .bitrate = 55, .flags = IEEE80211_RATE_SHORT_PREAMBLE },
 { .bitrate = 110, .flags = IEEE80211_RATE_SHORT_PREAMBLE },
 { .bitrate = 60 },
 { .bitrate = 90 },
 { .bitrate = 120 },
 { .bitrate = 180 },
 { .bitrate = 240 },
 { .bitrate = 360 },
 { .bitrate = 480 },
 { .bitrate = 540 }
};

#define DEFAULT_RX_RSSI -50

static const u32 hwsim_ciphers[] = {
 WLAN_CIPHER_SUITE_WEP40,
 WLAN_CIPHER_SUITE_WEP104,
 WLAN_CIPHER_SUITE_TKIP,
 WLAN_CIPHER_SUITE_CCMP,
 WLAN_CIPHER_SUITE_CCMP_256,
 WLAN_CIPHER_SUITE_GCMP,
 WLAN_CIPHER_SUITE_GCMP_256,
 WLAN_CIPHER_SUITE_AES_CMAC,
 WLAN_CIPHER_SUITE_BIP_CMAC_256,
 WLAN_CIPHER_SUITE_BIP_GMAC_128,
 WLAN_CIPHER_SUITE_BIP_GMAC_256,
};

#define OUI_QCA 0x001374
#define QCA_NL80211_SUBCMD_TEST 1
enum qca_nl80211_vendor_subcmds {
 QCA_WLAN_VENDOR_ATTR_TEST = 8,
 QCA_WLAN_VENDOR_ATTR_MAX = QCA_WLAN_VENDOR_ATTR_TEST
};

static const struct nla_policy
hwsim_vendor_test_policy[QCA_WLAN_VENDOR_ATTR_MAX + 1] = {
 [QCA_WLAN_VENDOR_ATTR_MAX] = { .type = NLA_U32 },
};

static int mac80211_hwsim_vendor_cmd_test(struct wiphy *wiphy,
       struct wireless_dev *wdev,
       const void *data, int data_len)
{
 struct sk_buff *skb;
 struct nlattr *tb[QCA_WLAN_VENDOR_ATTR_MAX + 1];
 int err;
 u32 val;

 err = nla_parse_deprecated(tb, QCA_WLAN_VENDOR_ATTR_MAX, data,
       data_len, hwsim_vendor_test_policy, NULL);
 if (err)
  return err;
 if (!tb[QCA_WLAN_VENDOR_ATTR_TEST])
  return -EINVAL;
 val = nla_get_u32(tb[QCA_WLAN_VENDOR_ATTR_TEST]);
 wiphy_dbg(wiphy, "%s: test=%u\n", __func__, val);

 /* Send a vendor event as a test. Note that this would not normally be
 * done within a command handler, but rather, based on some other
 * trigger. For simplicity, this command is used to trigger the event
 * here.
 *
 * event_idx = 0 (index in mac80211_hwsim_vendor_commands)
 */

 skb = cfg80211_vendor_event_alloc(wiphy, wdev, 100, 0, GFP_KERNEL);
 if (skb) {
  /* skb_put() or nla_put() will fill up data within
 * NL80211_ATTR_VENDOR_DATA.
 */


  /* Add vendor data */
  nla_put_u32(skb, QCA_WLAN_VENDOR_ATTR_TEST, val + 1);

  /* Send the event - this will call nla_nest_end() */
  cfg80211_vendor_event(skb, GFP_KERNEL);
 }

 /* Send a response to the command */
 skb = cfg80211_vendor_cmd_alloc_reply_skb(wiphy, 10);
 if (!skb)
  return -ENOMEM;

 /* skb_put() or nla_put() will fill up data within
 * NL80211_ATTR_VENDOR_DATA
 */

 nla_put_u32(skb, QCA_WLAN_VENDOR_ATTR_TEST, val + 2);

 return cfg80211_vendor_cmd_reply(skb);
}

static struct wiphy_vendor_command mac80211_hwsim_vendor_commands[] = {
 {
  .info = { .vendor_id = OUI_QCA,
     .subcmd = QCA_NL80211_SUBCMD_TEST },
  .flags = WIPHY_VENDOR_CMD_NEED_NETDEV,
  .doit = mac80211_hwsim_vendor_cmd_test,
  .policy = hwsim_vendor_test_policy,
  .maxattr = QCA_WLAN_VENDOR_ATTR_MAX,
 }
};

/* Advertise support vendor specific events */
static const struct nl80211_vendor_cmd_info mac80211_hwsim_vendor_events[] = {
 { .vendor_id = OUI_QCA, .subcmd = 1 },
};

static DEFINE_SPINLOCK(hwsim_radio_lock);
static LIST_HEAD(hwsim_radios);
static struct rhashtable hwsim_radios_rht;
static int hwsim_radio_idx;
static int hwsim_radios_generation = 1;

static struct platform_driver mac80211_hwsim_driver = {
 .driver = {
  .name = "mac80211_hwsim",
 },
};

struct mac80211_hwsim_link_data {
 u32 link_id;
 u64 beacon_int /* beacon interval in us */;
 struct hrtimer beacon_timer;
};

struct mac80211_hwsim_data {
 struct list_head list;
 struct rhash_head rht;
 struct ieee80211_hw *hw;
 struct device *dev;
 struct ieee80211_supported_band bands[NUM_NL80211_BANDS];
 struct ieee80211_channel channels_2ghz[ARRAY_SIZE(hwsim_channels_2ghz)];
 struct ieee80211_channel channels_5ghz[ARRAY_SIZE(hwsim_channels_5ghz)];
 struct ieee80211_channel channels_6ghz[ARRAY_SIZE(hwsim_channels_6ghz)];
 struct ieee80211_channel channels_s1g[ARRAY_SIZE(hwsim_channels_s1g)];
 struct ieee80211_rate rates[ARRAY_SIZE(hwsim_rates)];
 struct ieee80211_iface_combination if_combination;
 struct ieee80211_iface_limit if_limits[3];
 int n_if_limits;

 struct ieee80211_iface_combination if_combination_radio;
 struct wiphy_radio_freq_range radio_range[NUM_NL80211_BANDS];
 struct wiphy_radio radio[NUM_NL80211_BANDS];

 u32 ciphers[ARRAY_SIZE(hwsim_ciphers)];

 struct mac_address addresses[2];
 int channels, idx;
 bool use_chanctx;
 bool destroy_on_close;
 u32 portid;
 char alpha2[2];
 const struct ieee80211_regdomain *regd;

 struct ieee80211_channel *tmp_chan;
 struct ieee80211_channel *roc_chan;
 u32 roc_duration;
 struct delayed_work roc_start;
 struct delayed_work roc_done;
 struct delayed_work hw_scan;
 struct cfg80211_scan_request *hw_scan_request;
 struct ieee80211_vif *hw_scan_vif;
 int scan_chan_idx;
 u8 scan_addr[ETH_ALEN];
 struct {
  struct ieee80211_channel *channel;
  unsigned long next_start, start, end;
 } survey_data[ARRAY_SIZE(hwsim_channels_2ghz) +
        ARRAY_SIZE(hwsim_channels_5ghz) +
        ARRAY_SIZE(hwsim_channels_6ghz)];

 struct ieee80211_channel *channel;
 enum nl80211_chan_width bw;
 unsigned int rx_filter;
 bool started, idle, scanning;
 struct mutex mutex;
 enum ps_mode {
  PS_DISABLED, PS_ENABLED, PS_AUTO_POLL, PS_MANUAL_POLL
 } ps;
 bool ps_poll_pending;
 struct dentry *debugfs;

 atomic_t pending_cookie;
 struct sk_buff_head pending; /* packets pending */
 /*
 * Only radios in the same group can communicate together (the
 * channel has to match too). Each bit represents a group. A
 * radio can be in more than one group.
 */

 u64 group;

 /* group shared by radios created in the same netns */
 int netgroup;
 /* wmediumd portid responsible for netgroup of this radio */
 u32 wmediumd;

 /* difference between this hw's clock and the real clock, in usecs */
 s64 tsf_offset;
 s64 bcn_delta;
 /* absolute beacon transmission time. Used to cover up "tx" delay. */
 u64 abs_bcn_ts;

 /* Stats */
 u64 tx_pkts;
 u64 rx_pkts;
 u64 tx_bytes;
 u64 rx_bytes;
 u64 tx_dropped;
 u64 tx_failed;

 /* RSSI in rx status of the receiver */
 int rx_rssi;

 /* only used when pmsr capability is supplied */
 struct cfg80211_pmsr_capabilities pmsr_capa;
 struct cfg80211_pmsr_request *pmsr_request;
 struct wireless_dev *pmsr_request_wdev;

 struct mac80211_hwsim_link_data link_data[IEEE80211_MLD_MAX_NUM_LINKS];
};

static const struct rhashtable_params hwsim_rht_params = {
 .nelem_hint = 2,
 .automatic_shrinking = true,
 .key_len = ETH_ALEN,
 .key_offset = offsetof(struct mac80211_hwsim_data, addresses[1]),
 .head_offset = offsetof(struct mac80211_hwsim_data, rht),
};

struct hwsim_radiotap_hdr {
 struct ieee80211_radiotap_header_fixed hdr;
 __le64 rt_tsft;
 u8 rt_flags;
 u8 rt_rate;
 __le16 rt_channel;
 __le16 rt_chbitmask;
} __packed;

struct hwsim_radiotap_ack_hdr {
 struct ieee80211_radiotap_header_fixed hdr;
 u8 rt_flags;
 u8 pad;
 __le16 rt_channel;
 __le16 rt_chbitmask;
} __packed;

static struct mac80211_hwsim_data *get_hwsim_data_ref_from_addr(const u8 *addr)
{
 return rhashtable_lookup_fast(&hwsim_radios_rht, addr, hwsim_rht_params);
}

/* MAC80211_HWSIM netlink family */
static struct genl_family hwsim_genl_family;

enum hwsim_multicast_groups {
 HWSIM_MCGRP_CONFIG,
};

static const struct genl_multicast_group hwsim_mcgrps[] = {
 [HWSIM_MCGRP_CONFIG] = { .name = "config", },
};

/* MAC80211_HWSIM netlink policy */

static const struct nla_policy
hwsim_rate_info_policy[HWSIM_RATE_INFO_ATTR_MAX + 1] = {
 [HWSIM_RATE_INFO_ATTR_FLAGS] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_MCS] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_LEGACY] = { .type = NLA_U16 },
 [HWSIM_RATE_INFO_ATTR_NSS] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_BW] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_HE_GI] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_HE_DCM] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_HE_RU_ALLOC] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_N_BOUNDED_CH] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_EHT_GI] = { .type = NLA_U8 },
 [HWSIM_RATE_INFO_ATTR_EHT_RU_ALLOC] = { .type = NLA_U8 },
};

static const struct nla_policy
hwsim_ftm_result_policy[NL80211_PMSR_FTM_RESP_ATTR_MAX + 1] = {
 [NL80211_PMSR_FTM_RESP_ATTR_FAIL_REASON] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_RESP_ATTR_BURST_INDEX] = { .type = NLA_U16 },
 [NL80211_PMSR_FTM_RESP_ATTR_NUM_FTMR_ATTEMPTS] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_RESP_ATTR_NUM_FTMR_SUCCESSES] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_RESP_ATTR_BUSY_RETRY_TIME] = { .type = NLA_U8 },
 [NL80211_PMSR_FTM_RESP_ATTR_NUM_BURSTS_EXP] = { .type = NLA_U8 },
 [NL80211_PMSR_FTM_RESP_ATTR_BURST_DURATION] = { .type = NLA_U8 },
 [NL80211_PMSR_FTM_RESP_ATTR_FTMS_PER_BURST] = { .type = NLA_U8 },
 [NL80211_PMSR_FTM_RESP_ATTR_RSSI_AVG] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_RESP_ATTR_RSSI_SPREAD] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_RESP_ATTR_TX_RATE] = NLA_POLICY_NESTED(hwsim_rate_info_policy),
 [NL80211_PMSR_FTM_RESP_ATTR_RX_RATE] = NLA_POLICY_NESTED(hwsim_rate_info_policy),
 [NL80211_PMSR_FTM_RESP_ATTR_RTT_AVG] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_RTT_VARIANCE] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_RTT_SPREAD] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_DIST_AVG] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_DIST_VARIANCE] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_DIST_SPREAD] = { .type = NLA_U64 },
 [NL80211_PMSR_FTM_RESP_ATTR_LCI] = { .type = NLA_STRING },
 [NL80211_PMSR_FTM_RESP_ATTR_CIVICLOC] = { .type = NLA_STRING },
};

static const struct nla_policy
hwsim_pmsr_resp_type_policy[NL80211_PMSR_TYPE_MAX + 1] = {
 [NL80211_PMSR_TYPE_FTM] = NLA_POLICY_NESTED(hwsim_ftm_result_policy),
};

static const struct nla_policy
hwsim_pmsr_resp_policy[NL80211_PMSR_RESP_ATTR_MAX + 1] = {
 [NL80211_PMSR_RESP_ATTR_STATUS] = { .type = NLA_U32 },
 [NL80211_PMSR_RESP_ATTR_HOST_TIME] = { .type = NLA_U64 },
 [NL80211_PMSR_RESP_ATTR_AP_TSF] = { .type = NLA_U64 },
 [NL80211_PMSR_RESP_ATTR_FINAL] = { .type = NLA_FLAG },
 [NL80211_PMSR_RESP_ATTR_DATA] = NLA_POLICY_NESTED(hwsim_pmsr_resp_type_policy),
};

static const struct nla_policy
hwsim_pmsr_peer_result_policy[NL80211_PMSR_PEER_ATTR_MAX + 1] = {
 [NL80211_PMSR_PEER_ATTR_ADDR] = NLA_POLICY_ETH_ADDR_COMPAT,
 [NL80211_PMSR_PEER_ATTR_CHAN] = { .type = NLA_REJECT },
 [NL80211_PMSR_PEER_ATTR_REQ] = { .type = NLA_REJECT },
 [NL80211_PMSR_PEER_ATTR_RESP] = NLA_POLICY_NESTED(hwsim_pmsr_resp_policy),
};

static const struct nla_policy
hwsim_pmsr_peers_result_policy[NL80211_PMSR_ATTR_MAX + 1] = {
 [NL80211_PMSR_ATTR_MAX_PEERS] = { .type = NLA_REJECT },
 [NL80211_PMSR_ATTR_REPORT_AP_TSF] = { .type = NLA_REJECT },
 [NL80211_PMSR_ATTR_RANDOMIZE_MAC_ADDR] = { .type = NLA_REJECT },
 [NL80211_PMSR_ATTR_TYPE_CAPA] = { .type = NLA_REJECT },
 [NL80211_PMSR_ATTR_PEERS] = NLA_POLICY_NESTED_ARRAY(hwsim_pmsr_peer_result_policy),
};

static const struct nla_policy
hwsim_ftm_capa_policy[NL80211_PMSR_FTM_CAPA_ATTR_MAX + 1] = {
 [NL80211_PMSR_FTM_CAPA_ATTR_ASAP] = { .type = NLA_FLAG },
 [NL80211_PMSR_FTM_CAPA_ATTR_NON_ASAP] = { .type = NLA_FLAG },
 [NL80211_PMSR_FTM_CAPA_ATTR_REQ_LCI] = { .type = NLA_FLAG },
 [NL80211_PMSR_FTM_CAPA_ATTR_REQ_CIVICLOC] = { .type = NLA_FLAG },
 [NL80211_PMSR_FTM_CAPA_ATTR_PREAMBLES] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_CAPA_ATTR_BANDWIDTHS] = { .type = NLA_U32 },
 [NL80211_PMSR_FTM_CAPA_ATTR_MAX_BURSTS_EXPONENT] = NLA_POLICY_MAX(NLA_U8, 15),
 [NL80211_PMSR_FTM_CAPA_ATTR_MAX_FTMS_PER_BURST] = NLA_POLICY_MAX(NLA_U8, 31),
 [NL80211_PMSR_FTM_CAPA_ATTR_TRIGGER_BASED] = { .type = NLA_FLAG },
 [NL80211_PMSR_FTM_CAPA_ATTR_NON_TRIGGER_BASED] = { .type = NLA_FLAG },
};

static const struct nla_policy
hwsim_pmsr_capa_type_policy[NL80211_PMSR_TYPE_MAX + 1] = {
 [NL80211_PMSR_TYPE_FTM] = NLA_POLICY_NESTED(hwsim_ftm_capa_policy),
};

static const struct nla_policy
hwsim_pmsr_capa_policy[NL80211_PMSR_ATTR_MAX + 1] = {
 [NL80211_PMSR_ATTR_MAX_PEERS] = { .type = NLA_U32 },
 [NL80211_PMSR_ATTR_REPORT_AP_TSF] = { .type = NLA_FLAG },
 [NL80211_PMSR_ATTR_RANDOMIZE_MAC_ADDR] = { .type = NLA_FLAG },
 [NL80211_PMSR_ATTR_TYPE_CAPA] = NLA_POLICY_NESTED(hwsim_pmsr_capa_type_policy),
 [NL80211_PMSR_ATTR_PEERS] = { .type = NLA_REJECT }, // only for request.
};

static const struct nla_policy hwsim_genl_policy[HWSIM_ATTR_MAX + 1] = {
 [HWSIM_ATTR_ADDR_RECEIVER] = NLA_POLICY_ETH_ADDR_COMPAT,
 [HWSIM_ATTR_ADDR_TRANSMITTER] = NLA_POLICY_ETH_ADDR_COMPAT,
 [HWSIM_ATTR_FRAME] = { .type = NLA_BINARY,
          .len = IEEE80211_MAX_DATA_LEN },
 [HWSIM_ATTR_FLAGS] = { .type = NLA_U32 },
 [HWSIM_ATTR_RX_RATE] = { .type = NLA_U32 },
 [HWSIM_ATTR_SIGNAL] = { .type = NLA_U32 },
 [HWSIM_ATTR_TX_INFO] = { .type = NLA_BINARY,
     .len = IEEE80211_TX_MAX_RATES *
     sizeof(struct hwsim_tx_rate)},
 [HWSIM_ATTR_COOKIE] = { .type = NLA_U64 },
 [HWSIM_ATTR_CHANNELS] = { .type = NLA_U32 },
 [HWSIM_ATTR_RADIO_ID] = { .type = NLA_U32 },
 [HWSIM_ATTR_REG_HINT_ALPHA2] = { .type = NLA_STRING, .len = 2 },
 [HWSIM_ATTR_REG_CUSTOM_REG] = { .type = NLA_U32 },
 [HWSIM_ATTR_REG_STRICT_REG] = { .type = NLA_FLAG },
 [HWSIM_ATTR_SUPPORT_P2P_DEVICE] = { .type = NLA_FLAG },
 [HWSIM_ATTR_USE_CHANCTX] = { .type = NLA_FLAG },
 [HWSIM_ATTR_DESTROY_RADIO_ON_CLOSE] = { .type = NLA_FLAG },
 [HWSIM_ATTR_RADIO_NAME] = { .type = NLA_STRING },
 [HWSIM_ATTR_NO_VIF] = { .type = NLA_FLAG },
 [HWSIM_ATTR_FREQ] = { .type = NLA_U32 },
 [HWSIM_ATTR_TX_INFO_FLAGS] = { .type = NLA_BINARY },
 [HWSIM_ATTR_PERM_ADDR] = NLA_POLICY_ETH_ADDR_COMPAT,
 [HWSIM_ATTR_IFTYPE_SUPPORT] = { .type = NLA_U32 },
 [HWSIM_ATTR_CIPHER_SUPPORT] = { .type = NLA_BINARY },
 [HWSIM_ATTR_MLO_SUPPORT] = { .type = NLA_FLAG },
 [HWSIM_ATTR_PMSR_SUPPORT] = NLA_POLICY_NESTED(hwsim_pmsr_capa_policy),
 [HWSIM_ATTR_PMSR_RESULT] = NLA_POLICY_NESTED(hwsim_pmsr_peers_result_policy),
 [HWSIM_ATTR_MULTI_RADIO] = { .type = NLA_FLAG },
};

#if IS_REACHABLE(CONFIG_VIRTIO)

/* MAC80211_HWSIM virtio queues */
static struct virtqueue *hwsim_vqs[HWSIM_NUM_VQS];
static bool hwsim_virtio_enabled;
static DEFINE_SPINLOCK(hwsim_virtio_lock);

static void hwsim_virtio_rx_work(struct work_struct *work);
static DECLARE_WORK(hwsim_virtio_rx, hwsim_virtio_rx_work);

static int hwsim_tx_virtio(struct mac80211_hwsim_data *data,
      struct sk_buff *skb)
{
 struct scatterlist sg[1];
 unsigned long flags;
 int err;

 spin_lock_irqsave(&hwsim_virtio_lock, flags);
 if (!hwsim_virtio_enabled) {
  err = -ENODEV;
  goto out_free;
 }

 sg_init_one(sg, skb->head, skb_end_offset(skb));
 err = virtqueue_add_outbuf(hwsim_vqs[HWSIM_VQ_TX], sg, 1, skb,
       GFP_ATOMIC);
 if (err)
  goto out_free;
 virtqueue_kick(hwsim_vqs[HWSIM_VQ_TX]);
 spin_unlock_irqrestore(&hwsim_virtio_lock, flags);
 return 0;

out_free:
 spin_unlock_irqrestore(&hwsim_virtio_lock, flags);
 nlmsg_free(skb);
 return err;
}
#else
/* cause a linker error if this ends up being needed */
extern int hwsim_tx_virtio(struct mac80211_hwsim_data *data,
      struct sk_buff *skb);
#define hwsim_virtio_enabled false
#endif

static int hwsim_get_chanwidth(enum nl80211_chan_width bw)
{
 switch (bw) {
 case NL80211_CHAN_WIDTH_20_NOHT:
 case NL80211_CHAN_WIDTH_20:
  return 20;
 case NL80211_CHAN_WIDTH_40:
  return 40;
 case NL80211_CHAN_WIDTH_80:
  return 80;
 case NL80211_CHAN_WIDTH_80P80:
 case NL80211_CHAN_WIDTH_160:
  return 160;
 case NL80211_CHAN_WIDTH_320:
  return 320;
 case NL80211_CHAN_WIDTH_5:
  return 5;
 case NL80211_CHAN_WIDTH_10:
  return 10;
 case NL80211_CHAN_WIDTH_1:
  return 1;
 case NL80211_CHAN_WIDTH_2:
  return 2;
 case NL80211_CHAN_WIDTH_4:
  return 4;
 case NL80211_CHAN_WIDTH_8:
  return 8;
 case NL80211_CHAN_WIDTH_16:
  return 16;
 }

 return INT_MAX;
}

static void mac80211_hwsim_tx_frame(struct ieee80211_hw *hw,
        struct sk_buff *skb,
        struct ieee80211_channel *chan);

/* sysfs attributes */
static void hwsim_send_ps_poll(void *dat, u8 *mac, struct ieee80211_vif *vif)
{
 struct mac80211_hwsim_data *data = dat;
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 struct sk_buff *skb;
 struct ieee80211_pspoll *pspoll;

 if (!vp->assoc)
  return;

 wiphy_dbg(data->hw->wiphy,
    "%s: send PS-Poll to %pM for aid %d\n",
    __func__, vp->bssid, vp->aid);

 skb = dev_alloc_skb(sizeof(*pspoll));
 if (!skb)
  return;
 pspoll = skb_put(skb, sizeof(*pspoll));
 pspoll->frame_control = cpu_to_le16(IEEE80211_FTYPE_CTL |
         IEEE80211_STYPE_PSPOLL |
         IEEE80211_FCTL_PM);
 pspoll->aid = cpu_to_le16(0xc000 | vp->aid);
 memcpy(pspoll->bssid, vp->bssid, ETH_ALEN);
 memcpy(pspoll->ta, mac, ETH_ALEN);

 rcu_read_lock();
 mac80211_hwsim_tx_frame(data->hw, skb,
    rcu_dereference(vif->bss_conf.chanctx_conf)->def.chan);
 rcu_read_unlock();
}

static void hwsim_send_nullfunc(struct mac80211_hwsim_data *data, u8 *mac,
    struct ieee80211_vif *vif, int ps)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 struct sk_buff *skb;
 struct ieee80211_hdr *hdr;
 struct ieee80211_tx_info *cb;

 if (!vp->assoc)
  return;

 wiphy_dbg(data->hw->wiphy,
    "%s: send data::nullfunc to %pM ps=%d\n",
    __func__, vp->bssid, ps);

 skb = dev_alloc_skb(sizeof(*hdr));
 if (!skb)
  return;
 hdr = skb_put(skb, sizeof(*hdr) - ETH_ALEN);
 hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_DATA |
      IEEE80211_STYPE_NULLFUNC |
      IEEE80211_FCTL_TODS |
      (ps ? IEEE80211_FCTL_PM : 0));
 hdr->duration_id = cpu_to_le16(0);
 memcpy(hdr->addr1, vp->bssid, ETH_ALEN);
 memcpy(hdr->addr2, mac, ETH_ALEN);
 memcpy(hdr->addr3, vp->bssid, ETH_ALEN);

 cb = IEEE80211_SKB_CB(skb);
 cb->control.rates[0].count = 1;
 cb->control.rates[1].idx = -1;

 rcu_read_lock();
 mac80211_hwsim_tx_frame(data->hw, skb,
    rcu_dereference(vif->bss_conf.chanctx_conf)->def.chan);
 rcu_read_unlock();
}


static void hwsim_send_nullfunc_ps(void *dat, u8 *mac,
       struct ieee80211_vif *vif)
{
 struct mac80211_hwsim_data *data = dat;
 hwsim_send_nullfunc(data, mac, vif, 1);
}

static void hwsim_send_nullfunc_no_ps(void *dat, u8 *mac,
          struct ieee80211_vif *vif)
{
 struct mac80211_hwsim_data *data = dat;
 hwsim_send_nullfunc(data, mac, vif, 0);
}

static int hwsim_fops_ps_read(void *dat, u64 *val)
{
 struct mac80211_hwsim_data *data = dat;
 *val = data->ps;
 return 0;
}

static int hwsim_fops_ps_write(void *dat, u64 val)
{
 struct mac80211_hwsim_data *data = dat;
 enum ps_mode old_ps;

 if (val != PS_DISABLED && val != PS_ENABLED && val != PS_AUTO_POLL &&
     val != PS_MANUAL_POLL)
  return -EINVAL;

 if (val == PS_MANUAL_POLL) {
  if (data->ps != PS_ENABLED)
   return -EINVAL;
  local_bh_disable();
  ieee80211_iterate_active_interfaces_atomic(
   data->hw, IEEE80211_IFACE_ITER_NORMAL,
   hwsim_send_ps_poll, data);
  local_bh_enable();
  return 0;
 }
 old_ps = data->ps;
 data->ps = val;

 local_bh_disable();
 if (old_ps == PS_DISABLED && val != PS_DISABLED) {
  ieee80211_iterate_active_interfaces_atomic(
   data->hw, IEEE80211_IFACE_ITER_NORMAL,
   hwsim_send_nullfunc_ps, data);
 } else if (old_ps != PS_DISABLED && val == PS_DISABLED) {
  ieee80211_iterate_active_interfaces_atomic(
   data->hw, IEEE80211_IFACE_ITER_NORMAL,
   hwsim_send_nullfunc_no_ps, data);
 }
 local_bh_enable();

 return 0;
}

DEFINE_DEBUGFS_ATTRIBUTE(hwsim_fops_ps, hwsim_fops_ps_read, hwsim_fops_ps_write,
    "%llu\n");

static int hwsim_write_simulate_radar(void *dat, u64 val)
{
 struct mac80211_hwsim_data *data = dat;

 ieee80211_radar_detected(data->hw, NULL);

 return 0;
}

DEFINE_DEBUGFS_ATTRIBUTE(hwsim_simulate_radar, NULL,
    hwsim_write_simulate_radar, "%llu\n");

static int hwsim_fops_group_read(void *dat, u64 *val)
{
 struct mac80211_hwsim_data *data = dat;
 *val = data->group;
 return 0;
}

static int hwsim_fops_group_write(void *dat, u64 val)
{
 struct mac80211_hwsim_data *data = dat;
 data->group = val;
 return 0;
}

DEFINE_DEBUGFS_ATTRIBUTE(hwsim_fops_group,
    hwsim_fops_group_read, hwsim_fops_group_write,
    "%llx\n");

static int hwsim_fops_rx_rssi_read(void *dat, u64 *val)
{
 struct mac80211_hwsim_data *data = dat;
 *val = data->rx_rssi;
 return 0;
}

static int hwsim_fops_rx_rssi_write(void *dat, u64 val)
{
 struct mac80211_hwsim_data *data = dat;
 int rssi = (int)val;

 if (rssi >= 0 || rssi < -100)
  return -EINVAL;

 data->rx_rssi = rssi;
 return 0;
}

DEFINE_DEBUGFS_ATTRIBUTE(hwsim_fops_rx_rssi,
    hwsim_fops_rx_rssi_read, hwsim_fops_rx_rssi_write,
    "%lld\n");

static netdev_tx_t hwsim_mon_xmit(struct sk_buff *skb,
     struct net_device *dev)
{
 /* TODO: allow packet injection */
 dev_kfree_skb(skb);
 return NETDEV_TX_OK;
}

static inline u64 mac80211_hwsim_get_tsf_raw(void)
{
 return ktime_to_us(ktime_get_real());
}

static __le64 __mac80211_hwsim_get_tsf(struct mac80211_hwsim_data *data)
{
 u64 now = mac80211_hwsim_get_tsf_raw();
 return cpu_to_le64(now + data->tsf_offset);
}

static u64 mac80211_hwsim_get_tsf(struct ieee80211_hw *hw,
      struct ieee80211_vif *vif)
{
 struct mac80211_hwsim_data *data = hw->priv;
 return le64_to_cpu(__mac80211_hwsim_get_tsf(data));
}

static void mac80211_hwsim_set_tsf(struct ieee80211_hw *hw,
  struct ieee80211_vif *vif, u64 tsf)
{
 struct mac80211_hwsim_data *data = hw->priv;
 u64 now = mac80211_hwsim_get_tsf(hw, vif);
 /* MLD not supported here */
 u32 bcn_int = data->link_data[0].beacon_int;
 u64 delta = abs(tsf - now);
 struct ieee80211_bss_conf *conf;

 conf = link_conf_dereference_protected(vif, data->link_data[0].link_id);
 if (conf && !conf->enable_beacon)
  return;

 /* adjust after beaconing with new timestamp at old TBTT */
 if (tsf > now) {
  data->tsf_offset += delta;
  data->bcn_delta = do_div(delta, bcn_int);
 } else {
  data->tsf_offset -= delta;
  data->bcn_delta = -(s64)do_div(delta, bcn_int);
 }
}

static void mac80211_hwsim_monitor_rx(struct ieee80211_hw *hw,
          struct sk_buff *tx_skb,
          struct ieee80211_channel *chan)
{
 struct mac80211_hwsim_data *data = hw->priv;
 struct sk_buff *skb;
 struct hwsim_radiotap_hdr *hdr;
 u16 flags, bitrate;
 struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx_skb);
 struct ieee80211_rate *txrate = ieee80211_get_tx_rate(hw, info);

 if (!txrate)
  bitrate = 0;
 else
  bitrate = txrate->bitrate;

 if (!netif_running(hwsim_mon))
  return;

 skb = skb_copy_expand(tx_skb, sizeof(*hdr), 0, GFP_ATOMIC);
 if (skb == NULL)
  return;

 hdr = skb_push(skb, sizeof(*hdr));
 hdr->hdr.it_version = PKTHDR_RADIOTAP_VERSION;
 hdr->hdr.it_pad = 0;
 hdr->hdr.it_len = cpu_to_le16(sizeof(*hdr));
 hdr->hdr.it_present = cpu_to_le32((1 << IEEE80211_RADIOTAP_FLAGS) |
       (1 << IEEE80211_RADIOTAP_RATE) |
       (1 << IEEE80211_RADIOTAP_TSFT) |
       (1 << IEEE80211_RADIOTAP_CHANNEL));
 hdr->rt_tsft = __mac80211_hwsim_get_tsf(data);
 hdr->rt_flags = 0;
 hdr->rt_rate = bitrate / 5;
 hdr->rt_channel = cpu_to_le16(chan->center_freq);
 flags = IEEE80211_CHAN_2GHZ;
 if (txrate && txrate->flags & IEEE80211_RATE_ERP_G)
  flags |= IEEE80211_CHAN_OFDM;
 else
  flags |= IEEE80211_CHAN_CCK;
 hdr->rt_chbitmask = cpu_to_le16(flags);

 skb->dev = hwsim_mon;
 skb_reset_mac_header(skb);
 skb->ip_summed = CHECKSUM_UNNECESSARY;
 skb->pkt_type = PACKET_OTHERHOST;
 skb->protocol = htons(ETH_P_802_2);
 memset(skb->cb, 0, sizeof(skb->cb));
 netif_rx(skb);
}


static void mac80211_hwsim_monitor_ack(struct ieee80211_channel *chan,
           const u8 *addr)
{
 struct sk_buff *skb;
 struct hwsim_radiotap_ack_hdr *hdr;
 u16 flags;
 struct ieee80211_hdr *hdr11;

 if (!netif_running(hwsim_mon))
  return;

 skb = dev_alloc_skb(100);
 if (skb == NULL)
  return;

 hdr = skb_put(skb, sizeof(*hdr));
 hdr->hdr.it_version = PKTHDR_RADIOTAP_VERSION;
 hdr->hdr.it_pad = 0;
 hdr->hdr.it_len = cpu_to_le16(sizeof(*hdr));
 hdr->hdr.it_present = cpu_to_le32((1 << IEEE80211_RADIOTAP_FLAGS) |
       (1 << IEEE80211_RADIOTAP_CHANNEL));
 hdr->rt_flags = 0;
 hdr->pad = 0;
 hdr->rt_channel = cpu_to_le16(chan->center_freq);
 flags = IEEE80211_CHAN_2GHZ;
 hdr->rt_chbitmask = cpu_to_le16(flags);

 hdr11 = skb_put(skb, 10);
 hdr11->frame_control = cpu_to_le16(IEEE80211_FTYPE_CTL |
        IEEE80211_STYPE_ACK);
 hdr11->duration_id = cpu_to_le16(0);
 memcpy(hdr11->addr1, addr, ETH_ALEN);

 skb->dev = hwsim_mon;
 skb_reset_mac_header(skb);
 skb->ip_summed = CHECKSUM_UNNECESSARY;
 skb->pkt_type = PACKET_OTHERHOST;
 skb->protocol = htons(ETH_P_802_2);
 memset(skb->cb, 0, sizeof(skb->cb));
 netif_rx(skb);
}

struct mac80211_hwsim_addr_match_data {
 u8 addr[ETH_ALEN];
 bool ret;
};

static void mac80211_hwsim_addr_iter(void *data, u8 *mac,
         struct ieee80211_vif *vif)
{
 int i;
 struct mac80211_hwsim_addr_match_data *md = data;

 if (memcmp(mac, md->addr, ETH_ALEN) == 0) {
  md->ret = true;
  return;
 }

 /* Match the link address */
 for (i = 0; i < ARRAY_SIZE(vif->link_conf); i++) {
  struct ieee80211_bss_conf *conf;

  conf = rcu_dereference(vif->link_conf[i]);
  if (!conf)
   continue;

  if (memcmp(conf->addr, md->addr, ETH_ALEN) == 0) {
   md->ret = true;
   return;
  }
 }
}

static bool mac80211_hwsim_addr_match(struct mac80211_hwsim_data *data,
          const u8 *addr)
{
 struct mac80211_hwsim_addr_match_data md = {
  .ret = false,
 };

 if (data->scanning && memcmp(addr, data->scan_addr, ETH_ALEN) == 0)
  return true;

 memcpy(md.addr, addr, ETH_ALEN);

 ieee80211_iterate_active_interfaces_atomic(data->hw,
         IEEE80211_IFACE_ITER_NORMAL,
         mac80211_hwsim_addr_iter,
         &md);

 return md.ret;
}

static bool hwsim_ps_rx_ok(struct mac80211_hwsim_data *data,
      struct sk_buff *skb)
{
 switch (data->ps) {
 case PS_DISABLED:
  return true;
 case PS_ENABLED:
  return false;
 case PS_AUTO_POLL:
  /* TODO: accept (some) Beacons by default and other frames only
 * if pending PS-Poll has been sent */

  return true;
 case PS_MANUAL_POLL:
  /* Allow unicast frames to own address if there is a pending
 * PS-Poll */

  if (data->ps_poll_pending &&
      mac80211_hwsim_addr_match(data, skb->data + 4)) {
   data->ps_poll_pending = false;
   return true;
  }
  return false;
 }

 return true;
}

static int hwsim_unicast_netgroup(struct mac80211_hwsim_data *data,
      struct sk_buff *skb, int portid)
{
 struct net *net;
 bool found = false;
 int res = -ENOENT;

 rcu_read_lock();
 for_each_net_rcu(net) {
  if (data->netgroup == hwsim_net_get_netgroup(net)) {
   res = genlmsg_unicast(net, skb, portid);
   found = true;
   break;
  }
 }
 rcu_read_unlock();

 if (!found)
  nlmsg_free(skb);

 return res;
}

static void mac80211_hwsim_config_mac_nl(struct ieee80211_hw *hw,
      const u8 *addr, bool add)
{
 struct mac80211_hwsim_data *data = hw->priv;
 u32 _portid = READ_ONCE(data->wmediumd);
 struct sk_buff *skb;
 void *msg_head;

 WARN_ON(!is_valid_ether_addr(addr));

 if (!_portid && !hwsim_virtio_enabled)
  return;

 skb = genlmsg_new(GENLMSG_DEFAULT_SIZE, GFP_ATOMIC);
 if (!skb)
  return;

 msg_head = genlmsg_put(skb, 0, 0, &hwsim_genl_family, 0,
          add ? HWSIM_CMD_ADD_MAC_ADDR :
         HWSIM_CMD_DEL_MAC_ADDR);
 if (!msg_head) {
  pr_debug("mac80211_hwsim: problem with msg_head\n");
  goto nla_put_failure;
 }

 if (nla_put(skb, HWSIM_ATTR_ADDR_TRANSMITTER,
      ETH_ALEN, data->addresses[1].addr))
  goto nla_put_failure;

 if (nla_put(skb, HWSIM_ATTR_ADDR_RECEIVER, ETH_ALEN, addr))
  goto nla_put_failure;

 genlmsg_end(skb, msg_head);

 if (hwsim_virtio_enabled)
  hwsim_tx_virtio(data, skb);
 else
  hwsim_unicast_netgroup(data, skb, _portid);
 return;
nla_put_failure:
 nlmsg_free(skb);
}

static inline u16 trans_tx_rate_flags_ieee2hwsim(struct ieee80211_tx_rate *rate)
{
 u16 result = 0;

 if (rate->flags & IEEE80211_TX_RC_USE_RTS_CTS)
  result |= MAC80211_HWSIM_TX_RC_USE_RTS_CTS;
 if (rate->flags & IEEE80211_TX_RC_USE_CTS_PROTECT)
  result |= MAC80211_HWSIM_TX_RC_USE_CTS_PROTECT;
 if (rate->flags & IEEE80211_TX_RC_USE_SHORT_PREAMBLE)
  result |= MAC80211_HWSIM_TX_RC_USE_SHORT_PREAMBLE;
 if (rate->flags & IEEE80211_TX_RC_MCS)
  result |= MAC80211_HWSIM_TX_RC_MCS;
 if (rate->flags & IEEE80211_TX_RC_GREEN_FIELD)
  result |= MAC80211_HWSIM_TX_RC_GREEN_FIELD;
 if (rate->flags & IEEE80211_TX_RC_40_MHZ_WIDTH)
  result |= MAC80211_HWSIM_TX_RC_40_MHZ_WIDTH;
 if (rate->flags & IEEE80211_TX_RC_DUP_DATA)
  result |= MAC80211_HWSIM_TX_RC_DUP_DATA;
 if (rate->flags & IEEE80211_TX_RC_SHORT_GI)
  result |= MAC80211_HWSIM_TX_RC_SHORT_GI;
 if (rate->flags & IEEE80211_TX_RC_VHT_MCS)
  result |= MAC80211_HWSIM_TX_RC_VHT_MCS;
 if (rate->flags & IEEE80211_TX_RC_80_MHZ_WIDTH)
  result |= MAC80211_HWSIM_TX_RC_80_MHZ_WIDTH;
 if (rate->flags & IEEE80211_TX_RC_160_MHZ_WIDTH)
  result |= MAC80211_HWSIM_TX_RC_160_MHZ_WIDTH;

 return result;
}

static void mac80211_hwsim_tx_frame_nl(struct ieee80211_hw *hw,
           struct sk_buff *my_skb,
           int dst_portid,
           struct ieee80211_channel *channel)
{
 struct sk_buff *skb;
 struct mac80211_hwsim_data *data = hw->priv;
 struct ieee80211_hdr *hdr = (struct ieee80211_hdr *) my_skb->data;
 struct ieee80211_tx_info *info = IEEE80211_SKB_CB(my_skb);
 void *msg_head;
 unsigned int hwsim_flags = 0;
 int i;
 struct hwsim_tx_rate tx_attempts[IEEE80211_TX_MAX_RATES];
 struct hwsim_tx_rate_flag tx_attempts_flags[IEEE80211_TX_MAX_RATES];
 uintptr_t cookie;

 if (data->ps != PS_DISABLED)
  hdr->frame_control |= cpu_to_le16(IEEE80211_FCTL_PM);
 /* If the queue contains MAX_QUEUE skb's drop some */
 if (skb_queue_len(&data->pending) >= MAX_QUEUE) {
  /* Dropping until WARN_QUEUE level */
  while (skb_queue_len(&data->pending) >= WARN_QUEUE) {
   ieee80211_free_txskb(hw, skb_dequeue(&data->pending));
   data->tx_dropped++;
  }
 }

 skb = genlmsg_new(GENLMSG_DEFAULT_SIZE, GFP_ATOMIC);
 if (skb == NULL)
  goto nla_put_failure;

 msg_head = genlmsg_put(skb, 0, 0, &hwsim_genl_family, 0,
          HWSIM_CMD_FRAME);
 if (msg_head == NULL) {
  pr_debug("mac80211_hwsim: problem with msg_head\n");
  goto nla_put_failure;
 }

 if (nla_put(skb, HWSIM_ATTR_ADDR_TRANSMITTER,
      ETH_ALEN, data->addresses[1].addr))
  goto nla_put_failure;

 /* We get the skb->data */
 if (nla_put(skb, HWSIM_ATTR_FRAME, my_skb->len, my_skb->data))
  goto nla_put_failure;

 /* We get the flags for this transmission, and we translate them to
   wmediumd flags  */


 if (info->flags & IEEE80211_TX_CTL_REQ_TX_STATUS)
  hwsim_flags |= HWSIM_TX_CTL_REQ_TX_STATUS;

 if (info->flags & IEEE80211_TX_CTL_NO_ACK)
  hwsim_flags |= HWSIM_TX_CTL_NO_ACK;

 if (nla_put_u32(skb, HWSIM_ATTR_FLAGS, hwsim_flags))
  goto nla_put_failure;

 if (nla_put_u32(skb, HWSIM_ATTR_FREQ, channel->center_freq))
  goto nla_put_failure;

 /* We get the tx control (rate and retries) info*/

 for (i = 0; i < IEEE80211_TX_MAX_RATES; i++) {
  tx_attempts[i].idx = info->status.rates[i].idx;
  tx_attempts_flags[i].idx = info->status.rates[i].idx;
  tx_attempts[i].count = info->status.rates[i].count;
  tx_attempts_flags[i].flags =
    trans_tx_rate_flags_ieee2hwsim(
      &info->status.rates[i]);
 }

 if (nla_put(skb, HWSIM_ATTR_TX_INFO,
      sizeof(struct hwsim_tx_rate)*IEEE80211_TX_MAX_RATES,
      tx_attempts))
  goto nla_put_failure;

 if (nla_put(skb, HWSIM_ATTR_TX_INFO_FLAGS,
      sizeof(struct hwsim_tx_rate_flag) * IEEE80211_TX_MAX_RATES,
      tx_attempts_flags))
  goto nla_put_failure;

 /* We create a cookie to identify this skb */
 cookie = atomic_inc_return(&data->pending_cookie);
 info->rate_driver_data[0] = (void *)cookie;
 if (nla_put_u64_64bit(skb, HWSIM_ATTR_COOKIE, cookie, HWSIM_ATTR_PAD))
  goto nla_put_failure;

 genlmsg_end(skb, msg_head);

 if (hwsim_virtio_enabled) {
  if (hwsim_tx_virtio(data, skb))
   goto err_free_txskb;
 } else {
  if (hwsim_unicast_netgroup(data, skb, dst_portid))
   goto err_free_txskb;
 }

 /* Enqueue the packet */
 skb_queue_tail(&data->pending, my_skb);
 data->tx_pkts++;
 data->tx_bytes += my_skb->len;
 return;

nla_put_failure:
 nlmsg_free(skb);
err_free_txskb:
 pr_debug("mac80211_hwsim: error occurred in %s\n", __func__);
 ieee80211_free_txskb(hw, my_skb);
 data->tx_failed++;
}

static bool hwsim_chans_compat(struct ieee80211_channel *c1,
          struct ieee80211_channel *c2)
{
 if (!c1 || !c2)
  return false;

 return c1->center_freq == c2->center_freq;
}

struct tx_iter_data {
 struct ieee80211_channel *channel;
 bool receive;
};

static void mac80211_hwsim_tx_iter(void *_data, u8 *addr,
       struct ieee80211_vif *vif)
{
 struct tx_iter_data *data = _data;
 int i;

 for (i = 0; i < ARRAY_SIZE(vif->link_conf); i++) {
  struct ieee80211_bss_conf *conf;
  struct ieee80211_chanctx_conf *chanctx;

  conf = rcu_dereference(vif->link_conf[i]);
  if (!conf)
   continue;

  chanctx = rcu_dereference(conf->chanctx_conf);
  if (!chanctx)
   continue;

  if (!hwsim_chans_compat(data->channel, chanctx->def.chan))
   continue;

  data->receive = true;
  return;
 }
}

static void mac80211_hwsim_add_vendor_rtap(struct sk_buff *skb)
{
 /*
 * To enable this code, #define the HWSIM_RADIOTAP_OUI,
 * e.g. like this:
 * #define HWSIM_RADIOTAP_OUI "\x02\x00\x00"
 * (but you should use a valid OUI, not that)
 *
 * If anyone wants to 'donate' a radiotap OUI/subns code
 * please send a patch removing this #ifdef and changing
 * the values accordingly.
 */

#ifdef HWSIM_RADIOTAP_OUI
 struct ieee80211_radiotap_vendor_tlv *rtap;
 static const char vendor_data[8] = "ABCDEFGH";

 // Make sure no padding is needed
 BUILD_BUG_ON(sizeof(vendor_data) % 4);
 /* this is last radiotap info before the mac header, so
 * skb_reset_mac_header for mac8022 to know the end of
 * the radiotap TLV/beginning of the 802.11 header
 */

 skb_reset_mac_header(skb);

 /*
 * Note that this code requires the headroom in the SKB
 * that was allocated earlier.
 */

 rtap = skb_push(skb, sizeof(*rtap) + sizeof(vendor_data));

 rtap->len = cpu_to_le16(sizeof(*rtap) -
    sizeof(struct ieee80211_radiotap_tlv) +
    sizeof(vendor_data));
 rtap->type = cpu_to_le16(IEEE80211_RADIOTAP_VENDOR_NAMESPACE);

 rtap->content.oui[0] = HWSIM_RADIOTAP_OUI[0];
 rtap->content.oui[1] = HWSIM_RADIOTAP_OUI[1];
 rtap->content.oui[2] = HWSIM_RADIOTAP_OUI[2];
 rtap->content.oui_subtype = 127;
 /* clear reserved field */
 rtap->content.reserved = 0;
 rtap->content.vendor_type = 0;
 memcpy(rtap->content.data, vendor_data, sizeof(vendor_data));

 IEEE80211_SKB_RXCB(skb)->flag |= RX_FLAG_RADIOTAP_TLV_AT_END;
#endif
}

static void mac80211_hwsim_rx(struct mac80211_hwsim_data *data,
         struct ieee80211_rx_status *rx_status,
         struct sk_buff *skb)
{
 struct ieee80211_hdr *hdr = (void *)skb->data;

 if (!ieee80211_has_morefrags(hdr->frame_control) &&
     !is_multicast_ether_addr(hdr->addr1) &&
     (ieee80211_is_mgmt(hdr->frame_control) ||
      ieee80211_is_data(hdr->frame_control))) {
  struct ieee80211_sta *sta;
  unsigned int link_id;

  rcu_read_lock();
  sta = ieee80211_find_sta_by_link_addrs(data->hw, hdr->addr2,
             hdr->addr1, &link_id);
  if (sta) {
   struct hwsim_sta_priv *sp = (void *)sta->drv_priv;

   if (ieee80211_has_pm(hdr->frame_control))
    sp->active_links_rx &= ~BIT(link_id);
   else
    sp->active_links_rx |= BIT(link_id);

   rx_status->link_valid = true;
   rx_status->link_id = link_id;
  }
  rcu_read_unlock();
 }

 memcpy(IEEE80211_SKB_RXCB(skb), rx_status, sizeof(*rx_status));

 mac80211_hwsim_add_vendor_rtap(skb);

 data->rx_pkts++;
 data->rx_bytes += skb->len;
 ieee80211_rx_irqsafe(data->hw, skb);
}

static bool mac80211_hwsim_tx_frame_no_nl(struct ieee80211_hw *hw,
       struct sk_buff *skb,
       struct ieee80211_channel *chan)
{
 struct mac80211_hwsim_data *data = hw->priv, *data2;
 bool ack = false;
 struct ieee80211_hdr *hdr = (struct ieee80211_hdr *) skb->data;
 struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
 struct ieee80211_rx_status rx_status;
 u64 now;

 memset(&rx_status, 0, sizeof(rx_status));
 rx_status.flag |= RX_FLAG_MACTIME_START;
 rx_status.freq = chan->center_freq;
 rx_status.freq_offset = chan->freq_offset ? 1 : 0;
 rx_status.band = chan->band;
 if (info->control.rates[0].flags & IEEE80211_TX_RC_VHT_MCS) {
  rx_status.rate_idx =
   ieee80211_rate_get_vht_mcs(&info->control.rates[0]);
  rx_status.nss =
   ieee80211_rate_get_vht_nss(&info->control.rates[0]);
  rx_status.encoding = RX_ENC_VHT;
 } else {
  rx_status.rate_idx = info->control.rates[0].idx;
  if (info->control.rates[0].flags & IEEE80211_TX_RC_MCS)
   rx_status.encoding = RX_ENC_HT;
 }
 if (info->control.rates[0].flags & IEEE80211_TX_RC_40_MHZ_WIDTH)
  rx_status.bw = RATE_INFO_BW_40;
 else if (info->control.rates[0].flags & IEEE80211_TX_RC_80_MHZ_WIDTH)
  rx_status.bw = RATE_INFO_BW_80;
 else if (info->control.rates[0].flags & IEEE80211_TX_RC_160_MHZ_WIDTH)
  rx_status.bw = RATE_INFO_BW_160;
 else
  rx_status.bw = RATE_INFO_BW_20;
 if (info->control.rates[0].flags & IEEE80211_TX_RC_SHORT_GI)
  rx_status.enc_flags |= RX_ENC_FLAG_SHORT_GI;
 /* TODO: simulate optional packet loss */
 rx_status.signal = data->rx_rssi;
 if (info->control.vif)
  rx_status.signal += info->control.vif->bss_conf.txpower;

 if (data->ps != PS_DISABLED)
  hdr->frame_control |= cpu_to_le16(IEEE80211_FCTL_PM);

 /* release the skb's source info */
 skb_orphan(skb);
 skb_dst_drop(skb);
 skb->mark = 0;
 skb_ext_reset(skb);
 nf_reset_ct(skb);

 /*
 * Get absolute mactime here so all HWs RX at the "same time", and
 * absolute TX time for beacon mactime so the timestamp matches.
 * Giving beacons a different mactime than non-beacons looks messy, but
 * it helps the Toffset be exact and a ~10us mactime discrepancy
 * probably doesn't really matter.
 */

 if (ieee80211_is_beacon(hdr->frame_control) ||
     ieee80211_is_probe_resp(hdr->frame_control)) {
  rx_status.boottime_ns = ktime_get_boottime_ns();
  now = data->abs_bcn_ts;
 } else {
  now = mac80211_hwsim_get_tsf_raw();
 }

 /* Copy skb to all enabled radios that are on the current frequency */
 spin_lock(&hwsim_radio_lock);
 list_for_each_entry(data2, &hwsim_radios, list) {
  struct sk_buff *nskb;
  struct tx_iter_data tx_iter_data = {
   .receive = false,
   .channel = chan,
  };

  if (data == data2)
   continue;

  if (!data2->started || (data2->idle && !data2->tmp_chan) ||
      !hwsim_ps_rx_ok(data2, skb))
   continue;

  if (!(data->group & data2->group))
   continue;

  if (data->netgroup != data2->netgroup)
   continue;

  if (!hwsim_chans_compat(chan, data2->tmp_chan) &&
      !hwsim_chans_compat(chan, data2->channel)) {
   ieee80211_iterate_active_interfaces_atomic(
    data2->hw, IEEE80211_IFACE_ITER_NORMAL,
    mac80211_hwsim_tx_iter, &tx_iter_data);
   if (!tx_iter_data.receive)
    continue;
  }

  /*
 * reserve some space for our vendor and the normal
 * radiotap header, since we're copying anyway
 */

  if (skb->len < PAGE_SIZE && paged_rx) {
   struct page *page = alloc_page(GFP_ATOMIC);

   if (!page)
    continue;

   nskb = dev_alloc_skb(128);
   if (!nskb) {
    __free_page(page);
    continue;
   }

   memcpy(page_address(page), skb->data, skb->len);
   skb_add_rx_frag(nskb, 0, page, 0, skb->len, skb->len);
  } else {
   nskb = skb_copy(skb, GFP_ATOMIC);
   if (!nskb)
    continue;
  }

  if (mac80211_hwsim_addr_match(data2, hdr->addr1))
   ack = true;

  rx_status.mactime = now + data2->tsf_offset;

  mac80211_hwsim_rx(data2, &rx_status, nskb);
 }
 spin_unlock(&hwsim_radio_lock);

 return ack;
}

static struct ieee80211_bss_conf *
mac80211_hwsim_select_tx_link(struct mac80211_hwsim_data *data,
         struct ieee80211_vif *vif,
         struct ieee80211_sta *sta,
         struct ieee80211_hdr *hdr,
         struct ieee80211_link_sta **link_sta)
{
 struct hwsim_sta_priv *sp = (void *)sta->drv_priv;
 int i;

 if (!ieee80211_vif_is_mld(vif))
  return &vif->bss_conf;

 WARN_ON(is_multicast_ether_addr(hdr->addr1));

 if (WARN_ON_ONCE(!sta || !sta->valid_links))
  return &vif->bss_conf;

 for (i = 0; i < ARRAY_SIZE(vif->link_conf); i++) {
  struct ieee80211_bss_conf *bss_conf;
  unsigned int link_id;

  /* round-robin the available link IDs */
  link_id = (sp->last_link + i + 1) % ARRAY_SIZE(vif->link_conf);

  if (!(vif->active_links & BIT(link_id)))
   continue;

  if (!(sp->active_links_rx & BIT(link_id)))
   continue;

  *link_sta = rcu_dereference(sta->link[link_id]);
  if (!*link_sta)
   continue;

  bss_conf = rcu_dereference(vif->link_conf[link_id]);
  if (WARN_ON_ONCE(!bss_conf))
   continue;

  /* can happen while switching links */
  if (!rcu_access_pointer(bss_conf->chanctx_conf))
   continue;

  sp->last_link = link_id;
  return bss_conf;
 }

 return NULL;
}

static void mac80211_hwsim_tx(struct ieee80211_hw *hw,
         struct ieee80211_tx_control *control,
         struct sk_buff *skb)
{
 struct mac80211_hwsim_data *data = hw->priv;
 struct ieee80211_tx_info *txi = IEEE80211_SKB_CB(skb);
 struct ieee80211_hdr *hdr = (void *)skb->data;
 struct ieee80211_chanctx_conf *chanctx_conf;
 struct ieee80211_channel *channel;
 bool ack;
 enum nl80211_chan_width confbw = NL80211_CHAN_WIDTH_20_NOHT;
 u32 _portid, i;

 if (WARN_ON(skb->len < 10)) {
  /* Should not happen; just a sanity check for addr1 use */
  ieee80211_free_txskb(hw, skb);
  return;
 }

 if (!data->use_chanctx) {
  channel = data->channel;
  confbw = data->bw;
 } else if (txi->hw_queue == 4) {
  channel = data->tmp_chan;
 } else {
  u8 link = u32_get_bits(IEEE80211_SKB_CB(skb)->control.flags,
           IEEE80211_TX_CTRL_MLO_LINK);
  struct ieee80211_vif *vif = txi->control.vif;
  struct ieee80211_link_sta *link_sta = NULL;
  struct ieee80211_sta *sta = control->sta;
  struct ieee80211_bss_conf *bss_conf;

  if (link != IEEE80211_LINK_UNSPECIFIED) {
   bss_conf = rcu_dereference(txi->control.vif->link_conf[link]);
   if (sta)
    link_sta = rcu_dereference(sta->link[link]);
  } else {
   bss_conf = mac80211_hwsim_select_tx_link(data, vif, sta,
         hdr, &link_sta);
  }

  if (unlikely(!bss_conf)) {
   /* if it's an MLO STA, it might have deactivated all
 * links temporarily - but we don't handle real PS in
 * this code yet, so just drop the frame in that case
 */

   WARN(link != IEEE80211_LINK_UNSPECIFIED || !sta || !sta->mlo,
        "link:%d, sta:%pM, sta->mlo:%d\n",
        link, sta ? sta->addr : NULL, sta ? sta->mlo : -1);
   ieee80211_free_txskb(hw, skb);
   return;
  }

  /* Do address translations only between shared links. It is
 * possible that while an non-AP MLD station and an AP MLD
 * station have shared links, the frame is intended to be sent
 * on a link which is not shared (for example when sending a
 * probe response).
 */

  if (sta && sta->mlo && link_sta) {
   /* address translation to link addresses on TX */
   ether_addr_copy(hdr->addr1, link_sta->addr);
   ether_addr_copy(hdr->addr2, bss_conf->addr);
   /* translate A3 only if it's the BSSID */
   if (!ieee80211_has_tods(hdr->frame_control) &&
       !ieee80211_has_fromds(hdr->frame_control)) {
    if (ether_addr_equal(hdr->addr3, sta->addr))
     ether_addr_copy(hdr->addr3, link_sta->addr);
    else if (ether_addr_equal(hdr->addr3, vif->addr))
     ether_addr_copy(hdr->addr3, bss_conf->addr);
   }
   /* no need to look at A4, if present it's SA */
  }

  chanctx_conf = rcu_dereference(bss_conf->chanctx_conf);
  if (chanctx_conf) {
   channel = chanctx_conf->def.chan;
   confbw = chanctx_conf->def.width;
  } else {
   channel = NULL;
  }
 }

 if (WARN(!channel, "TX w/o channel - queue = %d\n", txi->hw_queue)) {
  ieee80211_free_txskb(hw, skb);
  return;
 }

 if (data->idle && !data->tmp_chan) {
  wiphy_dbg(hw->wiphy, "Trying to TX when idle - reject\n");
  ieee80211_free_txskb(hw, skb);
  return;
 }

 if (txi->control.vif)
  hwsim_check_magic(txi->control.vif);
 if (control->sta)
  hwsim_check_sta_magic(control->sta);

 if (ieee80211_hw_check(hw, SUPPORTS_RC_TABLE))
  ieee80211_get_tx_rates(txi->control.vif, control->sta, skb,
           txi->control.rates,
           ARRAY_SIZE(txi->control.rates));

 for (i = 0; i < ARRAY_SIZE(txi->control.rates); i++) {
  u16 rflags = txi->control.rates[i].flags;
  /* initialize to data->bw for 5/10 MHz handling */
  enum nl80211_chan_width bw = data->bw;

  if (txi->control.rates[i].idx == -1)
   break;

  if (rflags & IEEE80211_TX_RC_40_MHZ_WIDTH)
   bw = NL80211_CHAN_WIDTH_40;
  else if (rflags & IEEE80211_TX_RC_80_MHZ_WIDTH)
   bw = NL80211_CHAN_WIDTH_80;
  else if (rflags & IEEE80211_TX_RC_160_MHZ_WIDTH)
   bw = NL80211_CHAN_WIDTH_160;

  if (WARN_ON(hwsim_get_chanwidth(bw) > hwsim_get_chanwidth(confbw)))
   return;
 }

 if (skb->len >= 24 + 8 &&
     ieee80211_is_probe_resp(hdr->frame_control)) {
  /* fake header transmission time */
  struct ieee80211_mgmt *mgmt;
  struct ieee80211_rate *txrate;
  /* TODO: get MCS */
  int bitrate = 100;
  u64 ts;

  mgmt = (struct ieee80211_mgmt *)skb->data;
  txrate = ieee80211_get_tx_rate(hw, txi);
  if (txrate)
   bitrate = txrate->bitrate;
  ts = mac80211_hwsim_get_tsf_raw();
  mgmt->u.probe_resp.timestamp =
   cpu_to_le64(ts + data->tsf_offset +
        24 * 8 * 10 / bitrate);
 }

 mac80211_hwsim_monitor_rx(hw, skb, channel);

 /* wmediumd mode check */
 _portid = READ_ONCE(data->wmediumd);

 if (_portid || hwsim_virtio_enabled)
  return mac80211_hwsim_tx_frame_nl(hw, skb, _portid, channel);

 /* NO wmediumd detected, perfect medium simulation */
 data->tx_pkts++;
 data->tx_bytes += skb->len;
 ack = mac80211_hwsim_tx_frame_no_nl(hw, skb, channel);

 if (ack && skb->len >= 16)
  mac80211_hwsim_monitor_ack(channel, hdr->addr2);

 ieee80211_tx_info_clear_status(txi);

 /* frame was transmitted at most favorable rate at first attempt */
 txi->control.rates[0].count = 1;
 txi->control.rates[1].idx = -1;

 if (!(txi->flags & IEEE80211_TX_CTL_NO_ACK) && ack)
  txi->flags |= IEEE80211_TX_STAT_ACK;
 ieee80211_tx_status_irqsafe(hw, skb);
}


static int mac80211_hwsim_start(struct ieee80211_hw *hw)
{
 struct mac80211_hwsim_data *data = hw->priv;
 wiphy_dbg(hw->wiphy, "%s\n", __func__);
 data->started = true;
 return 0;
}


static void mac80211_hwsim_stop(struct ieee80211_hw *hw, bool suspend)
{
 struct mac80211_hwsim_data *data = hw->priv;
 int i;

 data->started = false;

 for (i = 0; i < ARRAY_SIZE(data->link_data); i++)
  hrtimer_cancel(&data->link_data[i].beacon_timer);

 while (!skb_queue_empty(&data->pending))
  ieee80211_free_txskb(hw, skb_dequeue(&data->pending));

 wiphy_dbg(hw->wiphy, "%s\n", __func__);
}


static int mac80211_hwsim_add_interface(struct ieee80211_hw *hw,
     struct ieee80211_vif *vif)
{
 wiphy_dbg(hw->wiphy, "%s (type=%d mac_addr=%pM)\n",
    __func__, ieee80211_vif_type_p2p(vif),
    vif->addr);
 hwsim_set_magic(vif);

 if (vif->type != NL80211_IFTYPE_MONITOR)
  mac80211_hwsim_config_mac_nl(hw, vif->addr, true);

 vif->cab_queue = 0;
 vif->hw_queue[IEEE80211_AC_VO] = 0;
 vif->hw_queue[IEEE80211_AC_VI] = 1;
 vif->hw_queue[IEEE80211_AC_BE] = 2;
 vif->hw_queue[IEEE80211_AC_BK] = 3;

 return 0;
}

#ifdef CONFIG_MAC80211_DEBUGFS
static void
mac80211_hwsim_link_add_debugfs(struct ieee80211_hw *hw,
    struct ieee80211_vif *vif,
    struct ieee80211_bss_conf *link_conf,
    struct dentry *dir)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;

 debugfs_create_u32("skip_beacons", 0600, dir,
      &vp->skip_beacons[link_conf->link_id]);
}
#endif

static int mac80211_hwsim_change_interface(struct ieee80211_hw *hw,
        struct ieee80211_vif *vif,
        enum nl80211_iftype newtype,
        bool newp2p)
{
 newtype = ieee80211_iftype_p2p(newtype, newp2p);
 wiphy_dbg(hw->wiphy,
    "%s (old type=%d, new type=%d, mac_addr=%pM)\n",
    __func__, ieee80211_vif_type_p2p(vif),
      newtype, vif->addr);
 hwsim_check_magic(vif);

 /*
 * interface may change from non-AP to AP in
 * which case this needs to be set up again
 */

 vif->cab_queue = 0;

 return 0;
}

static void mac80211_hwsim_remove_interface(
 struct ieee80211_hw *hw, struct ieee80211_vif *vif)
{
 wiphy_dbg(hw->wiphy, "%s (type=%d mac_addr=%pM)\n",
    __func__, ieee80211_vif_type_p2p(vif),
    vif->addr);
 hwsim_check_magic(vif);
 hwsim_clear_magic(vif);
 if (vif->type != NL80211_IFTYPE_MONITOR)
  mac80211_hwsim_config_mac_nl(hw, vif->addr, false);
}

static void mac80211_hwsim_tx_frame(struct ieee80211_hw *hw,
        struct sk_buff *skb,
        struct ieee80211_channel *chan)
{
 struct mac80211_hwsim_data *data = hw->priv;
 u32 _portid = READ_ONCE(data->wmediumd);

 if (ieee80211_hw_check(hw, SUPPORTS_RC_TABLE)) {
  struct ieee80211_tx_info *txi = IEEE80211_SKB_CB(skb);
  ieee80211_get_tx_rates(txi->control.vif, NULL, skb,
           txi->control.rates,
           ARRAY_SIZE(txi->control.rates));
 }

 mac80211_hwsim_monitor_rx(hw, skb, chan);

 if (_portid || hwsim_virtio_enabled)
  return mac80211_hwsim_tx_frame_nl(hw, skb, _portid, chan);

 data->tx_pkts++;
 data->tx_bytes += skb->len;
 mac80211_hwsim_tx_frame_no_nl(hw, skb, chan);
 dev_kfree_skb(skb);
}

static void __mac80211_hwsim_beacon_tx(struct ieee80211_bss_conf *link_conf,
           struct mac80211_hwsim_data *data,
           struct ieee80211_hw *hw,
           struct ieee80211_vif *vif,
           struct sk_buff *skb)
{
 struct hwsim_vif_priv *vp = (void *)vif->drv_priv;
 struct ieee80211_tx_info *info;
 struct ieee80211_rate *txrate;
 struct ieee80211_mgmt *mgmt;
 /* TODO: get MCS */
 int bitrate = 100;

 if (vp->skip_beacons[link_conf->link_id]) {
  vp->skip_beacons[link_conf->link_id]--;
  dev_kfree_skb(skb);
  return;
 }

 info = IEEE80211_SKB_CB(skb);
 if (ieee80211_hw_check(hw, SUPPORTS_RC_TABLE))
  ieee80211_get_tx_rates(vif, NULL, skb,
           info->control.rates,
           ARRAY_SIZE(info->control.rates));

--> --------------------

--> maximum size reached

--> --------------------

Messung V0.5
C=92 H=95 G=93

¤ Dauer der Verarbeitung: 0.27 Sekunden  (vorverarbeitet)  ¤

*© Formatika GbR, Deutschland






Wurzel

Suchen

Beweissystem der NASA

Beweissystem Isabelle

NIST Cobol Testsuite

Cephes Mathematical Library

Wiener Entwicklungsmethode

Haftungshinweis

Die Informationen auf dieser Webseite wurden nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit, noch Qualität der bereit gestellten Informationen zugesichert.

Bemerkung:

Die farbliche Syntaxdarstellung und die Messung sind noch experimentell.