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(); + } + +} +
