开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 网格计算 > 查看源码
hadoopfs_types.cpp
资源名称：hadoop-0.20.0.tar.gz　[点击查看]
上传用户：quxuerui
上传日期：2018-01-08
资源大小：41811k
文件大小：15k
源码类别：

网格计算

开发平台：

Java

hadoopfs_types.cpp：源码内容
  1. /**
  2.  * Autogenerated by Thrift
  3.  *
  4.  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5.  */
  6. #include "hadoopfs_types.h"
  10. const char* ThriftHandle::ascii_fingerprint = "2317B51D4172A111734AAB85F990F7C6";
  11. const uint8_t ThriftHandle::binary_fingerprint[16] = {0x23,0x17,0xB5,0x1D,0x41,0x72,0xA1,0x11,0x73,0x4A,0xAB,0x85,0xF9,0x90,0xF7,0xC6};
  13. uint32_t ThriftHandle::read(facebook::thrift::protocol::TProtocol* iprot) {
  15.   uint32_t xfer = 0;
  16.   std::string fname;
  17.   facebook::thrift::protocol::TType ftype;
  18.   int16_t fid;
  20.   xfer += iprot->readStructBegin(fname);
  22.   using facebook::thrift::protocol::TProtocolException;
  25.   while (true)
  26.   {
  27.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  28.     if (ftype == facebook::thrift::protocol::T_STOP) {
  29.       break;
  30.     }
  31.     switch (fid)
  32.     {
  33.       case -1:
  34.         if (ftype == facebook::thrift::protocol::T_I64) {
  35.           xfer += iprot->readI64(this->id);
  36.           this->__isset.id = true;
  37.         } else {
  38.           xfer += iprot->skip(ftype);
  39.         }
  40.         break;
  41.       default:
  42.         xfer += iprot->skip(ftype);
  43.         break;
  44.     }
  45.     xfer += iprot->readFieldEnd();
  46.   }
  48.   xfer += iprot->readStructEnd();
  50.   return xfer;
  51. }
  53. uint32_t ThriftHandle::write(facebook::thrift::protocol::TProtocol* oprot) const {
  54.   uint32_t xfer = 0;
  55.   xfer += oprot->writeStructBegin("ThriftHandle");
  56.   xfer += oprot->writeFieldBegin("id", facebook::thrift::protocol::T_I64, -1);
  57.   xfer += oprot->writeI64(this->id);
  58.   xfer += oprot->writeFieldEnd();
  59.   xfer += oprot->writeFieldStop();
  60.   xfer += oprot->writeStructEnd();
  61.   return xfer;
  62. }
  64. const char* Pathname::ascii_fingerprint = "E2167DA91A8F7459A2FE1B5F56D14B5D";
  65. const uint8_t Pathname::binary_fingerprint[16] = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
  67. uint32_t Pathname::read(facebook::thrift::protocol::TProtocol* iprot) {
  69.   uint32_t xfer = 0;
  70.   std::string fname;
  71.   facebook::thrift::protocol::TType ftype;
  72.   int16_t fid;
  74.   xfer += iprot->readStructBegin(fname);
  76.   using facebook::thrift::protocol::TProtocolException;
  79.   while (true)
  80.   {
  81.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  82.     if (ftype == facebook::thrift::protocol::T_STOP) {
  83.       break;
  84.     }
  85.     switch (fid)
  86.     {
  87.       case -1:
  88.         if (ftype == facebook::thrift::protocol::T_STRING) {
  89.           xfer += iprot->readString(this->pathname);
  90.           this->__isset.pathname = true;
  91.         } else {
  92.           xfer += iprot->skip(ftype);
  93.         }
  94.         break;
  95.       default:
  96.         xfer += iprot->skip(ftype);
  97.         break;
  98.     }
  99.     xfer += iprot->readFieldEnd();
  100.   }
  102.   xfer += iprot->readStructEnd();
  104.   return xfer;
  105. }
  107. uint32_t Pathname::write(facebook::thrift::protocol::TProtocol* oprot) const {
  108.   uint32_t xfer = 0;
  109.   xfer += oprot->writeStructBegin("Pathname");
  110.   xfer += oprot->writeFieldBegin("pathname", facebook::thrift::protocol::T_STRING, -1);
  111.   xfer += oprot->writeString(this->pathname);
  112.   xfer += oprot->writeFieldEnd();
  113.   xfer += oprot->writeFieldStop();
  114.   xfer += oprot->writeStructEnd();
  115.   return xfer;
  116. }
  118. const char* FileStatus::ascii_fingerprint = "68FE7242A6727149B291A86FB9570D2B";
  119. const uint8_t FileStatus::binary_fingerprint[16] = {0x68,0xFE,0x72,0x42,0xA6,0x72,0x71,0x49,0xB2,0x91,0xA8,0x6F,0xB9,0x57,0x0D,0x2B};
  121. uint32_t FileStatus::read(facebook::thrift::protocol::TProtocol* iprot) {
  123.   uint32_t xfer = 0;
  124.   std::string fname;
  125.   facebook::thrift::protocol::TType ftype;
  126.   int16_t fid;
  128.   xfer += iprot->readStructBegin(fname);
  130.   using facebook::thrift::protocol::TProtocolException;
  133.   while (true)
  134.   {
  135.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  136.     if (ftype == facebook::thrift::protocol::T_STOP) {
  137.       break;
  138.     }
  139.     switch (fid)
  140.     {
  141.       case 1:
  142.         if (ftype == facebook::thrift::protocol::T_STRING) {
  143.           xfer += iprot->readString(this->path);
  144.           this->__isset.path = true;
  145.         } else {
  146.           xfer += iprot->skip(ftype);
  147.         }
  148.         break;
  149.       case 2:
  150.         if (ftype == facebook::thrift::protocol::T_I64) {
  151.           xfer += iprot->readI64(this->length);
  152.           this->__isset.length = true;
  153.         } else {
  154.           xfer += iprot->skip(ftype);
  155.         }
  156.         break;
  157.       case 3:
  158.         if (ftype == facebook::thrift::protocol::T_BOOL) {
  159.           xfer += iprot->readBool(this->isdir);
  160.           this->__isset.isdir = true;
  161.         } else {
  162.           xfer += iprot->skip(ftype);
  163.         }
  164.         break;
  165.       case 4:
  166.         if (ftype == facebook::thrift::protocol::T_I16) {
  167.           xfer += iprot->readI16(this->block_replication);
  168.           this->__isset.block_replication = true;
  169.         } else {
  170.           xfer += iprot->skip(ftype);
  171.         }
  172.         break;
  173.       case 5:
  174.         if (ftype == facebook::thrift::protocol::T_I64) {
  175.           xfer += iprot->readI64(this->blocksize);
  176.           this->__isset.blocksize = true;
  177.         } else {
  178.           xfer += iprot->skip(ftype);
  179.         }
  180.         break;
  181.       case 6:
  182.         if (ftype == facebook::thrift::protocol::T_I64) {
  183.           xfer += iprot->readI64(this->modification_time);
  184.           this->__isset.modification_time = true;
  185.         } else {
  186.           xfer += iprot->skip(ftype);
  187.         }
  188.         break;
  189.       case 7:
  190.         if (ftype == facebook::thrift::protocol::T_STRING) {
  191.           xfer += iprot->readString(this->permission);
  192.           this->__isset.permission = true;
  193.         } else {
  194.           xfer += iprot->skip(ftype);
  195.         }
  196.         break;
  197.       case 8:
  198.         if (ftype == facebook::thrift::protocol::T_STRING) {
  199.           xfer += iprot->readString(this->owner);
  200.           this->__isset.owner = true;
  201.         } else {
  202.           xfer += iprot->skip(ftype);
  203.         }
  204.         break;
  205.       case 9:
  206.         if (ftype == facebook::thrift::protocol::T_STRING) {
  207.           xfer += iprot->readString(this->group);
  208.           this->__isset.group = true;
  209.         } else {
  210.           xfer += iprot->skip(ftype);
  211.         }
  212.         break;
  213.       default:
  214.         xfer += iprot->skip(ftype);
  215.         break;
  216.     }
  217.     xfer += iprot->readFieldEnd();
  218.   }
  220.   xfer += iprot->readStructEnd();
  222.   return xfer;
  223. }
  225. uint32_t FileStatus::write(facebook::thrift::protocol::TProtocol* oprot) const {
  226.   uint32_t xfer = 0;
  227.   xfer += oprot->writeStructBegin("FileStatus");
  228.   xfer += oprot->writeFieldBegin("path", facebook::thrift::protocol::T_STRING, 1);
  229.   xfer += oprot->writeString(this->path);
  230.   xfer += oprot->writeFieldEnd();
  231.   xfer += oprot->writeFieldBegin("length", facebook::thrift::protocol::T_I64, 2);
  232.   xfer += oprot->writeI64(this->length);
  233.   xfer += oprot->writeFieldEnd();
  234.   xfer += oprot->writeFieldBegin("isdir", facebook::thrift::protocol::T_BOOL, 3);
  235.   xfer += oprot->writeBool(this->isdir);
  236.   xfer += oprot->writeFieldEnd();
  237.   xfer += oprot->writeFieldBegin("block_replication", facebook::thrift::protocol::T_I16, 4);
  238.   xfer += oprot->writeI16(this->block_replication);
  239.   xfer += oprot->writeFieldEnd();
  240.   xfer += oprot->writeFieldBegin("blocksize", facebook::thrift::protocol::T_I64, 5);
  241.   xfer += oprot->writeI64(this->blocksize);
  242.   xfer += oprot->writeFieldEnd();
  243.   xfer += oprot->writeFieldBegin("modification_time", facebook::thrift::protocol::T_I64, 6);
  244.   xfer += oprot->writeI64(this->modification_time);
  245.   xfer += oprot->writeFieldEnd();
  246.   xfer += oprot->writeFieldBegin("permission", facebook::thrift::protocol::T_STRING, 7);
  247.   xfer += oprot->writeString(this->permission);
  248.   xfer += oprot->writeFieldEnd();
  249.   xfer += oprot->writeFieldBegin("owner", facebook::thrift::protocol::T_STRING, 8);
  250.   xfer += oprot->writeString(this->owner);
  251.   xfer += oprot->writeFieldEnd();
  252.   xfer += oprot->writeFieldBegin("group", facebook::thrift::protocol::T_STRING, 9);
  253.   xfer += oprot->writeString(this->group);
  254.   xfer += oprot->writeFieldEnd();
  255.   xfer += oprot->writeFieldStop();
  256.   xfer += oprot->writeStructEnd();
  257.   return xfer;
  258. }
  260. const char* BlockLocation::ascii_fingerprint = "8BF3B16BED96367B21783389BDF8B1C0";
  261. const uint8_t BlockLocation::binary_fingerprint[16] = {0x8B,0xF3,0xB1,0x6B,0xED,0x96,0x36,0x7B,0x21,0x78,0x33,0x89,0xBD,0xF8,0xB1,0xC0};
  263. uint32_t BlockLocation::read(facebook::thrift::protocol::TProtocol* iprot) {
  265.   uint32_t xfer = 0;
  266.   std::string fname;
  267.   facebook::thrift::protocol::TType ftype;
  268.   int16_t fid;
  270.   xfer += iprot->readStructBegin(fname);
  272.   using facebook::thrift::protocol::TProtocolException;
  275.   while (true)
  276.   {
  277.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  278.     if (ftype == facebook::thrift::protocol::T_STOP) {
  279.       break;
  280.     }
  281.     switch (fid)
  282.     {
  283.       case 1:
  284.         if (ftype == facebook::thrift::protocol::T_LIST) {
  285.           {
  286.             this->hosts.clear();
  287.             uint32_t _size0;
  288.             facebook::thrift::protocol::TType _etype3;
  289.             iprot->readListBegin(_etype3, _size0);
  290.             this->hosts.resize(_size0);
  291.             uint32_t _i4;
  292.             for (_i4 = 0; _i4 < _size0; ++_i4)
  293.             {
  294.               xfer += iprot->readString(this->hosts[_i4]);
  295.             }
  296.             iprot->readListEnd();
  297.           }
  298.           this->__isset.hosts = true;
  299.         } else {
  300.           xfer += iprot->skip(ftype);
  301.         }
  302.         break;
  303.       case 2:
  304.         if (ftype == facebook::thrift::protocol::T_LIST) {
  305.           {
  306.             this->names.clear();
  307.             uint32_t _size5;
  308.             facebook::thrift::protocol::TType _etype8;
  309.             iprot->readListBegin(_etype8, _size5);
  310.             this->names.resize(_size5);
  311.             uint32_t _i9;
  312.             for (_i9 = 0; _i9 < _size5; ++_i9)
  313.             {
  314.               xfer += iprot->readString(this->names[_i9]);
  315.             }
  316.             iprot->readListEnd();
  317.           }
  318.           this->__isset.names = true;
  319.         } else {
  320.           xfer += iprot->skip(ftype);
  321.         }
  322.         break;
  323.       case 3:
  324.         if (ftype == facebook::thrift::protocol::T_I64) {
  325.           xfer += iprot->readI64(this->offset);
  326.           this->__isset.offset = true;
  327.         } else {
  328.           xfer += iprot->skip(ftype);
  329.         }
  330.         break;
  331.       case 4:
  332.         if (ftype == facebook::thrift::protocol::T_I64) {
  333.           xfer += iprot->readI64(this->length);
  334.           this->__isset.length = true;
  335.         } else {
  336.           xfer += iprot->skip(ftype);
  337.         }
  338.         break;
  339.       default:
  340.         xfer += iprot->skip(ftype);
  341.         break;
  342.     }
  343.     xfer += iprot->readFieldEnd();
  344.   }
  346.   xfer += iprot->readStructEnd();
  348.   return xfer;
  349. }
  351. uint32_t BlockLocation::write(facebook::thrift::protocol::TProtocol* oprot) const {
  352.   uint32_t xfer = 0;
  353.   xfer += oprot->writeStructBegin("BlockLocation");
  354.   xfer += oprot->writeFieldBegin("hosts", facebook::thrift::protocol::T_LIST, 1);
  355.   {
  356.     xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->hosts.size());
  357.     std::vector<std::string> ::const_iterator _iter10;
  358.     for (_iter10 = this->hosts.begin(); _iter10 != this->hosts.end(); ++_iter10)
  359.     {
  360.       xfer += oprot->writeString((*_iter10));
  361.     }
  362.     xfer += oprot->writeListEnd();
  363.   }
  364.   xfer += oprot->writeFieldEnd();
  365.   xfer += oprot->writeFieldBegin("names", facebook::thrift::protocol::T_LIST, 2);
  366.   {
  367.     xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->names.size());
  368.     std::vector<std::string> ::const_iterator _iter11;
  369.     for (_iter11 = this->names.begin(); _iter11 != this->names.end(); ++_iter11)
  370.     {
  371.       xfer += oprot->writeString((*_iter11));
  372.     }
  373.     xfer += oprot->writeListEnd();
  374.   }
  375.   xfer += oprot->writeFieldEnd();
  376.   xfer += oprot->writeFieldBegin("offset", facebook::thrift::protocol::T_I64, 3);
  377.   xfer += oprot->writeI64(this->offset);
  378.   xfer += oprot->writeFieldEnd();
  379.   xfer += oprot->writeFieldBegin("length", facebook::thrift::protocol::T_I64, 4);
  380.   xfer += oprot->writeI64(this->length);
  381.   xfer += oprot->writeFieldEnd();
  382.   xfer += oprot->writeFieldStop();
  383.   xfer += oprot->writeStructEnd();
  384.   return xfer;
  385. }
  387. const char* MalformedInputException::ascii_fingerprint = "E2167DA91A8F7459A2FE1B5F56D14B5D";
  388. const uint8_t MalformedInputException::binary_fingerprint[16] = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
  390. uint32_t MalformedInputException::read(facebook::thrift::protocol::TProtocol* iprot) {
  392.   uint32_t xfer = 0;
  393.   std::string fname;
  394.   facebook::thrift::protocol::TType ftype;
  395.   int16_t fid;
  397.   xfer += iprot->readStructBegin(fname);
  399.   using facebook::thrift::protocol::TProtocolException;
  402.   while (true)
  403.   {
  404.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  405.     if (ftype == facebook::thrift::protocol::T_STOP) {
  406.       break;
  407.     }
  408.     switch (fid)
  409.     {
  410.       case -1:
  411.         if (ftype == facebook::thrift::protocol::T_STRING) {
  412.           xfer += iprot->readString(this->message);
  413.           this->__isset.message = true;
  414.         } else {
  415.           xfer += iprot->skip(ftype);
  416.         }
  417.         break;
  418.       default:
  419.         xfer += iprot->skip(ftype);
  420.         break;
  421.     }
  422.     xfer += iprot->readFieldEnd();
  423.   }
  425.   xfer += iprot->readStructEnd();
  427.   return xfer;
  428. }
  430. uint32_t MalformedInputException::write(facebook::thrift::protocol::TProtocol* oprot) const {
  431.   uint32_t xfer = 0;
  432.   xfer += oprot->writeStructBegin("MalformedInputException");
  433.   xfer += oprot->writeFieldBegin("message", facebook::thrift::protocol::T_STRING, -1);
  434.   xfer += oprot->writeString(this->message);
  435.   xfer += oprot->writeFieldEnd();
  436.   xfer += oprot->writeFieldStop();
  437.   xfer += oprot->writeStructEnd();
  438.   return xfer;
  439. }
  441. const char* ThriftIOException::ascii_fingerprint = "E2167DA91A8F7459A2FE1B5F56D14B5D";
  442. const uint8_t ThriftIOException::binary_fingerprint[16] = {0xE2,0x16,0x7D,0xA9,0x1A,0x8F,0x74,0x59,0xA2,0xFE,0x1B,0x5F,0x56,0xD1,0x4B,0x5D};
  444. uint32_t ThriftIOException::read(facebook::thrift::protocol::TProtocol* iprot) {
  446.   uint32_t xfer = 0;
  447.   std::string fname;
  448.   facebook::thrift::protocol::TType ftype;
  449.   int16_t fid;
  451.   xfer += iprot->readStructBegin(fname);
  453.   using facebook::thrift::protocol::TProtocolException;
  456.   while (true)
  457.   {
  458.     xfer += iprot->readFieldBegin(fname, ftype, fid);
  459.     if (ftype == facebook::thrift::protocol::T_STOP) {
  460.       break;
  461.     }
  462.     switch (fid)
  463.     {
  464.       case -1:
  465.         if (ftype == facebook::thrift::protocol::T_STRING) {
  466.           xfer += iprot->readString(this->message);
  467.           this->__isset.message = true;
  468.         } else {
  469.           xfer += iprot->skip(ftype);
  470.         }
  471.         break;
  472.       default:
  473.         xfer += iprot->skip(ftype);
  474.         break;
  475.     }
  476.     xfer += iprot->readFieldEnd();
  477.   }
  479.   xfer += iprot->readStructEnd();
  481.   return xfer;
  482. }
  484. uint32_t ThriftIOException::write(facebook::thrift::protocol::TProtocol* oprot) const {
  485.   uint32_t xfer = 0;
  486.   xfer += oprot->writeStructBegin("ThriftIOException");
  487.   xfer += oprot->writeFieldBegin("message", facebook::thrift::protocol::T_STRING, -1);
  488.   xfer += oprot->writeString(this->message);
  489.   xfer += oprot->writeFieldEnd();
  490.   xfer += oprot->writeFieldStop();
  491.   xfer += oprot->writeStructEnd();
  492.   return xfer;
  493. }