@@ -256,7 +256,7 @@ def process_next_entry
256
256
# operation was successful.
257
257
def on_opendir ( response )
258
258
entry = response . request [ :entry ]
259
- raise "opendir #{ entry . remote } : #{ response } " unless response . ok?
259
+ raise StatusException . new ( response , "opendir #{ entry . remote } " ) unless response . ok?
260
260
entry . handle = response [ :handle ]
261
261
request = sftp . readdir ( response [ :handle ] , &method ( :on_readdir ) )
262
262
request [ :parent ] = entry
@@ -271,7 +271,7 @@ def on_readdir(response)
271
271
request = sftp . close ( entry . handle , &method ( :on_closedir ) )
272
272
request [ :parent ] = entry
273
273
elsif !response . ok?
274
- raise "readdir #{ entry . remote } : #{ response } "
274
+ raise StatusException . new ( response , "readdir #{ entry . remote } " )
275
275
else
276
276
response [ :names ] . each do |item |
277
277
next if item . name == "." || item . name == ".."
@@ -297,15 +297,15 @@ def open_file(entry)
297
297
def on_closedir ( response )
298
298
@active -= 1
299
299
entry = response . request [ :parent ]
300
- raise "close #{ entry . remote } : #{ response } " unless response . ok?
300
+ raise StatusException . new ( response , "close #{ entry . remote } " ) unless response . ok?
301
301
process_next_entry
302
302
end
303
303
304
304
# Called when a file has been opened. This will call #download_next_chunk
305
305
# to initiate the data transfer.
306
306
def on_open ( response )
307
307
entry = response . request [ :entry ]
308
- raise "open #{ entry . remote } : #{ response } " unless response . ok?
308
+ raise StatusException . new ( response , "open #{ entry . remote } " ) unless response . ok?
309
309
310
310
entry . handle = response [ :handle ]
311
311
entry . sink = entry . local . respond_to? ( :write ) ? entry . local : ::File . open ( entry . local , "wb" )
@@ -333,7 +333,7 @@ def on_read(response)
333
333
request = sftp . close ( entry . handle , &method ( :on_close ) )
334
334
request [ :entry ] = entry
335
335
elsif !response . ok?
336
- raise "read #{ entry . remote } : #{ response } "
336
+ raise StatusException . new ( response , "read #{ entry . remote } " )
337
337
else
338
338
entry . offset += response [ :data ] . bytesize
339
339
update_progress ( :get , entry , response . request [ :offset ] , response [ :data ] )
@@ -346,7 +346,7 @@ def on_read(response)
346
346
def on_close ( response )
347
347
@active -= 1
348
348
entry = response . request [ :entry ]
349
- raise "close #{ entry . remote } : #{ response } " unless response . ok?
349
+ raise StatusException . new ( response , "close #{ entry . remote } " ) unless response . ok?
350
350
process_next_entry
351
351
end
352
352
0 commit comments