1*10465441SEvalZero /*
2*10465441SEvalZero * Copyright (c) 2006-2018, RT-Thread Development Team
3*10465441SEvalZero *
4*10465441SEvalZero * SPDX-License-Identifier: Apache-2.0
5*10465441SEvalZero *
6*10465441SEvalZero * Change Logs:
7*10465441SEvalZero * Date Author Notes
8*10465441SEvalZero * 2018-08-19 tyx the first version
9*10465441SEvalZero */
10*10465441SEvalZero
11*10465441SEvalZero #include <rthw.h>
12*10465441SEvalZero #include <rtthread.h>
13*10465441SEvalZero #include <wlan_workqueue.h>
14*10465441SEvalZero #include <ipc/workqueue.h>
15*10465441SEvalZero
16*10465441SEvalZero #define DBG_ENABLE
17*10465441SEvalZero #define DBG_LEVEL DBG_INFO
18*10465441SEvalZero #define DBG_SECTION_NAME "WLAN.work"
19*10465441SEvalZero #define DBG_COLOR
20*10465441SEvalZero #include <rtdbg.h>
21*10465441SEvalZero
22*10465441SEvalZero struct rt_wlan_work
23*10465441SEvalZero {
24*10465441SEvalZero struct rt_work work;
25*10465441SEvalZero void (*fun)(void *parameter);
26*10465441SEvalZero void *parameter;
27*10465441SEvalZero };
28*10465441SEvalZero
29*10465441SEvalZero static struct rt_workqueue *wlan_workqueue;
30*10465441SEvalZero
rt_wlan_workqueue_fun(struct rt_work * work,void * work_data)31*10465441SEvalZero static void rt_wlan_workqueue_fun(struct rt_work *work, void *work_data)
32*10465441SEvalZero {
33*10465441SEvalZero struct rt_wlan_work *wlan_work = work_data;
34*10465441SEvalZero
35*10465441SEvalZero wlan_work->fun(wlan_work->parameter);
36*10465441SEvalZero rt_free(wlan_work);
37*10465441SEvalZero }
38*10465441SEvalZero
rt_wlan_get_workqueue(void)39*10465441SEvalZero struct rt_workqueue *rt_wlan_get_workqueue(void)
40*10465441SEvalZero {
41*10465441SEvalZero return wlan_workqueue;
42*10465441SEvalZero }
43*10465441SEvalZero
rt_wlan_workqueue_dowork(void (* func)(void * parameter),void * parameter)44*10465441SEvalZero rt_err_t rt_wlan_workqueue_dowork(void (*func)(void *parameter), void *parameter)
45*10465441SEvalZero {
46*10465441SEvalZero struct rt_wlan_work *wlan_work;
47*10465441SEvalZero rt_err_t err = RT_EOK;
48*10465441SEvalZero
49*10465441SEvalZero LOG_D("F:%s is run", __FUNCTION__);
50*10465441SEvalZero if (func == RT_NULL)
51*10465441SEvalZero {
52*10465441SEvalZero LOG_E("F:%s L:%d func is null", __FUNCTION__, __LINE__);
53*10465441SEvalZero return -RT_EINVAL;
54*10465441SEvalZero }
55*10465441SEvalZero
56*10465441SEvalZero if (wlan_workqueue == RT_NULL)
57*10465441SEvalZero {
58*10465441SEvalZero LOG_E("F:%s L:%d not init wlan work queue", __FUNCTION__, __LINE__);
59*10465441SEvalZero return -RT_ERROR;
60*10465441SEvalZero }
61*10465441SEvalZero
62*10465441SEvalZero wlan_work = rt_malloc(sizeof(struct rt_wlan_work));
63*10465441SEvalZero if (wlan_work == RT_NULL)
64*10465441SEvalZero {
65*10465441SEvalZero LOG_E("F:%s L:%d create work failed", __FUNCTION__, __LINE__);
66*10465441SEvalZero return -RT_ENOMEM;
67*10465441SEvalZero }
68*10465441SEvalZero wlan_work->fun = func;
69*10465441SEvalZero wlan_work->parameter = parameter;
70*10465441SEvalZero rt_work_init(&wlan_work->work, rt_wlan_workqueue_fun, wlan_work);
71*10465441SEvalZero err = rt_workqueue_dowork(wlan_workqueue, &wlan_work->work);
72*10465441SEvalZero if (err != RT_EOK)
73*10465441SEvalZero {
74*10465441SEvalZero LOG_E("F:%s L:%d do work failed", __FUNCTION__, __LINE__);
75*10465441SEvalZero rt_free(wlan_work);
76*10465441SEvalZero return err;
77*10465441SEvalZero }
78*10465441SEvalZero return err;
79*10465441SEvalZero }
80*10465441SEvalZero
rt_wlan_workqueue_init(void)81*10465441SEvalZero int rt_wlan_workqueue_init(void)
82*10465441SEvalZero {
83*10465441SEvalZero static rt_int8_t _init_flag = 0;
84*10465441SEvalZero
85*10465441SEvalZero if (_init_flag == 0)
86*10465441SEvalZero {
87*10465441SEvalZero wlan_workqueue = rt_workqueue_create(RT_WLAN_WORKQUEUE_THREAD_NAME, RT_WLAN_WORKQUEUE_THREAD_SIZE,
88*10465441SEvalZero RT_WLAN_WORKQUEUE_THREAD_PRIO);
89*10465441SEvalZero if (wlan_workqueue == RT_NULL)
90*10465441SEvalZero {
91*10465441SEvalZero LOG_E("F:%s L:%d wlan work queue create failed", __FUNCTION__, __LINE__);
92*10465441SEvalZero return -1;
93*10465441SEvalZero }
94*10465441SEvalZero _init_flag = 1;
95*10465441SEvalZero return 0;
96*10465441SEvalZero }
97*10465441SEvalZero return 0;
98*10465441SEvalZero }
99*10465441SEvalZero INIT_PREV_EXPORT(rt_wlan_workqueue_init);
100