You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by om...@apache.org on 2008/08/29 06:32:00 UTC
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...
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();
+ }
+
+}
+