hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From omal...@apache.org
Subject svn commit: r690096 [13/15] - in /hadoop/core/trunk: ./ src/contrib/thriftfs/ src/contrib/thriftfs/gen-cocoa/ src/contrib/thriftfs/gen-cpp/ src/contrib/thriftfs/gen-java/ src/contrib/thriftfs/gen-java/org/ src/contrib/thriftfs/gen-java/org/apache/ src/...
Date Fri, 29 Aug 2008 04:32:00 GMT
Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ThriftHadoopFileSystem.pyc
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ThriftHadoopFileSystem.pyc?rev=690096&view=auto
==============================================================================
Binary file - no diff available.

Propchange: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ThriftHadoopFileSystem.pyc
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.py?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.py (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.py Thu Aug 28 21:31:57 2008
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants', 'ThriftHadoopFileSystem']

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.pyc
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.pyc?rev=690096&view=auto
==============================================================================
Binary file - no diff available.

Propchange: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/__init__.pyc
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/constants.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/constants.py?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/constants.py (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/constants.py Thu Aug 28 21:31:57 2008
@@ -0,0 +1,9 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+from thrift.Thrift import *
+from ttypes import *
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.py?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.py (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.py Thu Aug 28 21:31:57 2008
@@ -0,0 +1,495 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+from thrift.Thrift import *
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol
+try:
+  from thrift.protocol import fastbinary
+except:
+  fastbinary = None
+
+
+class ThriftHandle:
+
+  thrift_spec = None
+  def __init__(self, d=None):
+    self.id = None
+    if isinstance(d, dict):
+      if 'id' in d:
+        self.id = d['id']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == -1:
+        if ftype == TType.I64:
+          self.id = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('ThriftHandle')
+    if self.id != None:
+      oprot.writeFieldBegin('id', TType.I64, -1)
+      oprot.writeI64(self.id)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+
+class Pathname:
+
+  thrift_spec = None
+  def __init__(self, d=None):
+    self.pathname = None
+    if isinstance(d, dict):
+      if 'pathname' in d:
+        self.pathname = d['pathname']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == -1:
+        if ftype == TType.STRING:
+          self.pathname = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('Pathname')
+    if self.pathname != None:
+      oprot.writeFieldBegin('pathname', TType.STRING, -1)
+      oprot.writeString(self.pathname)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+
+class FileStatus:
+
+  thrift_spec = (
+    None, # 0
+    (1, TType.STRING, 'path', None, None, ), # 1
+    (2, TType.I64, 'length', None, None, ), # 2
+    (3, TType.BOOL, 'isdir', None, None, ), # 3
+    (4, TType.I16, 'block_replication', None, None, ), # 4
+    (5, TType.I64, 'blocksize', None, None, ), # 5
+    (6, TType.I64, 'modification_time', None, None, ), # 6
+    (7, TType.STRING, 'permission', None, None, ), # 7
+    (8, TType.STRING, 'owner', None, None, ), # 8
+    (9, TType.STRING, 'group', None, None, ), # 9
+  )
+
+  def __init__(self, d=None):
+    self.path = None
+    self.length = None
+    self.isdir = None
+    self.block_replication = None
+    self.blocksize = None
+    self.modification_time = None
+    self.permission = None
+    self.owner = None
+    self.group = None
+    if isinstance(d, dict):
+      if 'path' in d:
+        self.path = d['path']
+      if 'length' in d:
+        self.length = d['length']
+      if 'isdir' in d:
+        self.isdir = d['isdir']
+      if 'block_replication' in d:
+        self.block_replication = d['block_replication']
+      if 'blocksize' in d:
+        self.blocksize = d['blocksize']
+      if 'modification_time' in d:
+        self.modification_time = d['modification_time']
+      if 'permission' in d:
+        self.permission = d['permission']
+      if 'owner' in d:
+        self.owner = d['owner']
+      if 'group' in d:
+        self.group = d['group']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.STRING:
+          self.path = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.length = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 3:
+        if ftype == TType.BOOL:
+          self.isdir = iprot.readBool();
+        else:
+          iprot.skip(ftype)
+      elif fid == 4:
+        if ftype == TType.I16:
+          self.block_replication = iprot.readI16();
+        else:
+          iprot.skip(ftype)
+      elif fid == 5:
+        if ftype == TType.I64:
+          self.blocksize = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 6:
+        if ftype == TType.I64:
+          self.modification_time = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 7:
+        if ftype == TType.STRING:
+          self.permission = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      elif fid == 8:
+        if ftype == TType.STRING:
+          self.owner = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      elif fid == 9:
+        if ftype == TType.STRING:
+          self.group = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('FileStatus')
+    if self.path != None:
+      oprot.writeFieldBegin('path', TType.STRING, 1)
+      oprot.writeString(self.path)
+      oprot.writeFieldEnd()
+    if self.length != None:
+      oprot.writeFieldBegin('length', TType.I64, 2)
+      oprot.writeI64(self.length)
+      oprot.writeFieldEnd()
+    if self.isdir != None:
+      oprot.writeFieldBegin('isdir', TType.BOOL, 3)
+      oprot.writeBool(self.isdir)
+      oprot.writeFieldEnd()
+    if self.block_replication != None:
+      oprot.writeFieldBegin('block_replication', TType.I16, 4)
+      oprot.writeI16(self.block_replication)
+      oprot.writeFieldEnd()
+    if self.blocksize != None:
+      oprot.writeFieldBegin('blocksize', TType.I64, 5)
+      oprot.writeI64(self.blocksize)
+      oprot.writeFieldEnd()
+    if self.modification_time != None:
+      oprot.writeFieldBegin('modification_time', TType.I64, 6)
+      oprot.writeI64(self.modification_time)
+      oprot.writeFieldEnd()
+    if self.permission != None:
+      oprot.writeFieldBegin('permission', TType.STRING, 7)
+      oprot.writeString(self.permission)
+      oprot.writeFieldEnd()
+    if self.owner != None:
+      oprot.writeFieldBegin('owner', TType.STRING, 8)
+      oprot.writeString(self.owner)
+      oprot.writeFieldEnd()
+    if self.group != None:
+      oprot.writeFieldBegin('group', TType.STRING, 9)
+      oprot.writeString(self.group)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+
+class BlockLocation:
+
+  thrift_spec = (
+    None, # 0
+    (1, TType.LIST, 'hosts', (TType.STRING,None), None, ), # 1
+    (2, TType.LIST, 'names', (TType.STRING,None), None, ), # 2
+    (3, TType.I64, 'offset', None, None, ), # 3
+    (4, TType.I64, 'length', None, None, ), # 4
+  )
+
+  def __init__(self, d=None):
+    self.hosts = None
+    self.names = None
+    self.offset = None
+    self.length = None
+    if isinstance(d, dict):
+      if 'hosts' in d:
+        self.hosts = d['hosts']
+      if 'names' in d:
+        self.names = d['names']
+      if 'offset' in d:
+        self.offset = d['offset']
+      if 'length' in d:
+        self.length = d['length']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.LIST:
+          self.hosts = []
+          (_etype3, _size0) = iprot.readListBegin()
+          for _i4 in xrange(_size0):
+            _elem5 = iprot.readString();
+            self.hosts.append(_elem5)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.LIST:
+          self.names = []
+          (_etype9, _size6) = iprot.readListBegin()
+          for _i10 in xrange(_size6):
+            _elem11 = iprot.readString();
+            self.names.append(_elem11)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      elif fid == 3:
+        if ftype == TType.I64:
+          self.offset = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 4:
+        if ftype == TType.I64:
+          self.length = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('BlockLocation')
+    if self.hosts != None:
+      oprot.writeFieldBegin('hosts', TType.LIST, 1)
+      oprot.writeListBegin(TType.STRING, len(self.hosts))
+      for iter12 in self.hosts:
+        oprot.writeString(iter12)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    if self.names != None:
+      oprot.writeFieldBegin('names', TType.LIST, 2)
+      oprot.writeListBegin(TType.STRING, len(self.names))
+      for iter13 in self.names:
+        oprot.writeString(iter13)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    if self.offset != None:
+      oprot.writeFieldBegin('offset', TType.I64, 3)
+      oprot.writeI64(self.offset)
+      oprot.writeFieldEnd()
+    if self.length != None:
+      oprot.writeFieldBegin('length', TType.I64, 4)
+      oprot.writeI64(self.length)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+
+class MalformedInputException(Exception):
+
+  thrift_spec = None
+  def __init__(self, d=None):
+    self.message = None
+    if isinstance(d, dict):
+      if 'message' in d:
+        self.message = d['message']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == -1:
+        if ftype == TType.STRING:
+          self.message = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('MalformedInputException')
+    if self.message != None:
+      oprot.writeFieldBegin('message', TType.STRING, -1)
+      oprot.writeString(self.message)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+
+class ThriftIOException(Exception):
+
+  thrift_spec = None
+  def __init__(self, d=None):
+    self.message = None
+    if isinstance(d, dict):
+      if 'message' in d:
+        self.message = d['message']
+
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == -1:
+        if ftype == TType.STRING:
+          self.message = iprot.readString();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('ThriftIOException')
+    if self.message != None:
+      oprot.writeFieldBegin('message', TType.STRING, -1)
+      oprot.writeString(self.message)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+
+  def __str__(self):
+    return str(self.__dict__)
+
+  def __repr__(self):
+    return repr(self.__dict__)
+
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+  def __ne__(self, other):
+    return not (self == other)
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.pyc
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.pyc?rev=690096&view=auto
==============================================================================
Binary file - no diff available.

Propchange: hadoop/core/trunk/src/contrib/thriftfs/gen-py/hadoopfs/ttypes.pyc
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-rb/ThriftHadoopFileSystem.rb
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-rb/ThriftHadoopFileSystem.rb?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-rb/ThriftHadoopFileSystem.rb (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-rb/ThriftHadoopFileSystem.rb Thu Aug 28 21:31:57 2008
@@ -0,0 +1,855 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift/protocol'
+require 'thrift'
+require 'hadoopfs_types'
+
+module ThriftHadoopFileSystem
+  class Client
+    include Thrift::Client
+
+    def setInactivityTimeoutPeriod(periodInSeconds)
+      send_setInactivityTimeoutPeriod(periodInSeconds)
+      recv_setInactivityTimeoutPeriod()
+    end
+
+    def send_setInactivityTimeoutPeriod(periodInSeconds)
+      send_message('setInactivityTimeoutPeriod', SetInactivityTimeoutPeriod_args, :periodInSeconds => periodInSeconds)
+    end
+
+    def recv_setInactivityTimeoutPeriod()
+      result = receive_message(SetInactivityTimeoutPeriod_result)
+      return
+    end
+
+    def shutdown(status)
+      send_shutdown(status)
+      recv_shutdown()
+    end
+
+    def send_shutdown(status)
+      send_message('shutdown', Shutdown_args, :status => status)
+    end
+
+    def recv_shutdown()
+      result = receive_message(Shutdown_result)
+      return
+    end
+
+    def create(path)
+      send_create(path)
+      return recv_create()
+    end
+
+    def send_create(path)
+      send_message('create', Create_args, :path => path)
+    end
+
+    def recv_create()
+      result = receive_message(Create_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'create failed: unknown result')
+    end
+
+    def createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
+      send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
+      return recv_createFile()
+    end
+
+    def send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
+      send_message('createFile', CreateFile_args, :path => path, :mode => mode, :overwrite => overwrite, :bufferSize => bufferSize, :block_replication => block_replication, :blocksize => blocksize)
+    end
+
+    def recv_createFile()
+      result = receive_message(CreateFile_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'createFile failed: unknown result')
+    end
+
+    def open(path)
+      send_open(path)
+      return recv_open()
+    end
+
+    def send_open(path)
+      send_message('open', Open_args, :path => path)
+    end
+
+    def recv_open()
+      result = receive_message(Open_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'open failed: unknown result')
+    end
+
+    def append(path)
+      send_append(path)
+      return recv_append()
+    end
+
+    def send_append(path)
+      send_message('append', Append_args, :path => path)
+    end
+
+    def recv_append()
+      result = receive_message(Append_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result')
+    end
+
+    def write(handle, data)
+      send_write(handle, data)
+      return recv_write()
+    end
+
+    def send_write(handle, data)
+      send_message('write', Write_args, :handle => handle, :data => data)
+    end
+
+    def recv_write()
+      result = receive_message(Write_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'write failed: unknown result')
+    end
+
+    def read(handle, offset, size)
+      send_read(handle, offset, size)
+      return recv_read()
+    end
+
+    def send_read(handle, offset, size)
+      send_message('read', Read_args, :handle => handle, :offset => offset, :size => size)
+    end
+
+    def recv_read()
+      result = receive_message(Read_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'read failed: unknown result')
+    end
+
+    def close(out)
+      send_close(out)
+      return recv_close()
+    end
+
+    def send_close(out)
+      send_message('close', Close_args, :out => out)
+    end
+
+    def recv_close()
+      result = receive_message(Close_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'close failed: unknown result')
+    end
+
+    def rm(path, recursive)
+      send_rm(path, recursive)
+      return recv_rm()
+    end
+
+    def send_rm(path, recursive)
+      send_message('rm', Rm_args, :path => path, :recursive => recursive)
+    end
+
+    def recv_rm()
+      result = receive_message(Rm_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rm failed: unknown result')
+    end
+
+    def rename(path, dest)
+      send_rename(path, dest)
+      return recv_rename()
+    end
+
+    def send_rename(path, dest)
+      send_message('rename', Rename_args, :path => path, :dest => dest)
+    end
+
+    def recv_rename()
+      result = receive_message(Rename_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rename failed: unknown result')
+    end
+
+    def mkdirs(path)
+      send_mkdirs(path)
+      return recv_mkdirs()
+    end
+
+    def send_mkdirs(path)
+      send_message('mkdirs', Mkdirs_args, :path => path)
+    end
+
+    def recv_mkdirs()
+      result = receive_message(Mkdirs_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'mkdirs failed: unknown result')
+    end
+
+    def exists(path)
+      send_exists(path)
+      return recv_exists()
+    end
+
+    def send_exists(path)
+      send_message('exists', Exists_args, :path => path)
+    end
+
+    def recv_exists()
+      result = receive_message(Exists_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'exists failed: unknown result')
+    end
+
+    def stat(path)
+      send_stat(path)
+      return recv_stat()
+    end
+
+    def send_stat(path)
+      send_message('stat', Stat_args, :path => path)
+    end
+
+    def recv_stat()
+      result = receive_message(Stat_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'stat failed: unknown result')
+    end
+
+    def listStatus(path)
+      send_listStatus(path)
+      return recv_listStatus()
+    end
+
+    def send_listStatus(path)
+      send_message('listStatus', ListStatus_args, :path => path)
+    end
+
+    def recv_listStatus()
+      result = receive_message(ListStatus_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'listStatus failed: unknown result')
+    end
+
+    def chmod(path, mode)
+      send_chmod(path, mode)
+      recv_chmod()
+    end
+
+    def send_chmod(path, mode)
+      send_message('chmod', Chmod_args, :path => path, :mode => mode)
+    end
+
+    def recv_chmod()
+      result = receive_message(Chmod_result)
+      raise result.ouch unless result.ouch.nil?
+      return
+    end
+
+    def chown(path, owner, group)
+      send_chown(path, owner, group)
+      recv_chown()
+    end
+
+    def send_chown(path, owner, group)
+      send_message('chown', Chown_args, :path => path, :owner => owner, :group => group)
+    end
+
+    def recv_chown()
+      result = receive_message(Chown_result)
+      raise result.ouch unless result.ouch.nil?
+      return
+    end
+
+    def setReplication(path, replication)
+      send_setReplication(path, replication)
+      recv_setReplication()
+    end
+
+    def send_setReplication(path, replication)
+      send_message('setReplication', SetReplication_args, :path => path, :replication => replication)
+    end
+
+    def recv_setReplication()
+      result = receive_message(SetReplication_result)
+      raise result.ouch unless result.ouch.nil?
+      return
+    end
+
+    def getFileBlockLocations(path, start, length)
+      send_getFileBlockLocations(path, start, length)
+      return recv_getFileBlockLocations()
+    end
+
+    def send_getFileBlockLocations(path, start, length)
+      send_message('getFileBlockLocations', GetFileBlockLocations_args, :path => path, :start => start, :length => length)
+    end
+
+    def recv_getFileBlockLocations()
+      result = receive_message(GetFileBlockLocations_result)
+      return result.success unless result.success.nil?
+      raise result.ouch unless result.ouch.nil?
+      raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'getFileBlockLocations failed: unknown result')
+    end
+
+  end
+
+  class Processor
+    include Thrift::Processor
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+    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
+
+  end
+
+  # HELPER FUNCTIONS AND STRUCTURES
+
+  class SetInactivityTimeoutPeriod_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :periodInSeconds
+    FIELDS = {
+      1 => {:type => Thrift::Types::I64, :name => 'periodInSeconds'}
+    }
+  end
+
+  class SetInactivityTimeoutPeriod_result
+    include Thrift::Struct
+    FIELDS = {
+
+    }
+  end
+
+  class Shutdown_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :status
+    FIELDS = {
+      1 => {:type => Thrift::Types::I32, :name => 'status'}
+    }
+  end
+
+  class Shutdown_result
+    include Thrift::Struct
+    FIELDS = {
+
+    }
+  end
+
+  class Create_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Create_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class CreateFile_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :mode, :overwrite, :bufferSize, :block_replication, :blocksize
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::I16, :name => 'mode'},
+      3 => {:type => Thrift::Types::BOOL, :name => 'overwrite'},
+      4 => {:type => Thrift::Types::I32, :name => 'bufferSize'},
+      5 => {:type => Thrift::Types::I16, :name => 'block_replication'},
+      6 => {:type => Thrift::Types::I64, :name => 'blocksize'}
+    }
+  end
+
+  class CreateFile_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Open_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Open_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Append_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Append_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Write_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :handle, :data
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle},
+      -1 => {:type => Thrift::Types::STRING, :name => 'data'}
+    }
+  end
+
+  class Write_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Read_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :handle, :offset, :size
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle},
+      -1 => {:type => Thrift::Types::I64, :name => 'offset'},
+      -2 => {:type => Thrift::Types::I32, :name => 'size'}
+    }
+  end
+
+  class Read_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRING, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Close_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :out
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'out', :class => ThriftHandle}
+    }
+  end
+
+  class Close_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Rm_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :recursive
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::BOOL, :name => 'recursive'}
+    }
+  end
+
+  class Rm_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Rename_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :dest
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::STRUCT, :name => 'dest', :class => Pathname}
+    }
+  end
+
+  class Rename_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Mkdirs_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Mkdirs_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Exists_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Exists_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::BOOL, :name => 'success'},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Stat_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class Stat_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => FileStatus},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class ListStatus_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
+    }
+  end
+
+  class ListStatus_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => FileStatus}},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Chmod_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :mode
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::I16, :name => 'mode'}
+    }
+  end
+
+  class Chmod_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :ouch
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class Chown_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :owner, :group
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::STRING, :name => 'owner'},
+      3 => {:type => Thrift::Types::STRING, :name => 'group'}
+    }
+  end
+
+  class Chown_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :ouch
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class SetReplication_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :replication
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::I16, :name => 'replication'}
+    }
+  end
+
+  class SetReplication_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :ouch
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+  class GetFileBlockLocations_args
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :path, :start, :length
+    FIELDS = {
+      1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
+      2 => {:type => Thrift::Types::I64, :name => 'start'},
+      3 => {:type => Thrift::Types::I64, :name => 'length'}
+    }
+  end
+
+  class GetFileBlockLocations_result
+    include Thrift::Struct
+    Thrift::Struct.field_accessor self, :success, :ouch
+    FIELDS = {
+      0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => BlockLocation}},
+      1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
+    }
+  end
+
+end
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_constants.rb
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_constants.rb?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_constants.rb (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_constants.rb Thu Aug 28 21:31:57 2008
@@ -0,0 +1,9 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift/protocol'
+require 'hadoopfs_types'
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_types.rb
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_types.rb?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_types.rb (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-rb/hadoopfs_types.rb Thu Aug 28 21:31:57 2008
@@ -0,0 +1,77 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift/protocol'
+
+class ThriftHandle
+  include Thrift::Struct
+  Thrift::Struct.field_accessor self, :id
+  FIELDS = {
+    -1 => {:type => Thrift::Types::I64, :name => 'id'}
+  }
+end
+
+class Pathname
+  include Thrift::Struct
+  Thrift::Struct.field_accessor self, :pathname
+  FIELDS = {
+    -1 => {:type => Thrift::Types::STRING, :name => 'pathname'}
+  }
+end
+
+class FileStatus
+  include Thrift::Struct
+  Thrift::Struct.field_accessor self, :path, :length, :isdir, :block_replication, :blocksize, :modification_time, :permission, :owner, :group
+  FIELDS = {
+    1 => {:type => Thrift::Types::STRING, :name => 'path'},
+    2 => {:type => Thrift::Types::I64, :name => 'length'},
+    3 => {:type => Thrift::Types::BOOL, :name => 'isdir'},
+    4 => {:type => Thrift::Types::I16, :name => 'block_replication'},
+    5 => {:type => Thrift::Types::I64, :name => 'blocksize'},
+    6 => {:type => Thrift::Types::I64, :name => 'modification_time'},
+    7 => {:type => Thrift::Types::STRING, :name => 'permission'},
+    8 => {:type => Thrift::Types::STRING, :name => 'owner'},
+    9 => {:type => Thrift::Types::STRING, :name => 'group'}
+  }
+end
+
+class BlockLocation
+  include Thrift::Struct
+  Thrift::Struct.field_accessor self, :hosts, :names, :offset, :length
+  FIELDS = {
+    1 => {:type => Thrift::Types::LIST, :name => 'hosts', :element => {:type => Thrift::Types::STRING}},
+    2 => {:type => Thrift::Types::LIST, :name => 'names', :element => {:type => Thrift::Types::STRING}},
+    3 => {:type => Thrift::Types::I64, :name => 'offset'},
+    4 => {:type => Thrift::Types::I64, :name => 'length'}
+  }
+end
+
+class MalformedInputException < StandardError
+  include Thrift::Struct
+  def initialize(message=nil)
+    super()
+    self.message = message
+  end
+
+  Thrift::Struct.field_accessor self, :message
+  FIELDS = {
+    -1 => {:type => Thrift::Types::STRING, :name => 'message'}
+  }
+end
+
+class ThriftIOException < StandardError
+  include Thrift::Struct
+  def initialize(message=nil)
+    super()
+    self.message = message
+  end
+
+  Thrift::Struct.field_accessor self, :message
+  FIELDS = {
+    -1 => {:type => Thrift::Types::STRING, :name => 'message'}
+  }
+end
+



Mime
View raw message