hfcsusb.c 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134
  1. /* hfcsusb.c
  2. * mISDN driver for Colognechip HFC-S USB chip
  3. *
  4. * Copyright 2001 by Peter Sprenger (sprenger@moving-bytes.de)
  5. * Copyright 2008 by Martin Bachem (info@bachem-it.com)
  6. *
  7. * This program is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation; either version 2, or (at your option)
  10. * any later version.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to the Free Software
  19. * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20. *
  21. *
  22. * module params
  23. * debug=<n>, default=0, with n=0xHHHHGGGG
  24. * H - l1 driver flags described in hfcsusb.h
  25. * G - common mISDN debug flags described at mISDNhw.h
  26. *
  27. * poll=<n>, default 128
  28. * n : burst size of PH_DATA_IND at transparent rx data
  29. *
  30. * Revision: 0.3.3 (socket), 2008-11-05
  31. */
  32. #include <linux/module.h>
  33. #include <linux/delay.h>
  34. #include <linux/usb.h>
  35. #include <linux/mISDNhw.h>
  36. #include <linux/slab.h>
  37. #include "hfcsusb.h"
  38. static unsigned int debug;
  39. static int poll = DEFAULT_TRANSP_BURST_SZ;
  40. static LIST_HEAD(HFClist);
  41. static DEFINE_RWLOCK(HFClock);
  42. MODULE_AUTHOR("Martin Bachem");
  43. MODULE_LICENSE("GPL");
  44. module_param(debug, uint, S_IRUGO | S_IWUSR);
  45. module_param(poll, int, 0);
  46. static int hfcsusb_cnt;
  47. /* some function prototypes */
  48. static void hfcsusb_ph_command(struct hfcsusb *hw, u_char command);
  49. static void release_hw(struct hfcsusb *hw);
  50. static void reset_hfcsusb(struct hfcsusb *hw);
  51. static void setPortMode(struct hfcsusb *hw);
  52. static void hfcsusb_start_endpoint(struct hfcsusb *hw, int channel);
  53. static void hfcsusb_stop_endpoint(struct hfcsusb *hw, int channel);
  54. static int hfcsusb_setup_bch(struct bchannel *bch, int protocol);
  55. static void deactivate_bchannel(struct bchannel *bch);
  56. static void hfcsusb_ph_info(struct hfcsusb *hw);
  57. /* start next background transfer for control channel */
  58. static void
  59. ctrl_start_transfer(struct hfcsusb *hw)
  60. {
  61. if (debug & DBG_HFC_CALL_TRACE)
  62. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  63. if (hw->ctrl_cnt) {
  64. hw->ctrl_urb->pipe = hw->ctrl_out_pipe;
  65. hw->ctrl_urb->setup_packet = (u_char *)&hw->ctrl_write;
  66. hw->ctrl_urb->transfer_buffer = NULL;
  67. hw->ctrl_urb->transfer_buffer_length = 0;
  68. hw->ctrl_write.wIndex =
  69. cpu_to_le16(hw->ctrl_buff[hw->ctrl_out_idx].hfcs_reg);
  70. hw->ctrl_write.wValue =
  71. cpu_to_le16(hw->ctrl_buff[hw->ctrl_out_idx].reg_val);
  72. usb_submit_urb(hw->ctrl_urb, GFP_ATOMIC);
  73. }
  74. }
  75. /*
  76. * queue a control transfer request to write HFC-S USB
  77. * chip register using CTRL resuest queue
  78. */
  79. static int write_reg(struct hfcsusb *hw, __u8 reg, __u8 val)
  80. {
  81. struct ctrl_buf *buf;
  82. if (debug & DBG_HFC_CALL_TRACE)
  83. printk(KERN_DEBUG "%s: %s reg(0x%02x) val(0x%02x)\n",
  84. hw->name, __func__, reg, val);
  85. spin_lock(&hw->ctrl_lock);
  86. if (hw->ctrl_cnt >= HFC_CTRL_BUFSIZE) {
  87. spin_unlock(&hw->ctrl_lock);
  88. return 1;
  89. }
  90. buf = &hw->ctrl_buff[hw->ctrl_in_idx];
  91. buf->hfcs_reg = reg;
  92. buf->reg_val = val;
  93. if (++hw->ctrl_in_idx >= HFC_CTRL_BUFSIZE)
  94. hw->ctrl_in_idx = 0;
  95. if (++hw->ctrl_cnt == 1)
  96. ctrl_start_transfer(hw);
  97. spin_unlock(&hw->ctrl_lock);
  98. return 0;
  99. }
  100. /* control completion routine handling background control cmds */
  101. static void
  102. ctrl_complete(struct urb *urb)
  103. {
  104. struct hfcsusb *hw = (struct hfcsusb *) urb->context;
  105. if (debug & DBG_HFC_CALL_TRACE)
  106. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  107. urb->dev = hw->dev;
  108. if (hw->ctrl_cnt) {
  109. hw->ctrl_cnt--; /* decrement actual count */
  110. if (++hw->ctrl_out_idx >= HFC_CTRL_BUFSIZE)
  111. hw->ctrl_out_idx = 0; /* pointer wrap */
  112. ctrl_start_transfer(hw); /* start next transfer */
  113. }
  114. }
  115. /* handle LED bits */
  116. static void
  117. set_led_bit(struct hfcsusb *hw, signed short led_bits, int set_on)
  118. {
  119. if (set_on) {
  120. if (led_bits < 0)
  121. hw->led_state &= ~abs(led_bits);
  122. else
  123. hw->led_state |= led_bits;
  124. } else {
  125. if (led_bits < 0)
  126. hw->led_state |= abs(led_bits);
  127. else
  128. hw->led_state &= ~led_bits;
  129. }
  130. }
  131. /* handle LED requests */
  132. static void
  133. handle_led(struct hfcsusb *hw, int event)
  134. {
  135. struct hfcsusb_vdata *driver_info = (struct hfcsusb_vdata *)
  136. hfcsusb_idtab[hw->vend_idx].driver_info;
  137. __u8 tmpled;
  138. if (driver_info->led_scheme == LED_OFF)
  139. return;
  140. tmpled = hw->led_state;
  141. switch (event) {
  142. case LED_POWER_ON:
  143. set_led_bit(hw, driver_info->led_bits[0], 1);
  144. set_led_bit(hw, driver_info->led_bits[1], 0);
  145. set_led_bit(hw, driver_info->led_bits[2], 0);
  146. set_led_bit(hw, driver_info->led_bits[3], 0);
  147. break;
  148. case LED_POWER_OFF:
  149. set_led_bit(hw, driver_info->led_bits[0], 0);
  150. set_led_bit(hw, driver_info->led_bits[1], 0);
  151. set_led_bit(hw, driver_info->led_bits[2], 0);
  152. set_led_bit(hw, driver_info->led_bits[3], 0);
  153. break;
  154. case LED_S0_ON:
  155. set_led_bit(hw, driver_info->led_bits[1], 1);
  156. break;
  157. case LED_S0_OFF:
  158. set_led_bit(hw, driver_info->led_bits[1], 0);
  159. break;
  160. case LED_B1_ON:
  161. set_led_bit(hw, driver_info->led_bits[2], 1);
  162. break;
  163. case LED_B1_OFF:
  164. set_led_bit(hw, driver_info->led_bits[2], 0);
  165. break;
  166. case LED_B2_ON:
  167. set_led_bit(hw, driver_info->led_bits[3], 1);
  168. break;
  169. case LED_B2_OFF:
  170. set_led_bit(hw, driver_info->led_bits[3], 0);
  171. break;
  172. }
  173. if (hw->led_state != tmpled) {
  174. if (debug & DBG_HFC_CALL_TRACE)
  175. printk(KERN_DEBUG "%s: %s reg(0x%02x) val(x%02x)\n",
  176. hw->name, __func__,
  177. HFCUSB_P_DATA, hw->led_state);
  178. write_reg(hw, HFCUSB_P_DATA, hw->led_state);
  179. }
  180. }
  181. /*
  182. * Layer2 -> Layer 1 Bchannel data
  183. */
  184. static int
  185. hfcusb_l2l1B(struct mISDNchannel *ch, struct sk_buff *skb)
  186. {
  187. struct bchannel *bch = container_of(ch, struct bchannel, ch);
  188. struct hfcsusb *hw = bch->hw;
  189. int ret = -EINVAL;
  190. struct mISDNhead *hh = mISDN_HEAD_P(skb);
  191. u_long flags;
  192. if (debug & DBG_HFC_CALL_TRACE)
  193. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  194. switch (hh->prim) {
  195. case PH_DATA_REQ:
  196. spin_lock_irqsave(&hw->lock, flags);
  197. ret = bchannel_senddata(bch, skb);
  198. spin_unlock_irqrestore(&hw->lock, flags);
  199. if (debug & DBG_HFC_CALL_TRACE)
  200. printk(KERN_DEBUG "%s: %s PH_DATA_REQ ret(%i)\n",
  201. hw->name, __func__, ret);
  202. if (ret > 0)
  203. ret = 0;
  204. return ret;
  205. case PH_ACTIVATE_REQ:
  206. if (!test_and_set_bit(FLG_ACTIVE, &bch->Flags)) {
  207. hfcsusb_start_endpoint(hw, bch->nr - 1);
  208. ret = hfcsusb_setup_bch(bch, ch->protocol);
  209. } else
  210. ret = 0;
  211. if (!ret)
  212. _queue_data(ch, PH_ACTIVATE_IND, MISDN_ID_ANY,
  213. 0, NULL, GFP_KERNEL);
  214. break;
  215. case PH_DEACTIVATE_REQ:
  216. deactivate_bchannel(bch);
  217. _queue_data(ch, PH_DEACTIVATE_IND, MISDN_ID_ANY,
  218. 0, NULL, GFP_KERNEL);
  219. ret = 0;
  220. break;
  221. }
  222. if (!ret)
  223. dev_kfree_skb(skb);
  224. return ret;
  225. }
  226. /*
  227. * send full D/B channel status information
  228. * as MPH_INFORMATION_IND
  229. */
  230. static void
  231. hfcsusb_ph_info(struct hfcsusb *hw)
  232. {
  233. struct ph_info *phi;
  234. struct dchannel *dch = &hw->dch;
  235. int i;
  236. phi = kzalloc(sizeof(struct ph_info) +
  237. dch->dev.nrbchan * sizeof(struct ph_info_ch), GFP_ATOMIC);
  238. phi->dch.ch.protocol = hw->protocol;
  239. phi->dch.ch.Flags = dch->Flags;
  240. phi->dch.state = dch->state;
  241. phi->dch.num_bch = dch->dev.nrbchan;
  242. for (i = 0; i < dch->dev.nrbchan; i++) {
  243. phi->bch[i].protocol = hw->bch[i].ch.protocol;
  244. phi->bch[i].Flags = hw->bch[i].Flags;
  245. }
  246. _queue_data(&dch->dev.D, MPH_INFORMATION_IND, MISDN_ID_ANY,
  247. sizeof(struct ph_info_dch) + dch->dev.nrbchan *
  248. sizeof(struct ph_info_ch), phi, GFP_ATOMIC);
  249. kfree(phi);
  250. }
  251. /*
  252. * Layer2 -> Layer 1 Dchannel data
  253. */
  254. static int
  255. hfcusb_l2l1D(struct mISDNchannel *ch, struct sk_buff *skb)
  256. {
  257. struct mISDNdevice *dev = container_of(ch, struct mISDNdevice, D);
  258. struct dchannel *dch = container_of(dev, struct dchannel, dev);
  259. struct mISDNhead *hh = mISDN_HEAD_P(skb);
  260. struct hfcsusb *hw = dch->hw;
  261. int ret = -EINVAL;
  262. u_long flags;
  263. switch (hh->prim) {
  264. case PH_DATA_REQ:
  265. if (debug & DBG_HFC_CALL_TRACE)
  266. printk(KERN_DEBUG "%s: %s: PH_DATA_REQ\n",
  267. hw->name, __func__);
  268. spin_lock_irqsave(&hw->lock, flags);
  269. ret = dchannel_senddata(dch, skb);
  270. spin_unlock_irqrestore(&hw->lock, flags);
  271. if (ret > 0) {
  272. ret = 0;
  273. queue_ch_frame(ch, PH_DATA_CNF, hh->id, NULL);
  274. }
  275. break;
  276. case PH_ACTIVATE_REQ:
  277. if (debug & DBG_HFC_CALL_TRACE)
  278. printk(KERN_DEBUG "%s: %s: PH_ACTIVATE_REQ %s\n",
  279. hw->name, __func__,
  280. (hw->protocol == ISDN_P_NT_S0) ? "NT" : "TE");
  281. if (hw->protocol == ISDN_P_NT_S0) {
  282. ret = 0;
  283. if (test_bit(FLG_ACTIVE, &dch->Flags)) {
  284. _queue_data(&dch->dev.D,
  285. PH_ACTIVATE_IND, MISDN_ID_ANY, 0,
  286. NULL, GFP_ATOMIC);
  287. } else {
  288. hfcsusb_ph_command(hw,
  289. HFC_L1_ACTIVATE_NT);
  290. test_and_set_bit(FLG_L2_ACTIVATED,
  291. &dch->Flags);
  292. }
  293. } else {
  294. hfcsusb_ph_command(hw, HFC_L1_ACTIVATE_TE);
  295. ret = l1_event(dch->l1, hh->prim);
  296. }
  297. break;
  298. case PH_DEACTIVATE_REQ:
  299. if (debug & DBG_HFC_CALL_TRACE)
  300. printk(KERN_DEBUG "%s: %s: PH_DEACTIVATE_REQ\n",
  301. hw->name, __func__);
  302. test_and_clear_bit(FLG_L2_ACTIVATED, &dch->Flags);
  303. if (hw->protocol == ISDN_P_NT_S0) {
  304. hfcsusb_ph_command(hw, HFC_L1_DEACTIVATE_NT);
  305. spin_lock_irqsave(&hw->lock, flags);
  306. skb_queue_purge(&dch->squeue);
  307. if (dch->tx_skb) {
  308. dev_kfree_skb(dch->tx_skb);
  309. dch->tx_skb = NULL;
  310. }
  311. dch->tx_idx = 0;
  312. if (dch->rx_skb) {
  313. dev_kfree_skb(dch->rx_skb);
  314. dch->rx_skb = NULL;
  315. }
  316. test_and_clear_bit(FLG_TX_BUSY, &dch->Flags);
  317. spin_unlock_irqrestore(&hw->lock, flags);
  318. #ifdef FIXME
  319. if (test_and_clear_bit(FLG_L1_BUSY, &dch->Flags))
  320. dchannel_sched_event(&hc->dch, D_CLEARBUSY);
  321. #endif
  322. ret = 0;
  323. } else
  324. ret = l1_event(dch->l1, hh->prim);
  325. break;
  326. case MPH_INFORMATION_REQ:
  327. hfcsusb_ph_info(hw);
  328. ret = 0;
  329. break;
  330. }
  331. return ret;
  332. }
  333. /*
  334. * Layer 1 callback function
  335. */
  336. static int
  337. hfc_l1callback(struct dchannel *dch, u_int cmd)
  338. {
  339. struct hfcsusb *hw = dch->hw;
  340. if (debug & DBG_HFC_CALL_TRACE)
  341. printk(KERN_DEBUG "%s: %s cmd 0x%x\n",
  342. hw->name, __func__, cmd);
  343. switch (cmd) {
  344. case INFO3_P8:
  345. case INFO3_P10:
  346. case HW_RESET_REQ:
  347. case HW_POWERUP_REQ:
  348. break;
  349. case HW_DEACT_REQ:
  350. skb_queue_purge(&dch->squeue);
  351. if (dch->tx_skb) {
  352. dev_kfree_skb(dch->tx_skb);
  353. dch->tx_skb = NULL;
  354. }
  355. dch->tx_idx = 0;
  356. if (dch->rx_skb) {
  357. dev_kfree_skb(dch->rx_skb);
  358. dch->rx_skb = NULL;
  359. }
  360. test_and_clear_bit(FLG_TX_BUSY, &dch->Flags);
  361. break;
  362. case PH_ACTIVATE_IND:
  363. test_and_set_bit(FLG_ACTIVE, &dch->Flags);
  364. _queue_data(&dch->dev.D, cmd, MISDN_ID_ANY, 0, NULL,
  365. GFP_ATOMIC);
  366. break;
  367. case PH_DEACTIVATE_IND:
  368. test_and_clear_bit(FLG_ACTIVE, &dch->Flags);
  369. _queue_data(&dch->dev.D, cmd, MISDN_ID_ANY, 0, NULL,
  370. GFP_ATOMIC);
  371. break;
  372. default:
  373. if (dch->debug & DEBUG_HW)
  374. printk(KERN_DEBUG "%s: %s: unknown cmd %x\n",
  375. hw->name, __func__, cmd);
  376. return -1;
  377. }
  378. hfcsusb_ph_info(hw);
  379. return 0;
  380. }
  381. static int
  382. open_dchannel(struct hfcsusb *hw, struct mISDNchannel *ch,
  383. struct channel_req *rq)
  384. {
  385. int err = 0;
  386. if (debug & DEBUG_HW_OPEN)
  387. printk(KERN_DEBUG "%s: %s: dev(%d) open addr(%i) from %p\n",
  388. hw->name, __func__, hw->dch.dev.id, rq->adr.channel,
  389. __builtin_return_address(0));
  390. if (rq->protocol == ISDN_P_NONE)
  391. return -EINVAL;
  392. test_and_clear_bit(FLG_ACTIVE, &hw->dch.Flags);
  393. test_and_clear_bit(FLG_ACTIVE, &hw->ech.Flags);
  394. hfcsusb_start_endpoint(hw, HFC_CHAN_D);
  395. /* E-Channel logging */
  396. if (rq->adr.channel == 1) {
  397. if (hw->fifos[HFCUSB_PCM_RX].pipe) {
  398. hfcsusb_start_endpoint(hw, HFC_CHAN_E);
  399. set_bit(FLG_ACTIVE, &hw->ech.Flags);
  400. _queue_data(&hw->ech.dev.D, PH_ACTIVATE_IND,
  401. MISDN_ID_ANY, 0, NULL, GFP_ATOMIC);
  402. } else
  403. return -EINVAL;
  404. }
  405. if (!hw->initdone) {
  406. hw->protocol = rq->protocol;
  407. if (rq->protocol == ISDN_P_TE_S0) {
  408. err = create_l1(&hw->dch, hfc_l1callback);
  409. if (err)
  410. return err;
  411. }
  412. setPortMode(hw);
  413. ch->protocol = rq->protocol;
  414. hw->initdone = 1;
  415. } else {
  416. if (rq->protocol != ch->protocol)
  417. return -EPROTONOSUPPORT;
  418. }
  419. if (((ch->protocol == ISDN_P_NT_S0) && (hw->dch.state == 3)) ||
  420. ((ch->protocol == ISDN_P_TE_S0) && (hw->dch.state == 7)))
  421. _queue_data(ch, PH_ACTIVATE_IND, MISDN_ID_ANY,
  422. 0, NULL, GFP_KERNEL);
  423. rq->ch = ch;
  424. if (!try_module_get(THIS_MODULE))
  425. printk(KERN_WARNING "%s: %s: cannot get module\n",
  426. hw->name, __func__);
  427. return 0;
  428. }
  429. static int
  430. open_bchannel(struct hfcsusb *hw, struct channel_req *rq)
  431. {
  432. struct bchannel *bch;
  433. if (rq->adr.channel == 0 || rq->adr.channel > 2)
  434. return -EINVAL;
  435. if (rq->protocol == ISDN_P_NONE)
  436. return -EINVAL;
  437. if (debug & DBG_HFC_CALL_TRACE)
  438. printk(KERN_DEBUG "%s: %s B%i\n",
  439. hw->name, __func__, rq->adr.channel);
  440. bch = &hw->bch[rq->adr.channel - 1];
  441. if (test_and_set_bit(FLG_OPEN, &bch->Flags))
  442. return -EBUSY; /* b-channel can be only open once */
  443. test_and_clear_bit(FLG_FILLEMPTY, &bch->Flags);
  444. bch->ch.protocol = rq->protocol;
  445. rq->ch = &bch->ch;
  446. if (!try_module_get(THIS_MODULE))
  447. printk(KERN_WARNING "%s: %s:cannot get module\n",
  448. hw->name, __func__);
  449. return 0;
  450. }
  451. static int
  452. channel_ctrl(struct hfcsusb *hw, struct mISDN_ctrl_req *cq)
  453. {
  454. int ret = 0;
  455. if (debug & DBG_HFC_CALL_TRACE)
  456. printk(KERN_DEBUG "%s: %s op(0x%x) channel(0x%x)\n",
  457. hw->name, __func__, (cq->op), (cq->channel));
  458. switch (cq->op) {
  459. case MISDN_CTRL_GETOP:
  460. cq->op = MISDN_CTRL_LOOP | MISDN_CTRL_CONNECT |
  461. MISDN_CTRL_DISCONNECT;
  462. break;
  463. default:
  464. printk(KERN_WARNING "%s: %s: unknown Op %x\n",
  465. hw->name, __func__, cq->op);
  466. ret = -EINVAL;
  467. break;
  468. }
  469. return ret;
  470. }
  471. /*
  472. * device control function
  473. */
  474. static int
  475. hfc_dctrl(struct mISDNchannel *ch, u_int cmd, void *arg)
  476. {
  477. struct mISDNdevice *dev = container_of(ch, struct mISDNdevice, D);
  478. struct dchannel *dch = container_of(dev, struct dchannel, dev);
  479. struct hfcsusb *hw = dch->hw;
  480. struct channel_req *rq;
  481. int err = 0;
  482. if (dch->debug & DEBUG_HW)
  483. printk(KERN_DEBUG "%s: %s: cmd:%x %p\n",
  484. hw->name, __func__, cmd, arg);
  485. switch (cmd) {
  486. case OPEN_CHANNEL:
  487. rq = arg;
  488. if ((rq->protocol == ISDN_P_TE_S0) ||
  489. (rq->protocol == ISDN_P_NT_S0))
  490. err = open_dchannel(hw, ch, rq);
  491. else
  492. err = open_bchannel(hw, rq);
  493. if (!err)
  494. hw->open++;
  495. break;
  496. case CLOSE_CHANNEL:
  497. hw->open--;
  498. if (debug & DEBUG_HW_OPEN)
  499. printk(KERN_DEBUG
  500. "%s: %s: dev(%d) close from %p (open %d)\n",
  501. hw->name, __func__, hw->dch.dev.id,
  502. __builtin_return_address(0), hw->open);
  503. if (!hw->open) {
  504. hfcsusb_stop_endpoint(hw, HFC_CHAN_D);
  505. if (hw->fifos[HFCUSB_PCM_RX].pipe)
  506. hfcsusb_stop_endpoint(hw, HFC_CHAN_E);
  507. handle_led(hw, LED_POWER_ON);
  508. }
  509. module_put(THIS_MODULE);
  510. break;
  511. case CONTROL_CHANNEL:
  512. err = channel_ctrl(hw, arg);
  513. break;
  514. default:
  515. if (dch->debug & DEBUG_HW)
  516. printk(KERN_DEBUG "%s: %s: unknown command %x\n",
  517. hw->name, __func__, cmd);
  518. return -EINVAL;
  519. }
  520. return err;
  521. }
  522. /*
  523. * S0 TE state change event handler
  524. */
  525. static void
  526. ph_state_te(struct dchannel *dch)
  527. {
  528. struct hfcsusb *hw = dch->hw;
  529. if (debug & DEBUG_HW) {
  530. if (dch->state <= HFC_MAX_TE_LAYER1_STATE)
  531. printk(KERN_DEBUG "%s: %s: %s\n", hw->name, __func__,
  532. HFC_TE_LAYER1_STATES[dch->state]);
  533. else
  534. printk(KERN_DEBUG "%s: %s: TE F%d\n",
  535. hw->name, __func__, dch->state);
  536. }
  537. switch (dch->state) {
  538. case 0:
  539. l1_event(dch->l1, HW_RESET_IND);
  540. break;
  541. case 3:
  542. l1_event(dch->l1, HW_DEACT_IND);
  543. break;
  544. case 5:
  545. case 8:
  546. l1_event(dch->l1, ANYSIGNAL);
  547. break;
  548. case 6:
  549. l1_event(dch->l1, INFO2);
  550. break;
  551. case 7:
  552. l1_event(dch->l1, INFO4_P8);
  553. break;
  554. }
  555. if (dch->state == 7)
  556. handle_led(hw, LED_S0_ON);
  557. else
  558. handle_led(hw, LED_S0_OFF);
  559. }
  560. /*
  561. * S0 NT state change event handler
  562. */
  563. static void
  564. ph_state_nt(struct dchannel *dch)
  565. {
  566. struct hfcsusb *hw = dch->hw;
  567. if (debug & DEBUG_HW) {
  568. if (dch->state <= HFC_MAX_NT_LAYER1_STATE)
  569. printk(KERN_DEBUG "%s: %s: %s\n",
  570. hw->name, __func__,
  571. HFC_NT_LAYER1_STATES[dch->state]);
  572. else
  573. printk(KERN_INFO DRIVER_NAME "%s: %s: NT G%d\n",
  574. hw->name, __func__, dch->state);
  575. }
  576. switch (dch->state) {
  577. case (1):
  578. test_and_clear_bit(FLG_ACTIVE, &dch->Flags);
  579. test_and_clear_bit(FLG_L2_ACTIVATED, &dch->Flags);
  580. hw->nt_timer = 0;
  581. hw->timers &= ~NT_ACTIVATION_TIMER;
  582. handle_led(hw, LED_S0_OFF);
  583. break;
  584. case (2):
  585. if (hw->nt_timer < 0) {
  586. hw->nt_timer = 0;
  587. hw->timers &= ~NT_ACTIVATION_TIMER;
  588. hfcsusb_ph_command(dch->hw, HFC_L1_DEACTIVATE_NT);
  589. } else {
  590. hw->timers |= NT_ACTIVATION_TIMER;
  591. hw->nt_timer = NT_T1_COUNT;
  592. /* allow G2 -> G3 transition */
  593. write_reg(hw, HFCUSB_STATES, 2 | HFCUSB_NT_G2_G3);
  594. }
  595. break;
  596. case (3):
  597. hw->nt_timer = 0;
  598. hw->timers &= ~NT_ACTIVATION_TIMER;
  599. test_and_set_bit(FLG_ACTIVE, &dch->Flags);
  600. _queue_data(&dch->dev.D, PH_ACTIVATE_IND,
  601. MISDN_ID_ANY, 0, NULL, GFP_ATOMIC);
  602. handle_led(hw, LED_S0_ON);
  603. break;
  604. case (4):
  605. hw->nt_timer = 0;
  606. hw->timers &= ~NT_ACTIVATION_TIMER;
  607. break;
  608. default:
  609. break;
  610. }
  611. hfcsusb_ph_info(hw);
  612. }
  613. static void
  614. ph_state(struct dchannel *dch)
  615. {
  616. struct hfcsusb *hw = dch->hw;
  617. if (hw->protocol == ISDN_P_NT_S0)
  618. ph_state_nt(dch);
  619. else if (hw->protocol == ISDN_P_TE_S0)
  620. ph_state_te(dch);
  621. }
  622. /*
  623. * disable/enable BChannel for desired protocoll
  624. */
  625. static int
  626. hfcsusb_setup_bch(struct bchannel *bch, int protocol)
  627. {
  628. struct hfcsusb *hw = bch->hw;
  629. __u8 conhdlc, sctrl, sctrl_r;
  630. if (debug & DEBUG_HW)
  631. printk(KERN_DEBUG "%s: %s: protocol %x-->%x B%d\n",
  632. hw->name, __func__, bch->state, protocol,
  633. bch->nr);
  634. /* setup val for CON_HDLC */
  635. conhdlc = 0;
  636. if (protocol > ISDN_P_NONE)
  637. conhdlc = 8; /* enable FIFO */
  638. switch (protocol) {
  639. case (-1): /* used for init */
  640. bch->state = -1;
  641. /* fall through */
  642. case (ISDN_P_NONE):
  643. if (bch->state == ISDN_P_NONE)
  644. return 0; /* already in idle state */
  645. bch->state = ISDN_P_NONE;
  646. clear_bit(FLG_HDLC, &bch->Flags);
  647. clear_bit(FLG_TRANSPARENT, &bch->Flags);
  648. break;
  649. case (ISDN_P_B_RAW):
  650. conhdlc |= 2;
  651. bch->state = protocol;
  652. set_bit(FLG_TRANSPARENT, &bch->Flags);
  653. break;
  654. case (ISDN_P_B_HDLC):
  655. bch->state = protocol;
  656. set_bit(FLG_HDLC, &bch->Flags);
  657. break;
  658. default:
  659. if (debug & DEBUG_HW)
  660. printk(KERN_DEBUG "%s: %s: prot not known %x\n",
  661. hw->name, __func__, protocol);
  662. return -ENOPROTOOPT;
  663. }
  664. if (protocol >= ISDN_P_NONE) {
  665. write_reg(hw, HFCUSB_FIFO, (bch->nr == 1) ? 0 : 2);
  666. write_reg(hw, HFCUSB_CON_HDLC, conhdlc);
  667. write_reg(hw, HFCUSB_INC_RES_F, 2);
  668. write_reg(hw, HFCUSB_FIFO, (bch->nr == 1) ? 1 : 3);
  669. write_reg(hw, HFCUSB_CON_HDLC, conhdlc);
  670. write_reg(hw, HFCUSB_INC_RES_F, 2);
  671. sctrl = 0x40 + ((hw->protocol == ISDN_P_TE_S0) ? 0x00 : 0x04);
  672. sctrl_r = 0x0;
  673. if (test_bit(FLG_ACTIVE, &hw->bch[0].Flags)) {
  674. sctrl |= 1;
  675. sctrl_r |= 1;
  676. }
  677. if (test_bit(FLG_ACTIVE, &hw->bch[1].Flags)) {
  678. sctrl |= 2;
  679. sctrl_r |= 2;
  680. }
  681. write_reg(hw, HFCUSB_SCTRL, sctrl);
  682. write_reg(hw, HFCUSB_SCTRL_R, sctrl_r);
  683. if (protocol > ISDN_P_NONE)
  684. handle_led(hw, (bch->nr == 1) ? LED_B1_ON : LED_B2_ON);
  685. else
  686. handle_led(hw, (bch->nr == 1) ? LED_B1_OFF :
  687. LED_B2_OFF);
  688. }
  689. hfcsusb_ph_info(hw);
  690. return 0;
  691. }
  692. static void
  693. hfcsusb_ph_command(struct hfcsusb *hw, u_char command)
  694. {
  695. if (debug & DEBUG_HW)
  696. printk(KERN_DEBUG "%s: %s: %x\n",
  697. hw->name, __func__, command);
  698. switch (command) {
  699. case HFC_L1_ACTIVATE_TE:
  700. /* force sending sending INFO1 */
  701. write_reg(hw, HFCUSB_STATES, 0x14);
  702. /* start l1 activation */
  703. write_reg(hw, HFCUSB_STATES, 0x04);
  704. break;
  705. case HFC_L1_FORCE_DEACTIVATE_TE:
  706. write_reg(hw, HFCUSB_STATES, 0x10);
  707. write_reg(hw, HFCUSB_STATES, 0x03);
  708. break;
  709. case HFC_L1_ACTIVATE_NT:
  710. if (hw->dch.state == 3)
  711. _queue_data(&hw->dch.dev.D, PH_ACTIVATE_IND,
  712. MISDN_ID_ANY, 0, NULL, GFP_ATOMIC);
  713. else
  714. write_reg(hw, HFCUSB_STATES, HFCUSB_ACTIVATE |
  715. HFCUSB_DO_ACTION | HFCUSB_NT_G2_G3);
  716. break;
  717. case HFC_L1_DEACTIVATE_NT:
  718. write_reg(hw, HFCUSB_STATES,
  719. HFCUSB_DO_ACTION);
  720. break;
  721. }
  722. }
  723. /*
  724. * Layer 1 B-channel hardware access
  725. */
  726. static int
  727. channel_bctrl(struct bchannel *bch, struct mISDN_ctrl_req *cq)
  728. {
  729. int ret = 0;
  730. switch (cq->op) {
  731. case MISDN_CTRL_GETOP:
  732. ret = mISDN_ctrl_bchannel(bch, cq);
  733. cq->op |= MISDN_CTRL_FILL_EMPTY;
  734. break;
  735. case MISDN_CTRL_FILL_EMPTY: /* fill fifo, if empty */
  736. test_and_set_bit(FLG_FILLEMPTY, &bch->Flags);
  737. if (debug & DEBUG_HW_OPEN)
  738. printk(KERN_DEBUG "%s: FILL_EMPTY request (nr=%d "
  739. "off=%d)\n", __func__, bch->nr, !!cq->p1);
  740. break;
  741. default:
  742. ret = mISDN_ctrl_bchannel(bch, cq);
  743. break;
  744. }
  745. return ret;
  746. }
  747. /* collect data from incoming interrupt or isochron USB data */
  748. static void
  749. hfcsusb_rx_frame(struct usb_fifo *fifo, __u8 *data, unsigned int len,
  750. int finish)
  751. {
  752. struct hfcsusb *hw = fifo->hw;
  753. struct sk_buff *rx_skb = NULL;
  754. int maxlen = 0;
  755. int fifon = fifo->fifonum;
  756. int i;
  757. int hdlc = 0;
  758. if (debug & DBG_HFC_CALL_TRACE)
  759. printk(KERN_DEBUG "%s: %s: fifo(%i) len(%i) "
  760. "dch(%p) bch(%p) ech(%p)\n",
  761. hw->name, __func__, fifon, len,
  762. fifo->dch, fifo->bch, fifo->ech);
  763. if (!len)
  764. return;
  765. if ((!!fifo->dch + !!fifo->bch + !!fifo->ech) != 1) {
  766. printk(KERN_DEBUG "%s: %s: undefined channel\n",
  767. hw->name, __func__);
  768. return;
  769. }
  770. spin_lock(&hw->lock);
  771. if (fifo->dch) {
  772. rx_skb = fifo->dch->rx_skb;
  773. maxlen = fifo->dch->maxlen;
  774. hdlc = 1;
  775. }
  776. if (fifo->bch) {
  777. maxlen = bchannel_get_rxbuf(fifo->bch, len);
  778. rx_skb = fifo->bch->rx_skb;
  779. if (maxlen < 0) {
  780. if (rx_skb)
  781. skb_trim(rx_skb, 0);
  782. pr_warning("%s.B%d: No bufferspace for %d bytes\n",
  783. hw->name, fifo->bch->nr, len);
  784. spin_unlock(&hw->lock);
  785. return;
  786. }
  787. maxlen = fifo->bch->maxlen;
  788. hdlc = test_bit(FLG_HDLC, &fifo->bch->Flags);
  789. }
  790. if (fifo->ech) {
  791. rx_skb = fifo->ech->rx_skb;
  792. maxlen = fifo->ech->maxlen;
  793. hdlc = 1;
  794. }
  795. if (fifo->dch || fifo->ech) {
  796. if (!rx_skb) {
  797. rx_skb = mI_alloc_skb(maxlen, GFP_ATOMIC);
  798. if (rx_skb) {
  799. if (fifo->dch)
  800. fifo->dch->rx_skb = rx_skb;
  801. if (fifo->ech)
  802. fifo->ech->rx_skb = rx_skb;
  803. skb_trim(rx_skb, 0);
  804. } else {
  805. printk(KERN_DEBUG "%s: %s: No mem for rx_skb\n",
  806. hw->name, __func__);
  807. spin_unlock(&hw->lock);
  808. return;
  809. }
  810. }
  811. /* D/E-Channel SKB range check */
  812. if ((rx_skb->len + len) >= MAX_DFRAME_LEN_L1) {
  813. printk(KERN_DEBUG "%s: %s: sbk mem exceeded "
  814. "for fifo(%d) HFCUSB_D_RX\n",
  815. hw->name, __func__, fifon);
  816. skb_trim(rx_skb, 0);
  817. spin_unlock(&hw->lock);
  818. return;
  819. }
  820. }
  821. memcpy(skb_put(rx_skb, len), data, len);
  822. if (hdlc) {
  823. /* we have a complete hdlc packet */
  824. if (finish) {
  825. if ((rx_skb->len > 3) &&
  826. (!(rx_skb->data[rx_skb->len - 1]))) {
  827. if (debug & DBG_HFC_FIFO_VERBOSE) {
  828. printk(KERN_DEBUG "%s: %s: fifon(%i)"
  829. " new RX len(%i): ",
  830. hw->name, __func__, fifon,
  831. rx_skb->len);
  832. i = 0;
  833. while (i < rx_skb->len)
  834. printk("%02x ",
  835. rx_skb->data[i++]);
  836. printk("\n");
  837. }
  838. /* remove CRC & status */
  839. skb_trim(rx_skb, rx_skb->len - 3);
  840. if (fifo->dch)
  841. recv_Dchannel(fifo->dch);
  842. if (fifo->bch)
  843. recv_Bchannel(fifo->bch, MISDN_ID_ANY,
  844. 0);
  845. if (fifo->ech)
  846. recv_Echannel(fifo->ech,
  847. &hw->dch);
  848. } else {
  849. if (debug & DBG_HFC_FIFO_VERBOSE) {
  850. printk(KERN_DEBUG
  851. "%s: CRC or minlen ERROR fifon(%i) "
  852. "RX len(%i): ",
  853. hw->name, fifon, rx_skb->len);
  854. i = 0;
  855. while (i < rx_skb->len)
  856. printk("%02x ",
  857. rx_skb->data[i++]);
  858. printk("\n");
  859. }
  860. skb_trim(rx_skb, 0);
  861. }
  862. }
  863. } else {
  864. /* deliver transparent data to layer2 */
  865. recv_Bchannel(fifo->bch, MISDN_ID_ANY, false);
  866. }
  867. spin_unlock(&hw->lock);
  868. }
  869. static void
  870. fill_isoc_urb(struct urb *urb, struct usb_device *dev, unsigned int pipe,
  871. void *buf, int num_packets, int packet_size, int interval,
  872. usb_complete_t complete, void *context)
  873. {
  874. int k;
  875. usb_fill_bulk_urb(urb, dev, pipe, buf, packet_size * num_packets,
  876. complete, context);
  877. urb->number_of_packets = num_packets;
  878. urb->transfer_flags = URB_ISO_ASAP;
  879. urb->actual_length = 0;
  880. urb->interval = interval;
  881. for (k = 0; k < num_packets; k++) {
  882. urb->iso_frame_desc[k].offset = packet_size * k;
  883. urb->iso_frame_desc[k].length = packet_size;
  884. urb->iso_frame_desc[k].actual_length = 0;
  885. }
  886. }
  887. /* receive completion routine for all ISO tx fifos */
  888. static void
  889. rx_iso_complete(struct urb *urb)
  890. {
  891. struct iso_urb *context_iso_urb = (struct iso_urb *) urb->context;
  892. struct usb_fifo *fifo = context_iso_urb->owner_fifo;
  893. struct hfcsusb *hw = fifo->hw;
  894. int k, len, errcode, offset, num_isoc_packets, fifon, maxlen,
  895. status, iso_status, i;
  896. __u8 *buf;
  897. static __u8 eof[8];
  898. __u8 s0_state;
  899. fifon = fifo->fifonum;
  900. status = urb->status;
  901. spin_lock(&hw->lock);
  902. if (fifo->stop_gracefull) {
  903. fifo->stop_gracefull = 0;
  904. fifo->active = 0;
  905. spin_unlock(&hw->lock);
  906. return;
  907. }
  908. spin_unlock(&hw->lock);
  909. /*
  910. * ISO transfer only partially completed,
  911. * look at individual frame status for details
  912. */
  913. if (status == -EXDEV) {
  914. if (debug & DEBUG_HW)
  915. printk(KERN_DEBUG "%s: %s: with -EXDEV "
  916. "urb->status %d, fifonum %d\n",
  917. hw->name, __func__, status, fifon);
  918. /* clear status, so go on with ISO transfers */
  919. status = 0;
  920. }
  921. s0_state = 0;
  922. if (fifo->active && !status) {
  923. num_isoc_packets = iso_packets[fifon];
  924. maxlen = fifo->usb_packet_maxlen;
  925. for (k = 0; k < num_isoc_packets; ++k) {
  926. len = urb->iso_frame_desc[k].actual_length;
  927. offset = urb->iso_frame_desc[k].offset;
  928. buf = context_iso_urb->buffer + offset;
  929. iso_status = urb->iso_frame_desc[k].status;
  930. if (iso_status && (debug & DBG_HFC_FIFO_VERBOSE)) {
  931. printk(KERN_DEBUG "%s: %s: "
  932. "ISO packet %i, status: %i\n",
  933. hw->name, __func__, k, iso_status);
  934. }
  935. /* USB data log for every D ISO in */
  936. if ((fifon == HFCUSB_D_RX) &&
  937. (debug & DBG_HFC_USB_VERBOSE)) {
  938. printk(KERN_DEBUG
  939. "%s: %s: %d (%d/%d) len(%d) ",
  940. hw->name, __func__, urb->start_frame,
  941. k, num_isoc_packets - 1,
  942. len);
  943. for (i = 0; i < len; i++)
  944. printk("%x ", buf[i]);
  945. printk("\n");
  946. }
  947. if (!iso_status) {
  948. if (fifo->last_urblen != maxlen) {
  949. /*
  950. * save fifo fill-level threshold bits
  951. * to use them later in TX ISO URB
  952. * completions
  953. */
  954. hw->threshold_mask = buf[1];
  955. if (fifon == HFCUSB_D_RX)
  956. s0_state = (buf[0] >> 4);
  957. eof[fifon] = buf[0] & 1;
  958. if (len > 2)
  959. hfcsusb_rx_frame(fifo, buf + 2,
  960. len - 2, (len < maxlen)
  961. ? eof[fifon] : 0);
  962. } else
  963. hfcsusb_rx_frame(fifo, buf, len,
  964. (len < maxlen) ?
  965. eof[fifon] : 0);
  966. fifo->last_urblen = len;
  967. }
  968. }
  969. /* signal S0 layer1 state change */
  970. if ((s0_state) && (hw->initdone) &&
  971. (s0_state != hw->dch.state)) {
  972. hw->dch.state = s0_state;
  973. schedule_event(&hw->dch, FLG_PHCHANGE);
  974. }
  975. fill_isoc_urb(urb, fifo->hw->dev, fifo->pipe,
  976. context_iso_urb->buffer, num_isoc_packets,
  977. fifo->usb_packet_maxlen, fifo->intervall,
  978. (usb_complete_t)rx_iso_complete, urb->context);
  979. errcode = usb_submit_urb(urb, GFP_ATOMIC);
  980. if (errcode < 0) {
  981. if (debug & DEBUG_HW)
  982. printk(KERN_DEBUG "%s: %s: error submitting "
  983. "ISO URB: %d\n",
  984. hw->name, __func__, errcode);
  985. }
  986. } else {
  987. if (status && (debug & DBG_HFC_URB_INFO))
  988. printk(KERN_DEBUG "%s: %s: rx_iso_complete : "
  989. "urb->status %d, fifonum %d\n",
  990. hw->name, __func__, status, fifon);
  991. }
  992. }
  993. /* receive completion routine for all interrupt rx fifos */
  994. static void
  995. rx_int_complete(struct urb *urb)
  996. {
  997. int len, status, i;
  998. __u8 *buf, maxlen, fifon;
  999. struct usb_fifo *fifo = (struct usb_fifo *) urb->context;
  1000. struct hfcsusb *hw = fifo->hw;
  1001. static __u8 eof[8];
  1002. spin_lock(&hw->lock);
  1003. if (fifo->stop_gracefull) {
  1004. fifo->stop_gracefull = 0;
  1005. fifo->active = 0;
  1006. spin_unlock(&hw->lock);
  1007. return;
  1008. }
  1009. spin_unlock(&hw->lock);
  1010. fifon = fifo->fifonum;
  1011. if ((!fifo->active) || (urb->status)) {
  1012. if (debug & DBG_HFC_URB_ERROR)
  1013. printk(KERN_DEBUG
  1014. "%s: %s: RX-Fifo %i is going down (%i)\n",
  1015. hw->name, __func__, fifon, urb->status);
  1016. fifo->urb->interval = 0; /* cancel automatic rescheduling */
  1017. return;
  1018. }
  1019. len = urb->actual_length;
  1020. buf = fifo->buffer;
  1021. maxlen = fifo->usb_packet_maxlen;
  1022. /* USB data log for every D INT in */
  1023. if ((fifon == HFCUSB_D_RX) && (debug & DBG_HFC_USB_VERBOSE)) {
  1024. printk(KERN_DEBUG "%s: %s: D RX INT len(%d) ",
  1025. hw->name, __func__, len);
  1026. for (i = 0; i < len; i++)
  1027. printk("%02x ", buf[i]);
  1028. printk("\n");
  1029. }
  1030. if (fifo->last_urblen != fifo->usb_packet_maxlen) {
  1031. /* the threshold mask is in the 2nd status byte */
  1032. hw->threshold_mask = buf[1];
  1033. /* signal S0 layer1 state change */
  1034. if (hw->initdone && ((buf[0] >> 4) != hw->dch.state)) {
  1035. hw->dch.state = (buf[0] >> 4);
  1036. schedule_event(&hw->dch, FLG_PHCHANGE);
  1037. }
  1038. eof[fifon] = buf[0] & 1;
  1039. /* if we have more than the 2 status bytes -> collect data */
  1040. if (len > 2)
  1041. hfcsusb_rx_frame(fifo, buf + 2,
  1042. urb->actual_length - 2,
  1043. (len < maxlen) ? eof[fifon] : 0);
  1044. } else {
  1045. hfcsusb_rx_frame(fifo, buf, urb->actual_length,
  1046. (len < maxlen) ? eof[fifon] : 0);
  1047. }
  1048. fifo->last_urblen = urb->actual_length;
  1049. status = usb_submit_urb(urb, GFP_ATOMIC);
  1050. if (status) {
  1051. if (debug & DEBUG_HW)
  1052. printk(KERN_DEBUG "%s: %s: error resubmitting USB\n",
  1053. hw->name, __func__);
  1054. }
  1055. }
  1056. /* transmit completion routine for all ISO tx fifos */
  1057. static void
  1058. tx_iso_complete(struct urb *urb)
  1059. {
  1060. struct iso_urb *context_iso_urb = (struct iso_urb *) urb->context;
  1061. struct usb_fifo *fifo = context_iso_urb->owner_fifo;
  1062. struct hfcsusb *hw = fifo->hw;
  1063. struct sk_buff *tx_skb;
  1064. int k, tx_offset, num_isoc_packets, sink, remain, current_len,
  1065. errcode, hdlc, i;
  1066. int *tx_idx;
  1067. int frame_complete, fifon, status;
  1068. __u8 threshbit;
  1069. spin_lock(&hw->lock);
  1070. if (fifo->stop_gracefull) {
  1071. fifo->stop_gracefull = 0;
  1072. fifo->active = 0;
  1073. spin_unlock(&hw->lock);
  1074. return;
  1075. }
  1076. if (fifo->dch) {
  1077. tx_skb = fifo->dch->tx_skb;
  1078. tx_idx = &fifo->dch->tx_idx;
  1079. hdlc = 1;
  1080. } else if (fifo->bch) {
  1081. tx_skb = fifo->bch->tx_skb;
  1082. tx_idx = &fifo->bch->tx_idx;
  1083. hdlc = test_bit(FLG_HDLC, &fifo->bch->Flags);
  1084. } else {
  1085. printk(KERN_DEBUG "%s: %s: neither BCH nor DCH\n",
  1086. hw->name, __func__);
  1087. spin_unlock(&hw->lock);
  1088. return;
  1089. }
  1090. fifon = fifo->fifonum;
  1091. status = urb->status;
  1092. tx_offset = 0;
  1093. /*
  1094. * ISO transfer only partially completed,
  1095. * look at individual frame status for details
  1096. */
  1097. if (status == -EXDEV) {
  1098. if (debug & DBG_HFC_URB_ERROR)
  1099. printk(KERN_DEBUG "%s: %s: "
  1100. "-EXDEV (%i) fifon (%d)\n",
  1101. hw->name, __func__, status, fifon);
  1102. /* clear status, so go on with ISO transfers */
  1103. status = 0;
  1104. }
  1105. if (fifo->active && !status) {
  1106. /* is FifoFull-threshold set for our channel? */
  1107. threshbit = (hw->threshold_mask & (1 << fifon));
  1108. num_isoc_packets = iso_packets[fifon];
  1109. /* predict dataflow to avoid fifo overflow */
  1110. if (fifon >= HFCUSB_D_TX)
  1111. sink = (threshbit) ? SINK_DMIN : SINK_DMAX;
  1112. else
  1113. sink = (threshbit) ? SINK_MIN : SINK_MAX;
  1114. fill_isoc_urb(urb, fifo->hw->dev, fifo->pipe,
  1115. context_iso_urb->buffer, num_isoc_packets,
  1116. fifo->usb_packet_maxlen, fifo->intervall,
  1117. (usb_complete_t)tx_iso_complete, urb->context);
  1118. memset(context_iso_urb->buffer, 0,
  1119. sizeof(context_iso_urb->buffer));
  1120. frame_complete = 0;
  1121. for (k = 0; k < num_isoc_packets; ++k) {
  1122. /* analyze tx success of previous ISO packets */
  1123. if (debug & DBG_HFC_URB_ERROR) {
  1124. errcode = urb->iso_frame_desc[k].status;
  1125. if (errcode) {
  1126. printk(KERN_DEBUG "%s: %s: "
  1127. "ISO packet %i, status: %i\n",
  1128. hw->name, __func__, k, errcode);
  1129. }
  1130. }
  1131. /* Generate next ISO Packets */
  1132. if (tx_skb)
  1133. remain = tx_skb->len - *tx_idx;
  1134. else
  1135. remain = 0;
  1136. if (remain > 0) {
  1137. fifo->bit_line -= sink;
  1138. current_len = (0 - fifo->bit_line) / 8;
  1139. if (current_len > 14)
  1140. current_len = 14;
  1141. if (current_len < 0)
  1142. current_len = 0;
  1143. if (remain < current_len)
  1144. current_len = remain;
  1145. /* how much bit do we put on the line? */
  1146. fifo->bit_line += current_len * 8;
  1147. context_iso_urb->buffer[tx_offset] = 0;
  1148. if (current_len == remain) {
  1149. if (hdlc) {
  1150. /* signal frame completion */
  1151. context_iso_urb->
  1152. buffer[tx_offset] = 1;
  1153. /* add 2 byte flags and 16bit
  1154. * CRC at end of ISDN frame */
  1155. fifo->bit_line += 32;
  1156. }
  1157. frame_complete = 1;
  1158. }
  1159. /* copy tx data to iso-urb buffer */
  1160. memcpy(context_iso_urb->buffer + tx_offset + 1,
  1161. (tx_skb->data + *tx_idx), current_len);
  1162. *tx_idx += current_len;
  1163. urb->iso_frame_desc[k].offset = tx_offset;
  1164. urb->iso_frame_desc[k].length = current_len + 1;
  1165. /* USB data log for every D ISO out */
  1166. if ((fifon == HFCUSB_D_RX) &&
  1167. (debug & DBG_HFC_USB_VERBOSE)) {
  1168. printk(KERN_DEBUG
  1169. "%s: %s (%d/%d) offs(%d) len(%d) ",
  1170. hw->name, __func__,
  1171. k, num_isoc_packets - 1,
  1172. urb->iso_frame_desc[k].offset,
  1173. urb->iso_frame_desc[k].length);
  1174. for (i = urb->iso_frame_desc[k].offset;
  1175. i < (urb->iso_frame_desc[k].offset
  1176. + urb->iso_frame_desc[k].length);
  1177. i++)
  1178. printk("%x ",
  1179. context_iso_urb->buffer[i]);
  1180. printk(" skb->len(%i) tx-idx(%d)\n",
  1181. tx_skb->len, *tx_idx);
  1182. }
  1183. tx_offset += (current_len + 1);
  1184. } else {
  1185. urb->iso_frame_desc[k].offset = tx_offset++;
  1186. urb->iso_frame_desc[k].length = 1;
  1187. /* we lower data margin every msec */
  1188. fifo->bit_line -= sink;
  1189. if (fifo->bit_line < BITLINE_INF)
  1190. fifo->bit_line = BITLINE_INF;
  1191. }
  1192. if (frame_complete) {
  1193. frame_complete = 0;
  1194. if (debug & DBG_HFC_FIFO_VERBOSE) {
  1195. printk(KERN_DEBUG "%s: %s: "
  1196. "fifon(%i) new TX len(%i): ",
  1197. hw->name, __func__,
  1198. fifon, tx_skb->len);
  1199. i = 0;
  1200. while (i < tx_skb->len)
  1201. printk("%02x ",
  1202. tx_skb->data[i++]);
  1203. printk("\n");
  1204. }
  1205. dev_kfree_skb(tx_skb);
  1206. tx_skb = NULL;
  1207. if (fifo->dch && get_next_dframe(fifo->dch))
  1208. tx_skb = fifo->dch->tx_skb;
  1209. else if (fifo->bch &&
  1210. get_next_bframe(fifo->bch))
  1211. tx_skb = fifo->bch->tx_skb;
  1212. }
  1213. }
  1214. errcode = usb_submit_urb(urb, GFP_ATOMIC);
  1215. if (errcode < 0) {
  1216. if (debug & DEBUG_HW)
  1217. printk(KERN_DEBUG
  1218. "%s: %s: error submitting ISO URB: %d \n",
  1219. hw->name, __func__, errcode);
  1220. }
  1221. /*
  1222. * abuse DChannel tx iso completion to trigger NT mode state
  1223. * changes tx_iso_complete is assumed to be called every
  1224. * fifo->intervall (ms)
  1225. */
  1226. if ((fifon == HFCUSB_D_TX) && (hw->protocol == ISDN_P_NT_S0)
  1227. && (hw->timers & NT_ACTIVATION_TIMER)) {
  1228. if ((--hw->nt_timer) < 0)
  1229. schedule_event(&hw->dch, FLG_PHCHANGE);
  1230. }
  1231. } else {
  1232. if (status && (debug & DBG_HFC_URB_ERROR))
  1233. printk(KERN_DEBUG "%s: %s: urb->status %s (%i)"
  1234. "fifonum=%d\n",
  1235. hw->name, __func__,
  1236. symbolic(urb_errlist, status), status, fifon);
  1237. }
  1238. spin_unlock(&hw->lock);
  1239. }
  1240. /*
  1241. * allocs urbs and start isoc transfer with two pending urbs to avoid
  1242. * gaps in the transfer chain
  1243. */
  1244. static int
  1245. start_isoc_chain(struct usb_fifo *fifo, int num_packets_per_urb,
  1246. usb_complete_t complete, int packet_size)
  1247. {
  1248. struct hfcsusb *hw = fifo->hw;
  1249. int i, k, errcode;
  1250. if (debug)
  1251. printk(KERN_DEBUG "%s: %s: fifo %i\n",
  1252. hw->name, __func__, fifo->fifonum);
  1253. /* allocate Memory for Iso out Urbs */
  1254. for (i = 0; i < 2; i++) {
  1255. if (!(fifo->iso[i].urb)) {
  1256. fifo->iso[i].urb =
  1257. usb_alloc_urb(num_packets_per_urb, GFP_KERNEL);
  1258. if (!(fifo->iso[i].urb)) {
  1259. printk(KERN_DEBUG
  1260. "%s: %s: alloc urb for fifo %i failed",
  1261. hw->name, __func__, fifo->fifonum);
  1262. }
  1263. fifo->iso[i].owner_fifo = (struct usb_fifo *) fifo;
  1264. fifo->iso[i].indx = i;
  1265. /* Init the first iso */
  1266. if (ISO_BUFFER_SIZE >=
  1267. (fifo->usb_packet_maxlen *
  1268. num_packets_per_urb)) {
  1269. fill_isoc_urb(fifo->iso[i].urb,
  1270. fifo->hw->dev, fifo->pipe,
  1271. fifo->iso[i].buffer,
  1272. num_packets_per_urb,
  1273. fifo->usb_packet_maxlen,
  1274. fifo->intervall, complete,
  1275. &fifo->iso[i]);
  1276. memset(fifo->iso[i].buffer, 0,
  1277. sizeof(fifo->iso[i].buffer));
  1278. for (k = 0; k < num_packets_per_urb; k++) {
  1279. fifo->iso[i].urb->
  1280. iso_frame_desc[k].offset =
  1281. k * packet_size;
  1282. fifo->iso[i].urb->
  1283. iso_frame_desc[k].length =
  1284. packet_size;
  1285. }
  1286. } else {
  1287. printk(KERN_DEBUG
  1288. "%s: %s: ISO Buffer size to small!\n",
  1289. hw->name, __func__);
  1290. }
  1291. }
  1292. fifo->bit_line = BITLINE_INF;
  1293. errcode = usb_submit_urb(fifo->iso[i].urb, GFP_KERNEL);
  1294. fifo->active = (errcode >= 0) ? 1 : 0;
  1295. fifo->stop_gracefull = 0;
  1296. if (errcode < 0) {
  1297. printk(KERN_DEBUG "%s: %s: %s URB nr:%d\n",
  1298. hw->name, __func__,
  1299. symbolic(urb_errlist, errcode), i);
  1300. }
  1301. }
  1302. return fifo->active;
  1303. }
  1304. static void
  1305. stop_iso_gracefull(struct usb_fifo *fifo)
  1306. {
  1307. struct hfcsusb *hw = fifo->hw;
  1308. int i, timeout;
  1309. u_long flags;
  1310. for (i = 0; i < 2; i++) {
  1311. spin_lock_irqsave(&hw->lock, flags);
  1312. if (debug)
  1313. printk(KERN_DEBUG "%s: %s for fifo %i.%i\n",
  1314. hw->name, __func__, fifo->fifonum, i);
  1315. fifo->stop_gracefull = 1;
  1316. spin_unlock_irqrestore(&hw->lock, flags);
  1317. }
  1318. for (i = 0; i < 2; i++) {
  1319. timeout = 3;
  1320. while (fifo->stop_gracefull && timeout--)
  1321. schedule_timeout_interruptible((HZ / 1000) * 16);
  1322. if (debug && fifo->stop_gracefull)
  1323. printk(KERN_DEBUG "%s: ERROR %s for fifo %i.%i\n",
  1324. hw->name, __func__, fifo->fifonum, i);
  1325. }
  1326. }
  1327. static void
  1328. stop_int_gracefull(struct usb_fifo *fifo)
  1329. {
  1330. struct hfcsusb *hw = fifo->hw;
  1331. int timeout;
  1332. u_long flags;
  1333. spin_lock_irqsave(&hw->lock, flags);
  1334. if (debug)
  1335. printk(KERN_DEBUG "%s: %s for fifo %i\n",
  1336. hw->name, __func__, fifo->fifonum);
  1337. fifo->stop_gracefull = 1;
  1338. spin_unlock_irqrestore(&hw->lock, flags);
  1339. timeout = 3;
  1340. while (fifo->stop_gracefull && timeout--)
  1341. schedule_timeout_interruptible((HZ / 1000) * 3);
  1342. if (debug && fifo->stop_gracefull)
  1343. printk(KERN_DEBUG "%s: ERROR %s for fifo %i\n",
  1344. hw->name, __func__, fifo->fifonum);
  1345. }
  1346. /* start the interrupt transfer for the given fifo */
  1347. static void
  1348. start_int_fifo(struct usb_fifo *fifo)
  1349. {
  1350. struct hfcsusb *hw = fifo->hw;
  1351. int errcode;
  1352. if (debug)
  1353. printk(KERN_DEBUG "%s: %s: INT IN fifo:%d\n",
  1354. hw->name, __func__, fifo->fifonum);
  1355. if (!fifo->urb) {
  1356. fifo->urb = usb_alloc_urb(0, GFP_KERNEL);
  1357. if (!fifo->urb)
  1358. return;
  1359. }
  1360. usb_fill_int_urb(fifo->urb, fifo->hw->dev, fifo->pipe,
  1361. fifo->buffer, fifo->usb_packet_maxlen,
  1362. (usb_complete_t)rx_int_complete, fifo, fifo->intervall);
  1363. fifo->active = 1;
  1364. fifo->stop_gracefull = 0;
  1365. errcode = usb_submit_urb(fifo->urb, GFP_KERNEL);
  1366. if (errcode) {
  1367. printk(KERN_DEBUG "%s: %s: submit URB: status:%i\n",
  1368. hw->name, __func__, errcode);
  1369. fifo->active = 0;
  1370. }
  1371. }
  1372. static void
  1373. setPortMode(struct hfcsusb *hw)
  1374. {
  1375. if (debug & DEBUG_HW)
  1376. printk(KERN_DEBUG "%s: %s %s\n", hw->name, __func__,
  1377. (hw->protocol == ISDN_P_TE_S0) ? "TE" : "NT");
  1378. if (hw->protocol == ISDN_P_TE_S0) {
  1379. write_reg(hw, HFCUSB_SCTRL, 0x40);
  1380. write_reg(hw, HFCUSB_SCTRL_E, 0x00);
  1381. write_reg(hw, HFCUSB_CLKDEL, CLKDEL_TE);
  1382. write_reg(hw, HFCUSB_STATES, 3 | 0x10);
  1383. write_reg(hw, HFCUSB_STATES, 3);
  1384. } else {
  1385. write_reg(hw, HFCUSB_SCTRL, 0x44);
  1386. write_reg(hw, HFCUSB_SCTRL_E, 0x09);
  1387. write_reg(hw, HFCUSB_CLKDEL, CLKDEL_NT);
  1388. write_reg(hw, HFCUSB_STATES, 1 | 0x10);
  1389. write_reg(hw, HFCUSB_STATES, 1);
  1390. }
  1391. }
  1392. static void
  1393. reset_hfcsusb(struct hfcsusb *hw)
  1394. {
  1395. struct usb_fifo *fifo;
  1396. int i;
  1397. if (debug & DEBUG_HW)
  1398. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  1399. /* do Chip reset */
  1400. write_reg(hw, HFCUSB_CIRM, 8);
  1401. /* aux = output, reset off */
  1402. write_reg(hw, HFCUSB_CIRM, 0x10);
  1403. /* set USB_SIZE to match the wMaxPacketSize for INT or BULK transfers */
  1404. write_reg(hw, HFCUSB_USB_SIZE, (hw->packet_size / 8) |
  1405. ((hw->packet_size / 8) << 4));
  1406. /* set USB_SIZE_I to match the the wMaxPacketSize for ISO transfers */
  1407. write_reg(hw, HFCUSB_USB_SIZE_I, hw->iso_packet_size);
  1408. /* enable PCM/GCI master mode */
  1409. write_reg(hw, HFCUSB_MST_MODE1, 0); /* set default values */
  1410. write_reg(hw, HFCUSB_MST_MODE0, 1); /* enable master mode */
  1411. /* init the fifos */
  1412. write_reg(hw, HFCUSB_F_THRES,
  1413. (HFCUSB_TX_THRESHOLD / 8) | ((HFCUSB_RX_THRESHOLD / 8) << 4));
  1414. fifo = hw->fifos;
  1415. for (i = 0; i < HFCUSB_NUM_FIFOS; i++) {
  1416. write_reg(hw, HFCUSB_FIFO, i); /* select the desired fifo */
  1417. fifo[i].max_size =
  1418. (i <= HFCUSB_B2_RX) ? MAX_BCH_SIZE : MAX_DFRAME_LEN;
  1419. fifo[i].last_urblen = 0;
  1420. /* set 2 bit for D- & E-channel */
  1421. write_reg(hw, HFCUSB_HDLC_PAR, ((i <= HFCUSB_B2_RX) ? 0 : 2));
  1422. /* enable all fifos */
  1423. if (i == HFCUSB_D_TX)
  1424. write_reg(hw, HFCUSB_CON_HDLC,
  1425. (hw->protocol == ISDN_P_NT_S0) ? 0x08 : 0x09);
  1426. else
  1427. write_reg(hw, HFCUSB_CON_HDLC, 0x08);
  1428. write_reg(hw, HFCUSB_INC_RES_F, 2); /* reset the fifo */
  1429. }
  1430. write_reg(hw, HFCUSB_SCTRL_R, 0); /* disable both B receivers */
  1431. handle_led(hw, LED_POWER_ON);
  1432. }
  1433. /* start USB data pipes dependand on device's endpoint configuration */
  1434. static void
  1435. hfcsusb_start_endpoint(struct hfcsusb *hw, int channel)
  1436. {
  1437. /* quick check if endpoint already running */
  1438. if ((channel == HFC_CHAN_D) && (hw->fifos[HFCUSB_D_RX].active))
  1439. return;
  1440. if ((channel == HFC_CHAN_B1) && (hw->fifos[HFCUSB_B1_RX].active))
  1441. return;
  1442. if ((channel == HFC_CHAN_B2) && (hw->fifos[HFCUSB_B2_RX].active))
  1443. return;
  1444. if ((channel == HFC_CHAN_E) && (hw->fifos[HFCUSB_PCM_RX].active))
  1445. return;
  1446. /* start rx endpoints using USB INT IN method */
  1447. if (hw->cfg_used == CNF_3INT3ISO || hw->cfg_used == CNF_4INT3ISO)
  1448. start_int_fifo(hw->fifos + channel * 2 + 1);
  1449. /* start rx endpoints using USB ISO IN method */
  1450. if (hw->cfg_used == CNF_3ISO3ISO || hw->cfg_used == CNF_4ISO3ISO) {
  1451. switch (channel) {
  1452. case HFC_CHAN_D:
  1453. start_isoc_chain(hw->fifos + HFCUSB_D_RX,
  1454. ISOC_PACKETS_D,
  1455. (usb_complete_t)rx_iso_complete,
  1456. 16);
  1457. break;
  1458. case HFC_CHAN_E:
  1459. start_isoc_chain(hw->fifos + HFCUSB_PCM_RX,
  1460. ISOC_PACKETS_D,
  1461. (usb_complete_t)rx_iso_complete,
  1462. 16);
  1463. break;
  1464. case HFC_CHAN_B1:
  1465. start_isoc_chain(hw->fifos + HFCUSB_B1_RX,
  1466. ISOC_PACKETS_B,
  1467. (usb_complete_t)rx_iso_complete,
  1468. 16);
  1469. break;
  1470. case HFC_CHAN_B2:
  1471. start_isoc_chain(hw->fifos + HFCUSB_B2_RX,
  1472. ISOC_PACKETS_B,
  1473. (usb_complete_t)rx_iso_complete,
  1474. 16);
  1475. break;
  1476. }
  1477. }
  1478. /* start tx endpoints using USB ISO OUT method */
  1479. switch (channel) {
  1480. case HFC_CHAN_D:
  1481. start_isoc_chain(hw->fifos + HFCUSB_D_TX,
  1482. ISOC_PACKETS_B,
  1483. (usb_complete_t)tx_iso_complete, 1);
  1484. break;
  1485. case HFC_CHAN_B1:
  1486. start_isoc_chain(hw->fifos + HFCUSB_B1_TX,
  1487. ISOC_PACKETS_D,
  1488. (usb_complete_t)tx_iso_complete, 1);
  1489. break;
  1490. case HFC_CHAN_B2:
  1491. start_isoc_chain(hw->fifos + HFCUSB_B2_TX,
  1492. ISOC_PACKETS_B,
  1493. (usb_complete_t)tx_iso_complete, 1);
  1494. break;
  1495. }
  1496. }
  1497. /* stop USB data pipes dependand on device's endpoint configuration */
  1498. static void
  1499. hfcsusb_stop_endpoint(struct hfcsusb *hw, int channel)
  1500. {
  1501. /* quick check if endpoint currently running */
  1502. if ((channel == HFC_CHAN_D) && (!hw->fifos[HFCUSB_D_RX].active))
  1503. return;
  1504. if ((channel == HFC_CHAN_B1) && (!hw->fifos[HFCUSB_B1_RX].active))
  1505. return;
  1506. if ((channel == HFC_CHAN_B2) && (!hw->fifos[HFCUSB_B2_RX].active))
  1507. return;
  1508. if ((channel == HFC_CHAN_E) && (!hw->fifos[HFCUSB_PCM_RX].active))
  1509. return;
  1510. /* rx endpoints using USB INT IN method */
  1511. if (hw->cfg_used == CNF_3INT3ISO || hw->cfg_used == CNF_4INT3ISO)
  1512. stop_int_gracefull(hw->fifos + channel * 2 + 1);
  1513. /* rx endpoints using USB ISO IN method */
  1514. if (hw->cfg_used == CNF_3ISO3ISO || hw->cfg_used == CNF_4ISO3ISO)
  1515. stop_iso_gracefull(hw->fifos + channel * 2 + 1);
  1516. /* tx endpoints using USB ISO OUT method */
  1517. if (channel != HFC_CHAN_E)
  1518. stop_iso_gracefull(hw->fifos + channel * 2);
  1519. }
  1520. /* Hardware Initialization */
  1521. static int
  1522. setup_hfcsusb(struct hfcsusb *hw)
  1523. {
  1524. u_char b;
  1525. if (debug & DBG_HFC_CALL_TRACE)
  1526. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  1527. /* check the chip id */
  1528. if (read_reg_atomic(hw, HFCUSB_CHIP_ID, &b) != 1) {
  1529. printk(KERN_DEBUG "%s: %s: cannot read chip id\n",
  1530. hw->name, __func__);
  1531. return 1;
  1532. }
  1533. if (b != HFCUSB_CHIPID) {
  1534. printk(KERN_DEBUG "%s: %s: Invalid chip id 0x%02x\n",
  1535. hw->name, __func__, b);
  1536. return 1;
  1537. }
  1538. /* first set the needed config, interface and alternate */
  1539. (void) usb_set_interface(hw->dev, hw->if_used, hw->alt_used);
  1540. hw->led_state = 0;
  1541. /* init the background machinery for control requests */
  1542. hw->ctrl_read.bRequestType = 0xc0;
  1543. hw->ctrl_read.bRequest = 1;
  1544. hw->ctrl_read.wLength = cpu_to_le16(1);
  1545. hw->ctrl_write.bRequestType = 0x40;
  1546. hw->ctrl_write.bRequest = 0;
  1547. hw->ctrl_write.wLength = 0;
  1548. usb_fill_control_urb(hw->ctrl_urb, hw->dev, hw->ctrl_out_pipe,
  1549. (u_char *)&hw->ctrl_write, NULL, 0,
  1550. (usb_complete_t)ctrl_complete, hw);
  1551. reset_hfcsusb(hw);
  1552. return 0;
  1553. }
  1554. static void
  1555. release_hw(struct hfcsusb *hw)
  1556. {
  1557. if (debug & DBG_HFC_CALL_TRACE)
  1558. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  1559. /*
  1560. * stop all endpoints gracefully
  1561. * TODO: mISDN_core should generate CLOSE_CHANNEL
  1562. * signals after calling mISDN_unregister_device()
  1563. */
  1564. hfcsusb_stop_endpoint(hw, HFC_CHAN_D);
  1565. hfcsusb_stop_endpoint(hw, HFC_CHAN_B1);
  1566. hfcsusb_stop_endpoint(hw, HFC_CHAN_B2);
  1567. if (hw->fifos[HFCUSB_PCM_RX].pipe)
  1568. hfcsusb_stop_endpoint(hw, HFC_CHAN_E);
  1569. if (hw->protocol == ISDN_P_TE_S0)
  1570. l1_event(hw->dch.l1, CLOSE_CHANNEL);
  1571. mISDN_unregister_device(&hw->dch.dev);
  1572. mISDN_freebchannel(&hw->bch[1]);
  1573. mISDN_freebchannel(&hw->bch[0]);
  1574. mISDN_freedchannel(&hw->dch);
  1575. if (hw->ctrl_urb) {
  1576. usb_kill_urb(hw->ctrl_urb);
  1577. usb_free_urb(hw->ctrl_urb);
  1578. hw->ctrl_urb = NULL;
  1579. }
  1580. if (hw->intf)
  1581. usb_set_intfdata(hw->intf, NULL);
  1582. list_del(&hw->list);
  1583. kfree(hw);
  1584. hw = NULL;
  1585. }
  1586. static void
  1587. deactivate_bchannel(struct bchannel *bch)
  1588. {
  1589. struct hfcsusb *hw = bch->hw;
  1590. u_long flags;
  1591. if (bch->debug & DEBUG_HW)
  1592. printk(KERN_DEBUG "%s: %s: bch->nr(%i)\n",
  1593. hw->name, __func__, bch->nr);
  1594. spin_lock_irqsave(&hw->lock, flags);
  1595. mISDN_clear_bchannel(bch);
  1596. spin_unlock_irqrestore(&hw->lock, flags);
  1597. hfcsusb_setup_bch(bch, ISDN_P_NONE);
  1598. hfcsusb_stop_endpoint(hw, bch->nr - 1);
  1599. }
  1600. /*
  1601. * Layer 1 B-channel hardware access
  1602. */
  1603. static int
  1604. hfc_bctrl(struct mISDNchannel *ch, u_int cmd, void *arg)
  1605. {
  1606. struct bchannel *bch = container_of(ch, struct bchannel, ch);
  1607. int ret = -EINVAL;
  1608. if (bch->debug & DEBUG_HW)
  1609. printk(KERN_DEBUG "%s: cmd:%x %p\n", __func__, cmd, arg);
  1610. switch (cmd) {
  1611. case HW_TESTRX_RAW:
  1612. case HW_TESTRX_HDLC:
  1613. case HW_TESTRX_OFF:
  1614. ret = -EINVAL;
  1615. break;
  1616. case CLOSE_CHANNEL:
  1617. test_and_clear_bit(FLG_OPEN, &bch->Flags);
  1618. deactivate_bchannel(bch);
  1619. ch->protocol = ISDN_P_NONE;
  1620. ch->peer = NULL;
  1621. module_put(THIS_MODULE);
  1622. ret = 0;
  1623. break;
  1624. case CONTROL_CHANNEL:
  1625. ret = channel_bctrl(bch, arg);
  1626. break;
  1627. default:
  1628. printk(KERN_WARNING "%s: unknown prim(%x)\n",
  1629. __func__, cmd);
  1630. }
  1631. return ret;
  1632. }
  1633. static int
  1634. setup_instance(struct hfcsusb *hw, struct device *parent)
  1635. {
  1636. u_long flags;
  1637. int err, i;
  1638. if (debug & DBG_HFC_CALL_TRACE)
  1639. printk(KERN_DEBUG "%s: %s\n", hw->name, __func__);
  1640. spin_lock_init(&hw->ctrl_lock);
  1641. spin_lock_init(&hw->lock);
  1642. mISDN_initdchannel(&hw->dch, MAX_DFRAME_LEN_L1, ph_state);
  1643. hw->dch.debug = debug & 0xFFFF;
  1644. hw->dch.hw = hw;
  1645. hw->dch.dev.Dprotocols = (1 << ISDN_P_TE_S0) | (1 << ISDN_P_NT_S0);
  1646. hw->dch.dev.D.send = hfcusb_l2l1D;
  1647. hw->dch.dev.D.ctrl = hfc_dctrl;
  1648. /* enable E-Channel logging */
  1649. if (hw->fifos[HFCUSB_PCM_RX].pipe)
  1650. mISDN_initdchannel(&hw->ech, MAX_DFRAME_LEN_L1, NULL);
  1651. hw->dch.dev.Bprotocols = (1 << (ISDN_P_B_RAW & ISDN_P_B_MASK)) |
  1652. (1 << (ISDN_P_B_HDLC & ISDN_P_B_MASK));
  1653. hw->dch.dev.nrbchan = 2;
  1654. for (i = 0; i < 2; i++) {
  1655. hw->bch[i].nr = i + 1;
  1656. set_channelmap(i + 1, hw->dch.dev.channelmap);
  1657. hw->bch[i].debug = debug;
  1658. mISDN_initbchannel(&hw->bch[i], MAX_DATA_MEM, poll >> 1);
  1659. hw->bch[i].hw = hw;
  1660. hw->bch[i].ch.send = hfcusb_l2l1B;
  1661. hw->bch[i].ch.ctrl = hfc_bctrl;
  1662. hw->bch[i].ch.nr = i + 1;
  1663. list_add(&hw->bch[i].ch.list, &hw->dch.dev.bchannels);
  1664. }
  1665. hw->fifos[HFCUSB_B1_TX].bch = &hw->bch[0];
  1666. hw->fifos[HFCUSB_B1_RX].bch = &hw->bch[0];
  1667. hw->fifos[HFCUSB_B2_TX].bch = &hw->bch[1];
  1668. hw->fifos[HFCUSB_B2_RX].bch = &hw->bch[1];
  1669. hw->fifos[HFCUSB_D_TX].dch = &hw->dch;
  1670. hw->fifos[HFCUSB_D_RX].dch = &hw->dch;
  1671. hw->fifos[HFCUSB_PCM_RX].ech = &hw->ech;
  1672. hw->fifos[HFCUSB_PCM_TX].ech = &hw->ech;
  1673. err = setup_hfcsusb(hw);
  1674. if (err)
  1675. goto out;
  1676. snprintf(hw->name, MISDN_MAX_IDLEN - 1, "%s.%d", DRIVER_NAME,
  1677. hfcsusb_cnt + 1);
  1678. printk(KERN_INFO "%s: registered as '%s'\n",
  1679. DRIVER_NAME, hw->name);
  1680. err = mISDN_register_device(&hw->dch.dev, parent, hw->name);
  1681. if (err)
  1682. goto out;
  1683. hfcsusb_cnt++;
  1684. write_lock_irqsave(&HFClock, flags);
  1685. list_add_tail(&hw->list, &HFClist);
  1686. write_unlock_irqrestore(&HFClock, flags);
  1687. return 0;
  1688. out:
  1689. mISDN_freebchannel(&hw->bch[1]);
  1690. mISDN_freebchannel(&hw->bch[0]);
  1691. mISDN_freedchannel(&hw->dch);
  1692. kfree(hw);
  1693. return err;
  1694. }
  1695. static int
  1696. hfcsusb_probe(struct usb_interface *intf, const struct usb_device_id *id)
  1697. {
  1698. struct hfcsusb *hw;
  1699. struct usb_device *dev = interface_to_usbdev(intf);
  1700. struct usb_host_interface *iface = intf->cur_altsetting;
  1701. struct usb_host_interface *iface_used = NULL;
  1702. struct usb_host_endpoint *ep;
  1703. struct hfcsusb_vdata *driver_info;
  1704. int ifnum = iface->desc.bInterfaceNumber, i, idx, alt_idx,
  1705. probe_alt_setting, vend_idx, cfg_used, *vcf, attr, cfg_found,
  1706. ep_addr, cmptbl[16], small_match, iso_packet_size, packet_size,
  1707. alt_used = 0;
  1708. vend_idx = 0xffff;
  1709. for (i = 0; hfcsusb_idtab[i].idVendor; i++) {
  1710. if ((le16_to_cpu(dev->descriptor.idVendor)
  1711. == hfcsusb_idtab[i].idVendor) &&
  1712. (le16_to_cpu(dev->descriptor.idProduct)
  1713. == hfcsusb_idtab[i].idProduct)) {
  1714. vend_idx = i;
  1715. continue;
  1716. }
  1717. }
  1718. printk(KERN_DEBUG
  1719. "%s: interface(%d) actalt(%d) minor(%d) vend_idx(%d)\n",
  1720. __func__, ifnum, iface->desc.bAlternateSetting,
  1721. intf->minor, vend_idx);
  1722. if (vend_idx == 0xffff) {
  1723. printk(KERN_WARNING
  1724. "%s: no valid vendor found in USB descriptor\n",
  1725. __func__);
  1726. return -EIO;
  1727. }
  1728. /* if vendor and product ID is OK, start probing alternate settings */
  1729. alt_idx = 0;
  1730. small_match = -1;
  1731. /* default settings */
  1732. iso_packet_size = 16;
  1733. packet_size = 64;
  1734. while (alt_idx < intf->num_altsetting) {
  1735. iface = intf->altsetting + alt_idx;
  1736. probe_alt_setting = iface->desc.bAlternateSetting;
  1737. cfg_used = 0;
  1738. while (validconf[cfg_used][0]) {
  1739. cfg_found = 1;
  1740. vcf = validconf[cfg_used];
  1741. ep = iface->endpoint;
  1742. memcpy(cmptbl, vcf, 16 * sizeof(int));
  1743. /* check for all endpoints in this alternate setting */
  1744. for (i = 0; i < iface->desc.bNumEndpoints; i++) {
  1745. ep_addr = ep->desc.bEndpointAddress;
  1746. /* get endpoint base */
  1747. idx = ((ep_addr & 0x7f) - 1) * 2;
  1748. if (ep_addr & 0x80)
  1749. idx++;
  1750. attr = ep->desc.bmAttributes;
  1751. if (cmptbl[idx] != EP_NOP) {
  1752. if (cmptbl[idx] == EP_NUL)
  1753. cfg_found = 0;
  1754. if (attr == USB_ENDPOINT_XFER_INT
  1755. && cmptbl[idx] == EP_INT)
  1756. cmptbl[idx] = EP_NUL;
  1757. if (attr == USB_ENDPOINT_XFER_BULK
  1758. && cmptbl[idx] == EP_BLK)
  1759. cmptbl[idx] = EP_NUL;
  1760. if (attr == USB_ENDPOINT_XFER_ISOC
  1761. && cmptbl[idx] == EP_ISO)
  1762. cmptbl[idx] = EP_NUL;
  1763. if (attr == USB_ENDPOINT_XFER_INT &&
  1764. ep->desc.bInterval < vcf[17]) {
  1765. cfg_found = 0;
  1766. }
  1767. }
  1768. ep++;
  1769. }
  1770. for (i = 0; i < 16; i++)
  1771. if (cmptbl[i] != EP_NOP && cmptbl[i] != EP_NUL)
  1772. cfg_found = 0;
  1773. if (cfg_found) {
  1774. if (small_match < cfg_used) {
  1775. small_match = cfg_used;
  1776. alt_used = probe_alt_setting;
  1777. iface_used = iface;
  1778. }
  1779. }
  1780. cfg_used++;
  1781. }
  1782. alt_idx++;
  1783. } /* (alt_idx < intf->num_altsetting) */
  1784. /* not found a valid USB Ta Endpoint config */
  1785. if (small_match == -1)
  1786. return -EIO;
  1787. iface = iface_used;
  1788. hw = kzalloc(sizeof(struct hfcsusb), GFP_KERNEL);
  1789. if (!hw)
  1790. return -ENOMEM; /* got no mem */
  1791. snprintf(hw->name, MISDN_MAX_IDLEN - 1, "%s", DRIVER_NAME);
  1792. ep = iface->endpoint;
  1793. vcf = validconf[small_match];
  1794. for (i = 0; i < iface->desc.bNumEndpoints; i++) {
  1795. struct usb_fifo *f;
  1796. ep_addr = ep->desc.bEndpointAddress;
  1797. /* get endpoint base */
  1798. idx = ((ep_addr & 0x7f) - 1) * 2;
  1799. if (ep_addr & 0x80)
  1800. idx++;
  1801. f = &hw->fifos[idx & 7];
  1802. /* init Endpoints */
  1803. if (vcf[idx] == EP_NOP || vcf[idx] == EP_NUL) {
  1804. ep++;
  1805. continue;
  1806. }
  1807. switch (ep->desc.bmAttributes) {
  1808. case USB_ENDPOINT_XFER_INT:
  1809. f->pipe = usb_rcvintpipe(dev,
  1810. ep->desc.bEndpointAddress);
  1811. f->usb_transfer_mode = USB_INT;
  1812. packet_size = le16_to_cpu(ep->desc.wMaxPacketSize);
  1813. break;
  1814. case USB_ENDPOINT_XFER_BULK:
  1815. if (ep_addr & 0x80)
  1816. f->pipe = usb_rcvbulkpipe(dev,
  1817. ep->desc.bEndpointAddress);
  1818. else
  1819. f->pipe = usb_sndbulkpipe(dev,
  1820. ep->desc.bEndpointAddress);
  1821. f->usb_transfer_mode = USB_BULK;
  1822. packet_size = le16_to_cpu(ep->desc.wMaxPacketSize);
  1823. break;
  1824. case USB_ENDPOINT_XFER_ISOC:
  1825. if (ep_addr & 0x80)
  1826. f->pipe = usb_rcvisocpipe(dev,
  1827. ep->desc.bEndpointAddress);
  1828. else
  1829. f->pipe = usb_sndisocpipe(dev,
  1830. ep->desc.bEndpointAddress);
  1831. f->usb_transfer_mode = USB_ISOC;
  1832. iso_packet_size = le16_to_cpu(ep->desc.wMaxPacketSize);
  1833. break;
  1834. default:
  1835. f->pipe = 0;
  1836. }
  1837. if (f->pipe) {
  1838. f->fifonum = idx & 7;
  1839. f->hw = hw;
  1840. f->usb_packet_maxlen =
  1841. le16_to_cpu(ep->desc.wMaxPacketSize);
  1842. f->intervall = ep->desc.bInterval;
  1843. }
  1844. ep++;
  1845. }
  1846. hw->dev = dev; /* save device */
  1847. hw->if_used = ifnum; /* save used interface */
  1848. hw->alt_used = alt_used; /* and alternate config */
  1849. hw->ctrl_paksize = dev->descriptor.bMaxPacketSize0; /* control size */
  1850. hw->cfg_used = vcf[16]; /* store used config */
  1851. hw->vend_idx = vend_idx; /* store found vendor */
  1852. hw->packet_size = packet_size;
  1853. hw->iso_packet_size = iso_packet_size;
  1854. /* create the control pipes needed for register access */
  1855. hw->ctrl_in_pipe = usb_rcvctrlpipe(hw->dev, 0);
  1856. hw->ctrl_out_pipe = usb_sndctrlpipe(hw->dev, 0);
  1857. hw->ctrl_urb = usb_alloc_urb(0, GFP_KERNEL);
  1858. driver_info =
  1859. (struct hfcsusb_vdata *)hfcsusb_idtab[vend_idx].driver_info;
  1860. printk(KERN_DEBUG "%s: %s: detected \"%s\" (%s, if=%d alt=%d)\n",
  1861. hw->name, __func__, driver_info->vend_name,
  1862. conf_str[small_match], ifnum, alt_used);
  1863. if (setup_instance(hw, dev->dev.parent))
  1864. return -EIO;
  1865. hw->intf = intf;
  1866. usb_set_intfdata(hw->intf, hw);
  1867. return 0;
  1868. }
  1869. /* function called when an active device is removed */
  1870. static void
  1871. hfcsusb_disconnect(struct usb_interface *intf)
  1872. {
  1873. struct hfcsusb *hw = usb_get_intfdata(intf);
  1874. struct hfcsusb *next;
  1875. int cnt = 0;
  1876. printk(KERN_INFO "%s: device disconnected\n", hw->name);
  1877. handle_led(hw, LED_POWER_OFF);
  1878. release_hw(hw);
  1879. list_for_each_entry_safe(hw, next, &HFClist, list)
  1880. cnt++;
  1881. if (!cnt)
  1882. hfcsusb_cnt = 0;
  1883. usb_set_intfdata(intf, NULL);
  1884. }
  1885. static struct usb_driver hfcsusb_drv = {
  1886. .name = DRIVER_NAME,
  1887. .id_table = hfcsusb_idtab,
  1888. .probe = hfcsusb_probe,
  1889. .disconnect = hfcsusb_disconnect,
  1890. };
  1891. module_usb_driver(hfcsusb_drv);