#include "bpfilter.h"
#include <sys/param.h>
#include <sys/sockio.h>
#include <sys/mbuf.h>
#include <sys/systm.h>
#include <sys/queue.h>
#include <sys/device.h>
#include <machine/bus.h>
#include <dev/usb/usb.h>
#include <dev/usb/usbdi.h>
#include <dev/usb/usbdi_util.h>
#include <dev/usb/usbdivar.h>
#include <dev/usb/usbdevs.h>
#if NBPFILTER > 0
#include <net/bpf.h>
#endif
#include <net/if.h>
#include <net/if_media.h>
#include <netinet/in.h>
#include <netinet/if_ether.h>
#include <net80211/ieee80211_var.h>
#include <net80211/ieee80211_radiotap.h>
#include <dev/usb/if_atureg.h>
#ifdef ATU_DEBUG
#define DPRINTF(x) do { if (atudebug) printf x; } while (0)
#define DPRINTFN(n,x) do { if (atudebug>(n)) printf x; } while (0)
int atudebug = 1;
#else
#define DPRINTF(x)
#define DPRINTFN(n,x)
#endif
int atu_match(struct device *, void *, void *);
void atu_attach(struct device *, struct device *, void *);
int atu_detach(struct device *, int);
struct cfdriver atu_cd = {
NULL, "atu", DV_IFNET
};
const struct cfattach atu_ca = {
sizeof(struct atu_softc), atu_match, atu_attach, atu_detach
};
struct atu_type atu_devs[] = {
{ USB_VENDOR_3COM, USB_PRODUCT_3COM_3CRSHEW696,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ABOCOM, USB_PRODUCT_ABOCOM_BWU613,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ACCTON, USB_PRODUCT_ACCTON_2664W,
AT76C503_rfmd_acc, ATU_NO_QUIRK },
{ USB_VENDOR_ACERP, USB_PRODUCT_ACERP_AWL300,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_ACERP, USB_PRODUCT_ACERP_AWL400,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ACTIONTEC, USB_PRODUCT_ACTIONTEC_802UAT1,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ADDTRON, USB_PRODUCT_ADDTRON_AWU120,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_AINCOMM, USB_PRODUCT_AINCOMM_AWU2000B,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_ASKEY, USB_PRODUCT_ASKEY_VOYAGER1010,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_ASKEY, USB_PRODUCT_ASKEY_WLL013I,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_ASKEY, USB_PRODUCT_ASKEY_WLL013,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C503I1,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C503I2,
AT76C503_i3863, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C503RFMD,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C505RFMD,
AT76C505_rfmd, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C505RFMD2958,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C505A,
RadioRFMD2958_SMC, ATU_QUIRK_NO_REMAP | ATU_QUIRK_FW_DELAY },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_AT76C505AS,
RadioRFMD2958_SMC, ATU_QUIRK_NO_REMAP | ATU_QUIRK_FW_DELAY },
{ USB_VENDOR_ATMEL, USB_PRODUCT_ATMEL_WN210,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_BELKIN, USB_PRODUCT_BELKIN_F5D6050,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_CONCEPTRONIC, USB_PRODUCT_CONCEPTRONIC_C11U,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_CONCEPTRONIC, USB_PRODUCT_CONCEPTRONIC_WL210,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_COMPAQ, USB_PRODUCT_COMPAQ_IPAQWLAN,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_COREGA, USB_PRODUCT_COREGA_WLUSB_11_STICK,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_DICKSMITH, USB_PRODUCT_DICKSMITH_CHUSB611G,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_DICKSMITH, USB_PRODUCT_DICKSMITH_WL200U,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_DICKSMITH, USB_PRODUCT_DICKSMITH_WL240U,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_DICKSMITH, USB_PRODUCT_DICKSMITH_XH1153,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_DLINK, USB_PRODUCT_DLINK_DWL120E,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_GIGABYTE, USB_PRODUCT_GIGABYTE_GNWLBM101,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_GIGASET, USB_PRODUCT_GIGASET_WLAN,
RadioRFMD2958_SMC, ATU_QUIRK_NO_REMAP | ATU_QUIRK_FW_DELAY },
{ USB_VENDOR_HP, USB_PRODUCT_HP_HN210W,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_INTEL, USB_PRODUCT_INTEL_AP310,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_IODATA, USB_PRODUCT_IODATA_USBWNB11A,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_LEXAR, USB_PRODUCT_LEXAR_2662WAR,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_LINKSYS, USB_PRODUCT_LINKSYS_WUSB11,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_LINKSYS2, USB_PRODUCT_LINKSYS2_NWU11B,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_LINKSYS3, USB_PRODUCT_LINKSYS3_WUSB11V28,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_MSI, USB_PRODUCT_MSI_WLAN,
RadioRFMD2958, ATU_NO_QUIRK },
{ USB_VENDOR_NETGEAR2, USB_PRODUCT_NETGEAR2_MA101,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_NETGEAR2, USB_PRODUCT_NETGEAR2_MA101B,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_OQO, USB_PRODUCT_OQO_WIFI01,
RadioRFMD2958_SMC, ATU_QUIRK_NO_REMAP | ATU_QUIRK_FW_DELAY },
{ USB_VENDOR_PLANEX2, USB_PRODUCT_PLANEX2_GW_US11S,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_SAMSUNG, USB_PRODUCT_SAMSUNG_SWL2100W,
AT76C503_i3863, ATU_NO_QUIRK },
{ USB_VENDOR_SIEMENS2, USB_PRODUCT_SIEMENS2_WLL013,
RadioRFMD, ATU_NO_QUIRK },
{ USB_VENDOR_SMC3, USB_PRODUCT_SMC3_2662WV1,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_SMC3, USB_PRODUCT_SMC3_2662WV2,
AT76C503_rfmd_acc, ATU_NO_QUIRK },
{ USB_VENDOR_TEKRAM, USB_PRODUCT_TEKRAM_U300C,
RadioIntersil, ATU_NO_QUIRK },
{ USB_VENDOR_ZCOM, USB_PRODUCT_ZCOM_M4Y750,
RadioIntersil, ATU_NO_QUIRK },
};
struct atu_radfirm {
enum atu_radio_type atur_type;
char *atur_internal;
char *atur_external;
u_int8_t max_rssi;
} atu_radfirm[] = {
{ RadioRFMD, "atu-rfmd-int", "atu-rfmd-ext", 0 },
{ RadioRFMD2958, "atu-rfmd2958-int", "atu-rfmd2958-ext", 81 },
{ RadioRFMD2958_SMC, "atu-rfmd2958smc-int", "atu-rfmd2958smc-ext", 0 },
{ RadioIntersil, "atu-intersil-int", "atu-intersil-ext", 0 },
{
AT76C503_i3863,
"atu-at76c503-i3863-int",
"atu-at76c503-i3863-ext",
0
},
{
AT76C503_rfmd_acc,
"atu-at76c503-rfmd-acc-int",
"atu-at76c503-rfmd-acc-ext",
0
},
{
AT76C505_rfmd,
"atu-at76c505-rfmd-int",
"atu-at76c505-rfmd-ext",
0
}
};
int atu_newbuf(struct atu_softc *, struct atu_chain *, struct mbuf *);
void atu_rxeof(struct usbd_xfer *, void *, usbd_status);
void atu_txeof(struct usbd_xfer *, void *, usbd_status);
void atu_start(struct ifnet *);
int atu_ioctl(struct ifnet *, u_long, caddr_t);
int atu_init(struct ifnet *);
void atu_stop(struct ifnet *, int);
void atu_watchdog(struct ifnet *);
usbd_status atu_usb_request(struct atu_softc *sc, u_int8_t type,
u_int8_t request, u_int16_t value, u_int16_t index,
u_int16_t length, u_int8_t *data);
int atu_send_command(struct atu_softc *sc, u_int8_t *command, int size);
int atu_get_cmd_status(struct atu_softc *sc, u_int8_t cmd,
u_int8_t *status);
int atu_wait_completion(struct atu_softc *sc, u_int8_t cmd,
u_int8_t *status);
int atu_send_mib(struct atu_softc *sc, u_int8_t type,
u_int8_t size, u_int8_t index, void *data);
int atu_get_mib(struct atu_softc *sc, u_int8_t type,
u_int8_t size, u_int8_t index, u_int8_t *buf);
#if 0
int atu_start_ibss(struct atu_softc *sc);
#endif
int atu_start_scan(struct atu_softc *sc);
int atu_switch_radio(struct atu_softc *sc, int state);
int atu_initial_config(struct atu_softc *sc);
int atu_join(struct atu_softc *sc, struct ieee80211_node *node);
int8_t atu_get_dfu_state(struct atu_softc *sc);
u_int8_t atu_get_opmode(struct atu_softc *sc, u_int8_t *mode);
void atu_internal_firmware(struct device *);
void atu_external_firmware(struct device *);
int atu_get_card_config(struct atu_softc *sc);
int atu_media_change(struct ifnet *ifp);
void atu_media_status(struct ifnet *ifp, struct ifmediareq *req);
int atu_tx_list_init(struct atu_softc *);
int atu_rx_list_init(struct atu_softc *);
void atu_xfer_list_free(struct atu_softc *sc, struct atu_chain *ch,
int listlen);
void atu_task(void *);
int atu_newstate(struct ieee80211com *, enum ieee80211_state, int);
int atu_tx_start(struct atu_softc *, struct ieee80211_node *,
struct atu_chain *, struct mbuf *);
void atu_complete_attach(struct atu_softc *);
u_int8_t atu_calculate_padding(int);
usbd_status
atu_usb_request(struct atu_softc *sc, u_int8_t type,
u_int8_t request, u_int16_t value, u_int16_t index, u_int16_t length,
u_int8_t *data)
{
usb_device_request_t req;
struct usbd_xfer *xfer;
usbd_status err;
int total_len = 0, s;
req.bmRequestType = type;
req.bRequest = request;
USETW(req.wValue, value);
USETW(req.wIndex, index);
USETW(req.wLength, length);
#ifdef ATU_DEBUG
if (atudebug) {
if ((data == NULL) || (type & UT_READ)) {
DPRINTFN(20, ("%s: req=%02x val=%02x ind=%02x "
"len=%02x\n", sc->atu_dev.dv_xname, request,
value, index, length));
} else {
DPRINTFN(20, ("%s: req=%02x val=%02x ind=%02x "
"len=%02x [%8D]\n", sc->atu_dev.dv_xname,
request, value, index, length, data, " "));
}
}
#endif
s = splnet();
xfer = usbd_alloc_xfer(sc->atu_udev);
usbd_setup_default_xfer(xfer, sc->atu_udev, 0, 500000, &req, data,
length, USBD_SHORT_XFER_OK | USBD_SYNCHRONOUS, 0);
err = usbd_transfer(xfer);
usbd_get_xfer_status(xfer, NULL, NULL, &total_len, NULL);
#ifdef ATU_DEBUG
if (atudebug) {
if (type & UT_READ) {
DPRINTFN(20, ("%s: transferred 0x%x bytes in\n",
sc->atu_dev.dv_xname, total_len));
DPRINTFN(20, ("%s: dump [%10D]\n",
sc->atu_dev.dv_xname, data, " "));
} else {
if (total_len != length)
DPRINTF(("%s: ARG! wrote only %x bytes\n",
sc->atu_dev.dv_xname, total_len));
}
}
#endif
usbd_free_xfer(xfer);
splx(s);
return(err);
}
int
atu_send_command(struct atu_softc *sc, u_int8_t *command, int size)
{
return atu_usb_request(sc, UT_WRITE_VENDOR_DEVICE, 0x0e, 0x0000,
0x0000, size, command);
}
int
atu_get_cmd_status(struct atu_softc *sc, u_int8_t cmd, u_int8_t *status)
{
return atu_usb_request(sc, UT_READ_VENDOR_INTERFACE, 0x22, cmd,
0x0000, 6, status);
}
int
atu_wait_completion(struct atu_softc *sc, u_int8_t cmd, u_int8_t *status)
{
int idle_count = 0, err;
u_int8_t statusreq[6];
DPRINTFN(15, ("%s: wait-completion: cmd=%02x\n",
sc->atu_dev.dv_xname, cmd));
while (1) {
err = atu_get_cmd_status(sc, cmd, statusreq);
if (err)
return err;
#ifdef ATU_DEBUG
if (atudebug) {
DPRINTFN(20, ("%s: status=%s cmd=%02x\n",
sc->atu_dev.dv_xname,
ether_sprintf(statusreq), cmd));
}
#endif
if ((statusreq[5] == STATUS_IDLE) && (idle_count++ > 20)) {
DPRINTF(("%s: AAARRGGG!!! FIX ME!\n",
sc->atu_dev.dv_xname));
return 0;
}
if ((statusreq[5] != STATUS_IN_PROGRESS) &&
(statusreq[5] != STATUS_IDLE)) {
if (status != NULL)
*status = statusreq[5];
return 0;
}
usbd_delay_ms(sc->atu_udev, 25);
}
}
int
atu_send_mib(struct atu_softc *sc, u_int8_t type, u_int8_t size,
u_int8_t index, void *data)
{
int err;
struct atu_cmd_set_mib request;
memset(&request, 0, sizeof(request));
request.AtCmd = CMD_SET_MIB;
USETW(request.AtSize, size + 4);
request.MIBType = type;
request.MIBSize = size;
request.MIBIndex = index;
request.MIBReserved = 0;
switch (size) {
case 0:
break;
case 1:
request.data[0]=(long)data & 0x000000ff;
break;
case 2:
request.data[0]=(long)data & 0x000000ff;
request.data[1]=(long)data >> 8;
break;
default:
memcpy(request.data, data, size);
break;
}
err = atu_usb_request(sc, UT_WRITE_VENDOR_DEVICE, 0x0e, 0x0000,
0x0000, size+8, (uByte *)&request);
if (err)
return (err);
DPRINTFN(15, ("%s: sendmib : waitcompletion...\n",
sc->atu_dev.dv_xname));
return atu_wait_completion(sc, CMD_SET_MIB, NULL);
}
int
atu_get_mib(struct atu_softc *sc, u_int8_t type, u_int8_t size,
u_int8_t index, u_int8_t *buf)
{
return atu_usb_request(sc, UT_READ_VENDOR_INTERFACE, 0x033,
type << 8, index, size, buf);
}
#if 0
int
atu_start_ibss(struct atu_softc *sc)
{
int err;
struct atu_cmd_start_ibss Request;
Request.Cmd = CMD_START_IBSS;
Request.Reserved = 0;
Request.Size = sizeof(Request) - 4;
memset(Request.BSSID, 0x00, sizeof(Request.BSSID));
memset(Request.SSID, 0x00, sizeof(Request.SSID));
memcpy(Request.SSID, sc->atu_ssid, sc->atu_ssidlen);
Request.SSIDSize = sc->atu_ssidlen;
if (sc->atu_desired_channel != IEEE80211_CHAN_ANY)
Request.Channel = (u_int8_t)sc->atu_desired_channel;
else
Request.Channel = ATU_DEFAULT_CHANNEL;
Request.BSSType = AD_HOC_MODE;
memset(Request.Res, 0x00, sizeof(Request.Res));
err = atu_send_command(sc, (u_int8_t *)&Request, sizeof(Request));
if (err) {
DPRINTF(("%s: start ibss failed!\n",
sc->atu_dev.dv_xname));
return err;
}
err = atu_wait_completion(sc, CMD_START_IBSS, NULL);
if (err) {
DPRINTF(("%s: error waiting for start_ibss\n",
sc->atu_dev.dv_xname));
return err;
}
err = atu_get_mib(sc, MIB_MAC_MGMT__CURRENT_BSSID, sc->atu_bssid);
if (err) {
DPRINTF(("%s: could not get BSSID!\n",
sc->atu_dev.dv_xname));
return err;
}
DPRINTF(("%s: started a new IBSS (BSSID=%s)\n",
sc->atu_dev.dv_xname, ether_sprintf(sc->atu_bssid)));
return 0;
}
#endif
int
atu_start_scan(struct atu_softc *sc)
{
struct ieee80211com *ic = &sc->sc_ic;
struct atu_cmd_do_scan Scan;
usbd_status err;
int Cnt;
memset(&Scan, 0, sizeof(Scan));
Scan.Cmd = CMD_START_SCAN;
Scan.Reserved = 0;
USETW(Scan.Size, sizeof(Scan) - 4);
for (Cnt=0; Cnt<6; Cnt++)
Scan.BSSID[Cnt] = 0xff;
memcpy(Scan.SSID, ic->ic_des_essid, ic->ic_des_esslen);
Scan.SSID_Len = ic->ic_des_esslen;
Scan.ScanType = ATU_SCAN_ACTIVE;
if (sc->atu_desired_channel != IEEE80211_CHAN_ANY)
Scan.Channel = (u_int8_t)sc->atu_desired_channel;
else
Scan.Channel = sc->atu_channel;
USETW(Scan.ProbeDelay, 0);
USETW(Scan.MinChannelTime, 100);
USETW(Scan.MaxChannelTime, 200);
Scan.InternationalScan = 0xc1;
#ifdef ATU_DEBUG
if (atudebug) {
DPRINTFN(20, ("%s: scan cmd len=%02x\n",
sc->atu_dev.dv_xname, sizeof(Scan)));
DPRINTFN(20, ("%s: scan cmd: %52D\n", sc->atu_dev.dv_xname,
(u_int8_t *)&Scan, " "));
}
#endif
err = atu_send_command(sc, (u_int8_t *)&Scan, sizeof(Scan));
if (err)
return err;
return 0;
}
int
atu_switch_radio(struct atu_softc *sc, int state)
{
usbd_status err;
struct atu_cmd CmdRadio;
if (sc->atu_radio == RadioIntersil) {
return 0;
}
memset(&CmdRadio, 0, sizeof(CmdRadio));
CmdRadio.Cmd = CMD_RADIO_ON;
if (sc->atu_radio_on != state) {
if (state == 0)
CmdRadio.Cmd = CMD_RADIO_OFF;
err = atu_send_command(sc, (u_int8_t *)&CmdRadio,
sizeof(CmdRadio));
if (err)
return err;
err = atu_wait_completion(sc, CmdRadio.Cmd, NULL);
if (err)
return err;
DPRINTFN(10, ("%s: radio turned %s\n",
sc->atu_dev.dv_xname, state ? "on" : "off"));
sc->atu_radio_on = state;
}
return 0;
}
int
atu_initial_config(struct atu_softc *sc)
{
struct ieee80211com *ic = &sc->sc_ic;
u_int32_t i;
usbd_status err;
u_int8_t rates[4] = {0x82, 0x04, 0x0B, 0x16};
struct atu_cmd_card_config cmd;
u_int8_t reg_domain;
DPRINTFN(10, ("%s: sending mac-addr\n", sc->atu_dev.dv_xname));
err = atu_send_mib(sc, MIB_MAC_ADDR__ADDR, ic->ic_myaddr);
if (err) {
DPRINTF(("%s: error setting mac-addr\n",
sc->atu_dev.dv_xname));
return err;
}
memset(&cmd, 0, sizeof(cmd));
cmd.Cmd = CMD_STARTUP;
cmd.Reserved = 0;
USETW(cmd.Size, sizeof(cmd) - 4);
if (sc->atu_desired_channel != IEEE80211_CHAN_ANY)
cmd.Channel = (u_int8_t)sc->atu_desired_channel;
else
cmd.Channel = sc->atu_channel;
cmd.AutoRateFallback = 1;
memcpy(cmd.BasicRateSet, rates, 4);
cmd.ShortRetryLimit = 7;
USETW(cmd.RTS_Threshold, 2347);
USETW(cmd.FragThreshold, 2346);
cmd.PromiscuousMode = 1;
cmd.PrivacyInvoked = (ic->ic_flags & IEEE80211_F_WEPON) ? 1 : 0;
cmd.ExcludeUnencrypted = 0;
switch (ic->ic_nw_keys[ic->ic_wep_txkey].k_cipher) {
case IEEE80211_CIPHER_WEP40:
cmd.EncryptionType = ATU_WEP_40BITS;
break;
case IEEE80211_CIPHER_WEP104:
cmd.EncryptionType = ATU_WEP_104BITS;
break;
default:
cmd.EncryptionType = ATU_WEP_OFF;
break;
}
cmd.WEP_DefaultKeyID = ic->ic_wep_txkey;
for (i = 0; i < IEEE80211_WEP_NKID; i++) {
memcpy(cmd.WEP_DefaultKey[i], ic->ic_nw_keys[i].k_key,
ic->ic_nw_keys[i].k_len);
}
memcpy(cmd.SSID, ic->ic_des_essid, ic->ic_des_esslen);
cmd.SSID_Len = ic->ic_des_esslen;
cmd.ShortPreamble = 0;
USETW(cmd.BeaconPeriod, 100);
err = atu_get_mib(sc, MIB_PHY__REG_DOMAIN, ®_domain);
if (err) {
DPRINTF(("%s: could not get regdomain!\n",
sc->atu_dev.dv_xname));
} else {
DPRINTF(("%s: we're in reg domain 0x%x according to the "
"adapter\n", sc->atu_dev.dv_xname, reg_domain));
}
#ifdef ATU_DEBUG
if (atudebug) {
DPRINTFN(20, ("%s: configlen=%02x\n", sc->atu_dev.dv_xname,
sizeof(cmd)));
DPRINTFN(20, ("%s: configdata= %108D\n",
sc->atu_dev.dv_xname, (u_int8_t *)&cmd, " "));
}
#endif
err = atu_send_command(sc, (u_int8_t *)&cmd, sizeof(cmd));
if (err)
return err;
err = atu_wait_completion(sc, CMD_STARTUP, NULL);
if (err)
return err;
err = atu_switch_radio(sc, 1);
if (err)
return err;
err = atu_send_mib(sc, MIB_LOCAL__PREAMBLE, NR(PREAMBLE_SHORT));
if (err)
return err;
err = atu_send_mib(sc, MIB_MAC__FRAG, NR(2346));
if (err)
return err;
err = atu_send_mib(sc, MIB_MAC__RTS, NR(2347));
if (err)
return err;
err = atu_send_mib(sc, MIB_LOCAL__AUTO_RATE_FALLBACK, NR(1));
if (err)
return err;
err = atu_send_mib(sc, MIB_MAC_MGMT__POWER_MODE,
NR(POWER_MODE_ACTIVE));
if (err)
return err;
DPRINTFN(10, ("%s: completed initial config\n",
sc->atu_dev.dv_xname));
return 0;
}
int
atu_join(struct atu_softc *sc, struct ieee80211_node *node)
{
struct atu_cmd_join join;
u_int8_t status;
usbd_status err;
memset(&join, 0, sizeof(join));
join.Cmd = CMD_JOIN;
join.Reserved = 0x00;
USETW(join.Size, sizeof(join) - 4);
DPRINTFN(15, ("%s: pre-join sc->atu_bssid=%s\n",
sc->atu_dev.dv_xname, ether_sprintf(sc->atu_bssid)));
DPRINTFN(15, ("%s: mode=%d\n", sc->atu_dev.dv_xname,
sc->atu_mode));
memcpy(join.bssid, node->ni_bssid, IEEE80211_ADDR_LEN);
memcpy(join.essid, node->ni_essid, node->ni_esslen);
join.essid_size = node->ni_esslen;
if (node->ni_capinfo & IEEE80211_CAPINFO_IBSS)
join.bss_type = AD_HOC_MODE;
else
join.bss_type = INFRASTRUCTURE_MODE;
join.channel = ieee80211_chan2ieee(&sc->sc_ic, node->ni_chan);
USETW(join.timeout, ATU_JOIN_TIMEOUT);
join.reserved = 0x00;
DPRINTFN(10, ("%s: trying to join BSSID=%s\n",
sc->atu_dev.dv_xname, ether_sprintf(join.bssid)));
err = atu_send_command(sc, (u_int8_t *)&join, sizeof(join));
if (err) {
DPRINTF(("%s: ERROR trying to join IBSS\n",
sc->atu_dev.dv_xname));
return err;
}
err = atu_wait_completion(sc, CMD_JOIN, &status);
if (err) {
DPRINTF(("%s: error joining BSS!\n",
sc->atu_dev.dv_xname));
return err;
}
if (status != STATUS_COMPLETE) {
DPRINTF(("%s: error joining... [status=%02x]\n",
sc->atu_dev.dv_xname, status));
return status;
} else {
DPRINTFN(10, ("%s: joined BSS\n", sc->atu_dev.dv_xname));
}
return err;
}
int8_t
atu_get_dfu_state(struct atu_softc *sc)
{
u_int8_t state;
if (atu_usb_request(sc, DFU_GETSTATE, 0, 0, 1, &state))
return -1;
return state;
}
u_int8_t
atu_get_opmode(struct atu_softc *sc, u_int8_t *mode)
{
return atu_usb_request(sc, UT_READ_VENDOR_INTERFACE, 0x33, 0x0001,
0x0000, 1, mode);
}
void
atu_internal_firmware(struct device *self)
{
struct atu_softc *sc = (struct atu_softc *)self;
u_char state, *ptr = NULL, *firm = NULL, status[6];
int block_size, block = 0, err, i;
size_t firm_len, bytes_left = 0;
char *name = "unknown-device";
for (i = 0; i < nitems(atu_radfirm); i++)
if (sc->atu_radio == atu_radfirm[i].atur_type)
name = atu_radfirm[i].atur_internal;
DPRINTF(("%s: loading firmware %s...\n",
sc->atu_dev.dv_xname, name));
err = loadfirmware(name, &firm, &firm_len);
if (err != 0) {
printf("%s: %s loadfirmware error %d\n",
sc->atu_dev.dv_xname, name, err);
goto fail;
}
ptr = firm;
bytes_left = firm_len;
state = atu_get_dfu_state(sc);
while (block >= 0 && state > 0) {
switch (state) {
case DFUState_DnLoadSync:
err = atu_usb_request(sc, DFU_GETSTATUS, 0, 0 , 6,
status);
if (err) {
DPRINTF(("%s: dfu_getstatus failed!\n",
sc->atu_dev.dv_xname));
free(firm, M_DEVBUF, firm_len);
goto fail;
}
state = DFUState_DnLoadIdle;
continue;
break;
case DFUState_DFUIdle:
case DFUState_DnLoadIdle:
if (bytes_left>=DFU_MaxBlockSize)
block_size = DFU_MaxBlockSize;
else
block_size = bytes_left;
DPRINTFN(15, ("%s: firmware block %d\n",
sc->atu_dev.dv_xname, block));
err = atu_usb_request(sc, DFU_DNLOAD, block++, 0,
block_size, ptr);
if (err) {
DPRINTF(("%s: dfu_dnload failed\n",
sc->atu_dev.dv_xname));
free(firm, M_DEVBUF, firm_len);
goto fail;
}
ptr += block_size;
bytes_left -= block_size;
if (block_size == 0)
block = -1;
break;
default:
DPRINTFN(20, ("%s: sleeping for a while\n",
sc->atu_dev.dv_xname));
usbd_delay_ms(sc->atu_udev, 100);
break;
}
state = atu_get_dfu_state(sc);
}
free(firm, M_DEVBUF, firm_len);
if (state != DFUState_ManifestSync) {
DPRINTF(("%s: state != manifestsync... eek!\n",
sc->atu_dev.dv_xname));
}
err = atu_usb_request(sc, DFU_GETSTATUS, 0, 0, 6, status);
if (err) {
DPRINTF(("%s: dfu_getstatus failed!\n",
sc->atu_dev.dv_xname));
goto fail;
}
DPRINTFN(15, ("%s: sending remap\n", sc->atu_dev.dv_xname));
err = atu_usb_request(sc, DFU_REMAP, 0, 0, 0, NULL);
if ((err) && (!ISSET(sc->atu_quirk, ATU_QUIRK_NO_REMAP))) {
DPRINTF(("%s: remap failed!\n", sc->atu_dev.dv_xname));
goto fail;
}
usbd_delay_ms(sc->atu_udev, 56+100);
printf("%s: reattaching after firmware upload\n",
sc->atu_dev.dv_xname);
usb_needs_reattach(sc->atu_udev);
fail:
usbd_deactivate(sc->atu_udev);
}
void
atu_external_firmware(struct device *self)
{
struct atu_softc *sc = (struct atu_softc *)self;
u_char *ptr = NULL, *firm = NULL;
int block_size, block = 0, err, i;
size_t firm_len, bytes_left = 0;
char *name = "unknown-device";
for (i = 0; i < nitems(atu_radfirm); i++)
if (sc->atu_radio == atu_radfirm[i].atur_type)
name = atu_radfirm[i].atur_external;
DPRINTF(("%s: loading external firmware %s\n",
sc->atu_dev.dv_xname, name));
err = loadfirmware(name, &firm, &firm_len);
if (err != 0) {
printf("%s: %s loadfirmware error %d\n",
sc->atu_dev.dv_xname, name, err);
return;
}
ptr = firm;
bytes_left = firm_len;
while (bytes_left) {
if (bytes_left > 1024)
block_size = 1024;
else
block_size = bytes_left;
DPRINTFN(15, ("%s: block:%d size:%d\n",
sc->atu_dev.dv_xname, block, block_size));
err = atu_usb_request(sc, UT_WRITE_VENDOR_DEVICE, 0x0e,
0x0802, block, block_size, ptr);
if (err) {
DPRINTF(("%s: could not load external firmware "
"block\n", sc->atu_dev.dv_xname));
free(firm, M_DEVBUF, firm_len);
return;
}
ptr += block_size;
block++;
bytes_left -= block_size;
}
free(firm, M_DEVBUF, firm_len);
err = atu_usb_request(sc, UT_WRITE_VENDOR_DEVICE, 0x0e, 0x0802,
block, 0, NULL);
if (err) {
DPRINTF(("%s: could not load last zero-length firmware "
"block\n", sc->atu_dev.dv_xname));
return;
}
if (sc->atu_quirk & ATU_QUIRK_FW_DELAY)
usbd_delay_ms(sc->atu_udev, 21 + 100);
DPRINTFN(10, ("%s: external firmware upload done\n",
sc->atu_dev.dv_xname));
atu_complete_attach(sc);
}
int
atu_get_card_config(struct atu_softc *sc)
{
struct ieee80211com *ic = &sc->sc_ic;
struct atu_rfmd_conf rfmd_conf;
struct atu_intersil_conf intersil_conf;
int err;
switch (sc->atu_radio) {
case RadioRFMD:
case RadioRFMD2958:
case RadioRFMD2958_SMC:
case AT76C503_rfmd_acc:
case AT76C505_rfmd:
err = atu_usb_request(sc, UT_READ_VENDOR_INTERFACE, 0x33,
0x0a02, 0x0000, sizeof(rfmd_conf),
(u_int8_t *)&rfmd_conf);
if (err) {
DPRINTF(("%s: could not get rfmd config!\n",
sc->atu_dev.dv_xname));
return err;
}
memcpy(ic->ic_myaddr, rfmd_conf.MACAddr, IEEE80211_ADDR_LEN);
break;
case RadioIntersil:
case AT76C503_i3863:
err = atu_usb_request(sc, UT_READ_VENDOR_INTERFACE, 0x33,
0x0902, 0x0000, sizeof(intersil_conf),
(u_int8_t *)&intersil_conf);
if (err) {
DPRINTF(("%s: could not get intersil config!\n",
sc->atu_dev.dv_xname));
return err;
}
memcpy(ic->ic_myaddr, intersil_conf.MACAddr,
IEEE80211_ADDR_LEN);
break;
}
return 0;
}
int
atu_match(struct device *parent, void *match, void *aux)
{
struct usb_attach_arg *uaa = aux;
int i;
if (uaa->iface == NULL || uaa->configno != ATU_CONFIG_NO)
return(UMATCH_NONE);
for (i = 0; i < nitems(atu_devs); i++) {
struct atu_type *t = &atu_devs[i];
if (uaa->vendor == t->atu_vid &&
uaa->product == t->atu_pid) {
return(UMATCH_VENDOR_PRODUCT);
}
}
return(UMATCH_NONE);
}
int
atu_media_change(struct ifnet *ifp)
{
#ifdef ATU_DEBUG
struct atu_softc *sc = ifp->if_softc;
#endif
int err;
DPRINTFN(10, ("%s: atu_media_change\n", sc->atu_dev.dv_xname));
err = ieee80211_media_change(ifp);
if (err == ENETRESET) {
if ((ifp->if_flags & (IFF_RUNNING|IFF_UP)) ==
(IFF_RUNNING|IFF_UP))
atu_init(ifp);
err = 0;
}
return (err);
}
void
atu_media_status(struct ifnet *ifp, struct ifmediareq *req)
{
#ifdef ATU_DEBUG
struct atu_softc *sc = ifp->if_softc;
#endif
DPRINTFN(10, ("%s: atu_media_status\n", sc->atu_dev.dv_xname));
ieee80211_media_status(ifp, req);
}
void
atu_task(void *arg)
{
struct atu_softc *sc = (struct atu_softc *)arg;
struct ieee80211com *ic = &sc->sc_ic;
struct ifnet *ifp = &ic->ic_if;
usbd_status err;
int s;
DPRINTFN(10, ("%s: atu_task\n", sc->atu_dev.dv_xname));
if (usbd_is_dying(sc->atu_udev))
return;
switch (sc->sc_cmd) {
case ATU_C_SCAN:
err = atu_start_scan(sc);
if (err) {
DPRINTFN(1, ("%s: atu_init: couldn't start scan!\n",
sc->atu_dev.dv_xname));
return;
}
err = atu_wait_completion(sc, CMD_START_SCAN, NULL);
if (err) {
DPRINTF(("%s: atu_init: error waiting for scan\n",
sc->atu_dev.dv_xname));
return;
}
DPRINTF(("%s: ==========================> END OF SCAN!\n",
sc->atu_dev.dv_xname));
s = splnet();
ieee80211_end_scan(ifp);
splx(s);
DPRINTF(("%s: ----------------------======> END OF SCAN2!\n",
sc->atu_dev.dv_xname));
break;
case ATU_C_JOIN:
atu_join(sc, ic->ic_bss);
}
}
int
atu_newstate(struct ieee80211com *ic, enum ieee80211_state nstate, int arg)
{
struct ifnet *ifp = &ic->ic_if;
struct atu_softc *sc = ifp->if_softc;
enum ieee80211_state ostate = ic->ic_state;
switch (nstate) {
case IEEE80211_S_SCAN:
memcpy(ic->ic_chan_scan, ic->ic_chan_active,
sizeof(ic->ic_chan_active));
ieee80211_node_cleanup(ic, ic->ic_bss);
sc->sc_cmd = ATU_C_SCAN;
usb_add_task(sc->atu_udev, &sc->sc_task);
if (ifp->if_flags & IFF_DEBUG)
printf("%s: %s -> %s\n", ifp->if_xname,
ieee80211_state_name[ic->ic_state],
ieee80211_state_name[nstate]);
ieee80211_set_link_state(ic, LINK_STATE_DOWN);
ic->ic_state = nstate;
return (0);
case IEEE80211_S_AUTH:
case IEEE80211_S_RUN:
if (ostate == IEEE80211_S_SCAN) {
sc->sc_cmd = ATU_C_JOIN;
usb_add_task(sc->atu_udev, &sc->sc_task);
}
break;
default:
break;
}
return (*sc->sc_newstate)(ic, nstate, arg);
}
void
atu_attach(struct device *parent, struct device *self, void *aux)
{
struct atu_softc *sc = (struct atu_softc *)self;
struct usb_attach_arg *uaa = aux;
usbd_status err;
struct usbd_device *dev = uaa->device;
u_int8_t mode, channel;
int i;
sc->atu_unit = self->dv_unit;
sc->atu_udev = dev;
err = usbd_device2interface_handle(dev, ATU_IFACE_IDX, &sc->atu_iface);
if (err) {
printf("%s: getting interface handle failed\n",
sc->atu_dev.dv_xname);
goto fail;
}
for (i = 0; i < nitems(atu_devs); i++) {
struct atu_type *t = &atu_devs[i];
if (uaa->vendor == t->atu_vid &&
uaa->product == t->atu_pid) {
sc->atu_radio = t->atu_radio;
sc->atu_quirk = t->atu_quirk;
}
}
err = atu_get_opmode(sc, &mode);
DPRINTFN(20, ("%s: opmode: %d\n", sc->atu_dev.dv_xname, mode));
if (err || (mode != MODE_NETCARD && mode != MODE_NOFLASHNETCARD)) {
DPRINTF(("%s: starting internal firmware download\n",
sc->atu_dev.dv_xname));
config_mountroot(self, atu_internal_firmware);
return;
}
uaa->iface = sc->atu_iface;
if (mode != MODE_NETCARD) {
DPRINTFN(15, ("%s: device needs external firmware\n",
sc->atu_dev.dv_xname));
if (mode != MODE_NOFLASHNETCARD) {
DPRINTF(("%s: EEK! unexpected opmode=%d\n",
sc->atu_dev.dv_xname, mode));
}
if (sc->atu_radio != RadioIntersil) {
err = atu_get_mib(sc, MIB_PHY__CHANNEL, &channel);
if (!err) {
DPRINTF(("%s: external firmware has already"
" been downloaded\n",
sc->atu_dev.dv_xname));
atu_complete_attach(sc);
return;
}
}
config_mountroot(self, atu_external_firmware);
} else {
atu_complete_attach(sc);
}
fail:
usbd_deactivate(sc->atu_udev);
}
void
atu_complete_attach(struct atu_softc *sc)
{
struct ieee80211com *ic = &sc->sc_ic;
struct ifnet *ifp = &ic->ic_if;
usb_interface_descriptor_t *id;
usb_endpoint_descriptor_t *ed;
usbd_status err;
int i;
#ifdef ATU_DEBUG
struct atu_fw fw;
#endif
id = usbd_get_interface_descriptor(sc->atu_iface);
for (i = 0; i < id->bNumEndpoints; i++) {
ed = usbd_interface2endpoint_descriptor(sc->atu_iface, i);
if (!ed) {
DPRINTF(("%s: num_endp:%d\n", sc->atu_dev.dv_xname,
sc->atu_iface->idesc->bNumEndpoints));
DPRINTF(("%s: couldn't get ep %d\n",
sc->atu_dev.dv_xname, i));
goto fail;
}
if (UE_GET_DIR(ed->bEndpointAddress) == UE_DIR_IN &&
UE_GET_XFERTYPE(ed->bmAttributes) == UE_BULK) {
sc->atu_ed[ATU_ENDPT_RX] = ed->bEndpointAddress;
} else if (UE_GET_DIR(ed->bEndpointAddress) == UE_DIR_OUT &&
UE_GET_XFERTYPE(ed->bmAttributes) == UE_BULK) {
sc->atu_ed[ATU_ENDPT_TX] = ed->bEndpointAddress;
}
}
err = atu_get_card_config(sc);
if (err) {
printf("%s: could not get card cfg!\n",
sc->atu_dev.dv_xname);
goto fail;
}
#ifdef ATU_DEBUG
err = atu_get_mib(sc, MIB_FW_VERSION, sizeof(fw), 0,
(u_int8_t *)&fw);
if (!err) {
DPRINTFN(15, ("%s: firmware: maj:%d min:%d patch:%d "
"build:%d\n", sc->atu_dev.dv_xname, fw.major, fw.minor,
fw.patch, fw.build));
} else {
DPRINTF(("%s: get firmware version failed\n",
sc->atu_dev.dv_xname));
}
#endif
printf("%s: address %s\n", sc->atu_dev.dv_xname,
ether_sprintf(ic->ic_myaddr));
sc->atu_cdata.atu_tx_inuse = 0;
bzero(sc->atu_bssid, ETHER_ADDR_LEN);
sc->atu_channel = ATU_DEFAULT_CHANNEL;
sc->atu_desired_channel = IEEE80211_CHAN_ANY;
sc->atu_mode = INFRASTRUCTURE_MODE;
ic->ic_softc = sc;
ic->ic_phytype = IEEE80211_T_DS;
ic->ic_opmode = IEEE80211_M_STA;
ic->ic_state = IEEE80211_S_INIT;
ic->ic_caps = IEEE80211_C_IBSS | IEEE80211_C_WEP | IEEE80211_C_SCANALL;
ic->ic_max_rssi = atu_radfirm[sc->atu_radio].max_rssi;
ic->ic_sup_rates[IEEE80211_MODE_11B] = ieee80211_std_rateset_11b;
for (i = 1; i <= 14; i++) {
ic->ic_channels[i].ic_flags = IEEE80211_CHAN_B |
IEEE80211_CHAN_PASSIVE;
ic->ic_channels[i].ic_freq = ieee80211_ieee2mhz(i,
ic->ic_channels[i].ic_flags);
}
ic->ic_ibss_chan = &ic->ic_channels[0];
ifp->if_softc = sc;
memcpy(ifp->if_xname, sc->atu_dev.dv_xname, IFNAMSIZ);
ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
ifp->if_start = atu_start;
ifp->if_ioctl = atu_ioctl;
ifp->if_watchdog = atu_watchdog;
ifp->if_mtu = ATU_DEFAULT_MTU;
if_attach(ifp);
ieee80211_ifattach(ifp);
sc->sc_newstate = ic->ic_newstate;
ic->ic_newstate = atu_newstate;
ieee80211_media_init(ifp, atu_media_change, atu_media_status);
usb_init_task(&sc->sc_task, atu_task, sc, USB_TASK_TYPE_GENERIC);
#if NBPFILTER > 0
bpfattach(&sc->sc_radiobpf, &sc->sc_ic.ic_if, DLT_IEEE802_11_RADIO,
sizeof(struct ieee80211_frame) + 64);
bzero(&sc->sc_rxtapu, sizeof(sc->sc_rxtapu));
sc->sc_rxtap.rr_ihdr.it_len = sizeof(sc->sc_rxtapu);
sc->sc_rxtap.rr_ihdr.it_present = htole32(ATU_RX_RADIOTAP_PRESENT);
bzero(&sc->sc_txtapu, sizeof(sc->sc_txtapu));
sc->sc_txtap.rt_ihdr.it_len = sizeof(sc->sc_txtapu);
sc->sc_txtap.rt_ihdr.it_present = htole32(ATU_TX_RADIOTAP_PRESENT);
#endif
fail:
usbd_deactivate(sc->atu_udev);
}
int
atu_detach(struct device *self, int flags)
{
struct atu_softc *sc = (struct atu_softc *)self;
struct ifnet *ifp = &sc->sc_ic.ic_if;
DPRINTFN(10, ("%s: atu_detach\n", sc->atu_dev.dv_xname));
if (ifp->if_flags & IFF_RUNNING)
atu_stop(ifp, 1);
usb_rem_task(sc->atu_udev, &sc->sc_task);
if (sc->atu_ep[ATU_ENDPT_TX] != NULL)
usbd_abort_pipe(sc->atu_ep[ATU_ENDPT_TX]);
if (sc->atu_ep[ATU_ENDPT_RX] != NULL)
usbd_abort_pipe(sc->atu_ep[ATU_ENDPT_RX]);
if (ifp->if_softc != NULL) {
ieee80211_ifdetach(ifp);
if_detach(ifp);
}
return(0);
}
int
atu_newbuf(struct atu_softc *sc, struct atu_chain *c, struct mbuf *m)
{
struct mbuf *m_new = NULL;
if (m == NULL) {
MGETHDR(m_new, M_DONTWAIT, MT_DATA);
if (m_new == NULL) {
DPRINTF(("%s: no memory for rx list\n",
sc->atu_dev.dv_xname));
return(ENOBUFS);
}
MCLGET(m_new, M_DONTWAIT);
if (!(m_new->m_flags & M_EXT)) {
DPRINTF(("%s: no memory for rx list\n",
sc->atu_dev.dv_xname));
m_freem(m_new);
return(ENOBUFS);
}
m_new->m_len = m_new->m_pkthdr.len = MCLBYTES;
} else {
m_new = m;
m_new->m_len = m_new->m_pkthdr.len = MCLBYTES;
m_new->m_data = m_new->m_ext.ext_buf;
}
c->atu_mbuf = m_new;
return(0);
}
int
atu_rx_list_init(struct atu_softc *sc)
{
struct atu_cdata *cd = &sc->atu_cdata;
struct atu_chain *c;
int i;
DPRINTFN(15, ("%s: atu_rx_list_init: enter\n",
sc->atu_dev.dv_xname));
for (i = 0; i < ATU_RX_LIST_CNT; i++) {
c = &cd->atu_rx_chain[i];
c->atu_sc = sc;
c->atu_idx = i;
if (c->atu_xfer == NULL) {
c->atu_xfer = usbd_alloc_xfer(sc->atu_udev);
if (c->atu_xfer == NULL)
return (ENOBUFS);
c->atu_buf = usbd_alloc_buffer(c->atu_xfer,
ATU_RX_BUFSZ);
if (c->atu_buf == NULL)
return (ENOBUFS);
if (atu_newbuf(sc, c, NULL) == ENOBUFS)
return(ENOBUFS);
}
}
return (0);
}
int
atu_tx_list_init(struct atu_softc *sc)
{
struct atu_cdata *cd = &sc->atu_cdata;
struct atu_chain *c;
int i;
DPRINTFN(15, ("%s: atu_tx_list_init\n",
sc->atu_dev.dv_xname));
SLIST_INIT(&cd->atu_tx_free);
sc->atu_cdata.atu_tx_inuse = 0;
for (i = 0; i < ATU_TX_LIST_CNT; i++) {
c = &cd->atu_tx_chain[i];
c->atu_sc = sc;
c->atu_idx = i;
if (c->atu_xfer == NULL) {
c->atu_xfer = usbd_alloc_xfer(sc->atu_udev);
if (c->atu_xfer == NULL)
return(ENOBUFS);
c->atu_mbuf = NULL;
c->atu_buf = usbd_alloc_buffer(c->atu_xfer,
ATU_TX_BUFSZ);
if (c->atu_buf == NULL)
return(ENOBUFS);
SLIST_INSERT_HEAD(&cd->atu_tx_free, c, atu_list);
}
}
return(0);
}
void
atu_xfer_list_free(struct atu_softc *sc, struct atu_chain *ch,
int listlen)
{
int i;
for (i = 0; i < listlen; i++) {
if (ch[i].atu_buf != NULL)
ch[i].atu_buf = NULL;
if (ch[i].atu_mbuf != NULL) {
m_freem(ch[i].atu_mbuf);
ch[i].atu_mbuf = NULL;
}
if (ch[i].atu_xfer != NULL) {
usbd_free_xfer(ch[i].atu_xfer);
ch[i].atu_xfer = NULL;
}
}
}
void
atu_rxeof(struct usbd_xfer *xfer, void *priv, usbd_status status)
{
struct atu_chain *c = (struct atu_chain *)priv;
struct atu_softc *sc = c->atu_sc;
struct ieee80211com *ic = &sc->sc_ic;
struct ifnet *ifp = &ic->ic_if;
struct atu_rx_hdr *h;
struct ieee80211_frame *wh;
struct ieee80211_rxinfo rxi;
struct ieee80211_node *ni;
struct mbuf *m;
u_int32_t len;
int s;
DPRINTFN(25, ("%s: atu_rxeof\n", sc->atu_dev.dv_xname));
if (usbd_is_dying(sc->atu_udev))
return;
if ((ifp->if_flags & (IFF_RUNNING|IFF_UP)) != (IFF_RUNNING|IFF_UP))
goto done;
if (status != USBD_NORMAL_COMPLETION) {
DPRINTF(("%s: status != USBD_NORMAL_COMPLETION\n",
sc->atu_dev.dv_xname));
if (status == USBD_NOT_STARTED || status == USBD_CANCELLED) {
return;
}
#if 0
if (status == USBD_IOERROR) {
DPRINTF(("%s: rx: EEK! lost device?\n",
sc->atu_dev.dv_xname));
splx(s);
return;
}
#endif
if (usbd_ratecheck(&sc->atu_rx_notice)) {
DPRINTF(("%s: usb error on rx: %s\n",
sc->atu_dev.dv_xname, usbd_errstr(status)));
}
if (status == USBD_STALLED)
usbd_clear_endpoint_stall_async(
sc->atu_ep[ATU_ENDPT_RX]);
goto done;
}
usbd_get_xfer_status(xfer, NULL, NULL, &len, NULL);
if (len < ATU_RX_HDRLEN) {
DPRINTF(("%s: atu_rxeof: too short\n",
sc->atu_dev.dv_xname));
ic->ic_stats.is_rx_tooshort++;
ifp->if_ierrors++;
goto done;
}
h = (struct atu_rx_hdr *)c->atu_buf;
len = UGETW(h->length);
if (len < IEEE80211_MIN_LEN) {
ic->ic_stats.is_rx_tooshort++;
ifp->if_ierrors++;
goto done;
}
if (len > ATU_RX_BUFSZ) {
ifp->if_ierrors++;
goto done;
}
len -= IEEE80211_CRC_LEN;
m = c->atu_mbuf;
memcpy(mtod(m, char *), c->atu_buf + ATU_RX_HDRLEN, len);
m->m_pkthdr.len = m->m_len = len;
wh = mtod(m, struct ieee80211_frame *);
ni = ieee80211_find_rxnode(ic, wh);
s = splnet();
if (atu_newbuf(sc, c, NULL) == ENOBUFS) {
ifp->if_ierrors++;
goto done1;
}
#if NBPFILTER > 0
if (sc->sc_radiobpf != NULL) {
struct mbuf mb;
struct atu_rx_radiotap_header *rr = &sc->sc_rxtap;
rr->rr_flags = 0;
rr->rr_chan_freq =
htole16(ic->ic_bss->ni_chan->ic_freq);
rr->rr_chan_flags =
htole16(ic->ic_bss->ni_chan->ic_flags);
rr->rr_rssi = h->rssi;
rr->rr_max_rssi = ic->ic_max_rssi;
mb.m_data = (caddr_t)rr;
mb.m_len = sizeof(sc->sc_txtapu);
mb.m_next = m;
mb.m_nextpkt = NULL;
mb.m_type = 0;
mb.m_flags = 0;
bpf_mtap(sc->sc_radiobpf, &mb, BPF_DIRECTION_IN);
}
#endif
memset(&rxi, 0, sizeof(rxi));
if (wh->i_fc[1] & IEEE80211_FC1_WEP) {
wh->i_fc[1] &= ~IEEE80211_FC1_WEP;
rxi.rxi_flags |= IEEE80211_RXI_HWDEC;
}
rxi.rxi_rssi = h->rssi;
rxi.rxi_tstamp = UGETDW(h->rx_time);
ieee80211_input(ifp, m, ni, &rxi);
done1:
ieee80211_release_node(ic, ni);
splx(s);
done:
usbd_setup_xfer(c->atu_xfer, sc->atu_ep[ATU_ENDPT_RX], c, c->atu_buf,
ATU_RX_BUFSZ, USBD_SHORT_XFER_OK | USBD_NO_COPY, USBD_NO_TIMEOUT,
atu_rxeof);
usbd_transfer(c->atu_xfer);
}
void
atu_txeof(struct usbd_xfer *xfer, void *priv, usbd_status status)
{
struct atu_chain *c = (struct atu_chain *)priv;
struct atu_softc *sc = c->atu_sc;
struct ifnet *ifp = &sc->sc_ic.ic_if;
usbd_status err;
int s;
DPRINTFN(25, ("%s: atu_txeof status=%d\n", sc->atu_dev.dv_xname,
status));
if (c->atu_mbuf != NULL) {
m_freem(c->atu_mbuf);
c->atu_mbuf = NULL;
}
if (status != USBD_NORMAL_COMPLETION) {
if (status == USBD_NOT_STARTED || status == USBD_CANCELLED)
return;
DPRINTF(("%s: usb error on tx: %s\n", sc->atu_dev.dv_xname,
usbd_errstr(status)));
if (status == USBD_STALLED)
usbd_clear_endpoint_stall_async(sc->atu_ep[ATU_ENDPT_TX]);
return;
}
usbd_get_xfer_status(c->atu_xfer, NULL, NULL, NULL, &err);
if (err)
ifp->if_oerrors++;
s = splnet();
SLIST_INSERT_HEAD(&sc->atu_cdata.atu_tx_free, c, atu_list);
sc->atu_cdata.atu_tx_inuse--;
if (sc->atu_cdata.atu_tx_inuse == 0)
ifp->if_timer = 0;
ifq_clr_oactive(&ifp->if_snd);
splx(s);
atu_start(ifp);
}
u_int8_t
atu_calculate_padding(int size)
{
size %= 64;
if (size < 50)
return (50 - size);
if (size >=61)
return (64 + 50 - size);
return (0);
}
int
atu_tx_start(struct atu_softc *sc, struct ieee80211_node *ni,
struct atu_chain *c, struct mbuf *m)
{
int len;
struct atu_tx_hdr *h;
usbd_status err;
u_int8_t pad;
#if NBPFILTER > 0
struct ieee80211com *ic = &sc->sc_ic;
#endif
DPRINTFN(25, ("%s: atu_tx_start\n", sc->atu_dev.dv_xname));
if (usbd_is_dying(sc->atu_udev)) {
m_freem(m);
return(EIO);
}
#if NBPFILTER > 0
if (sc->sc_radiobpf != NULL) {
struct mbuf mb;
struct atu_tx_radiotap_header *rt = &sc->sc_txtap;
rt->rt_flags = 0;
rt->rt_chan_freq =
htole16(ic->ic_bss->ni_chan->ic_freq);
rt->rt_chan_flags =
htole16(ic->ic_bss->ni_chan->ic_flags);
mb.m_data = (caddr_t)rt;
mb.m_len = sizeof(sc->sc_txtapu);
mb.m_next = m;
mb.m_nextpkt = NULL;
mb.m_type = 0;
mb.m_flags = 0;
bpf_mtap(sc->sc_radiobpf, &mb, BPF_DIRECTION_OUT);
}
#endif
len = m->m_pkthdr.len;
m_copydata(m, 0, m->m_pkthdr.len, c->atu_buf + ATU_TX_HDRLEN);
h = (struct atu_tx_hdr *)c->atu_buf;
memset(h, 0, ATU_TX_HDRLEN);
USETW(h->length, len);
h->tx_rate = 4;
len += ATU_TX_HDRLEN;
pad = atu_calculate_padding(len);
len += pad;
h->padding = pad;
c->atu_length = len;
c->atu_mbuf = m;
usbd_setup_xfer(c->atu_xfer, sc->atu_ep[ATU_ENDPT_TX],
c, c->atu_buf, c->atu_length, USBD_NO_COPY, ATU_TX_TIMEOUT,
atu_txeof);
c->atu_in_xfer = 1;
err = usbd_transfer(c->atu_xfer);
if (err != USBD_IN_PROGRESS) {
DPRINTFN(25, ("%s: atu_tx_start: err=%d\n",
sc->atu_dev.dv_xname, err));
c->atu_mbuf = NULL;
m_freem(m);
return(EIO);
}
return (0);
}
void
atu_start(struct ifnet *ifp)
{
struct atu_softc *sc = ifp->if_softc;
struct ieee80211com *ic = &sc->sc_ic;
struct atu_cdata *cd = &sc->atu_cdata;
struct ieee80211_node *ni;
struct ieee80211_frame *wh;
struct atu_chain *c;
struct mbuf *m = NULL;
int s;
DPRINTFN(25, ("%s: atu_start: enter\n", sc->atu_dev.dv_xname));
if ((ifp->if_flags & (IFF_RUNNING|IFF_UP)) != (IFF_RUNNING|IFF_UP)) {
DPRINTFN(30, ("%s: atu_start: not running or up\n",
sc->atu_dev.dv_xname));
return;
}
if (ifq_is_oactive(&ifp->if_snd)) {
DPRINTFN(30, ("%s: atu_start: oactive\n",
sc->atu_dev.dv_xname));
return;
}
for (;;) {
s = splnet();
c = SLIST_FIRST(&cd->atu_tx_free);
if (c != NULL) {
SLIST_REMOVE_HEAD(&cd->atu_tx_free, atu_list);
cd->atu_tx_inuse++;
if (cd->atu_tx_inuse == ATU_TX_LIST_CNT)
ifq_set_oactive(&ifp->if_snd);
}
splx(s);
if (c == NULL) {
DPRINTFN(10, ("%s: out of tx xfers\n",
sc->atu_dev.dv_xname));
ifq_set_oactive(&ifp->if_snd);
break;
}
m = mq_dequeue(&ic->ic_mgtq);
if (m == NULL) {
DPRINTFN(10, ("%s: atu_start: data packet\n",
sc->atu_dev.dv_xname));
if (ic->ic_state != IEEE80211_S_RUN) {
DPRINTFN(25, ("%s: no data till running\n",
sc->atu_dev.dv_xname));
s = splnet();
SLIST_INSERT_HEAD(&cd->atu_tx_free, c,
atu_list);
cd->atu_tx_inuse--;
splx(s);
break;
}
m = ifq_dequeue(&ifp->if_snd);
if (m == NULL) {
DPRINTFN(25, ("%s: nothing to send\n",
sc->atu_dev.dv_xname));
s = splnet();
SLIST_INSERT_HEAD(&cd->atu_tx_free, c,
atu_list);
cd->atu_tx_inuse--;
splx(s);
break;
}
#if NBPFILTER > 0
if (ifp->if_bpf)
bpf_mtap(ifp->if_bpf, m, BPF_DIRECTION_OUT);
#endif
m = ieee80211_encap(ifp, m, &ni);
if (m == NULL)
goto bad;
wh = mtod(m, struct ieee80211_frame *);
#if NBPFILTER > 0
if (ic->ic_rawbpf != NULL)
bpf_mtap(ic->ic_rawbpf, m, BPF_DIRECTION_OUT);
#endif
} else {
DPRINTFN(25, ("%s: atu_start: mgmt packet\n",
sc->atu_dev.dv_xname));
ni = m->m_pkthdr.ph_cookie;
wh = mtod(m, struct ieee80211_frame *);
}
if (atu_tx_start(sc, ni, c, m)) {
bad:
s = splnet();
SLIST_INSERT_HEAD(&cd->atu_tx_free, c,
atu_list);
cd->atu_tx_inuse--;
splx(s);
if (ni != NULL)
ieee80211_release_node(ic, ni);
continue;
}
ifp->if_timer = 5;
}
}
int
atu_init(struct ifnet *ifp)
{
struct atu_softc *sc = ifp->if_softc;
struct ieee80211com *ic = &sc->sc_ic;
struct atu_chain *c;
usbd_status err;
int i, s;
s = splnet();
DPRINTFN(10, ("%s: atu_init\n", sc->atu_dev.dv_xname));
if (ifp->if_flags & IFF_RUNNING) {
splx(s);
return(0);
}
if (atu_tx_list_init(sc))
printf("%s: tx list init failed\n", sc->atu_dev.dv_xname);
if (atu_rx_list_init(sc))
printf("%s: rx list init failed\n", sc->atu_dev.dv_xname);
err = usbd_open_pipe(sc->atu_iface, sc->atu_ed[ATU_ENDPT_RX],
USBD_EXCLUSIVE_USE, &sc->atu_ep[ATU_ENDPT_RX]);
if (err) {
DPRINTF(("%s: open rx pipe failed: %s\n",
sc->atu_dev.dv_xname, usbd_errstr(err)));
splx(s);
return(EIO);
}
err = usbd_open_pipe(sc->atu_iface, sc->atu_ed[ATU_ENDPT_TX],
USBD_EXCLUSIVE_USE, &sc->atu_ep[ATU_ENDPT_TX]);
if (err) {
DPRINTF(("%s: open tx pipe failed: %s\n",
sc->atu_dev.dv_xname, usbd_errstr(err)));
splx(s);
return(EIO);
}
for (i = 0; i < ATU_RX_LIST_CNT; i++) {
c = &sc->atu_cdata.atu_rx_chain[i];
usbd_setup_xfer(c->atu_xfer, sc->atu_ep[ATU_ENDPT_RX], c,
c->atu_buf, ATU_RX_BUFSZ, USBD_SHORT_XFER_OK | USBD_NO_COPY,
USBD_NO_TIMEOUT, atu_rxeof);
usbd_transfer(c->atu_xfer);
}
DPRINTFN(10, ("%s: starting up using MAC=%s\n",
sc->atu_dev.dv_xname, ether_sprintf(ic->ic_myaddr)));
err = atu_initial_config(sc);
if (err) {
DPRINTF(("%s: initial config failed!\n",
sc->atu_dev.dv_xname));
splx(s);
return(EIO);
}
DPRINTFN(10, ("%s: initialised transceiver\n",
sc->atu_dev.dv_xname));
ifp->if_flags |= IFF_RUNNING;
ifq_clr_oactive(&ifp->if_snd);
splx(s);
s = splnet();
err = ieee80211_new_state(ic, IEEE80211_S_SCAN, -1);
if (err)
DPRINTFN(1, ("%s: atu_init: error calling "
"ieee80211_net_state", sc->atu_dev.dv_xname));
splx(s);
return 0;
}
int
atu_ioctl(struct ifnet *ifp, u_long command, caddr_t data)
{
struct atu_softc *sc = ifp->if_softc;
int err = 0, s;
s = splnet();
switch (command) {
case SIOCSIFADDR:
DPRINTFN(15, ("%s: SIOCSIFADDR\n", sc->atu_dev.dv_xname));
ifp->if_flags |= IFF_UP;
atu_init(ifp);
break;
case SIOCSIFFLAGS:
DPRINTFN(15, ("%s: SIOCSIFFLAGS\n", sc->atu_dev.dv_xname));
if (ifp->if_flags & IFF_UP) {
if (ifp->if_flags & IFF_RUNNING &&
ifp->if_flags & IFF_PROMISC &&
!(sc->atu_if_flags & IFF_PROMISC)) {
#if 0
sc->atu_rxfilt |= ATU_RXFILT_PROMISC;
atu_setword(sc, ATU_CMD_SET_PKT_FILTER,
sc->atu_rxfilt);
#endif
} else if (ifp->if_flags & IFF_RUNNING &&
!(ifp->if_flags & IFF_PROMISC) &&
sc->atu_if_flags & IFF_PROMISC) {
#if 0
sc->atu_rxfilt &= ~ATU_RXFILT_PROMISC;
atu_setword(sc, ATU_CMD_SET_PKT_FILTER,
sc->atu_rxfilt);
#endif
} else if (!(ifp->if_flags & IFF_RUNNING))
atu_init(ifp);
DPRINTFN(15, ("%s: ioctl calling atu_init()\n",
sc->atu_dev.dv_xname));
atu_init(ifp);
err = atu_switch_radio(sc, 1);
} else {
if (ifp->if_flags & IFF_RUNNING)
atu_stop(ifp, 0);
err = atu_switch_radio(sc, 0);
}
sc->atu_if_flags = ifp->if_flags;
err = 0;
break;
case SIOCADDMULTI:
DPRINTFN(15, ("%s: SIOCADDMULTI\n", sc->atu_dev.dv_xname));
err = 0;
break;
case SIOCDELMULTI:
DPRINTFN(15, ("%s: SIOCDELMULTI\n", sc->atu_dev.dv_xname));
err = 0;
break;
default:
DPRINTFN(15, ("%s: ieee80211_ioctl (%lu)\n",
sc->atu_dev.dv_xname, command));
err = ieee80211_ioctl(ifp, command, data);
break;
}
if (err == ENETRESET) {
if ((ifp->if_flags & (IFF_RUNNING|IFF_UP)) ==
(IFF_RUNNING|IFF_UP)) {
DPRINTF(("%s: atu_ioctl(): netreset\n",
sc->atu_dev.dv_xname));
atu_init(ifp);
}
err = 0;
}
splx(s);
return (err);
}
void
atu_watchdog(struct ifnet *ifp)
{
struct atu_softc *sc = ifp->if_softc;
struct atu_chain *c;
usbd_status stat;
int cnt, s;
DPRINTF(("%s: atu_watchdog\n", sc->atu_dev.dv_xname));
ifp->if_timer = 0;
if ((ifp->if_flags & (IFF_RUNNING|IFF_UP)) != (IFF_RUNNING|IFF_UP))
return;
if (usbd_is_dying(sc->atu_udev))
return;
sc = ifp->if_softc;
s = splnet();
ifp->if_oerrors++;
DPRINTF(("%s: watchdog timeout\n", sc->atu_dev.dv_xname));
for (cnt = 0; cnt < ATU_TX_LIST_CNT; cnt++) {
c = &sc->atu_cdata.atu_tx_chain[cnt];
if (c->atu_in_xfer) {
usbd_get_xfer_status(c->atu_xfer, NULL, NULL, NULL,
&stat);
atu_txeof(c->atu_xfer, c, stat);
}
}
if (!ifq_empty(&ifp->if_snd))
atu_start(ifp);
splx(s);
ieee80211_watchdog(ifp);
}
void
atu_stop(struct ifnet *ifp, int disable)
{
struct atu_softc *sc = ifp->if_softc;
struct atu_cdata *cd;
usbd_status err;
int s;
s = splnet();
ifp->if_flags &= ~IFF_RUNNING;
ifq_clr_oactive(&ifp->if_snd);
ifp->if_timer = 0;
if (sc->atu_ep[ATU_ENDPT_RX] != NULL) {
err = usbd_close_pipe(sc->atu_ep[ATU_ENDPT_RX]);
if (err) {
DPRINTF(("%s: close rx pipe failed: %s\n",
sc->atu_dev.dv_xname, usbd_errstr(err)));
}
sc->atu_ep[ATU_ENDPT_RX] = NULL;
}
if (sc->atu_ep[ATU_ENDPT_TX] != NULL) {
err = usbd_close_pipe(sc->atu_ep[ATU_ENDPT_TX]);
if (err) {
DPRINTF(("%s: close tx pipe failed: %s\n",
sc->atu_dev.dv_xname, usbd_errstr(err)));
}
sc->atu_ep[ATU_ENDPT_TX] = NULL;
}
cd = &sc->atu_cdata;
atu_xfer_list_free(sc, cd->atu_rx_chain, ATU_RX_LIST_CNT);
atu_xfer_list_free(sc, cd->atu_tx_chain, ATU_TX_LIST_CNT);
atu_switch_radio(sc, 0);
splx(s);
}