comparison: src/server/daemon/threadpools.c
src/server/daemon/threadpools.c
- changeset 570
- f95868a8ec37
- parent 556
- b036ccad4b49
- child 577
- 4f5ccaea4a92
equal
deleted
inserted
replaced
| 569:70bca6190669 | 570:f95868a8ec37 |
|---|---|
| 146 threadpool_t* get_iopool(cxstring name) { | 146 threadpool_t* get_iopool(cxstring name) { |
| 147 return cxMapGet(io_pool_map, cx_hash_key_bytes((const unsigned char*)name.ptr, name.length)); | 147 return cxMapGet(io_pool_map, cx_hash_key_bytes((const unsigned char*)name.ptr, name.length)); |
| 148 } | 148 } |
| 149 | 149 |
| 150 | 150 |
| 151 void shutdown_threadpools(void) { | 151 void shutdown_threadpools(int timeout) { |
| 152 log_ereport(LOG_INFORM, "shutdown threadpools"); | 152 log_ereport(LOG_INFORM, "shutdown threadpools"); |
| 153 CxIterator i = cxMapIteratorValues(thread_pool_map); | 153 CxIterator i = cxMapIteratorValues(thread_pool_map); |
| 154 cx_foreach(threadpool_t*, tp, i) { | 154 cx_foreach(threadpool_t*, tp, i) { |
| 155 threadpool_shutdown(tp); | 155 threadpool_shutdown(tp, timeout); |
| 156 } | 156 } |
| 157 i = cxMapIteratorValues(io_pool_map); | 157 i = cxMapIteratorValues(io_pool_map); |
| 158 cx_foreach(threadpool_t*, tp, i) { | 158 cx_foreach(threadpool_t*, tp, i) { |
| 159 threadpool_shutdown(tp); | 159 threadpool_shutdown(tp, timeout); |
| 160 } | 160 } |
| 161 } | 161 } |
