Lines Matching refs:retry
2221 } retry; variable
2225 struct retry_worker *retry = container_of(ws, struct retry_worker, worker); in do_retry() local
2229 spin_lock_irq(&retry->lock); in do_retry()
2230 list_splice_init(&retry->writes, &writes); in do_retry()
2231 spin_unlock_irq(&retry->lock); in do_retry()
2280 spin_lock_irqsave(&retry.lock, flags); in drbd_restart_request()
2281 list_move_tail(&req->tl_requests, &retry.writes); in drbd_restart_request()
2282 spin_unlock_irqrestore(&retry.lock, flags); in drbd_restart_request()
2289 queue_work(retry.wq, &retry.worker); in drbd_restart_request()
2334 if (retry.wq) in drbd_cleanup()
2335 destroy_workqueue(retry.wq); in drbd_cleanup()
2946 retry.wq = create_singlethread_workqueue("drbd-reissue"); in drbd_init()
2947 if (!retry.wq) { in drbd_init()
2951 INIT_WORK(&retry.worker, do_retry); in drbd_init()
2952 spin_lock_init(&retry.lock); in drbd_init()
2953 INIT_LIST_HEAD(&retry.writes); in drbd_init()