Lines Matching refs:ev_service
29 } ev_service; variable
64 eventlist_subscribe_fd(&ev_service.event, param->event_id, param->cb, param->data); in process_rpc()
65 aos_sem_signal(&ev_service.select_sem); in process_rpc()
69 eventlist_unsubscribe_fd(&ev_service.event, param->event_id, param->cb, param->data); in process_rpc()
73 eventlist_publish_fd(&ev_service.event, param->event_id, param->data); in process_rpc()
77 eventlist_subscribe(&ev_service.event, param->event_id, param->cb, param->data); in process_rpc()
81 eventlist_unsubscribe(&ev_service.event, param->event_id, param->cb, param->data); in process_rpc()
95 dlist_for_each_entry(&ev_service.timeouts, node, struct event_param, next) { in process_rpc()
100 aos_sem_signal(&ev_service.select_sem); in process_rpc()
102 eventlist_publish(&ev_service.event, param->event_id, param->data); in process_rpc()
115 if (ev_service.is_event_service_inited != 0) { in event_service_init()
118 ev_service.is_event_service_inited = 1; in event_service_init()
123 ev_service.is_event_service_inited = 0; in event_service_init()
126 eventlist_init(&ev_service.event); in event_service_init()
127 dlist_init(&ev_service.timeouts); in event_service_init()
128 if (aos_sem_new(&ev_service.select_sem, 0) < 0) { in event_service_init()
130 ev_service.is_event_service_inited = 0; in event_service_init()
133 if (aos_event_new(&ev_service.wait_event, 0) < 0) { in event_service_init()
135 aos_sem_free(&ev_service.select_sem); in event_service_init()
136 ev_service.is_event_service_inited = 0; in event_service_init()
140 ev_service.svr = uservice_new("event_svr", process_rpc, NULL); in event_service_init()
141 if (ev_service.svr == NULL) { in event_service_init()
143 aos_sem_free(&ev_service.select_sem); in event_service_init()
144 aos_event_free(&ev_service.select_sem); in event_service_init()
145 ev_service.is_event_service_inited = 0; in event_service_init()
149 aos_task_new_ext(&ev_service.select_task, "select", select_task_entry, NULL, in event_service_init()
151 utask_add(task, ev_service.svr); in event_service_init()
162 uservice_call(ev_service.svr, &rpc); in event_call()
250 uservice_lock(ev_service.svr); in do_time_event()
251 dlist_for_each_entry_safe(&ev_service.timeouts, tmp, node, struct event_param, next) { in do_time_event()
263 uservice_unlock(ev_service.svr); in do_time_event()
274 event_list_t *evlist = &ev_service.event; in select_task_entry()
275 utask_t *task = ev_service.svr->task; in select_task_entry()
292 …select2(max_fd + 1, &readfds, NULL, NULL, time_ms == -1 ? NULL : &timeout, &ev_service.select_sem); in select_task_entry()