| 9269 | |
| 9270 | |
| 9271 | static uint kill_threads_for_user(THD *thd, LEX_USER *user, |
| 9272 | killed_state kill_signal, ha_rows *rows) |
| 9273 | { |
| 9274 | kill_threads_callback_arg arg(thd, user, kill_signal); |
| 9275 | DBUG_ENTER("kill_threads_for_user"); |
| 9276 | DBUG_PRINT("enter", ("user: %s signal: %u", user->user.str, |
| 9277 | (uint) kill_signal)); |
| 9278 | |
| 9279 | *rows= 0; |
| 9280 | |
| 9281 | if (server_threads.iterate(kill_threads_callback, &arg)) |
| 9282 | DBUG_RETURN(ER_KILL_DENIED_ERROR); |
| 9283 | |
| 9284 | *rows= arg.counter; |
| 9285 | DBUG_RETURN(0); |
| 9286 | } |
| 9287 | |
| 9288 | |
| 9289 | /** |
no test coverage detected