lib/acfs/runner.rb in acfs-0.40.1.rc1 vs lib/acfs/runner.rb in acfs-0.41.0
- old
+ new
@@ -57,26 +57,30 @@
#
def start
return if running?
enqueue_operations
-
- @running = true
- adapter.start
+ start_all
rescue
queue.clear
raise
- ensure
- @running = false
end
def clear
queue.clear
adapter.abort
@running = false
end
private
+
+ def start_all
+ @running = true
+ adapter.start
+ ensure
+ @running = false
+ end
+
def enqueue_operations
while (op = queue.shift)
op_request(op) { |req| adapter.queue req }
end
end