Permalink
Switch branches/tags
Nothing to show
Find file
Fetching contributors…
Cannot retrieve contributors at this time
7376 lines (6451 sloc) 232 KB
/**
* Autogenerated by Thrift
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
#include "TabletClientService.h"
namespace accumulo { namespace tabletserver {
uint32_t TabletClientService_startScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 11:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->range.read(iprot);
this->__isset.range = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->columns.clear();
uint32_t _size42;
::apache::thrift::protocol::TType _etype45;
iprot->readListBegin(_etype45, _size42);
this->columns.resize(_size42);
uint32_t _i46;
for (_i46 = 0; _i46 < _size42; ++_i46)
{
xfer += this->columns[_i46].read(iprot);
}
iprot->readListEnd();
}
this->__isset.columns = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_I32) {
xfer += iprot->readI32(this->batchSize);
this->__isset.batchSize = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 6:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->ssiList.clear();
uint32_t _size47;
::apache::thrift::protocol::TType _etype50;
iprot->readListBegin(_etype50, _size47);
this->ssiList.resize(_size47);
uint32_t _i51;
for (_i51 = 0; _i51 < _size47; ++_i51)
{
xfer += this->ssiList[_i51].read(iprot);
}
iprot->readListEnd();
}
this->__isset.ssiList = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 7:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->ssio.clear();
uint32_t _size52;
::apache::thrift::protocol::TType _ktype53;
::apache::thrift::protocol::TType _vtype54;
iprot->readMapBegin(_ktype53, _vtype54, _size52);
uint32_t _i56;
for (_i56 = 0; _i56 < _size52; ++_i56)
{
std::string _key57;
xfer += iprot->readString(_key57);
std::map<std::string, std::string> & _val58 = this->ssio[_key57];
{
_val58.clear();
uint32_t _size59;
::apache::thrift::protocol::TType _ktype60;
::apache::thrift::protocol::TType _vtype61;
iprot->readMapBegin(_ktype60, _vtype61, _size59);
uint32_t _i63;
for (_i63 = 0; _i63 < _size59; ++_i63)
{
std::string _key64;
xfer += iprot->readString(_key64);
std::string& _val65 = _val58[_key64];
xfer += iprot->readString(_val65);
}
iprot->readMapEnd();
}
}
iprot->readMapEnd();
}
this->__isset.ssio = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 8:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->authorizations.clear();
uint32_t _size66;
::apache::thrift::protocol::TType _etype69;
iprot->readListBegin(_etype69, _size66);
this->authorizations.resize(_size66);
uint32_t _i70;
for (_i70 = 0; _i70 < _size66; ++_i70)
{
xfer += iprot->readBinary(this->authorizations[_i70]);
}
iprot->readListEnd();
}
this->__isset.authorizations = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 9:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->waitForWrites);
this->__isset.waitForWrites = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 10:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->isolated);
this->__isset.isolated = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startScan_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("range", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->range.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("columns", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->columns.size());
std::vector<accumulo::data::TColumn> ::const_iterator _iter71;
for (_iter71 = this->columns.begin(); _iter71 != this->columns.end(); ++_iter71)
{
xfer += (*_iter71).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("batchSize", ::apache::thrift::protocol::T_I32, 5);
xfer += oprot->writeI32(this->batchSize);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssiList", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->ssiList.size());
std::vector<accumulo::data::IterInfo> ::const_iterator _iter72;
for (_iter72 = this->ssiList.begin(); _iter72 != this->ssiList.end(); ++_iter72)
{
xfer += (*_iter72).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssio", ::apache::thrift::protocol::T_MAP, 7);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_MAP, this->ssio.size());
std::map<std::string, std::map<std::string, std::string> > ::const_iterator _iter73;
for (_iter73 = this->ssio.begin(); _iter73 != this->ssio.end(); ++_iter73)
{
xfer += oprot->writeString(_iter73->first);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, _iter73->second.size());
std::map<std::string, std::string> ::const_iterator _iter74;
for (_iter74 = _iter73->second.begin(); _iter74 != _iter73->second.end(); ++_iter74)
{
xfer += oprot->writeString(_iter74->first);
xfer += oprot->writeString(_iter74->second);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("authorizations", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, this->authorizations.size());
std::vector<std::string> ::const_iterator _iter75;
for (_iter75 = this->authorizations.begin(); _iter75 != this->authorizations.end(); ++_iter75)
{
xfer += oprot->writeBinary((*_iter75));
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("waitForWrites", ::apache::thrift::protocol::T_BOOL, 9);
xfer += oprot->writeBool(this->waitForWrites);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("isolated", ::apache::thrift::protocol::T_BOOL, 10);
xfer += oprot->writeBool(this->isolated);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 11);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startScan_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("range", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->range)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("columns", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, (*(this->columns)).size());
std::vector<accumulo::data::TColumn> ::const_iterator _iter76;
for (_iter76 = (*(this->columns)).begin(); _iter76 != (*(this->columns)).end(); ++_iter76)
{
xfer += (*_iter76).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("batchSize", ::apache::thrift::protocol::T_I32, 5);
xfer += oprot->writeI32((*(this->batchSize)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssiList", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, (*(this->ssiList)).size());
std::vector<accumulo::data::IterInfo> ::const_iterator _iter77;
for (_iter77 = (*(this->ssiList)).begin(); _iter77 != (*(this->ssiList)).end(); ++_iter77)
{
xfer += (*_iter77).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssio", ::apache::thrift::protocol::T_MAP, 7);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_MAP, (*(this->ssio)).size());
std::map<std::string, std::map<std::string, std::string> > ::const_iterator _iter78;
for (_iter78 = (*(this->ssio)).begin(); _iter78 != (*(this->ssio)).end(); ++_iter78)
{
xfer += oprot->writeString(_iter78->first);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, _iter78->second.size());
std::map<std::string, std::string> ::const_iterator _iter79;
for (_iter79 = _iter78->second.begin(); _iter79 != _iter78->second.end(); ++_iter79)
{
xfer += oprot->writeString(_iter79->first);
xfer += oprot->writeString(_iter79->second);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("authorizations", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, (*(this->authorizations)).size());
std::vector<std::string> ::const_iterator _iter80;
for (_iter80 = (*(this->authorizations)).begin(); _iter80 != (*(this->authorizations)).end(); ++_iter80)
{
xfer += oprot->writeBinary((*_iter80));
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("waitForWrites", ::apache::thrift::protocol::T_BOOL, 9);
xfer += oprot->writeBool((*(this->waitForWrites)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("isolated", ::apache::thrift::protocol::T_BOOL, 10);
xfer += oprot->writeBool((*(this->isolated)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 11);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startScan_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tmfe.read(iprot);
this->__isset.tmfe = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startScan_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startScan_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nste) {
xfer += oprot->writeFieldBegin("nste", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->nste.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.tmfe) {
xfer += oprot->writeFieldBegin("tmfe", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tmfe.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startScan_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tmfe.read(iprot);
this->__isset.tmfe = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->scanID);
this->__isset.scanID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueScan_args");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64(this->scanID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueScan_pargs");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64((*(this->scanID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tmfe.read(iprot);
this->__isset.tmfe = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueScan_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nssi) {
xfer += oprot->writeFieldBegin("nssi", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->nssi.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nste) {
xfer += oprot->writeFieldBegin("nste", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->nste.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.tmfe) {
xfer += oprot->writeFieldBegin("tmfe", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tmfe.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueScan_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tmfe.read(iprot);
this->__isset.tmfe = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->scanID);
this->__isset.scanID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeScan_args");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64(this->scanID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeScan_pargs");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64((*(this->scanID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 8:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->batch.clear();
uint32_t _size81;
::apache::thrift::protocol::TType _ktype82;
::apache::thrift::protocol::TType _vtype83;
iprot->readMapBegin(_ktype82, _vtype83, _size81);
uint32_t _i85;
for (_i85 = 0; _i85 < _size81; ++_i85)
{
accumulo::data::TKeyExtent _key86;
xfer += _key86.read(iprot);
std::vector<accumulo::data::TRange> & _val87 = this->batch[_key86];
{
_val87.clear();
uint32_t _size88;
::apache::thrift::protocol::TType _etype91;
iprot->readListBegin(_etype91, _size88);
_val87.resize(_size88);
uint32_t _i92;
for (_i92 = 0; _i92 < _size88; ++_i92)
{
xfer += _val87[_i92].read(iprot);
}
iprot->readListEnd();
}
}
iprot->readMapEnd();
}
this->__isset.batch = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->columns.clear();
uint32_t _size93;
::apache::thrift::protocol::TType _etype96;
iprot->readListBegin(_etype96, _size93);
this->columns.resize(_size93);
uint32_t _i97;
for (_i97 = 0; _i97 < _size93; ++_i97)
{
xfer += this->columns[_i97].read(iprot);
}
iprot->readListEnd();
}
this->__isset.columns = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->ssiList.clear();
uint32_t _size98;
::apache::thrift::protocol::TType _etype101;
iprot->readListBegin(_etype101, _size98);
this->ssiList.resize(_size98);
uint32_t _i102;
for (_i102 = 0; _i102 < _size98; ++_i102)
{
xfer += this->ssiList[_i102].read(iprot);
}
iprot->readListEnd();
}
this->__isset.ssiList = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->ssio.clear();
uint32_t _size103;
::apache::thrift::protocol::TType _ktype104;
::apache::thrift::protocol::TType _vtype105;
iprot->readMapBegin(_ktype104, _vtype105, _size103);
uint32_t _i107;
for (_i107 = 0; _i107 < _size103; ++_i107)
{
std::string _key108;
xfer += iprot->readString(_key108);
std::map<std::string, std::string> & _val109 = this->ssio[_key108];
{
_val109.clear();
uint32_t _size110;
::apache::thrift::protocol::TType _ktype111;
::apache::thrift::protocol::TType _vtype112;
iprot->readMapBegin(_ktype111, _vtype112, _size110);
uint32_t _i114;
for (_i114 = 0; _i114 < _size110; ++_i114)
{
std::string _key115;
xfer += iprot->readString(_key115);
std::string& _val116 = _val109[_key115];
xfer += iprot->readString(_val116);
}
iprot->readMapEnd();
}
}
iprot->readMapEnd();
}
this->__isset.ssio = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 6:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->authorizations.clear();
uint32_t _size117;
::apache::thrift::protocol::TType _etype120;
iprot->readListBegin(_etype120, _size117);
this->authorizations.resize(_size117);
uint32_t _i121;
for (_i121 = 0; _i121 < _size117; ++_i121)
{
xfer += iprot->readBinary(this->authorizations[_i121]);
}
iprot->readListEnd();
}
this->__isset.authorizations = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 7:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->waitForWrites);
this->__isset.waitForWrites = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startMultiScan_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("batch", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRUCT, ::apache::thrift::protocol::T_LIST, this->batch.size());
std::map<accumulo::data::TKeyExtent, std::vector<accumulo::data::TRange> > ::const_iterator _iter122;
for (_iter122 = this->batch.begin(); _iter122 != this->batch.end(); ++_iter122)
{
xfer += _iter122->first.write(oprot);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, _iter122->second.size());
std::vector<accumulo::data::TRange> ::const_iterator _iter123;
for (_iter123 = _iter122->second.begin(); _iter123 != _iter122->second.end(); ++_iter123)
{
xfer += (*_iter123).write(oprot);
}
xfer += oprot->writeListEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("columns", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->columns.size());
std::vector<accumulo::data::TColumn> ::const_iterator _iter124;
for (_iter124 = this->columns.begin(); _iter124 != this->columns.end(); ++_iter124)
{
xfer += (*_iter124).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssiList", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->ssiList.size());
std::vector<accumulo::data::IterInfo> ::const_iterator _iter125;
for (_iter125 = this->ssiList.begin(); _iter125 != this->ssiList.end(); ++_iter125)
{
xfer += (*_iter125).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssio", ::apache::thrift::protocol::T_MAP, 5);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_MAP, this->ssio.size());
std::map<std::string, std::map<std::string, std::string> > ::const_iterator _iter126;
for (_iter126 = this->ssio.begin(); _iter126 != this->ssio.end(); ++_iter126)
{
xfer += oprot->writeString(_iter126->first);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, _iter126->second.size());
std::map<std::string, std::string> ::const_iterator _iter127;
for (_iter127 = _iter126->second.begin(); _iter127 != _iter126->second.end(); ++_iter127)
{
xfer += oprot->writeString(_iter127->first);
xfer += oprot->writeString(_iter127->second);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("authorizations", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, this->authorizations.size());
std::vector<std::string> ::const_iterator _iter128;
for (_iter128 = this->authorizations.begin(); _iter128 != this->authorizations.end(); ++_iter128)
{
xfer += oprot->writeBinary((*_iter128));
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("waitForWrites", ::apache::thrift::protocol::T_BOOL, 7);
xfer += oprot->writeBool(this->waitForWrites);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 8);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startMultiScan_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("batch", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRUCT, ::apache::thrift::protocol::T_LIST, (*(this->batch)).size());
std::map<accumulo::data::TKeyExtent, std::vector<accumulo::data::TRange> > ::const_iterator _iter129;
for (_iter129 = (*(this->batch)).begin(); _iter129 != (*(this->batch)).end(); ++_iter129)
{
xfer += _iter129->first.write(oprot);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, _iter129->second.size());
std::vector<accumulo::data::TRange> ::const_iterator _iter130;
for (_iter130 = _iter129->second.begin(); _iter130 != _iter129->second.end(); ++_iter130)
{
xfer += (*_iter130).write(oprot);
}
xfer += oprot->writeListEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("columns", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, (*(this->columns)).size());
std::vector<accumulo::data::TColumn> ::const_iterator _iter131;
for (_iter131 = (*(this->columns)).begin(); _iter131 != (*(this->columns)).end(); ++_iter131)
{
xfer += (*_iter131).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssiList", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, (*(this->ssiList)).size());
std::vector<accumulo::data::IterInfo> ::const_iterator _iter132;
for (_iter132 = (*(this->ssiList)).begin(); _iter132 != (*(this->ssiList)).end(); ++_iter132)
{
xfer += (*_iter132).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("ssio", ::apache::thrift::protocol::T_MAP, 5);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_MAP, (*(this->ssio)).size());
std::map<std::string, std::map<std::string, std::string> > ::const_iterator _iter133;
for (_iter133 = (*(this->ssio)).begin(); _iter133 != (*(this->ssio)).end(); ++_iter133)
{
xfer += oprot->writeString(_iter133->first);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, _iter133->second.size());
std::map<std::string, std::string> ::const_iterator _iter134;
for (_iter134 = _iter133->second.begin(); _iter134 != _iter133->second.end(); ++_iter134)
{
xfer += oprot->writeString(_iter134->first);
xfer += oprot->writeString(_iter134->second);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("authorizations", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, (*(this->authorizations)).size());
std::vector<std::string> ::const_iterator _iter135;
for (_iter135 = (*(this->authorizations)).begin(); _iter135 != (*(this->authorizations)).end(); ++_iter135)
{
xfer += oprot->writeBinary((*_iter135));
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("waitForWrites", ::apache::thrift::protocol::T_BOOL, 7);
xfer += oprot->writeBool((*(this->waitForWrites)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 8);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startMultiScan_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startMultiScan_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->scanID);
this->__isset.scanID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueMultiScan_args");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64(this->scanID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueMultiScan_pargs");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64((*(this->scanID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_continueMultiScan_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nssi) {
xfer += oprot->writeFieldBegin("nssi", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->nssi.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_continueMultiScan_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->scanID);
this->__isset.scanID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeMultiScan_args");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64(this->scanID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeMultiScan_pargs");
xfer += oprot->writeFieldBegin("scanID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64((*(this->scanID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeMultiScan_result");
if (this->__isset.nssi) {
xfer += oprot->writeFieldBegin("nssi", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->nssi.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeMultiScan_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startUpdate_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startUpdate_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_startUpdate_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_I64, 0);
xfer += oprot->writeI64(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_startUpdate_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_applyUpdates_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->updateID);
this->__isset.updateID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->keyExtent.read(iprot);
this->__isset.keyExtent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->mutations.clear();
uint32_t _size136;
::apache::thrift::protocol::TType _etype139;
iprot->readListBegin(_etype139, _size136);
this->mutations.resize(_size136);
uint32_t _i140;
for (_i140 = 0; _i140 < _size136; ++_i140)
{
xfer += this->mutations[_i140].read(iprot);
}
iprot->readListEnd();
}
this->__isset.mutations = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_applyUpdates_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_applyUpdates_args");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("updateID", ::apache::thrift::protocol::T_I64, 2);
xfer += oprot->writeI64(this->updateID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("keyExtent", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->keyExtent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("mutations", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->mutations.size());
std::vector<accumulo::data::TMutation> ::const_iterator _iter141;
for (_iter141 = this->mutations.begin(); _iter141 != this->mutations.end(); ++_iter141)
{
xfer += (*_iter141).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_applyUpdates_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_applyUpdates_pargs");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("updateID", ::apache::thrift::protocol::T_I64, 2);
xfer += oprot->writeI64((*(this->updateID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("keyExtent", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->keyExtent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("mutations", ::apache::thrift::protocol::T_LIST, 4);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, (*(this->mutations)).size());
std::vector<accumulo::data::TMutation> ::const_iterator _iter142;
for (_iter142 = (*(this->mutations)).begin(); _iter142 != (*(this->mutations)).end(); ++_iter142)
{
xfer += (*_iter142).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->updateID);
this->__isset.updateID = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeUpdate_args");
xfer += oprot->writeFieldBegin("updateID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64(this->updateID);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeUpdate_pargs");
xfer += oprot->writeFieldBegin("updateID", ::apache::thrift::protocol::T_I64, 1);
xfer += oprot->writeI64((*(this->updateID)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_closeUpdate_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nssi) {
xfer += oprot->writeFieldBegin("nssi", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->nssi.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_closeUpdate_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nssi.read(iprot);
this->__isset.nssi = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_update_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->keyExtent.read(iprot);
this->__isset.keyExtent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->mutation.read(iprot);
this->__isset.mutation = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_update_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_update_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("keyExtent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->keyExtent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("mutation", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->mutation.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_update_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_update_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("keyExtent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->keyExtent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("mutation", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->mutation)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_update_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->cve.read(iprot);
this->__isset.cve = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_update_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_update_result");
if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nste) {
xfer += oprot->writeFieldBegin("nste", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->nste.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.cve) {
xfer += oprot->writeFieldBegin("cve", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->cve.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_update_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->cve.read(iprot);
this->__isset.cve = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->tid);
this->__isset.tid = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->files.clear();
uint32_t _size143;
::apache::thrift::protocol::TType _ktype144;
::apache::thrift::protocol::TType _vtype145;
iprot->readMapBegin(_ktype144, _vtype145, _size143);
uint32_t _i147;
for (_i147 = 0; _i147 < _size143; ++_i147)
{
accumulo::data::TKeyExtent _key148;
xfer += _key148.read(iprot);
std::map<std::string, accumulo::data::MapFileInfo> & _val149 = this->files[_key148];
{
_val149.clear();
uint32_t _size150;
::apache::thrift::protocol::TType _ktype151;
::apache::thrift::protocol::TType _vtype152;
iprot->readMapBegin(_ktype151, _vtype152, _size150);
uint32_t _i154;
for (_i154 = 0; _i154 < _size150; ++_i154)
{
std::string _key155;
xfer += iprot->readString(_key155);
accumulo::data::MapFileInfo& _val156 = _val149[_key155];
xfer += _val156.read(iprot);
}
iprot->readMapEnd();
}
}
iprot->readMapEnd();
}
this->__isset.files = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->setTime);
this->__isset.setTime = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_bulkImport_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("files", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRUCT, ::apache::thrift::protocol::T_MAP, this->files.size());
std::map<accumulo::data::TKeyExtent, std::map<std::string, accumulo::data::MapFileInfo> > ::const_iterator _iter157;
for (_iter157 = this->files.begin(); _iter157 != this->files.end(); ++_iter157)
{
xfer += _iter157->first.write(oprot);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, _iter157->second.size());
std::map<std::string, accumulo::data::MapFileInfo> ::const_iterator _iter158;
for (_iter158 = _iter157->second.begin(); _iter158 != _iter157->second.end(); ++_iter158)
{
xfer += oprot->writeString(_iter158->first);
xfer += _iter158->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tid", ::apache::thrift::protocol::T_I64, 4);
xfer += oprot->writeI64(this->tid);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("setTime", ::apache::thrift::protocol::T_BOOL, 5);
xfer += oprot->writeBool(this->setTime);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_bulkImport_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("files", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRUCT, ::apache::thrift::protocol::T_MAP, (*(this->files)).size());
std::map<accumulo::data::TKeyExtent, std::map<std::string, accumulo::data::MapFileInfo> > ::const_iterator _iter159;
for (_iter159 = (*(this->files)).begin(); _iter159 != (*(this->files)).end(); ++_iter159)
{
xfer += _iter159->first.write(oprot);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, _iter159->second.size());
std::map<std::string, accumulo::data::MapFileInfo> ::const_iterator _iter160;
for (_iter160 = _iter159->second.begin(); _iter160 != _iter159->second.end(); ++_iter160)
{
xfer += oprot->writeString(_iter160->first);
xfer += _iter160->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tid", ::apache::thrift::protocol::T_I64, 4);
xfer += oprot->writeI64((*(this->tid)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("setTime", ::apache::thrift::protocol::T_BOOL, 5);
xfer += oprot->writeBool((*(this->setTime)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
uint32_t _size161;
::apache::thrift::protocol::TType _etype164;
iprot->readListBegin(_etype164, _size161);
this->success.resize(_size161);
uint32_t _i165;
for (_i165 = 0; _i165 < _size161; ++_i165)
{
xfer += this->success[_i165].read(iprot);
}
iprot->readListEnd();
}
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_bulkImport_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, this->success.size());
std::vector<accumulo::data::TKeyExtent> ::const_iterator _iter166;
for (_iter166 = this->success.begin(); _iter166 != this->success.end(); ++_iter166)
{
xfer += (*_iter166).write(oprot);
}
xfer += oprot->writeListEnd();
}
xfer += oprot->writeFieldEnd();
} else if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_bulkImport_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
uint32_t _size167;
::apache::thrift::protocol::TType _etype170;
iprot->readListBegin(_etype170, _size167);
(*(this->success)).resize(_size167);
uint32_t _i171;
for (_i171 = 0; _i171 < _size167; ++_i171)
{
xfer += (*(this->success))[_i171].read(iprot);
}
iprot->readListEnd();
}
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readBinary(this->splitPoint);
this->__isset.splitPoint = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_splitTablet_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("splitPoint", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeBinary(this->splitPoint);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_splitTablet_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("splitPoint", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeBinary((*(this->splitPoint)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_splitTablet_result");
if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.nste) {
xfer += oprot->writeFieldBegin("nste", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->nste.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_splitTablet_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->nste.read(iprot);
this->__isset.nste = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_loadTablet_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 5:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_loadTablet_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_loadTablet_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 5);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_loadTablet_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_loadTablet_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 5);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_unloadTablet_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 5:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->save);
this->__isset.save = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_unloadTablet_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_unloadTablet_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("save", ::apache::thrift::protocol::T_BOOL, 3);
xfer += oprot->writeBool(this->save);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 5);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_unloadTablet_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_unloadTablet_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("save", ::apache::thrift::protocol::T_BOOL, 3);
xfer += oprot->writeBool((*(this->save)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 5);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_flush_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->tableId);
this->__isset.tableId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readBinary(this->startRow);
this->__isset.startRow = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 6:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readBinary(this->endRow);
this->__isset.endRow = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_flush_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_flush_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString(this->tableId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("startRow", ::apache::thrift::protocol::T_STRING, 5);
xfer += oprot->writeBinary(this->startRow);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("endRow", ::apache::thrift::protocol::T_STRING, 6);
xfer += oprot->writeBinary(this->endRow);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_flush_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_flush_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString((*(this->tableId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("startRow", ::apache::thrift::protocol::T_STRING, 5);
xfer += oprot->writeBinary((*(this->startRow)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("endRow", ::apache::thrift::protocol::T_STRING, 6);
xfer += oprot->writeBinary((*(this->endRow)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_flushTablet_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_flushTablet_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_flushTablet_args");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_flushTablet_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_flushTablet_pargs");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_chop_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->extent.read(iprot);
this->__isset.extent = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_chop_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_chop_args");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->extent.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_chop_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_chop_pargs");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("extent", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->extent)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_compact_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->lock);
this->__isset.lock = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->tableId);
this->__isset.tableId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readBinary(this->startRow);
this->__isset.startRow = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 6:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readBinary(this->endRow);
this->__isset.endRow = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_compact_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_compact_args");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString(this->lock);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString(this->tableId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("startRow", ::apache::thrift::protocol::T_STRING, 5);
xfer += oprot->writeBinary(this->startRow);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("endRow", ::apache::thrift::protocol::T_STRING, 6);
xfer += oprot->writeBinary(this->endRow);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_compact_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_compact_pargs");
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("lock", ::apache::thrift::protocol::T_STRING, 3);
xfer += oprot->writeString((*(this->lock)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 4);
xfer += oprot->writeString((*(this->tableId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("startRow", ::apache::thrift::protocol::T_STRING, 5);
xfer += oprot->writeBinary((*(this->startRow)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("endRow", ::apache::thrift::protocol::T_STRING, 6);
xfer += oprot->writeBinary((*(this->endRow)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_useLoggers_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_SET) {
{
this->loggers.clear();
uint32_t _size172;
::apache::thrift::protocol::TType _etype175;
iprot->readSetBegin(_etype175, _size172);
uint32_t _i176;
for (_i176 = 0; _i176 < _size172; ++_i176)
{
std::string _elem177;
xfer += iprot->readString(_elem177);
this->loggers.insert(_elem177);
}
iprot->readSetEnd();
}
this->__isset.loggers = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_useLoggers_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_useLoggers_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("loggers", ::apache::thrift::protocol::T_SET, 2);
{
xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, this->loggers.size());
std::set<std::string> ::const_iterator _iter178;
for (_iter178 = this->loggers.begin(); _iter178 != this->loggers.end(); ++_iter178)
{
xfer += oprot->writeString((*_iter178));
}
xfer += oprot->writeSetEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_useLoggers_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_useLoggers_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("loggers", ::apache::thrift::protocol::T_SET, 2);
{
xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, (*(this->loggers)).size());
std::set<std::string> ::const_iterator _iter179;
for (_iter179 = (*(this->loggers)).begin(); _iter179 != (*(this->loggers)).end(); ++_iter179)
{
xfer += oprot->writeString((*_iter179));
}
xfer += oprot->writeSetEnd();
}
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_getTabletServerStatus_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_getTabletServerStatus_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_getTabletServerStatus_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
xfer += this->success.write(oprot);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.sec) {
xfer += oprot->writeFieldBegin("sec", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->sec.write(oprot);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletServerStatus_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 0:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->sec.read(iprot);
this->__isset.sec = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletStats_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 3:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->tinfo.read(iprot);
this->__isset.tinfo = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->credentials.read(iprot);
this->__isset.credentials = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->tableId);
this->__isset.tableId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletStats_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_getTabletStats_args");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->credentials.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString(this->tableId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += this->tinfo.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletStats_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
xfer += oprot->writeStructBegin("TabletClientService_getTabletStats_pargs");
xfer += oprot->writeFieldBegin("credentials", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->credentials)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tableId", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString((*(this->tableId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldBegin("tinfo", ::apache::thrift::protocol::T_STRUCT, 3);
xfer += (*(this->tinfo)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
uint32_t TabletClientService_getTabletStats_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;