| 647 | } |
| 648 | |
| 649 | void connect_pool::keep_conns(thread_pool* threads /* NULL */) |
| 650 | { |
| 651 | lock_.lock(); |
| 652 | size_t min; |
| 653 | if (min_ > 0 && min_ > count_) { |
| 654 | min = min_ - count_; |
| 655 | } else { |
| 656 | min = 0; |
| 657 | } |
| 658 | lock_.unlock(); |
| 659 | |
| 660 | if (min == 0) { |
| 661 | return; |
| 662 | } |
| 663 | |
| 664 | if (threads) { |
| 665 | keep_conns(min, *threads); |
| 666 | } else { |
| 667 | keep_conns(min); |
| 668 | } |
| 669 | } |
| 670 | |
| 671 | void connect_pool::keep_conns(size_t min) |
| 672 | { |
no test coverage detected