comparison: src/server/daemon/threadpools.c
src/server/daemon/threadpools.c
- changeset 37
- 360b9aabe17e
- parent 30
- 27c7511c0e34
- child 44
- 3da1f7b6847f
equal
deleted
inserted
replaced
| 36:450d2d5f4735 | 37:360b9aabe17e |
|---|---|
| 40 threadpool_t *default_thread_pool = NULL; | 40 threadpool_t *default_thread_pool = NULL; |
| 41 | 41 |
| 42 threadpool_t *last_thrpool_c = NULL; | 42 threadpool_t *last_thrpool_c = NULL; |
| 43 | 43 |
| 44 int create_threadpool(sstr_t name, ThreadPoolConfig *cfg) { | 44 int create_threadpool(sstr_t name, ThreadPoolConfig *cfg) { |
| 45 // TODO: use ThreadPoolConfig | |
| 46 | |
| 45 if(thread_pool_map == NULL) { | 47 if(thread_pool_map == NULL) { |
| 46 thread_pool_map = ucx_map_new(16); | 48 thread_pool_map = ucx_map_new(16); |
| 47 } | 49 } |
| 48 | 50 |
| 49 threadpool_t *pool = ucx_map_sstr_get(thread_pool_map, name); | 51 threadpool_t *pool = ucx_map_sstr_get(thread_pool_map, name); |
| 85 | 87 |
| 86 threadpool_t* get_default_threadpool() { | 88 threadpool_t* get_default_threadpool() { |
| 87 return default_thread_pool; | 89 return default_thread_pool; |
| 88 } | 90 } |
| 89 | 91 |
| 92 threadpool_t* get_threadpool(sstr_t name) { | |
| 93 return ucx_map_sstr_get(thread_pool_map, name); | |
| 94 } |
