Acquires locks for the specified job. @param job job to be queued @param ctx database context of client
(final Job job, final Context ctx)
| 82 | * @param ctx database context of client |
| 83 | */ |
| 84 | public void acquire(final Job job, final Context ctx) { |
| 85 | // collect lock strings |
| 86 | job.addLocks(); |
| 87 | // prepare lock strings and acquire locks |
| 88 | try { |
| 89 | acquire(job.jc().locks.finish(ctx)); |
| 90 | } catch(final InterruptedException ex) { |
| 91 | throw Util.notExpected("Thread was interrupted: %", ex); |
| 92 | } |
| 93 | } |
| 94 | |
| 95 | /** |
| 96 | * Puts read and write locks for the specified lock lists. |