Unpause clients and queue them for reprocessing. */
| 3359 | |
| 3360 | /* Unpause clients and queue them for reprocessing. */ |
| 3361 | void unpauseClients(void) { |
| 3362 | listNode *ln; |
| 3363 | listIter li; |
| 3364 | client *c; |
| 3365 | |
| 3366 | server.client_pause_type = CLIENT_PAUSE_OFF; |
| 3367 | server.client_pause_end_time = 0; |
| 3368 | |
| 3369 | /* Unblock all of the clients so they are reprocessed. */ |
| 3370 | listRewind(server.paused_clients,&li); |
| 3371 | while ((ln = listNext(&li)) != NULL) { |
| 3372 | c = listNodeValue(ln); |
| 3373 | unblockClient(c); |
| 3374 | } |
| 3375 | } |
| 3376 | |
| 3377 | /* Returns true if clients are paused and false otherwise. */ |
| 3378 | int areClientsPaused(void) { |
no test coverage detected