Method: Pmux::MultiSession#process_scp_queue_once

Defined in:
lib/pmux/multi_session.rb

#process_scp_queue_once(addr) ⇒ Object



231
232
233
234
235
236
237
238
239
240
241
242
243
# File 'lib/pmux/multi_session.rb', line 231

def process_scp_queue_once addr
  scp = @sessions[addr].scp
  queue = (@scp_queue[addr] ||= [])
  if scp and !queue.empty?
    updown, future, addr, remote, local, options = queue.shift
    case updown
    when :down
      scp_download_sub scp, addr, future, remote, local, options
    when :up
      scp_upload_sub scp, addr, future, local, remote, options
    end
  end
end