ctdaio.c 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. /**
  2. * Copyright (C) 2008, Creative Technology Ltd. All Rights Reserved.
  3. *
  4. * This source file is released under GPL v2 license (no other versions).
  5. * See the COPYING file included in the main directory of this source
  6. * distribution for the license terms and conditions.
  7. *
  8. * @File ctdaio.c
  9. *
  10. * @Brief
  11. * This file contains the implementation of Digital Audio Input Output
  12. * resource management object.
  13. *
  14. * @Author Liu Chun
  15. * @Date May 23 2008
  16. *
  17. */
  18. #include "ctdaio.h"
  19. #include "cthardware.h"
  20. #include "ctimap.h"
  21. #include <linux/slab.h>
  22. #include <linux/kernel.h>
  23. #define DAIO_OUT_MAX SPDIFOO
  24. struct daio_usage {
  25. unsigned short data;
  26. };
  27. struct daio_rsc_idx {
  28. unsigned short left;
  29. unsigned short right;
  30. };
  31. struct daio_rsc_idx idx_20k1[NUM_DAIOTYP] = {
  32. [LINEO1] = {.left = 0x00, .right = 0x01},
  33. [LINEO2] = {.left = 0x18, .right = 0x19},
  34. [LINEO3] = {.left = 0x08, .right = 0x09},
  35. [LINEO4] = {.left = 0x10, .right = 0x11},
  36. [LINEIM] = {.left = 0x1b5, .right = 0x1bd},
  37. [SPDIFOO] = {.left = 0x20, .right = 0x21},
  38. [SPDIFIO] = {.left = 0x15, .right = 0x1d},
  39. [SPDIFI1] = {.left = 0x95, .right = 0x9d},
  40. };
  41. struct daio_rsc_idx idx_20k2[NUM_DAIOTYP] = {
  42. [LINEO1] = {.left = 0x40, .right = 0x41},
  43. [LINEO2] = {.left = 0x60, .right = 0x61},
  44. [LINEO3] = {.left = 0x50, .right = 0x51},
  45. [LINEO4] = {.left = 0x70, .right = 0x71},
  46. [LINEIM] = {.left = 0x45, .right = 0xc5},
  47. [MIC] = {.left = 0x55, .right = 0xd5},
  48. [SPDIFOO] = {.left = 0x00, .right = 0x01},
  49. [SPDIFIO] = {.left = 0x05, .right = 0x85},
  50. };
  51. static int daio_master(struct rsc *rsc)
  52. {
  53. /* Actually, this is not the resource index of DAIO.
  54. * For DAO, it is the input mapper index. And, for DAI,
  55. * it is the output time-slot index. */
  56. return rsc->conj = rsc->idx;
  57. }
  58. static int daio_index(const struct rsc *rsc)
  59. {
  60. return rsc->conj;
  61. }
  62. static int daio_out_next_conj(struct rsc *rsc)
  63. {
  64. return rsc->conj += 2;
  65. }
  66. static int daio_in_next_conj_20k1(struct rsc *rsc)
  67. {
  68. return rsc->conj += 0x200;
  69. }
  70. static int daio_in_next_conj_20k2(struct rsc *rsc)
  71. {
  72. return rsc->conj += 0x100;
  73. }
  74. static struct rsc_ops daio_out_rsc_ops = {
  75. .master = daio_master,
  76. .next_conj = daio_out_next_conj,
  77. .index = daio_index,
  78. .output_slot = NULL,
  79. };
  80. static struct rsc_ops daio_in_rsc_ops_20k1 = {
  81. .master = daio_master,
  82. .next_conj = daio_in_next_conj_20k1,
  83. .index = NULL,
  84. .output_slot = daio_index,
  85. };
  86. static struct rsc_ops daio_in_rsc_ops_20k2 = {
  87. .master = daio_master,
  88. .next_conj = daio_in_next_conj_20k2,
  89. .index = NULL,
  90. .output_slot = daio_index,
  91. };
  92. static unsigned int daio_device_index(enum DAIOTYP type, struct hw *hw)
  93. {
  94. switch (hw->chip_type) {
  95. case ATC20K1:
  96. switch (type) {
  97. case SPDIFOO: return 0;
  98. case SPDIFIO: return 0;
  99. case SPDIFI1: return 1;
  100. case LINEO1: return 4;
  101. case LINEO2: return 7;
  102. case LINEO3: return 5;
  103. case LINEO4: return 6;
  104. case LINEIM: return 7;
  105. default: return -EINVAL;
  106. }
  107. case ATC20K2:
  108. switch (type) {
  109. case SPDIFOO: return 0;
  110. case SPDIFIO: return 0;
  111. case LINEO1: return 4;
  112. case LINEO2: return 7;
  113. case LINEO3: return 5;
  114. case LINEO4: return 6;
  115. case LINEIM: return 4;
  116. case MIC: return 5;
  117. default: return -EINVAL;
  118. }
  119. default:
  120. return -EINVAL;
  121. }
  122. }
  123. static int dao_rsc_reinit(struct dao *dao, const struct dao_desc *desc);
  124. static int dao_spdif_get_spos(struct dao *dao, unsigned int *spos)
  125. {
  126. ((struct hw *)dao->hw)->dao_get_spos(dao->ctrl_blk, spos);
  127. return 0;
  128. }
  129. static int dao_spdif_set_spos(struct dao *dao, unsigned int spos)
  130. {
  131. ((struct hw *)dao->hw)->dao_set_spos(dao->ctrl_blk, spos);
  132. return 0;
  133. }
  134. static int dao_commit_write(struct dao *dao)
  135. {
  136. ((struct hw *)dao->hw)->dao_commit_write(dao->hw,
  137. daio_device_index(dao->daio.type, dao->hw), dao->ctrl_blk);
  138. return 0;
  139. }
  140. static int dao_set_left_input(struct dao *dao, struct rsc *input)
  141. {
  142. struct imapper *entry;
  143. struct daio *daio = &dao->daio;
  144. int i;
  145. entry = kzalloc((sizeof(*entry) * daio->rscl.msr), GFP_KERNEL);
  146. if (!entry)
  147. return -ENOMEM;
  148. dao->ops->clear_left_input(dao);
  149. /* Program master and conjugate resources */
  150. input->ops->master(input);
  151. daio->rscl.ops->master(&daio->rscl);
  152. for (i = 0; i < daio->rscl.msr; i++, entry++) {
  153. entry->slot = input->ops->output_slot(input);
  154. entry->user = entry->addr = daio->rscl.ops->index(&daio->rscl);
  155. dao->mgr->imap_add(dao->mgr, entry);
  156. dao->imappers[i] = entry;
  157. input->ops->next_conj(input);
  158. daio->rscl.ops->next_conj(&daio->rscl);
  159. }
  160. input->ops->master(input);
  161. daio->rscl.ops->master(&daio->rscl);
  162. return 0;
  163. }
  164. static int dao_set_right_input(struct dao *dao, struct rsc *input)
  165. {
  166. struct imapper *entry;
  167. struct daio *daio = &dao->daio;
  168. int i;
  169. entry = kzalloc((sizeof(*entry) * daio->rscr.msr), GFP_KERNEL);
  170. if (!entry)
  171. return -ENOMEM;
  172. dao->ops->clear_right_input(dao);
  173. /* Program master and conjugate resources */
  174. input->ops->master(input);
  175. daio->rscr.ops->master(&daio->rscr);
  176. for (i = 0; i < daio->rscr.msr; i++, entry++) {
  177. entry->slot = input->ops->output_slot(input);
  178. entry->user = entry->addr = daio->rscr.ops->index(&daio->rscr);
  179. dao->mgr->imap_add(dao->mgr, entry);
  180. dao->imappers[daio->rscl.msr + i] = entry;
  181. input->ops->next_conj(input);
  182. daio->rscr.ops->next_conj(&daio->rscr);
  183. }
  184. input->ops->master(input);
  185. daio->rscr.ops->master(&daio->rscr);
  186. return 0;
  187. }
  188. static int dao_clear_left_input(struct dao *dao)
  189. {
  190. struct imapper *entry;
  191. struct daio *daio = &dao->daio;
  192. int i;
  193. if (!dao->imappers[0])
  194. return 0;
  195. entry = dao->imappers[0];
  196. dao->mgr->imap_delete(dao->mgr, entry);
  197. /* Program conjugate resources */
  198. for (i = 1; i < daio->rscl.msr; i++) {
  199. entry = dao->imappers[i];
  200. dao->mgr->imap_delete(dao->mgr, entry);
  201. dao->imappers[i] = NULL;
  202. }
  203. kfree(dao->imappers[0]);
  204. dao->imappers[0] = NULL;
  205. return 0;
  206. }
  207. static int dao_clear_right_input(struct dao *dao)
  208. {
  209. struct imapper *entry;
  210. struct daio *daio = &dao->daio;
  211. int i;
  212. if (!dao->imappers[daio->rscl.msr])
  213. return 0;
  214. entry = dao->imappers[daio->rscl.msr];
  215. dao->mgr->imap_delete(dao->mgr, entry);
  216. /* Program conjugate resources */
  217. for (i = 1; i < daio->rscr.msr; i++) {
  218. entry = dao->imappers[daio->rscl.msr + i];
  219. dao->mgr->imap_delete(dao->mgr, entry);
  220. dao->imappers[daio->rscl.msr + i] = NULL;
  221. }
  222. kfree(dao->imappers[daio->rscl.msr]);
  223. dao->imappers[daio->rscl.msr] = NULL;
  224. return 0;
  225. }
  226. static struct dao_rsc_ops dao_ops = {
  227. .set_spos = dao_spdif_set_spos,
  228. .commit_write = dao_commit_write,
  229. .get_spos = dao_spdif_get_spos,
  230. .reinit = dao_rsc_reinit,
  231. .set_left_input = dao_set_left_input,
  232. .set_right_input = dao_set_right_input,
  233. .clear_left_input = dao_clear_left_input,
  234. .clear_right_input = dao_clear_right_input,
  235. };
  236. static int dai_set_srt_srcl(struct dai *dai, struct rsc *src)
  237. {
  238. src->ops->master(src);
  239. ((struct hw *)dai->hw)->dai_srt_set_srcm(dai->ctrl_blk,
  240. src->ops->index(src));
  241. return 0;
  242. }
  243. static int dai_set_srt_srcr(struct dai *dai, struct rsc *src)
  244. {
  245. src->ops->master(src);
  246. ((struct hw *)dai->hw)->dai_srt_set_srco(dai->ctrl_blk,
  247. src->ops->index(src));
  248. return 0;
  249. }
  250. static int dai_set_srt_msr(struct dai *dai, unsigned int msr)
  251. {
  252. unsigned int rsr;
  253. for (rsr = 0; msr > 1; msr >>= 1)
  254. rsr++;
  255. ((struct hw *)dai->hw)->dai_srt_set_rsr(dai->ctrl_blk, rsr);
  256. return 0;
  257. }
  258. static int dai_set_enb_src(struct dai *dai, unsigned int enb)
  259. {
  260. ((struct hw *)dai->hw)->dai_srt_set_ec(dai->ctrl_blk, enb);
  261. return 0;
  262. }
  263. static int dai_set_enb_srt(struct dai *dai, unsigned int enb)
  264. {
  265. ((struct hw *)dai->hw)->dai_srt_set_et(dai->ctrl_blk, enb);
  266. return 0;
  267. }
  268. static int dai_commit_write(struct dai *dai)
  269. {
  270. ((struct hw *)dai->hw)->dai_commit_write(dai->hw,
  271. daio_device_index(dai->daio.type, dai->hw), dai->ctrl_blk);
  272. return 0;
  273. }
  274. static struct dai_rsc_ops dai_ops = {
  275. .set_srt_srcl = dai_set_srt_srcl,
  276. .set_srt_srcr = dai_set_srt_srcr,
  277. .set_srt_msr = dai_set_srt_msr,
  278. .set_enb_src = dai_set_enb_src,
  279. .set_enb_srt = dai_set_enb_srt,
  280. .commit_write = dai_commit_write,
  281. };
  282. static int daio_rsc_init(struct daio *daio,
  283. const struct daio_desc *desc,
  284. void *hw)
  285. {
  286. int err;
  287. unsigned int idx_l, idx_r;
  288. switch (((struct hw *)hw)->chip_type) {
  289. case ATC20K1:
  290. idx_l = idx_20k1[desc->type].left;
  291. idx_r = idx_20k1[desc->type].right;
  292. break;
  293. case ATC20K2:
  294. idx_l = idx_20k2[desc->type].left;
  295. idx_r = idx_20k2[desc->type].right;
  296. break;
  297. default:
  298. return -EINVAL;
  299. }
  300. err = rsc_init(&daio->rscl, idx_l, DAIO, desc->msr, hw);
  301. if (err)
  302. return err;
  303. err = rsc_init(&daio->rscr, idx_r, DAIO, desc->msr, hw);
  304. if (err)
  305. goto error1;
  306. /* Set daio->rscl/r->ops to daio specific ones */
  307. if (desc->type <= DAIO_OUT_MAX) {
  308. daio->rscl.ops = daio->rscr.ops = &daio_out_rsc_ops;
  309. } else {
  310. switch (((struct hw *)hw)->chip_type) {
  311. case ATC20K1:
  312. daio->rscl.ops = daio->rscr.ops = &daio_in_rsc_ops_20k1;
  313. break;
  314. case ATC20K2:
  315. daio->rscl.ops = daio->rscr.ops = &daio_in_rsc_ops_20k2;
  316. break;
  317. default:
  318. break;
  319. }
  320. }
  321. daio->type = desc->type;
  322. return 0;
  323. error1:
  324. rsc_uninit(&daio->rscl);
  325. return err;
  326. }
  327. static int daio_rsc_uninit(struct daio *daio)
  328. {
  329. rsc_uninit(&daio->rscl);
  330. rsc_uninit(&daio->rscr);
  331. return 0;
  332. }
  333. static int dao_rsc_init(struct dao *dao,
  334. const struct daio_desc *desc,
  335. struct daio_mgr *mgr)
  336. {
  337. struct hw *hw = mgr->mgr.hw;
  338. unsigned int conf;
  339. int err;
  340. err = daio_rsc_init(&dao->daio, desc, mgr->mgr.hw);
  341. if (err)
  342. return err;
  343. dao->imappers = kzalloc(sizeof(void *)*desc->msr*2, GFP_KERNEL);
  344. if (!dao->imappers) {
  345. err = -ENOMEM;
  346. goto error1;
  347. }
  348. dao->ops = &dao_ops;
  349. dao->mgr = mgr;
  350. dao->hw = hw;
  351. err = hw->dao_get_ctrl_blk(&dao->ctrl_blk);
  352. if (err)
  353. goto error2;
  354. hw->daio_mgr_dsb_dao(mgr->mgr.ctrl_blk,
  355. daio_device_index(dao->daio.type, hw));
  356. hw->daio_mgr_commit_write(hw, mgr->mgr.ctrl_blk);
  357. conf = (desc->msr & 0x7) | (desc->passthru << 3);
  358. hw->daio_mgr_dao_init(mgr->mgr.ctrl_blk,
  359. daio_device_index(dao->daio.type, hw), conf);
  360. hw->daio_mgr_enb_dao(mgr->mgr.ctrl_blk,
  361. daio_device_index(dao->daio.type, hw));
  362. hw->daio_mgr_commit_write(hw, mgr->mgr.ctrl_blk);
  363. return 0;
  364. error2:
  365. kfree(dao->imappers);
  366. dao->imappers = NULL;
  367. error1:
  368. daio_rsc_uninit(&dao->daio);
  369. return err;
  370. }
  371. static int dao_rsc_uninit(struct dao *dao)
  372. {
  373. if (dao->imappers) {
  374. if (dao->imappers[0])
  375. dao_clear_left_input(dao);
  376. if (dao->imappers[dao->daio.rscl.msr])
  377. dao_clear_right_input(dao);
  378. kfree(dao->imappers);
  379. dao->imappers = NULL;
  380. }
  381. ((struct hw *)dao->hw)->dao_put_ctrl_blk(dao->ctrl_blk);
  382. dao->hw = dao->ctrl_blk = NULL;
  383. daio_rsc_uninit(&dao->daio);
  384. return 0;
  385. }
  386. static int dao_rsc_reinit(struct dao *dao, const struct dao_desc *desc)
  387. {
  388. struct daio_mgr *mgr = dao->mgr;
  389. struct daio_desc dsc = {0};
  390. dsc.type = dao->daio.type;
  391. dsc.msr = desc->msr;
  392. dsc.passthru = desc->passthru;
  393. dao_rsc_uninit(dao);
  394. return dao_rsc_init(dao, &dsc, mgr);
  395. }
  396. static int dai_rsc_init(struct dai *dai,
  397. const struct daio_desc *desc,
  398. struct daio_mgr *mgr)
  399. {
  400. int err;
  401. struct hw *hw = mgr->mgr.hw;
  402. unsigned int rsr, msr;
  403. err = daio_rsc_init(&dai->daio, desc, mgr->mgr.hw);
  404. if (err)
  405. return err;
  406. dai->ops = &dai_ops;
  407. dai->hw = mgr->mgr.hw;
  408. err = hw->dai_get_ctrl_blk(&dai->ctrl_blk);
  409. if (err)
  410. goto error1;
  411. for (rsr = 0, msr = desc->msr; msr > 1; msr >>= 1)
  412. rsr++;
  413. hw->dai_srt_set_rsr(dai->ctrl_blk, rsr);
  414. hw->dai_srt_set_drat(dai->ctrl_blk, 0);
  415. /* default to disabling control of a SRC */
  416. hw->dai_srt_set_ec(dai->ctrl_blk, 0);
  417. hw->dai_srt_set_et(dai->ctrl_blk, 0); /* default to disabling SRT */
  418. hw->dai_commit_write(hw,
  419. daio_device_index(dai->daio.type, dai->hw), dai->ctrl_blk);
  420. return 0;
  421. error1:
  422. daio_rsc_uninit(&dai->daio);
  423. return err;
  424. }
  425. static int dai_rsc_uninit(struct dai *dai)
  426. {
  427. ((struct hw *)dai->hw)->dai_put_ctrl_blk(dai->ctrl_blk);
  428. dai->hw = dai->ctrl_blk = NULL;
  429. daio_rsc_uninit(&dai->daio);
  430. return 0;
  431. }
  432. static int daio_mgr_get_rsc(struct rsc_mgr *mgr, enum DAIOTYP type)
  433. {
  434. if (((struct daio_usage *)mgr->rscs)->data & (0x1 << type))
  435. return -ENOENT;
  436. ((struct daio_usage *)mgr->rscs)->data |= (0x1 << type);
  437. return 0;
  438. }
  439. static int daio_mgr_put_rsc(struct rsc_mgr *mgr, enum DAIOTYP type)
  440. {
  441. ((struct daio_usage *)mgr->rscs)->data &= ~(0x1 << type);
  442. return 0;
  443. }
  444. static int get_daio_rsc(struct daio_mgr *mgr,
  445. const struct daio_desc *desc,
  446. struct daio **rdaio)
  447. {
  448. int err;
  449. struct dai *dai = NULL;
  450. struct dao *dao = NULL;
  451. unsigned long flags;
  452. *rdaio = NULL;
  453. /* Check whether there are sufficient daio resources to meet request. */
  454. spin_lock_irqsave(&mgr->mgr_lock, flags);
  455. err = daio_mgr_get_rsc(&mgr->mgr, desc->type);
  456. spin_unlock_irqrestore(&mgr->mgr_lock, flags);
  457. if (err) {
  458. printk(KERN_ERR "Can't meet DAIO resource request!\n");
  459. return err;
  460. }
  461. /* Allocate mem for daio resource */
  462. if (desc->type <= DAIO_OUT_MAX) {
  463. dao = kzalloc(sizeof(*dao), GFP_KERNEL);
  464. if (!dao) {
  465. err = -ENOMEM;
  466. goto error;
  467. }
  468. err = dao_rsc_init(dao, desc, mgr);
  469. if (err)
  470. goto error;
  471. *rdaio = &dao->daio;
  472. } else {
  473. dai = kzalloc(sizeof(*dai), GFP_KERNEL);
  474. if (!dai) {
  475. err = -ENOMEM;
  476. goto error;
  477. }
  478. err = dai_rsc_init(dai, desc, mgr);
  479. if (err)
  480. goto error;
  481. *rdaio = &dai->daio;
  482. }
  483. mgr->daio_enable(mgr, *rdaio);
  484. mgr->commit_write(mgr);
  485. return 0;
  486. error:
  487. if (dao)
  488. kfree(dao);
  489. else if (dai)
  490. kfree(dai);
  491. spin_lock_irqsave(&mgr->mgr_lock, flags);
  492. daio_mgr_put_rsc(&mgr->mgr, desc->type);
  493. spin_unlock_irqrestore(&mgr->mgr_lock, flags);
  494. return err;
  495. }
  496. static int put_daio_rsc(struct daio_mgr *mgr, struct daio *daio)
  497. {
  498. unsigned long flags;
  499. mgr->daio_disable(mgr, daio);
  500. mgr->commit_write(mgr);
  501. spin_lock_irqsave(&mgr->mgr_lock, flags);
  502. daio_mgr_put_rsc(&mgr->mgr, daio->type);
  503. spin_unlock_irqrestore(&mgr->mgr_lock, flags);
  504. if (daio->type <= DAIO_OUT_MAX) {
  505. dao_rsc_uninit(container_of(daio, struct dao, daio));
  506. kfree(container_of(daio, struct dao, daio));
  507. } else {
  508. dai_rsc_uninit(container_of(daio, struct dai, daio));
  509. kfree(container_of(daio, struct dai, daio));
  510. }
  511. return 0;
  512. }
  513. static int daio_mgr_enb_daio(struct daio_mgr *mgr, struct daio *daio)
  514. {
  515. struct hw *hw = mgr->mgr.hw;
  516. if (DAIO_OUT_MAX >= daio->type) {
  517. hw->daio_mgr_enb_dao(mgr->mgr.ctrl_blk,
  518. daio_device_index(daio->type, hw));
  519. } else {
  520. hw->daio_mgr_enb_dai(mgr->mgr.ctrl_blk,
  521. daio_device_index(daio->type, hw));
  522. }
  523. return 0;
  524. }
  525. static int daio_mgr_dsb_daio(struct daio_mgr *mgr, struct daio *daio)
  526. {
  527. struct hw *hw = mgr->mgr.hw;
  528. if (DAIO_OUT_MAX >= daio->type) {
  529. hw->daio_mgr_dsb_dao(mgr->mgr.ctrl_blk,
  530. daio_device_index(daio->type, hw));
  531. } else {
  532. hw->daio_mgr_dsb_dai(mgr->mgr.ctrl_blk,
  533. daio_device_index(daio->type, hw));
  534. }
  535. return 0;
  536. }
  537. static int daio_map_op(void *data, struct imapper *entry)
  538. {
  539. struct rsc_mgr *mgr = &((struct daio_mgr *)data)->mgr;
  540. struct hw *hw = mgr->hw;
  541. hw->daio_mgr_set_imaparc(mgr->ctrl_blk, entry->slot);
  542. hw->daio_mgr_set_imapnxt(mgr->ctrl_blk, entry->next);
  543. hw->daio_mgr_set_imapaddr(mgr->ctrl_blk, entry->addr);
  544. hw->daio_mgr_commit_write(mgr->hw, mgr->ctrl_blk);
  545. return 0;
  546. }
  547. static int daio_imap_add(struct daio_mgr *mgr, struct imapper *entry)
  548. {
  549. unsigned long flags;
  550. int err;
  551. spin_lock_irqsave(&mgr->imap_lock, flags);
  552. if (!entry->addr && mgr->init_imap_added) {
  553. input_mapper_delete(&mgr->imappers, mgr->init_imap,
  554. daio_map_op, mgr);
  555. mgr->init_imap_added = 0;
  556. }
  557. err = input_mapper_add(&mgr->imappers, entry, daio_map_op, mgr);
  558. spin_unlock_irqrestore(&mgr->imap_lock, flags);
  559. return err;
  560. }
  561. static int daio_imap_delete(struct daio_mgr *mgr, struct imapper *entry)
  562. {
  563. unsigned long flags;
  564. int err;
  565. spin_lock_irqsave(&mgr->imap_lock, flags);
  566. err = input_mapper_delete(&mgr->imappers, entry, daio_map_op, mgr);
  567. if (list_empty(&mgr->imappers)) {
  568. input_mapper_add(&mgr->imappers, mgr->init_imap,
  569. daio_map_op, mgr);
  570. mgr->init_imap_added = 1;
  571. }
  572. spin_unlock_irqrestore(&mgr->imap_lock, flags);
  573. return err;
  574. }
  575. static int daio_mgr_commit_write(struct daio_mgr *mgr)
  576. {
  577. struct hw *hw = mgr->mgr.hw;
  578. hw->daio_mgr_commit_write(hw, mgr->mgr.ctrl_blk);
  579. return 0;
  580. }
  581. int daio_mgr_create(void *hw, struct daio_mgr **rdaio_mgr)
  582. {
  583. int err, i;
  584. struct daio_mgr *daio_mgr;
  585. struct imapper *entry;
  586. *rdaio_mgr = NULL;
  587. daio_mgr = kzalloc(sizeof(*daio_mgr), GFP_KERNEL);
  588. if (!daio_mgr)
  589. return -ENOMEM;
  590. err = rsc_mgr_init(&daio_mgr->mgr, DAIO, NUM_DAIOTYP, hw);
  591. if (err)
  592. goto error1;
  593. spin_lock_init(&daio_mgr->mgr_lock);
  594. spin_lock_init(&daio_mgr->imap_lock);
  595. INIT_LIST_HEAD(&daio_mgr->imappers);
  596. entry = kzalloc(sizeof(*entry), GFP_KERNEL);
  597. if (!entry) {
  598. err = -ENOMEM;
  599. goto error2;
  600. }
  601. entry->slot = entry->addr = entry->next = entry->user = 0;
  602. list_add(&entry->list, &daio_mgr->imappers);
  603. daio_mgr->init_imap = entry;
  604. daio_mgr->init_imap_added = 1;
  605. daio_mgr->get_daio = get_daio_rsc;
  606. daio_mgr->put_daio = put_daio_rsc;
  607. daio_mgr->daio_enable = daio_mgr_enb_daio;
  608. daio_mgr->daio_disable = daio_mgr_dsb_daio;
  609. daio_mgr->imap_add = daio_imap_add;
  610. daio_mgr->imap_delete = daio_imap_delete;
  611. daio_mgr->commit_write = daio_mgr_commit_write;
  612. for (i = 0; i < 8; i++) {
  613. ((struct hw *)hw)->daio_mgr_dsb_dao(daio_mgr->mgr.ctrl_blk, i);
  614. ((struct hw *)hw)->daio_mgr_dsb_dai(daio_mgr->mgr.ctrl_blk, i);
  615. }
  616. ((struct hw *)hw)->daio_mgr_commit_write(hw, daio_mgr->mgr.ctrl_blk);
  617. *rdaio_mgr = daio_mgr;
  618. return 0;
  619. error2:
  620. rsc_mgr_uninit(&daio_mgr->mgr);
  621. error1:
  622. kfree(daio_mgr);
  623. return err;
  624. }
  625. int daio_mgr_destroy(struct daio_mgr *daio_mgr)
  626. {
  627. unsigned long flags;
  628. /* free daio input mapper list */
  629. spin_lock_irqsave(&daio_mgr->imap_lock, flags);
  630. free_input_mapper_list(&daio_mgr->imappers);
  631. spin_unlock_irqrestore(&daio_mgr->imap_lock, flags);
  632. rsc_mgr_uninit(&daio_mgr->mgr);
  633. kfree(daio_mgr);
  634. return 0;
  635. }