xref: /btstack/src/btstack_run_loop.c (revision 2c455dad9a589f886e28f6a5d10bb735305e4f1b)
1 /*
2  * Copyright (C) 2014 BlueKitchen GmbH
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  *
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. Neither the name of the copyright holders nor the names of
14  *    contributors may be used to endorse or promote products derived
15  *    from this software without specific prior written permission.
16  * 4. Any redistribution, use, or modification is done solely for
17  *    personal benefit and not for any commercial purpose or for
18  *    monetary gain.
19  *
20  * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS
21  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS
24  * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
25  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
26  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
27  * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
28  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
29  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
30  * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31  * SUCH DAMAGE.
32  *
33  * Please inquire about commercial licensing options at
34  * [email protected]
35  *
36  */
37 
38 /*
39  *  run_loop.c
40  *
41  *  Created by Matthias Ringwald on 6/6/09.
42  */
43 
44 #include "btstack_run_loop.h"
45 
46 #include <stdio.h>
47 #include <stdlib.h>  // exit()
48 
49 
50 #include "btstack_debug.h"
51 #include "btstack_config.h"
52 
53 static const btstack_run_loop_t * the_run_loop = NULL;
54 
55 extern const btstack_run_loop_t btstack_run_loop_embedded;
56 
57 // assert run loop initialized
58 static void btstack_run_loop_assert(void){
59     if (!the_run_loop){
60         log_error("ERROR: run_loop function called before btstack_run_loop_init!");
61         while(1);
62     }
63 }
64 
65 
66 void btstack_run_loop_set_timer_handler(btstack_timer_source_t *ts, void (*process)(btstack_timer_source_t *_ts)){
67     ts->process = process;
68 };
69 
70 void btstack_run_loop_set_data_source_handler(btstack_data_source_t *ds, void (*process)(btstack_data_source_t *_ds,  btstack_data_source_callback_type_t callback_type)){
71     ds->process = process;
72 };
73 
74 void btstack_run_loop_set_data_source_fd(btstack_data_source_t *ds, int fd){
75     ds->fd = fd;
76 }
77 
78 int btstack_run_loop_get_data_source_fd(btstack_data_source_t *ds){
79     return ds->fd;
80 }
81 
82 void btstack_run_loop_enable_data_source_callbacks(btstack_data_source_t *ds, uint16_t callbacks){
83     btstack_run_loop_assert();
84     if (the_run_loop->enable_data_source_callbacks){
85         return the_run_loop->enable_data_source_callbacks(ds, callbacks);
86     } else {
87         log_error("btstack_run_loop_remove_data_source not implemented");
88     }
89 }
90 
91 void btstack_run_loop_disable_data_source_callbacks(btstack_data_source_t *ds, uint16_t callbacks){
92     btstack_run_loop_assert();
93     if (the_run_loop->disable_data_source_callbacks){
94         return the_run_loop->disable_data_source_callbacks(ds, callbacks);
95     } else {
96         log_error("btstack_run_loop_disable_data_source_callbacks not implemented");
97     }
98 }
99 
100 /**
101  * Add data_source to run_loop
102  */
103 void btstack_run_loop_add_data_source(btstack_data_source_t *ds){
104     btstack_run_loop_assert();
105     if (the_run_loop->add_data_source){
106         the_run_loop->add_data_source(ds);
107     } else {
108         log_error("btstack_run_loop_add_data_source not implemented");
109     }
110 }
111 
112 /**
113  * Remove data_source from run loop
114  */
115 int btstack_run_loop_remove_data_source(btstack_data_source_t *ds){
116     btstack_run_loop_assert();
117     if (the_run_loop->remove_data_source){
118         return the_run_loop->remove_data_source(ds);
119     } else {
120         log_error("btstack_run_loop_remove_data_source not implemented");
121         return 0;
122     }
123 }
124 
125 void btstack_run_loop_set_timer(btstack_timer_source_t *a, uint32_t timeout_in_ms){
126     btstack_run_loop_assert();
127     the_run_loop->set_timer(a, timeout_in_ms);
128 }
129 
130 /**
131  * @brief Set context for this timer
132  */
133 void btstack_run_loop_set_timer_context(btstack_timer_source_t *ts, void * context){
134     ts->context = context;
135 }
136 
137 /**
138  * @brief Get context for this timer
139  */
140 void * btstack_run_loop_get_timer_context(btstack_timer_source_t *ts){
141     return ts->context;
142 }
143 
144 /**
145  * Add timer to run_loop (keep list sorted)
146  */
147 void btstack_run_loop_add_timer(btstack_timer_source_t *ts){
148     btstack_run_loop_assert();
149     the_run_loop->add_timer(ts);
150 }
151 
152 /**
153  * Remove timer from run loop
154  */
155 int btstack_run_loop_remove_timer(btstack_timer_source_t *ts){
156     btstack_run_loop_assert();
157     return the_run_loop->remove_timer(ts);
158 }
159 
160 /**
161  * @brief Get current time in ms
162  */
163 uint32_t btstack_run_loop_get_time_ms(void){
164     btstack_run_loop_assert();
165     return the_run_loop->get_time_ms();
166 }
167 
168 
169 void btstack_run_loop_timer_dump(void){
170     btstack_run_loop_assert();
171     the_run_loop->dump_timer();
172 }
173 
174 /**
175  * Execute run_loop
176  */
177 void btstack_run_loop_execute(void){
178     btstack_run_loop_assert();
179     the_run_loop->execute();
180 }
181 
182 // init must be called before any other run_loop call
183 void btstack_run_loop_init(const btstack_run_loop_t * run_loop){
184     if (the_run_loop){
185         log_error("ERROR: run loop initialized twice!");
186         while(1);
187     }
188     the_run_loop = run_loop;
189     the_run_loop->init();
190 }
191 
192