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 [5/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/c...
Date Fri, 29 Aug 2008 04:32:00 GMT
Added: hadoop/core/trunk/src/contrib/thriftfs/gen-cpp/hadoopfs_types.h
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-cpp/hadoopfs_types.h?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-cpp/hadoopfs_types.h (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-cpp/hadoopfs_types.h Thu Aug 28 21:31:57 2008
@@ -0,0 +1,274 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+#ifndef hadoopfs_TYPES_H
+#define hadoopfs_TYPES_H
+
+#include <Thrift.h>
+#include <reflection_limited_types.h>
+#include <protocol/TProtocol.h>
+#include <transport/TTransport.h>
+
+
+
+
+
+class ThriftHandle {
+ public:
+
+  static const char* ascii_fingerprint; // = "2317B51D4172A111734AAB85F990F7C6";
+  static const uint8_t binary_fingerprint[16]; // = {0x23,0x17,0xB5,0x1D,0x41,0x72,0xA1,0x11,0x73,0x4A,0xAB,0x85,0xF9,0x90,0xF7,0xC6};
+
+  ThriftHandle() : id(0) {
+  }
+
+  virtual ~ThriftHandle() throw() {}
+
+  int64_t id;
+
+  struct __isset {
+    __isset() : id(false) {}
+    bool id;
+  } __isset;
+
+  bool operator == (const ThriftHandle & rhs) const
+  {
+    if (!(id == rhs.id))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftHandle &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftHandle & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+class Pathname {
+ public:
+
+  static const char* ascii_fingerprint; // = "E2167DA91A8F7459A2FE1B5F56D14B5D";
+  static const uint8_t binary_fingerprint[16]; // = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
+
+  Pathname() : pathname("") {
+  }
+
+  virtual ~Pathname() throw() {}
+
+  std::string pathname;
+
+  struct __isset {
+    __isset() : pathname(false) {}
+    bool pathname;
+  } __isset;
+
+  bool operator == (const Pathname & rhs) const
+  {
+    if (!(pathname == rhs.pathname))
+      return false;
+    return true;
+  }
+  bool operator != (const Pathname &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const Pathname & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+class FileStatus {
+ public:
+
+  static const char* ascii_fingerprint; // = "68FE7242A6727149B291A86FB9570D2B";
+  static const uint8_t binary_fingerprint[16]; // = {0x68,0xFE,0x72,0x42,0xA6,0x72,0x71,0x49,0xB2,0x91,0xA8,0x6F,0xB9,0x57,0x0D,0x2B};
+
+  FileStatus() : path(""), length(0), isdir(0), block_replication(0), blocksize(0), modification_time(0),
permission(""), owner(""), group("") {
+  }
+
+  virtual ~FileStatus() throw() {}
+
+  std::string path;
+  int64_t length;
+  bool isdir;
+  int16_t block_replication;
+  int64_t blocksize;
+  int64_t modification_time;
+  std::string permission;
+  std::string owner;
+  std::string group;
+
+  struct __isset {
+    __isset() : path(false), length(false), isdir(false), block_replication(false), blocksize(false),
modification_time(false), permission(false), owner(false), group(false) {}
+    bool path;
+    bool length;
+    bool isdir;
+    bool block_replication;
+    bool blocksize;
+    bool modification_time;
+    bool permission;
+    bool owner;
+    bool group;
+  } __isset;
+
+  bool operator == (const FileStatus & rhs) const
+  {
+    if (!(path == rhs.path))
+      return false;
+    if (!(length == rhs.length))
+      return false;
+    if (!(isdir == rhs.isdir))
+      return false;
+    if (!(block_replication == rhs.block_replication))
+      return false;
+    if (!(blocksize == rhs.blocksize))
+      return false;
+    if (!(modification_time == rhs.modification_time))
+      return false;
+    if (!(permission == rhs.permission))
+      return false;
+    if (!(owner == rhs.owner))
+      return false;
+    if (!(group == rhs.group))
+      return false;
+    return true;
+  }
+  bool operator != (const FileStatus &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const FileStatus & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+class BlockLocation {
+ public:
+
+  static const char* ascii_fingerprint; // = "8BF3B16BED96367B21783389BDF8B1C0";
+  static const uint8_t binary_fingerprint[16]; // = {0x8B,0xF3,0xB1,0x6B,0xED,0x96,0x36,0x7B,0x21,0x78,0x33,0x89,0xBD,0xF8,0xB1,0xC0};
+
+  BlockLocation() : offset(0), length(0) {
+  }
+
+  virtual ~BlockLocation() throw() {}
+
+  std::vector<std::string>  hosts;
+  std::vector<std::string>  names;
+  int64_t offset;
+  int64_t length;
+
+  struct __isset {
+    __isset() : hosts(false), names(false), offset(false), length(false) {}
+    bool hosts;
+    bool names;
+    bool offset;
+    bool length;
+  } __isset;
+
+  bool operator == (const BlockLocation & rhs) const
+  {
+    if (!(hosts == rhs.hosts))
+      return false;
+    if (!(names == rhs.names))
+      return false;
+    if (!(offset == rhs.offset))
+      return false;
+    if (!(length == rhs.length))
+      return false;
+    return true;
+  }
+  bool operator != (const BlockLocation &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const BlockLocation & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+class MalformedInputException : public facebook::thrift::TException {
+ public:
+
+  static const char* ascii_fingerprint; // = "E2167DA91A8F7459A2FE1B5F56D14B5D";
+  static const uint8_t binary_fingerprint[16]; // = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
+
+  MalformedInputException() : message("") {
+  }
+
+  virtual ~MalformedInputException() throw() {}
+
+  std::string message;
+
+  struct __isset {
+    __isset() : message(false) {}
+    bool message;
+  } __isset;
+
+  bool operator == (const MalformedInputException & rhs) const
+  {
+    if (!(message == rhs.message))
+      return false;
+    return true;
+  }
+  bool operator != (const MalformedInputException &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const MalformedInputException & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+class ThriftIOException : public facebook::thrift::TException {
+ public:
+
+  static const char* ascii_fingerprint; // = "E2167DA91A8F7459A2FE1B5F56D14B5D";
+  static const uint8_t binary_fingerprint[16]; // = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
+
+  ThriftIOException() : message("") {
+  }
+
+  virtual ~ThriftIOException() throw() {}
+
+  std::string message;
+
+  struct __isset {
+    __isset() : message(false) {}
+    bool message;
+  } __isset;
+
+  bool operator == (const ThriftIOException & rhs) const
+  {
+    if (!(message == rhs.message))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftIOException &rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftIOException & ) const;
+
+  uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
+  uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+
+#endif

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/BlockLocation.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/BlockLocation.java?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/BlockLocation.java
(added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/BlockLocation.java
Thu Aug 28 21:31:57 2008
@@ -0,0 +1,243 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.thriftfs.api;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import com.facebook.thrift.*;
+
+import com.facebook.thrift.protocol.*;
+import com.facebook.thrift.transport.*;
+
+public class BlockLocation implements TBase, java.io.Serializable {
+  public List<String> hosts;
+  public List<String> names;
+  public long offset;
+  public long length;
+
+  public final Isset __isset = new Isset();
+  public static final class Isset implements java.io.Serializable {
+    public boolean hosts = false;
+    public boolean names = false;
+    public boolean offset = false;
+    public boolean length = false;
+  }
+
+  public BlockLocation() {
+  }
+
+  public BlockLocation(
+    List<String> hosts,
+    List<String> names,
+    long offset,
+    long length)
+  {
+    this();
+    this.hosts = hosts;
+    this.__isset.hosts = true;
+    this.names = names;
+    this.__isset.names = true;
+    this.offset = offset;
+    this.__isset.offset = true;
+    this.length = length;
+    this.__isset.length = true;
+  }
+
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof BlockLocation)
+      return this.equals((BlockLocation)that);
+    return false;
+  }
+
+  public boolean equals(BlockLocation that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_hosts = true && (this.hosts != null);
+    boolean that_present_hosts = true && (that.hosts != null);
+    if (this_present_hosts || that_present_hosts) {
+      if (!(this_present_hosts && that_present_hosts))
+        return false;
+      if (!this.hosts.equals(that.hosts))
+        return false;
+    }
+
+    boolean this_present_names = true && (this.names != null);
+    boolean that_present_names = true && (that.names != null);
+    if (this_present_names || that_present_names) {
+      if (!(this_present_names && that_present_names))
+        return false;
+      if (!this.names.equals(that.names))
+        return false;
+    }
+
+    boolean this_present_offset = true;
+    boolean that_present_offset = true;
+    if (this_present_offset || that_present_offset) {
+      if (!(this_present_offset && that_present_offset))
+        return false;
+      if (this.offset != that.offset)
+        return false;
+    }
+
+    boolean this_present_length = true;
+    boolean that_present_length = true;
+    if (this_present_length || that_present_length) {
+      if (!(this_present_length && that_present_length))
+        return false;
+      if (this.length != that.length)
+        return false;
+    }
+
+    return true;
+  }
+
+  public int hashCode() {
+    return 0;
+  }
+
+  public void read(TProtocol iprot) throws TException {
+    TField field;
+    iprot.readStructBegin();
+    while (true)
+    {
+      field = iprot.readFieldBegin();
+      if (field.type == TType.STOP) { 
+        break;
+      }
+      switch (field.id)
+      {
+        case 1:
+          if (field.type == TType.LIST) {
+            {
+              TList _list0 = iprot.readListBegin();
+              this.hosts = new ArrayList<String>(_list0.size);
+              for (int _i1 = 0; _i1 < _list0.size; ++_i1)
+              {
+                String _elem2 = null;
+                _elem2 = iprot.readString();
+                this.hosts.add(_elem2);
+              }
+              iprot.readListEnd();
+            }
+            this.__isset.hosts = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 2:
+          if (field.type == TType.LIST) {
+            {
+              TList _list3 = iprot.readListBegin();
+              this.names = new ArrayList<String>(_list3.size);
+              for (int _i4 = 0; _i4 < _list3.size; ++_i4)
+              {
+                String _elem5 = null;
+                _elem5 = iprot.readString();
+                this.names.add(_elem5);
+              }
+              iprot.readListEnd();
+            }
+            this.__isset.names = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 3:
+          if (field.type == TType.I64) {
+            this.offset = iprot.readI64();
+            this.__isset.offset = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 4:
+          if (field.type == TType.I64) {
+            this.length = iprot.readI64();
+            this.__isset.length = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        default:
+          TProtocolUtil.skip(iprot, field.type);
+          break;
+      }
+      iprot.readFieldEnd();
+    }
+    iprot.readStructEnd();
+  }
+
+  public void write(TProtocol oprot) throws TException {
+    TStruct struct = new TStruct("BlockLocation");
+    oprot.writeStructBegin(struct);
+    TField field = new TField();
+    if (this.hosts != null) {
+      field.name = "hosts";
+      field.type = TType.LIST;
+      field.id = 1;
+      oprot.writeFieldBegin(field);
+      {
+        oprot.writeListBegin(new TList(TType.STRING, this.hosts.size()));
+        for (String _iter6 : this.hosts)        {
+          oprot.writeString(_iter6);
+        }
+        oprot.writeListEnd();
+      }
+      oprot.writeFieldEnd();
+    }
+    if (this.names != null) {
+      field.name = "names";
+      field.type = TType.LIST;
+      field.id = 2;
+      oprot.writeFieldBegin(field);
+      {
+        oprot.writeListBegin(new TList(TType.STRING, this.names.size()));
+        for (String _iter7 : this.names)        {
+          oprot.writeString(_iter7);
+        }
+        oprot.writeListEnd();
+      }
+      oprot.writeFieldEnd();
+    }
+    field.name = "offset";
+    field.type = TType.I64;
+    field.id = 3;
+    oprot.writeFieldBegin(field);
+    oprot.writeI64(this.offset);
+    oprot.writeFieldEnd();
+    field.name = "length";
+    field.type = TType.I64;
+    field.id = 4;
+    oprot.writeFieldBegin(field);
+    oprot.writeI64(this.length);
+    oprot.writeFieldEnd();
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  public String toString() {
+    StringBuilder sb = new StringBuilder("BlockLocation(");
+    sb.append("hosts:");
+    sb.append(this.hosts);
+    sb.append(",names:");
+    sb.append(this.names);
+    sb.append(",offset:");
+    sb.append(this.offset);
+    sb.append(",length:");
+    sb.append(this.length);
+    sb.append(")");
+    return sb.toString();
+  }
+
+}
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/FileStatus.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/FileStatus.java?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/FileStatus.java
(added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/FileStatus.java
Thu Aug 28 21:31:57 2008
@@ -0,0 +1,365 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.thriftfs.api;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import com.facebook.thrift.*;
+
+import com.facebook.thrift.protocol.*;
+import com.facebook.thrift.transport.*;
+
+public class FileStatus implements TBase, java.io.Serializable {
+  public String path;
+  public long length;
+  public boolean isdir;
+  public short block_replication;
+  public long blocksize;
+  public long modification_time;
+  public String permission;
+  public String owner;
+  public String group;
+
+  public final Isset __isset = new Isset();
+  public static final class Isset implements java.io.Serializable {
+    public boolean path = false;
+    public boolean length = false;
+    public boolean isdir = false;
+    public boolean block_replication = false;
+    public boolean blocksize = false;
+    public boolean modification_time = false;
+    public boolean permission = false;
+    public boolean owner = false;
+    public boolean group = false;
+  }
+
+  public FileStatus() {
+  }
+
+  public FileStatus(
+    String path,
+    long length,
+    boolean isdir,
+    short block_replication,
+    long blocksize,
+    long modification_time,
+    String permission,
+    String owner,
+    String group)
+  {
+    this();
+    this.path = path;
+    this.__isset.path = true;
+    this.length = length;
+    this.__isset.length = true;
+    this.isdir = isdir;
+    this.__isset.isdir = true;
+    this.block_replication = block_replication;
+    this.__isset.block_replication = true;
+    this.blocksize = blocksize;
+    this.__isset.blocksize = true;
+    this.modification_time = modification_time;
+    this.__isset.modification_time = true;
+    this.permission = permission;
+    this.__isset.permission = true;
+    this.owner = owner;
+    this.__isset.owner = true;
+    this.group = group;
+    this.__isset.group = true;
+  }
+
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof FileStatus)
+      return this.equals((FileStatus)that);
+    return false;
+  }
+
+  public boolean equals(FileStatus that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_path = true && (this.path != null);
+    boolean that_present_path = true && (that.path != null);
+    if (this_present_path || that_present_path) {
+      if (!(this_present_path && that_present_path))
+        return false;
+      if (!this.path.equals(that.path))
+        return false;
+    }
+
+    boolean this_present_length = true;
+    boolean that_present_length = true;
+    if (this_present_length || that_present_length) {
+      if (!(this_present_length && that_present_length))
+        return false;
+      if (this.length != that.length)
+        return false;
+    }
+
+    boolean this_present_isdir = true;
+    boolean that_present_isdir = true;
+    if (this_present_isdir || that_present_isdir) {
+      if (!(this_present_isdir && that_present_isdir))
+        return false;
+      if (this.isdir != that.isdir)
+        return false;
+    }
+
+    boolean this_present_block_replication = true;
+    boolean that_present_block_replication = true;
+    if (this_present_block_replication || that_present_block_replication) {
+      if (!(this_present_block_replication && that_present_block_replication))
+        return false;
+      if (this.block_replication != that.block_replication)
+        return false;
+    }
+
+    boolean this_present_blocksize = true;
+    boolean that_present_blocksize = true;
+    if (this_present_blocksize || that_present_blocksize) {
+      if (!(this_present_blocksize && that_present_blocksize))
+        return false;
+      if (this.blocksize != that.blocksize)
+        return false;
+    }
+
+    boolean this_present_modification_time = true;
+    boolean that_present_modification_time = true;
+    if (this_present_modification_time || that_present_modification_time) {
+      if (!(this_present_modification_time && that_present_modification_time))
+        return false;
+      if (this.modification_time != that.modification_time)
+        return false;
+    }
+
+    boolean this_present_permission = true && (this.permission != null);
+    boolean that_present_permission = true && (that.permission != null);
+    if (this_present_permission || that_present_permission) {
+      if (!(this_present_permission && that_present_permission))
+        return false;
+      if (!this.permission.equals(that.permission))
+        return false;
+    }
+
+    boolean this_present_owner = true && (this.owner != null);
+    boolean that_present_owner = true && (that.owner != null);
+    if (this_present_owner || that_present_owner) {
+      if (!(this_present_owner && that_present_owner))
+        return false;
+      if (!this.owner.equals(that.owner))
+        return false;
+    }
+
+    boolean this_present_group = true && (this.group != null);
+    boolean that_present_group = true && (that.group != null);
+    if (this_present_group || that_present_group) {
+      if (!(this_present_group && that_present_group))
+        return false;
+      if (!this.group.equals(that.group))
+        return false;
+    }
+
+    return true;
+  }
+
+  public int hashCode() {
+    return 0;
+  }
+
+  public void read(TProtocol iprot) throws TException {
+    TField field;
+    iprot.readStructBegin();
+    while (true)
+    {
+      field = iprot.readFieldBegin();
+      if (field.type == TType.STOP) { 
+        break;
+      }
+      switch (field.id)
+      {
+        case 1:
+          if (field.type == TType.STRING) {
+            this.path = iprot.readString();
+            this.__isset.path = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 2:
+          if (field.type == TType.I64) {
+            this.length = iprot.readI64();
+            this.__isset.length = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 3:
+          if (field.type == TType.BOOL) {
+            this.isdir = iprot.readBool();
+            this.__isset.isdir = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 4:
+          if (field.type == TType.I16) {
+            this.block_replication = iprot.readI16();
+            this.__isset.block_replication = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 5:
+          if (field.type == TType.I64) {
+            this.blocksize = iprot.readI64();
+            this.__isset.blocksize = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 6:
+          if (field.type == TType.I64) {
+            this.modification_time = iprot.readI64();
+            this.__isset.modification_time = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 7:
+          if (field.type == TType.STRING) {
+            this.permission = iprot.readString();
+            this.__isset.permission = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 8:
+          if (field.type == TType.STRING) {
+            this.owner = iprot.readString();
+            this.__isset.owner = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 9:
+          if (field.type == TType.STRING) {
+            this.group = iprot.readString();
+            this.__isset.group = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        default:
+          TProtocolUtil.skip(iprot, field.type);
+          break;
+      }
+      iprot.readFieldEnd();
+    }
+    iprot.readStructEnd();
+  }
+
+  public void write(TProtocol oprot) throws TException {
+    TStruct struct = new TStruct("FileStatus");
+    oprot.writeStructBegin(struct);
+    TField field = new TField();
+    if (this.path != null) {
+      field.name = "path";
+      field.type = TType.STRING;
+      field.id = 1;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.path);
+      oprot.writeFieldEnd();
+    }
+    field.name = "length";
+    field.type = TType.I64;
+    field.id = 2;
+    oprot.writeFieldBegin(field);
+    oprot.writeI64(this.length);
+    oprot.writeFieldEnd();
+    field.name = "isdir";
+    field.type = TType.BOOL;
+    field.id = 3;
+    oprot.writeFieldBegin(field);
+    oprot.writeBool(this.isdir);
+    oprot.writeFieldEnd();
+    field.name = "block_replication";
+    field.type = TType.I16;
+    field.id = 4;
+    oprot.writeFieldBegin(field);
+    oprot.writeI16(this.block_replication);
+    oprot.writeFieldEnd();
+    field.name = "blocksize";
+    field.type = TType.I64;
+    field.id = 5;
+    oprot.writeFieldBegin(field);
+    oprot.writeI64(this.blocksize);
+    oprot.writeFieldEnd();
+    field.name = "modification_time";
+    field.type = TType.I64;
+    field.id = 6;
+    oprot.writeFieldBegin(field);
+    oprot.writeI64(this.modification_time);
+    oprot.writeFieldEnd();
+    if (this.permission != null) {
+      field.name = "permission";
+      field.type = TType.STRING;
+      field.id = 7;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.permission);
+      oprot.writeFieldEnd();
+    }
+    if (this.owner != null) {
+      field.name = "owner";
+      field.type = TType.STRING;
+      field.id = 8;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.owner);
+      oprot.writeFieldEnd();
+    }
+    if (this.group != null) {
+      field.name = "group";
+      field.type = TType.STRING;
+      field.id = 9;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.group);
+      oprot.writeFieldEnd();
+    }
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  public String toString() {
+    StringBuilder sb = new StringBuilder("FileStatus(");
+    sb.append("path:");
+    sb.append(this.path);
+    sb.append(",length:");
+    sb.append(this.length);
+    sb.append(",isdir:");
+    sb.append(this.isdir);
+    sb.append(",block_replication:");
+    sb.append(this.block_replication);
+    sb.append(",blocksize:");
+    sb.append(this.blocksize);
+    sb.append(",modification_time:");
+    sb.append(this.modification_time);
+    sb.append(",permission:");
+    sb.append(this.permission);
+    sb.append(",owner:");
+    sb.append(this.owner);
+    sb.append(",group:");
+    sb.append(this.group);
+    sb.append(")");
+    return sb.toString();
+  }
+
+}
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/MalformedInputException.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/MalformedInputException.java?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/MalformedInputException.java
(added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/MalformedInputException.java
Thu Aug 28 21:31:57 2008
@@ -0,0 +1,119 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.thriftfs.api;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import com.facebook.thrift.*;
+
+import com.facebook.thrift.protocol.*;
+import com.facebook.thrift.transport.*;
+
+public class MalformedInputException extends Exception implements TBase, java.io.Serializable
{
+  public String message;
+
+  public final Isset __isset = new Isset();
+  public static final class Isset implements java.io.Serializable {
+    public boolean message = false;
+  }
+
+  public MalformedInputException() {
+  }
+
+  public MalformedInputException(
+    String message)
+  {
+    this();
+    this.message = message;
+    this.__isset.message = true;
+  }
+
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof MalformedInputException)
+      return this.equals((MalformedInputException)that);
+    return false;
+  }
+
+  public boolean equals(MalformedInputException that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_message = true && (this.message != null);
+    boolean that_present_message = true && (that.message != null);
+    if (this_present_message || that_present_message) {
+      if (!(this_present_message && that_present_message))
+        return false;
+      if (!this.message.equals(that.message))
+        return false;
+    }
+
+    return true;
+  }
+
+  public int hashCode() {
+    return 0;
+  }
+
+  public void read(TProtocol iprot) throws TException {
+    TField field;
+    iprot.readStructBegin();
+    while (true)
+    {
+      field = iprot.readFieldBegin();
+      if (field.type == TType.STOP) { 
+        break;
+      }
+      switch (field.id)
+      {
+        case -1:
+          if (field.type == TType.STRING) {
+            this.message = iprot.readString();
+            this.__isset.message = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        default:
+          TProtocolUtil.skip(iprot, field.type);
+          break;
+      }
+      iprot.readFieldEnd();
+    }
+    iprot.readStructEnd();
+  }
+
+  public void write(TProtocol oprot) throws TException {
+    TStruct struct = new TStruct("MalformedInputException");
+    oprot.writeStructBegin(struct);
+    TField field = new TField();
+    if (this.message != null) {
+      field.name = "message";
+      field.type = TType.STRING;
+      field.id = -1;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.message);
+      oprot.writeFieldEnd();
+    }
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  public String toString() {
+    StringBuilder sb = new StringBuilder("MalformedInputException(");
+    sb.append("message:");
+    sb.append(this.message);
+    sb.append(")");
+    return sb.toString();
+  }
+
+}
+

Added: hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/Pathname.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/Pathname.java?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/Pathname.java
(added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-java/org/apache/hadoop/thriftfs/api/Pathname.java
Thu Aug 28 21:31:57 2008
@@ -0,0 +1,119 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.thriftfs.api;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import com.facebook.thrift.*;
+
+import com.facebook.thrift.protocol.*;
+import com.facebook.thrift.transport.*;
+
+public class Pathname implements TBase, java.io.Serializable {
+  public String pathname;
+
+  public final Isset __isset = new Isset();
+  public static final class Isset implements java.io.Serializable {
+    public boolean pathname = false;
+  }
+
+  public Pathname() {
+  }
+
+  public Pathname(
+    String pathname)
+  {
+    this();
+    this.pathname = pathname;
+    this.__isset.pathname = true;
+  }
+
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof Pathname)
+      return this.equals((Pathname)that);
+    return false;
+  }
+
+  public boolean equals(Pathname that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_pathname = true && (this.pathname != null);
+    boolean that_present_pathname = true && (that.pathname != null);
+    if (this_present_pathname || that_present_pathname) {
+      if (!(this_present_pathname && that_present_pathname))
+        return false;
+      if (!this.pathname.equals(that.pathname))
+        return false;
+    }
+
+    return true;
+  }
+
+  public int hashCode() {
+    return 0;
+  }
+
+  public void read(TProtocol iprot) throws TException {
+    TField field;
+    iprot.readStructBegin();
+    while (true)
+    {
+      field = iprot.readFieldBegin();
+      if (field.type == TType.STOP) { 
+        break;
+      }
+      switch (field.id)
+      {
+        case -1:
+          if (field.type == TType.STRING) {
+            this.pathname = iprot.readString();
+            this.__isset.pathname = true;
+          } else { 
+            TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        default:
+          TProtocolUtil.skip(iprot, field.type);
+          break;
+      }
+      iprot.readFieldEnd();
+    }
+    iprot.readStructEnd();
+  }
+
+  public void write(TProtocol oprot) throws TException {
+    TStruct struct = new TStruct("Pathname");
+    oprot.writeStructBegin(struct);
+    TField field = new TField();
+    if (this.pathname != null) {
+      field.name = "pathname";
+      field.type = TType.STRING;
+      field.id = -1;
+      oprot.writeFieldBegin(field);
+      oprot.writeString(this.pathname);
+      oprot.writeFieldEnd();
+    }
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  public String toString() {
+    StringBuilder sb = new StringBuilder("Pathname(");
+    sb.append("pathname:");
+    sb.append(this.pathname);
+    sb.append(")");
+    return sb.toString();
+  }
+
+}
+



Mime
View raw message