Searched refs:busy_threads (Results 1 – 9 of 9) sorted by relevance
133 threaddata_t **busy_threads= NULL; variable524 threadlist= (threaddata_t **) realloc (busy_threads,sizeof(*busy_threads)*busy_threads_max); in rtpstream_start_task()530 busy_threads= threadlist; in rtpstream_start_task()534 busy_threads[num_busy_threads++]= threaddata; in rtpstream_start_task()571 busy_threads[busy_index]->busy_list_index= -1; in rtpstream_stop_task()576 busy_threads[busy_index]= busy_threads[num_busy_threads]; in rtpstream_stop_task()577 busy_threads[busy_index]->busy_list_index= busy_index; in rtpstream_stop_task()1075 if (busy_threads) { in rtpstream_shutdown()1077 busy_threads[count]->exit_flag= 1; in rtpstream_shutdown()1079 free(busy_threads); in rtpstream_shutdown()[all …]
45 int busy_threads; member85 pool->busy_threads += 1; in worker_thread()91 pool->busy_threads -= 1; in worker_thread()195 if (pool->busy_threads + pool->num_work + 1 > pool->num_threads && in thread_pool_add()
135 self.busy_threads: List[NewsWrapper] = []167 if self.busy_threads and self.busy_threads[0].nntp:170 return self.busy_threads[0].nntp.host496 for nw in server.idle_threads + server.busy_threads:563 for nw in server.busy_threads[:]:574 if not server.busy_threads:634 server.busy_threads.append(nw)655 for nw in server.idle_threads + server.busy_threads:892 server.busy_threads.remove(nw)914 if nw in nw.server.busy_threads:[all …]
1205 for nw in server.busy_threads[:]:
15 executable("busy_threads") {21 sources = [ "busy_threads.cc" ]
32 "busy_threads",
89 int busy_threads; /* Number of threads processing request */ member134 #define BUSY_THREADS(i) (srv_socket[i].busy_threads)