49   thread_t *thread;  member
85   start.thread = ret;  in thread_new_sized()
109 void thread_free(thread_t *thread) {  in thread_free()  argument
110   if (!thread)  in thread_free()
113   thread_stop(thread);  in thread_free()
114   thread_join(thread);  in thread_free()
116   fixed_queue_free(thread->work_queue, osi_free);  in thread_free()
117   reactor_free(thread->reactor);  in thread_free()
118   osi_free(thread);  in thread_free()
121 void thread_join(thread_t *thread) {  in thread_join()  argument
122   assert(thread != NULL);  in thread_join()
125   if (!thread->is_joined) {  in thread_join()
126     thread->is_joined = true;  in thread_join()
127     pthread_join(thread->pthread, NULL);  in thread_join()
131 bool thread_post(thread_t *thread, thread_fn func, void *context) {  in thread_post()  argument
132   assert(thread != NULL);  in thread_post()
144   fixed_queue_enqueue(thread->work_queue, item);  in thread_post()
148 void thread_stop(thread_t *thread) {  in thread_stop()  argument
149   assert(thread != NULL);  in thread_stop()
150   reactor_stop(thread->reactor);  in thread_stop()
153 bool thread_set_priority(thread_t *thread, int priority) {  in thread_set_priority()  argument
154   if (!thread)  in thread_set_priority()
157   const int rc = setpriority(PRIO_PROCESS, thread->tid, priority);  in thread_set_priority()
160       __func__, priority, thread->tid, rc);  in thread_set_priority()
167 bool thread_is_self(const thread_t *thread) {  in thread_is_self()  argument
168   assert(thread != NULL);  in thread_is_self()
169   return !!pthread_equal(pthread_self(), thread->pthread);  in thread_is_self()
172 reactor_t *thread_get_reactor(const thread_t *thread) {  in thread_get_reactor()  argument
173   assert(thread != NULL);  in thread_get_reactor()
174   return thread->reactor;  in thread_get_reactor()
177 const char *thread_name(const thread_t *thread) {  in thread_name()  argument
178   assert(thread != NULL);  in thread_name()
179   return thread->name;  in thread_name()
186   thread_t *thread = start->thread;  in run_thread()  local
188   assert(thread != NULL);  in run_thread()
190   if (prctl(PR_SET_NAME, (unsigned long)thread->name) == -1) {  in run_thread()
196   thread->tid = gettid();  in run_thread()
198 …LOG_WARN(LOG_TAG, "%s: thread id %d, thread name %s started", __func__, thread->tid, thread->name);  in run_thread()
202   int fd = fixed_queue_get_dequeue_fd(thread->work_queue);  in run_thread()
203   void *context = thread->work_queue;  in run_thread()
205 …reactor_object_t *work_queue_object = reactor_register(thread->reactor, fd, context, work_queue_re…  in run_thread()
206   reactor_start(thread->reactor);  in run_thread()
213   work_item_t *item = fixed_queue_try_dequeue(thread->work_queue);  in run_thread()
214   while (item && count <= fixed_queue_capacity(thread->work_queue)) {  in run_thread()
217     item = fixed_queue_try_dequeue(thread->work_queue);  in run_thread()
221   if (count > fixed_queue_capacity(thread->work_queue))  in run_thread()
224   LOG_WARN(LOG_TAG, "%s: thread id %d, thread name %s exited", __func__, thread->tid, thread->name);  in run_thread()