ThriftHadoopFileSystem::Processor

# File lib/thrift/thrift_hadoop_file_system.rb, line 363
def process_append(seqid, iprot, oprot)
  args = read_args(iprot, Append_args)
  result = Append_result.new()
  begin
    result.success = @handler.append(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'append', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 473
def process_chmod(seqid, iprot, oprot)
  args = read_args(iprot, Chmod_args)
  result = Chmod_result.new()
  begin
    @handler.chmod(args.path, args.mode)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'chmod', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 484
def process_chown(seqid, iprot, oprot)
  args = read_args(iprot, Chown_args)
  result = Chown_result.new()
  begin
    @handler.chown(args.path, args.owner, args.group)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'chown', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 396
def process_close(seqid, iprot, oprot)
  args = read_args(iprot, Close_args)
  result = Close_result.new()
  begin
    result.success = @handler.close(args.out)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'close', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 330
def process_create(seqid, iprot, oprot)
  args = read_args(iprot, Create_args)
  result = Create_result.new()
  begin
    result.success = @handler.create(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'create', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 341
def process_createFile(seqid, iprot, oprot)
  args = read_args(iprot, CreateFile_args)
  result = CreateFile_result.new()
  begin
    result.success = @handler.createFile(args.path, args.mode, args.overwrite, args.bufferSize, args.block_replication, args.blocksize)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'createFile', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 440
def process_exists(seqid, iprot, oprot)
  args = read_args(iprot, Exists_args)
  result = Exists_result.new()
  begin
    result.success = @handler.exists(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'exists', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 506
def process_getFileBlockLocations(seqid, iprot, oprot)
  args = read_args(iprot, GetFileBlockLocations_args)
  result = GetFileBlockLocations_result.new()
  begin
    result.success = @handler.getFileBlockLocations(args.path, args.start, args.length)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'getFileBlockLocations', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 462
def process_listStatus(seqid, iprot, oprot)
  args = read_args(iprot, ListStatus_args)
  result = ListStatus_result.new()
  begin
    result.success = @handler.listStatus(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'listStatus', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 429
def process_mkdirs(seqid, iprot, oprot)
  args = read_args(iprot, Mkdirs_args)
  result = Mkdirs_result.new()
  begin
    result.success = @handler.mkdirs(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'mkdirs', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 352
def process_open(seqid, iprot, oprot)
  args = read_args(iprot, Open_args)
  result = Open_result.new()
  begin
    result.success = @handler.open(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'open', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 385
def process_read(seqid, iprot, oprot)
  args = read_args(iprot, Read_args)
  result = Read_result.new()
  begin
    result.success = @handler.read(args.handle, args.offset, args.size)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'read', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 418
def process_rename(seqid, iprot, oprot)
  args = read_args(iprot, Rename_args)
  result = Rename_result.new()
  begin
    result.success = @handler.rename(args.path, args.dest)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'rename', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 407
def process_rm(seqid, iprot, oprot)
  args = read_args(iprot, Rm_args)
  result = Rm_result.new()
  begin
    result.success = @handler.rm(args.path, args.recursive)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'rm', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 316
def process_setInactivityTimeoutPeriod(seqid, iprot, oprot)
  args = read_args(iprot, SetInactivityTimeoutPeriod_args)
  result = SetInactivityTimeoutPeriod_result.new()
  @handler.setInactivityTimeoutPeriod(args.periodInSeconds)
  write_result(result, oprot, 'setInactivityTimeoutPeriod', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 495
def process_setReplication(seqid, iprot, oprot)
  args = read_args(iprot, SetReplication_args)
  result = SetReplication_result.new()
  begin
    @handler.setReplication(args.path, args.replication)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'setReplication', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 323
def process_shutdown(seqid, iprot, oprot)
  args = read_args(iprot, Shutdown_args)
  result = Shutdown_result.new()
  @handler.shutdown(args.status)
  write_result(result, oprot, 'shutdown', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 451
def process_stat(seqid, iprot, oprot)
  args = read_args(iprot, Stat_args)
  result = Stat_result.new()
  begin
    result.success = @handler.stat(args.path)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'stat', seqid)
end

# File lib/thrift/thrift_hadoop_file_system.rb, line 374
def process_write(seqid, iprot, oprot)
  args = read_args(iprot, Write_args)
  result = Write_result.new()
  begin
    result.success = @handler.write(args.handle, args.data)
  rescue ThriftIOException => ouch
    result.ouch = ouch
  end
  write_result(result, oprot, 'write', seqid)
end