dev_alarm.c 22 KB

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