dev_alarm.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812
  1. /*
  2. * Copyright (c) 2006-2024 RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2012-10-27 heyuanjie87 first version.
  9. * 2013-05-17 aozima initial alarm event & mutex in system init.
  10. * 2020-10-15 zhangsz add alarm flags hour minute second.
  11. * 2020-11-09 zhangsz fix alarm set when modify rtc time.
  12. * 2024-09-29 milo make internal thread's attributes configurable.
  13. */
  14. #include <rtthread.h>
  15. #include <rtdevice.h>
  16. #include <sys/time.h>
  17. #define RT_RTC_YEARS_MAX 137
  18. #ifdef RT_USING_SOFT_RTC
  19. #define RT_ALARM_DELAY 0
  20. #else
  21. #define RT_ALARM_DELAY 2
  22. #endif
  23. #if (defined(RT_USING_RTC) && defined(RT_USING_ALARM))
  24. #ifndef RT_ALARM_STACK_SIZE
  25. #define RT_ALARM_STACK_SIZE 2048
  26. #endif
  27. #ifndef RT_ALARM_TIMESLICE
  28. #define RT_ALARM_TIMESLICE 5
  29. #endif
  30. #ifndef RT_ALARM_PRIORITY
  31. #define RT_ALARM_PRIORITY 10
  32. #endif
  33. static struct rt_alarm_container _container;
  34. rt_inline rt_uint32_t alarm_mkdaysec(struct tm *time)
  35. {
  36. rt_uint32_t sec;
  37. sec = time->tm_sec;
  38. sec += time->tm_min * 60;
  39. sec += time->tm_hour * 3600;
  40. return (sec);
  41. }
  42. static rt_err_t alarm_set(struct rt_alarm *alarm)
  43. {
  44. rt_device_t device;
  45. struct rt_rtc_wkalarm wkalarm;
  46. rt_err_t ret;
  47. device = rt_device_find("rtc");
  48. if (device == RT_NULL)
  49. {
  50. return (RT_ERROR);
  51. }
  52. if (alarm->flag & RT_ALARM_STATE_START)
  53. wkalarm.enable = RT_TRUE;
  54. else
  55. wkalarm.enable = RT_FALSE;
  56. wkalarm.tm_sec = alarm->wktime.tm_sec;
  57. wkalarm.tm_min = alarm->wktime.tm_min;
  58. wkalarm.tm_hour = alarm->wktime.tm_hour;
  59. wkalarm.tm_mday = alarm->wktime.tm_mday;
  60. wkalarm.tm_mon = alarm->wktime.tm_mon;
  61. wkalarm.tm_year = alarm->wktime.tm_year;
  62. ret = rt_device_control(device, RT_DEVICE_CTRL_RTC_SET_ALARM, &wkalarm);
  63. if ((ret == RT_EOK) && wkalarm.enable)
  64. {
  65. ret = rt_device_control(device, RT_DEVICE_CTRL_RTC_GET_ALARM, &wkalarm);
  66. if (ret == RT_EOK)
  67. {
  68. /*
  69. some RTC device like RX8025,it's alarms precision is 1 minute.
  70. in this case,low level RTC driver should set wkalarm->tm_sec to 0.
  71. */
  72. alarm->wktime.tm_sec = wkalarm.tm_sec;
  73. alarm->wktime.tm_min = wkalarm.tm_min;
  74. alarm->wktime.tm_hour = wkalarm.tm_hour;
  75. alarm->wktime.tm_mday = wkalarm.tm_mday;
  76. alarm->wktime.tm_mon = wkalarm.tm_mon;
  77. alarm->wktime.tm_year = wkalarm.tm_year;
  78. }
  79. }
  80. return (ret);
  81. }
  82. static void alarm_wakeup(struct rt_alarm *alarm, struct tm *now)
  83. {
  84. rt_uint32_t sec_alarm, sec_now;
  85. rt_bool_t wakeup = RT_FALSE;
  86. time_t timestamp;
  87. sec_alarm = alarm_mkdaysec(&alarm->wktime);
  88. sec_now = alarm_mkdaysec(now);
  89. if (alarm->flag & RT_ALARM_STATE_START)
  90. {
  91. switch (alarm->flag & 0xFF00)
  92. {
  93. case RT_ALARM_ONESHOT:
  94. {
  95. sec_alarm = timegm(&alarm->wktime);
  96. sec_now = timegm(now);
  97. if (((sec_now - sec_alarm) <= RT_ALARM_DELAY) && (sec_now >= sec_alarm))
  98. {
  99. /* stop alarm */
  100. alarm->flag &= ~RT_ALARM_STATE_START;
  101. alarm_set(alarm);
  102. wakeup = RT_TRUE;
  103. }
  104. }
  105. break;
  106. case RT_ALARM_SECOND:
  107. {
  108. alarm->wktime.tm_hour = now->tm_hour;
  109. alarm->wktime.tm_min = now->tm_min;
  110. alarm->wktime.tm_sec = now->tm_sec + 1;
  111. if (alarm->wktime.tm_sec > 59)
  112. {
  113. alarm->wktime.tm_sec = 0;
  114. alarm->wktime.tm_min = alarm->wktime.tm_min + 1;
  115. if (alarm->wktime.tm_min > 59)
  116. {
  117. alarm->wktime.tm_min = 0;
  118. alarm->wktime.tm_hour = alarm->wktime.tm_hour + 1;
  119. if (alarm->wktime.tm_hour > 23)
  120. {
  121. alarm->wktime.tm_hour = 0;
  122. }
  123. }
  124. }
  125. wakeup = RT_TRUE;
  126. }
  127. break;
  128. case RT_ALARM_MINUTE:
  129. {
  130. alarm->wktime.tm_hour = now->tm_hour;
  131. if (alarm->wktime.tm_sec == now->tm_sec)
  132. {
  133. alarm->wktime.tm_min = now->tm_min + 1;
  134. if (alarm->wktime.tm_min > 59)
  135. {
  136. alarm->wktime.tm_min = 0;
  137. alarm->wktime.tm_hour = alarm->wktime.tm_hour + 1;
  138. if (alarm->wktime.tm_hour > 23)
  139. {
  140. alarm->wktime.tm_hour = 0;
  141. }
  142. }
  143. wakeup = RT_TRUE;
  144. }
  145. }
  146. break;
  147. case RT_ALARM_HOUR:
  148. {
  149. if ((alarm->wktime.tm_min == now->tm_min) &&
  150. (alarm->wktime.tm_sec == now->tm_sec))
  151. {
  152. alarm->wktime.tm_hour = now->tm_hour + 1;
  153. if (alarm->wktime.tm_hour > 23)
  154. {
  155. alarm->wktime.tm_hour = 0;
  156. }
  157. wakeup = RT_TRUE;
  158. }
  159. }
  160. break;
  161. case RT_ALARM_DAILY:
  162. {
  163. if (((sec_now - sec_alarm) <= RT_ALARM_DELAY) && (sec_now >= sec_alarm))
  164. wakeup = RT_TRUE;
  165. }
  166. break;
  167. case RT_ALARM_WEEKLY:
  168. {
  169. /* alarm at wday */
  170. if (alarm->wktime.tm_wday == now->tm_wday)
  171. {
  172. sec_alarm += alarm->wktime.tm_wday * 24 * 3600;
  173. sec_now += now->tm_wday * 24 * 3600;
  174. if (sec_now == sec_alarm)
  175. wakeup = RT_TRUE;
  176. }
  177. }
  178. break;
  179. case RT_ALARM_MONTHLY:
  180. {
  181. /* monthly someday generate alarm signals */
  182. if (alarm->wktime.tm_mday == now->tm_mday)
  183. {
  184. if ((sec_now - sec_alarm) <= RT_ALARM_DELAY)
  185. wakeup = RT_TRUE;
  186. }
  187. }
  188. break;
  189. case RT_ALARM_YAERLY:
  190. {
  191. if ((alarm->wktime.tm_mday == now->tm_mday) && \
  192. (alarm->wktime.tm_mon == now->tm_mon))
  193. {
  194. if ((sec_now - sec_alarm) <= RT_ALARM_DELAY)
  195. wakeup = RT_TRUE;
  196. }
  197. }
  198. break;
  199. }
  200. if ((wakeup == RT_TRUE) && (alarm->callback != RT_NULL))
  201. {
  202. timestamp = (time_t)0;
  203. get_timestamp(&timestamp);
  204. alarm->callback(alarm, timestamp);
  205. }
  206. }
  207. }
  208. static void alarm_update(rt_uint32_t event)
  209. {
  210. struct rt_alarm *alm_prev = RT_NULL, *alm_next = RT_NULL;
  211. struct rt_alarm *alarm;
  212. rt_int32_t sec_now, sec_alarm, sec_tmp;
  213. rt_int32_t sec_next = 24 * 3600, sec_prev = 0;
  214. time_t timestamp = (time_t)0;
  215. struct tm now;
  216. rt_list_t *next;
  217. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  218. if (!rt_list_isempty(&_container.head))
  219. {
  220. /* get time of now */
  221. get_timestamp(&timestamp);
  222. gmtime_r(&timestamp, &now);
  223. for (next = _container.head.next; next != &_container.head; next = next->next)
  224. {
  225. alarm = rt_list_entry(next, struct rt_alarm, list);
  226. /* check the overtime alarm */
  227. alarm_wakeup(alarm, &now);
  228. }
  229. /* get time of now */
  230. get_timestamp(&timestamp);
  231. gmtime_r(&timestamp, &now);
  232. sec_now = alarm_mkdaysec(&now);
  233. for (next = _container.head.next; next != &_container.head; next = next->next)
  234. {
  235. alarm = rt_list_entry(next, struct rt_alarm, list);
  236. /* calculate seconds from 00:00:00 */
  237. sec_alarm = alarm_mkdaysec(&alarm->wktime);
  238. if (alarm->flag & RT_ALARM_STATE_START)
  239. {
  240. sec_tmp = sec_alarm - sec_now;
  241. if (sec_tmp > 0)
  242. {
  243. /* find alarm after now(now to 23:59:59) and the most recent */
  244. if (sec_tmp < sec_next)
  245. {
  246. sec_next = sec_tmp;
  247. alm_next = alarm;
  248. }
  249. }
  250. else
  251. {
  252. /* find alarm before now(00:00:00 to now) and furthest from now */
  253. if (sec_tmp < sec_prev)
  254. {
  255. sec_prev = sec_tmp;
  256. alm_prev = alarm;
  257. }
  258. }
  259. }
  260. }
  261. /* enable the alarm after now first */
  262. if (sec_next < 24 * 3600)
  263. {
  264. if (alarm_set(alm_next) == RT_EOK)
  265. _container.current = alm_next;
  266. }
  267. else if (sec_prev < 0)
  268. {
  269. /* enable the alarm before now */
  270. if (alarm_set(alm_prev) == RT_EOK)
  271. _container.current = alm_prev;
  272. }
  273. else
  274. {
  275. if (_container.current != RT_NULL)
  276. {
  277. alarm_set(_container.current);
  278. if (!(_container.current->flag & RT_ALARM_STATE_START))
  279. _container.current = RT_NULL;
  280. }
  281. }
  282. }
  283. rt_mutex_release(&_container.mutex);
  284. }
  285. static int days_of_year_month(int tm_year, int tm_mon)
  286. {
  287. int ret, year;
  288. year = tm_year + 1900;
  289. if (tm_mon == 1)
  290. {
  291. ret = 28 + ((!(year % 4) && (year % 100)) || !(year % 400));
  292. }
  293. else if (((tm_mon <= 6) && (tm_mon % 2 == 0)) || ((tm_mon > 6) && (tm_mon % 2 == 1)))
  294. {
  295. ret = 31;
  296. }
  297. else
  298. {
  299. ret = 30;
  300. }
  301. return (ret);
  302. }
  303. static rt_bool_t is_valid_date(struct tm *date)
  304. {
  305. if ((date->tm_year < 0) || (date->tm_year > RT_RTC_YEARS_MAX))
  306. {
  307. return (RT_FALSE);
  308. }
  309. if ((date->tm_mon < 0) || (date->tm_mon > 11))
  310. {
  311. return (RT_FALSE);
  312. }
  313. if ((date->tm_mday < 1) || \
  314. (date->tm_mday > days_of_year_month(date->tm_year, date->tm_mon)))
  315. {
  316. return (RT_FALSE);
  317. }
  318. return (RT_TRUE);
  319. }
  320. static rt_err_t alarm_setup(rt_alarm_t alarm, struct tm *wktime)
  321. {
  322. rt_err_t ret = -RT_ERROR;
  323. time_t timestamp = (time_t)0;
  324. struct tm *setup, now;
  325. setup = &alarm->wktime;
  326. *setup = *wktime;
  327. /* get time of now */
  328. get_timestamp(&timestamp);
  329. gmtime_r(&timestamp, &now);
  330. /* if these are a "don't care" value,we set them to now*/
  331. if ((setup->tm_sec > 59) || (setup->tm_sec < 0))
  332. setup->tm_sec = now.tm_sec;
  333. if ((setup->tm_min > 59) || (setup->tm_min < 0))
  334. setup->tm_min = now.tm_min;
  335. if ((setup->tm_hour > 23) || (setup->tm_hour < 0))
  336. setup->tm_hour = now.tm_hour;
  337. switch (alarm->flag & 0xFF00)
  338. {
  339. case RT_ALARM_SECOND:
  340. {
  341. alarm->wktime.tm_hour = now.tm_hour;
  342. alarm->wktime.tm_min = now.tm_min;
  343. alarm->wktime.tm_sec = now.tm_sec + 1;
  344. if (alarm->wktime.tm_sec > 59)
  345. {
  346. alarm->wktime.tm_sec = 0;
  347. alarm->wktime.tm_min = alarm->wktime.tm_min + 1;
  348. if (alarm->wktime.tm_min > 59)
  349. {
  350. alarm->wktime.tm_min = 0;
  351. alarm->wktime.tm_hour = alarm->wktime.tm_hour + 1;
  352. if (alarm->wktime.tm_hour > 23)
  353. {
  354. alarm->wktime.tm_hour = 0;
  355. }
  356. }
  357. }
  358. }
  359. break;
  360. case RT_ALARM_MINUTE:
  361. {
  362. alarm->wktime.tm_hour = now.tm_hour;
  363. alarm->wktime.tm_min = now.tm_min + 1;
  364. if (alarm->wktime.tm_min > 59)
  365. {
  366. alarm->wktime.tm_min = 0;
  367. alarm->wktime.tm_hour = alarm->wktime.tm_hour + 1;
  368. if (alarm->wktime.tm_hour > 23)
  369. {
  370. alarm->wktime.tm_hour = 0;
  371. }
  372. }
  373. }
  374. break;
  375. case RT_ALARM_HOUR:
  376. {
  377. alarm->wktime.tm_hour = now.tm_hour + 1;
  378. if (alarm->wktime.tm_hour > 23)
  379. {
  380. alarm->wktime.tm_hour = 0;
  381. }
  382. }
  383. break;
  384. case RT_ALARM_DAILY:
  385. {
  386. /* do nothing but needed */
  387. }
  388. break;
  389. case RT_ALARM_ONESHOT:
  390. {
  391. /* if these are "don't care" value we set them to now */
  392. if (setup->tm_year == RT_ALARM_TM_NOW)
  393. setup->tm_year = now.tm_year;
  394. if (setup->tm_mon == RT_ALARM_TM_NOW)
  395. setup->tm_mon = now.tm_mon;
  396. if (setup->tm_mday == RT_ALARM_TM_NOW)
  397. setup->tm_mday = now.tm_mday;
  398. /* make sure the setup is valid */
  399. if (!is_valid_date(setup))
  400. goto _exit;
  401. }
  402. break;
  403. case RT_ALARM_WEEKLY:
  404. {
  405. /* if tm_wday is a "don't care" value we set it to now */
  406. if ((setup->tm_wday < 0) || (setup->tm_wday > 6))
  407. setup->tm_wday = now.tm_wday;
  408. }
  409. break;
  410. case RT_ALARM_MONTHLY:
  411. {
  412. /* if tm_mday is a "don't care" value we set it to now */
  413. if ((setup->tm_mday < 1) || (setup->tm_mday > 31))
  414. setup->tm_mday = now.tm_mday;
  415. }
  416. break;
  417. case RT_ALARM_YAERLY:
  418. {
  419. /* if tm_mon is a "don't care" value we set it to now */
  420. if ((setup->tm_mon < 0) || (setup->tm_mon > 11))
  421. setup->tm_mon = now.tm_mon;
  422. if (setup->tm_mon == 1)
  423. {
  424. /* tm_mon is February */
  425. /* tm_mday should be 1~29.otherwise,it's a "don't care" value */
  426. if ((setup->tm_mday < 1) || (setup->tm_mday > 29))
  427. setup->tm_mday = now.tm_mday;
  428. }
  429. else if (((setup->tm_mon <= 6) && (setup->tm_mon % 2 == 0)) || \
  430. ((setup->tm_mon > 6) && (setup->tm_mon % 2 == 1)))
  431. {
  432. /* Jan,Mar,May,Jul,Aug,Oct,Dec */
  433. /* tm_mday should be 1~31.otherwise,it's a "don't care" value */
  434. if ((setup->tm_mday < 1) || (setup->tm_mday > 31))
  435. setup->tm_mday = now.tm_mday;
  436. }
  437. else
  438. {
  439. /* tm_mday should be 1~30.otherwise,it's a "don't care" value */
  440. if ((setup->tm_mday < 1) || (setup->tm_mday > 30))
  441. setup->tm_mday = now.tm_mday;
  442. }
  443. }
  444. break;
  445. default:
  446. {
  447. goto _exit;
  448. }
  449. }
  450. if ((setup->tm_hour == 23) && (setup->tm_min == 59) && (setup->tm_sec == 59))
  451. {
  452. /*
  453. for insurance purposes, we will generate an alarm
  454. signal two seconds ahead of.
  455. */
  456. setup->tm_sec = 60 - RT_ALARM_DELAY;
  457. }
  458. /* set initialized state */
  459. alarm->flag |= RT_ALARM_STATE_INITED;
  460. ret = RT_EOK;
  461. _exit:
  462. return (ret);
  463. }
  464. /** \brief send a rtc alarm event
  465. *
  466. * \param dev pointer to RTC device(currently unused,you can ignore it)
  467. * \param event RTC event(currently unused)
  468. * \return none
  469. */
  470. void rt_alarm_update(rt_device_t dev, rt_uint32_t event)
  471. {
  472. rt_event_send(&_container.event, 1);
  473. }
  474. /** \brief modify the alarm setup
  475. *
  476. * \param alarm pointer to alarm
  477. * \param cmd control command
  478. * \param arg argument
  479. */
  480. rt_err_t rt_alarm_control(rt_alarm_t alarm, int cmd, void *arg)
  481. {
  482. rt_err_t ret = -RT_ERROR;
  483. RT_ASSERT(alarm != RT_NULL);
  484. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  485. switch (cmd)
  486. {
  487. case RT_ALARM_CTRL_MODIFY:
  488. {
  489. struct rt_alarm_setup *setup;
  490. RT_ASSERT(arg != RT_NULL);
  491. setup = arg;
  492. rt_alarm_stop(alarm);
  493. alarm->flag = setup->flag & 0xFF00;
  494. alarm->wktime = setup->wktime;
  495. ret = alarm_setup(alarm, &alarm->wktime);
  496. }
  497. break;
  498. }
  499. rt_mutex_release(&_container.mutex);
  500. return (ret);
  501. }
  502. /** \brief start an alarm
  503. *
  504. * \param alarm pointer to alarm
  505. * \return RT_EOK
  506. */
  507. rt_err_t rt_alarm_start(rt_alarm_t alarm)
  508. {
  509. rt_int32_t sec_now, sec_old, sec_new;
  510. rt_err_t ret = RT_EOK;
  511. time_t timestamp = (time_t)0;
  512. struct tm now;
  513. if (alarm == RT_NULL)
  514. return (RT_ERROR);
  515. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  516. if (!(alarm->flag & RT_ALARM_STATE_START))
  517. {
  518. if (alarm_setup(alarm, &alarm->wktime) != RT_EOK)
  519. {
  520. ret = -RT_ERROR;
  521. goto _exit;
  522. }
  523. /* get time of now */
  524. get_timestamp(&timestamp);
  525. gmtime_r(&timestamp, &now);
  526. alarm->flag |= RT_ALARM_STATE_START;
  527. /* set alarm */
  528. if (_container.current == RT_NULL)
  529. {
  530. ret = alarm_set(alarm);
  531. }
  532. else
  533. {
  534. sec_now = alarm_mkdaysec(&now);
  535. sec_old = alarm_mkdaysec(&_container.current->wktime);
  536. sec_new = alarm_mkdaysec(&alarm->wktime);
  537. if ((sec_new < sec_old) && (sec_new > sec_now))
  538. {
  539. ret = alarm_set(alarm);
  540. }
  541. else if ((sec_new > sec_now) && (sec_old < sec_now))
  542. {
  543. ret = alarm_set(alarm);
  544. }
  545. else if ((sec_new < sec_old) && (sec_old < sec_now))
  546. {
  547. ret = alarm_set(alarm);
  548. }
  549. else
  550. {
  551. ret = RT_EOK;
  552. goto _exit;
  553. }
  554. }
  555. if (ret == RT_EOK)
  556. {
  557. _container.current = alarm;
  558. }
  559. }
  560. _exit:
  561. rt_mutex_release(&_container.mutex);
  562. return (ret);
  563. }
  564. /** \brief stop an alarm
  565. *
  566. * \param alarm pointer to alarm
  567. * \return RT_EOK
  568. */
  569. rt_err_t rt_alarm_stop(rt_alarm_t alarm)
  570. {
  571. rt_err_t ret = RT_EOK;
  572. if (alarm == RT_NULL)
  573. return (RT_ERROR);
  574. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  575. if (!(alarm->flag & RT_ALARM_STATE_START))
  576. goto _exit;
  577. /* stop alarm */
  578. alarm->flag &= ~RT_ALARM_STATE_START;
  579. if (_container.current == alarm)
  580. {
  581. ret = alarm_set(alarm);
  582. _container.current = RT_NULL;
  583. }
  584. if (ret == RT_EOK)
  585. alarm_update(0);
  586. _exit:
  587. rt_mutex_release(&_container.mutex);
  588. return (ret);
  589. }
  590. /** \brief delete an alarm
  591. *
  592. * \param alarm pointer to alarm
  593. * \return RT_EOK
  594. */
  595. rt_err_t rt_alarm_delete(rt_alarm_t alarm)
  596. {
  597. rt_err_t ret = RT_EOK;
  598. if (alarm == RT_NULL)
  599. return -RT_ERROR;
  600. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  601. /* stop the alarm */
  602. alarm->flag &= ~RT_ALARM_STATE_START;
  603. if (_container.current == alarm)
  604. {
  605. ret = alarm_set(alarm);
  606. _container.current = RT_NULL;
  607. /* set new alarm if necessary */
  608. alarm_update(0);
  609. }
  610. rt_list_remove(&alarm->list);
  611. rt_free(alarm);
  612. rt_mutex_release(&_container.mutex);
  613. return (ret);
  614. }
  615. /** \brief create an alarm
  616. *
  617. * \param flag set alarm mode e.g: RT_ALARM_DAILY
  618. * \param setup pointer to setup infomation
  619. */
  620. rt_alarm_t rt_alarm_create(rt_alarm_callback_t callback, struct rt_alarm_setup *setup)
  621. {
  622. struct rt_alarm *alarm;
  623. if (setup == RT_NULL)
  624. return (RT_NULL);
  625. alarm = rt_malloc(sizeof(struct rt_alarm));
  626. if (alarm == RT_NULL)
  627. return (RT_NULL);
  628. rt_list_init(&alarm->list);
  629. alarm->wktime = setup->wktime;
  630. alarm->flag = setup->flag & 0xFF00;
  631. alarm->callback = callback;
  632. rt_mutex_take(&_container.mutex, RT_WAITING_FOREVER);
  633. rt_list_insert_after(&_container.head, &alarm->list);
  634. rt_mutex_release(&_container.mutex);
  635. return (alarm);
  636. }
  637. /** \brief rtc alarm service thread entry
  638. *
  639. */
  640. static void rt_alarmsvc_thread_init(void *param)
  641. {
  642. rt_uint32_t recv;
  643. _container.current = RT_NULL;
  644. while (1)
  645. {
  646. if (rt_event_recv(&_container.event, 0xFFFF,
  647. RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
  648. RT_WAITING_FOREVER, &recv) == RT_EOK)
  649. {
  650. alarm_update(recv);
  651. }
  652. }
  653. }
  654. struct _alarm_flag
  655. {
  656. const char* name;
  657. rt_uint32_t flag;
  658. };
  659. static const struct _alarm_flag _alarm_flag_tbl[] =
  660. {
  661. {"N", 0xffff}, /* none */
  662. {"O", RT_ALARM_ONESHOT}, /* only alarm once */
  663. {"D", RT_ALARM_DAILY}, /* alarm everyday */
  664. {"W", RT_ALARM_WEEKLY}, /* alarm weekly at Monday or Friday etc. */
  665. {"Mo", RT_ALARM_MONTHLY}, /* alarm monthly at someday */
  666. {"Y", RT_ALARM_YAERLY}, /* alarm yearly at a certain date */
  667. {"H", RT_ALARM_HOUR}, /* alarm each hour at a certain min:second */
  668. {"M", RT_ALARM_MINUTE}, /* alarm each minute at a certain second */
  669. {"S", RT_ALARM_SECOND}, /* alarm each second */
  670. };
  671. static rt_uint8_t _alarm_flag_tbl_size = sizeof(_alarm_flag_tbl) / sizeof(_alarm_flag_tbl[0]);
  672. static rt_uint8_t get_alarm_flag_index(rt_uint32_t alarm_flag)
  673. {
  674. for (rt_uint8_t index = 0; index < _alarm_flag_tbl_size; index++)
  675. {
  676. alarm_flag &= 0xff00;
  677. if (alarm_flag == _alarm_flag_tbl[index].flag)
  678. {
  679. return index;
  680. }
  681. }
  682. return 0;
  683. }
  684. void rt_alarm_dump(void)
  685. {
  686. rt_list_t *next;
  687. rt_alarm_t alarm;
  688. rt_kprintf("| hh:mm:ss | week | flag | en |\n");
  689. rt_kprintf("+----------+------+------+----+\n");
  690. for (next = _container.head.next; next != &_container.head; next = next->next)
  691. {
  692. alarm = rt_list_entry(next, struct rt_alarm, list);
  693. rt_uint8_t flag_index = get_alarm_flag_index(alarm->flag);
  694. rt_kprintf("| %02d:%02d:%02d | %2d | %2s | %2d |\n",
  695. alarm->wktime.tm_hour, alarm->wktime.tm_min, alarm->wktime.tm_sec,
  696. alarm->wktime.tm_wday, _alarm_flag_tbl[flag_index].name, alarm->flag & RT_ALARM_STATE_START);
  697. }
  698. rt_kprintf("+----------+------+------+----+\n");
  699. }
  700. MSH_CMD_EXPORT_ALIAS(rt_alarm_dump, list_alarm, list alarm info);
  701. /** \brief initialize alarm service system
  702. *
  703. * \param none
  704. * \return none
  705. */
  706. int rt_alarm_system_init(void)
  707. {
  708. rt_thread_t tid;
  709. rt_list_init(&_container.head);
  710. rt_event_init(&_container.event, "alarmsvc", RT_IPC_FLAG_FIFO);
  711. rt_mutex_init(&_container.mutex, "alarmsvc", RT_IPC_FLAG_PRIO);
  712. tid = rt_thread_create("alarmsvc",
  713. rt_alarmsvc_thread_init, RT_NULL,
  714. RT_ALARM_STACK_SIZE,
  715. RT_ALARM_PRIORITY,
  716. RT_ALARM_TIMESLICE);
  717. if (tid != RT_NULL)
  718. rt_thread_startup(tid);
  719. return 0;
  720. }
  721. INIT_PREV_EXPORT(rt_alarm_system_init);
  722. #endif