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 [9/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-perl/Types.pm
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-perl/Types.pm?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-perl/Types.pm (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-perl/Types.pm Thu Aug 28 21:31:57 2008
@@ -0,0 +1,610 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+require 5.6.0;
+use strict;
+use warnings;
+use Thrift;
+
+package ThriftHandle;
+use base('Class::Accessor');
+ThriftHandle->mk_accessors( qw( id ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{id} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{id}) {
+      $self->{id} = $vals->{id};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'ThriftHandle';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^-1$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{id});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('ThriftHandle');
+  if (defined $self->{id}) {
+    $xfer += $output->writeFieldBegin('id', TType::I64, -1);
+    $xfer += $output->writeI64($self->{id});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package Pathname;
+use base('Class::Accessor');
+Pathname->mk_accessors( qw( pathname ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{pathname} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{pathname}) {
+      $self->{pathname} = $vals->{pathname};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'Pathname';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^-1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{pathname});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('Pathname');
+  if (defined $self->{pathname}) {
+    $xfer += $output->writeFieldBegin('pathname', TType::STRING, -1);
+    $xfer += $output->writeString($self->{pathname});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package FileStatus;
+use base('Class::Accessor');
+FileStatus->mk_accessors( qw( path length isdir block_replication blocksize modification_time
permission owner group ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{path} = undef;
+$self->{length} = undef;
+$self->{isdir} = undef;
+$self->{block_replication} = undef;
+$self->{blocksize} = undef;
+$self->{modification_time} = undef;
+$self->{permission} = undef;
+$self->{owner} = undef;
+$self->{group} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{path}) {
+      $self->{path} = $vals->{path};
+    }
+    if (defined $vals->{length}) {
+      $self->{length} = $vals->{length};
+    }
+    if (defined $vals->{isdir}) {
+      $self->{isdir} = $vals->{isdir};
+    }
+    if (defined $vals->{block_replication}) {
+      $self->{block_replication} = $vals->{block_replication};
+    }
+    if (defined $vals->{blocksize}) {
+      $self->{blocksize} = $vals->{blocksize};
+    }
+    if (defined $vals->{modification_time}) {
+      $self->{modification_time} = $vals->{modification_time};
+    }
+    if (defined $vals->{permission}) {
+      $self->{permission} = $vals->{permission};
+    }
+    if (defined $vals->{owner}) {
+      $self->{owner} = $vals->{owner};
+    }
+    if (defined $vals->{group}) {
+      $self->{group} = $vals->{group};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'FileStatus';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{path});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^2$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{length});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::BOOL) {
+        $xfer += $input->readBool(\$self->{isdir});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^4$/ && do{      if ($ftype == TType::I16) {
+        $xfer += $input->readI16(\$self->{block_replication});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^5$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{blocksize});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^6$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{modification_time});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^7$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{permission});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^8$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{owner});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^9$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{group});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('FileStatus');
+  if (defined $self->{path}) {
+    $xfer += $output->writeFieldBegin('path', TType::STRING, 1);
+    $xfer += $output->writeString($self->{path});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{length}) {
+    $xfer += $output->writeFieldBegin('length', TType::I64, 2);
+    $xfer += $output->writeI64($self->{length});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{isdir}) {
+    $xfer += $output->writeFieldBegin('isdir', TType::BOOL, 3);
+    $xfer += $output->writeBool($self->{isdir});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{block_replication}) {
+    $xfer += $output->writeFieldBegin('block_replication', TType::I16, 4);
+    $xfer += $output->writeI16($self->{block_replication});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{blocksize}) {
+    $xfer += $output->writeFieldBegin('blocksize', TType::I64, 5);
+    $xfer += $output->writeI64($self->{blocksize});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{modification_time}) {
+    $xfer += $output->writeFieldBegin('modification_time', TType::I64, 6);
+    $xfer += $output->writeI64($self->{modification_time});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{permission}) {
+    $xfer += $output->writeFieldBegin('permission', TType::STRING, 7);
+    $xfer += $output->writeString($self->{permission});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{owner}) {
+    $xfer += $output->writeFieldBegin('owner', TType::STRING, 8);
+    $xfer += $output->writeString($self->{owner});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{group}) {
+    $xfer += $output->writeFieldBegin('group', TType::STRING, 9);
+    $xfer += $output->writeString($self->{group});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package BlockLocation;
+use base('Class::Accessor');
+BlockLocation->mk_accessors( qw( hosts names offset length ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{hosts} = undef;
+$self->{names} = undef;
+$self->{offset} = undef;
+$self->{length} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{hosts}) {
+      $self->{hosts} = $vals->{hosts};
+    }
+    if (defined $vals->{names}) {
+      $self->{names} = $vals->{names};
+    }
+    if (defined $vals->{offset}) {
+      $self->{offset} = $vals->{offset};
+    }
+    if (defined $vals->{length}) {
+      $self->{length} = $vals->{length};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'BlockLocation';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::LIST) {
+        {
+          my $_size0 = 0;
+          $self->{hosts} = [];
+          my $_etype3 = 0;
+          $xfer += $input->readListBegin(\$_etype3, \$_size0);
+          for (my $_i4 = 0; $_i4 < $_size0; ++$_i4)
+          {
+            my $elem5 = undef;
+            $xfer += $input->readString(\$elem5);
+            push(@{$self->{hosts}},$elem5);
+          }
+          $xfer += $input->readListEnd();
+        }
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^2$/ && do{      if ($ftype == TType::LIST) {
+        {
+          my $_size6 = 0;
+          $self->{names} = [];
+          my $_etype9 = 0;
+          $xfer += $input->readListBegin(\$_etype9, \$_size6);
+          for (my $_i10 = 0; $_i10 < $_size6; ++$_i10)
+          {
+            my $elem11 = undef;
+            $xfer += $input->readString(\$elem11);
+            push(@{$self->{names}},$elem11);
+          }
+          $xfer += $input->readListEnd();
+        }
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{offset});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^4$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{length});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('BlockLocation');
+  if (defined $self->{hosts}) {
+    $xfer += $output->writeFieldBegin('hosts', TType::LIST, 1);
+    {
+      $output->writeListBegin(TType::STRING, scalar(@{$self->{hosts}}));
+      {
+        foreach my $iter12 (@{$self->{hosts}}) 
+        {
+          $xfer += $output->writeString($iter12);
+        }
+      }
+      $output->writeListEnd();
+    }
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{names}) {
+    $xfer += $output->writeFieldBegin('names', TType::LIST, 2);
+    {
+      $output->writeListBegin(TType::STRING, scalar(@{$self->{names}}));
+      {
+        foreach my $iter13 (@{$self->{names}}) 
+        {
+          $xfer += $output->writeString($iter13);
+        }
+      }
+      $output->writeListEnd();
+    }
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{offset}) {
+    $xfer += $output->writeFieldBegin('offset', TType::I64, 3);
+    $xfer += $output->writeI64($self->{offset});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{length}) {
+    $xfer += $output->writeFieldBegin('length', TType::I64, 4);
+    $xfer += $output->writeI64($self->{length});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package MalformedInputException;
+use base('Thrift::TException');
+use base('Class::Accessor');
+MalformedInputException->mk_accessors( qw( message ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{message} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{message}) {
+      $self->{message} = $vals->{message};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'MalformedInputException';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^-1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{message});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('MalformedInputException');
+  if (defined $self->{message}) {
+    $xfer += $output->writeFieldBegin('message', TType::STRING, -1);
+    $xfer += $output->writeString($self->{message});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package ThriftIOException;
+use base('Thrift::TException');
+use base('Class::Accessor');
+ThriftIOException->mk_accessors( qw( message ) );
+sub new {
+my $classname = shift;
+my $self      = {};
+my $vals      = shift || {};
+$self->{message} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{message}) {
+      $self->{message} = $vals->{message};
+    }
+  }
+return bless($self,$classname);
+}
+
+sub getName {
+  return 'ThriftIOException';
+}
+
+sub read {
+  my $self  = shift;
+  my $input = shift;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^-1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{message});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my $self   = shift;
+  my $output = shift;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('ThriftIOException');
+  if (defined $self->{message}) {
+    $xfer += $output->writeFieldBegin('message', TType::STRING, -1);
+    $xfer += $output->writeString($self->{message});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+1;



Mime
View raw message