You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by am...@apache.org on 2015/12/21 09:45:58 UTC
[08/23] hive git commit: HIVE-11487 : Adds getNumPartitionsByFilter
api in metastore api
http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/TCLIService.cpp
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-cpp/TCLIService.cpp b/service/src/gen/thrift/gen-cpp/TCLIService.cpp
index 7e2c028..7dae2f8 100644
--- a/service/src/gen/thrift/gen-cpp/TCLIService.cpp
+++ b/service/src/gen/thrift/gen-cpp/TCLIService.cpp
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -15,7 +15,6 @@ TCLIService_OpenSession_args::~TCLIService_OpenSession_args() throw() {
uint32_t TCLIService_OpenSession_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -56,7 +55,7 @@ uint32_t TCLIService_OpenSession_args::read(::apache::thrift::protocol::TProtoco
uint32_t TCLIService_OpenSession_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_OpenSession_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -65,6 +64,7 @@ uint32_t TCLIService_OpenSession_args::write(::apache::thrift::protocol::TProtoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -75,7 +75,7 @@ TCLIService_OpenSession_pargs::~TCLIService_OpenSession_pargs() throw() {
uint32_t TCLIService_OpenSession_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_OpenSession_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -84,6 +84,7 @@ uint32_t TCLIService_OpenSession_pargs::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -94,7 +95,6 @@ TCLIService_OpenSession_result::~TCLIService_OpenSession_result() throw() {
uint32_t TCLIService_OpenSession_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -156,7 +156,6 @@ TCLIService_OpenSession_presult::~TCLIService_OpenSession_presult() throw() {
uint32_t TCLIService_OpenSession_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -202,7 +201,6 @@ TCLIService_CloseSession_args::~TCLIService_CloseSession_args() throw() {
uint32_t TCLIService_CloseSession_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -243,7 +241,7 @@ uint32_t TCLIService_CloseSession_args::read(::apache::thrift::protocol::TProtoc
uint32_t TCLIService_CloseSession_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CloseSession_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -252,6 +250,7 @@ uint32_t TCLIService_CloseSession_args::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -262,7 +261,7 @@ TCLIService_CloseSession_pargs::~TCLIService_CloseSession_pargs() throw() {
uint32_t TCLIService_CloseSession_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CloseSession_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -271,6 +270,7 @@ uint32_t TCLIService_CloseSession_pargs::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -281,7 +281,6 @@ TCLIService_CloseSession_result::~TCLIService_CloseSession_result() throw() {
uint32_t TCLIService_CloseSession_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -343,7 +342,6 @@ TCLIService_CloseSession_presult::~TCLIService_CloseSession_presult() throw() {
uint32_t TCLIService_CloseSession_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -389,7 +387,6 @@ TCLIService_GetInfo_args::~TCLIService_GetInfo_args() throw() {
uint32_t TCLIService_GetInfo_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -430,7 +427,7 @@ uint32_t TCLIService_GetInfo_args::read(::apache::thrift::protocol::TProtocol* i
uint32_t TCLIService_GetInfo_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetInfo_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -439,6 +436,7 @@ uint32_t TCLIService_GetInfo_args::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -449,7 +447,7 @@ TCLIService_GetInfo_pargs::~TCLIService_GetInfo_pargs() throw() {
uint32_t TCLIService_GetInfo_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetInfo_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -458,6 +456,7 @@ uint32_t TCLIService_GetInfo_pargs::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -468,7 +467,6 @@ TCLIService_GetInfo_result::~TCLIService_GetInfo_result() throw() {
uint32_t TCLIService_GetInfo_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -530,7 +528,6 @@ TCLIService_GetInfo_presult::~TCLIService_GetInfo_presult() throw() {
uint32_t TCLIService_GetInfo_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -576,7 +573,6 @@ TCLIService_ExecuteStatement_args::~TCLIService_ExecuteStatement_args() throw()
uint32_t TCLIService_ExecuteStatement_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -617,7 +613,7 @@ uint32_t TCLIService_ExecuteStatement_args::read(::apache::thrift::protocol::TPr
uint32_t TCLIService_ExecuteStatement_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_ExecuteStatement_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -626,6 +622,7 @@ uint32_t TCLIService_ExecuteStatement_args::write(::apache::thrift::protocol::TP
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -636,7 +633,7 @@ TCLIService_ExecuteStatement_pargs::~TCLIService_ExecuteStatement_pargs() throw(
uint32_t TCLIService_ExecuteStatement_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_ExecuteStatement_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -645,6 +642,7 @@ uint32_t TCLIService_ExecuteStatement_pargs::write(::apache::thrift::protocol::T
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -655,7 +653,6 @@ TCLIService_ExecuteStatement_result::~TCLIService_ExecuteStatement_result() thro
uint32_t TCLIService_ExecuteStatement_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -717,7 +714,6 @@ TCLIService_ExecuteStatement_presult::~TCLIService_ExecuteStatement_presult() th
uint32_t TCLIService_ExecuteStatement_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -763,7 +759,6 @@ TCLIService_GetTypeInfo_args::~TCLIService_GetTypeInfo_args() throw() {
uint32_t TCLIService_GetTypeInfo_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -804,7 +799,7 @@ uint32_t TCLIService_GetTypeInfo_args::read(::apache::thrift::protocol::TProtoco
uint32_t TCLIService_GetTypeInfo_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTypeInfo_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -813,6 +808,7 @@ uint32_t TCLIService_GetTypeInfo_args::write(::apache::thrift::protocol::TProtoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -823,7 +819,7 @@ TCLIService_GetTypeInfo_pargs::~TCLIService_GetTypeInfo_pargs() throw() {
uint32_t TCLIService_GetTypeInfo_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTypeInfo_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -832,6 +828,7 @@ uint32_t TCLIService_GetTypeInfo_pargs::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -842,7 +839,6 @@ TCLIService_GetTypeInfo_result::~TCLIService_GetTypeInfo_result() throw() {
uint32_t TCLIService_GetTypeInfo_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -904,7 +900,6 @@ TCLIService_GetTypeInfo_presult::~TCLIService_GetTypeInfo_presult() throw() {
uint32_t TCLIService_GetTypeInfo_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -950,7 +945,6 @@ TCLIService_GetCatalogs_args::~TCLIService_GetCatalogs_args() throw() {
uint32_t TCLIService_GetCatalogs_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -991,7 +985,7 @@ uint32_t TCLIService_GetCatalogs_args::read(::apache::thrift::protocol::TProtoco
uint32_t TCLIService_GetCatalogs_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetCatalogs_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1000,6 +994,7 @@ uint32_t TCLIService_GetCatalogs_args::write(::apache::thrift::protocol::TProtoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1010,7 +1005,7 @@ TCLIService_GetCatalogs_pargs::~TCLIService_GetCatalogs_pargs() throw() {
uint32_t TCLIService_GetCatalogs_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetCatalogs_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1019,6 +1014,7 @@ uint32_t TCLIService_GetCatalogs_pargs::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1029,7 +1025,6 @@ TCLIService_GetCatalogs_result::~TCLIService_GetCatalogs_result() throw() {
uint32_t TCLIService_GetCatalogs_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1091,7 +1086,6 @@ TCLIService_GetCatalogs_presult::~TCLIService_GetCatalogs_presult() throw() {
uint32_t TCLIService_GetCatalogs_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1137,7 +1131,6 @@ TCLIService_GetSchemas_args::~TCLIService_GetSchemas_args() throw() {
uint32_t TCLIService_GetSchemas_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1178,7 +1171,7 @@ uint32_t TCLIService_GetSchemas_args::read(::apache::thrift::protocol::TProtocol
uint32_t TCLIService_GetSchemas_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetSchemas_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1187,6 +1180,7 @@ uint32_t TCLIService_GetSchemas_args::write(::apache::thrift::protocol::TProtoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1197,7 +1191,7 @@ TCLIService_GetSchemas_pargs::~TCLIService_GetSchemas_pargs() throw() {
uint32_t TCLIService_GetSchemas_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetSchemas_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1206,6 +1200,7 @@ uint32_t TCLIService_GetSchemas_pargs::write(::apache::thrift::protocol::TProtoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1216,7 +1211,6 @@ TCLIService_GetSchemas_result::~TCLIService_GetSchemas_result() throw() {
uint32_t TCLIService_GetSchemas_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1278,7 +1272,6 @@ TCLIService_GetSchemas_presult::~TCLIService_GetSchemas_presult() throw() {
uint32_t TCLIService_GetSchemas_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1324,7 +1317,6 @@ TCLIService_GetTables_args::~TCLIService_GetTables_args() throw() {
uint32_t TCLIService_GetTables_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1365,7 +1357,7 @@ uint32_t TCLIService_GetTables_args::read(::apache::thrift::protocol::TProtocol*
uint32_t TCLIService_GetTables_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTables_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1374,6 +1366,7 @@ uint32_t TCLIService_GetTables_args::write(::apache::thrift::protocol::TProtocol
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1384,7 +1377,7 @@ TCLIService_GetTables_pargs::~TCLIService_GetTables_pargs() throw() {
uint32_t TCLIService_GetTables_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTables_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1393,6 +1386,7 @@ uint32_t TCLIService_GetTables_pargs::write(::apache::thrift::protocol::TProtoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1403,7 +1397,6 @@ TCLIService_GetTables_result::~TCLIService_GetTables_result() throw() {
uint32_t TCLIService_GetTables_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1465,7 +1458,6 @@ TCLIService_GetTables_presult::~TCLIService_GetTables_presult() throw() {
uint32_t TCLIService_GetTables_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1511,7 +1503,6 @@ TCLIService_GetTableTypes_args::~TCLIService_GetTableTypes_args() throw() {
uint32_t TCLIService_GetTableTypes_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1552,7 +1543,7 @@ uint32_t TCLIService_GetTableTypes_args::read(::apache::thrift::protocol::TProto
uint32_t TCLIService_GetTableTypes_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTableTypes_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1561,6 +1552,7 @@ uint32_t TCLIService_GetTableTypes_args::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1571,7 +1563,7 @@ TCLIService_GetTableTypes_pargs::~TCLIService_GetTableTypes_pargs() throw() {
uint32_t TCLIService_GetTableTypes_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetTableTypes_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1580,6 +1572,7 @@ uint32_t TCLIService_GetTableTypes_pargs::write(::apache::thrift::protocol::TPro
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1590,7 +1583,6 @@ TCLIService_GetTableTypes_result::~TCLIService_GetTableTypes_result() throw() {
uint32_t TCLIService_GetTableTypes_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1652,7 +1644,6 @@ TCLIService_GetTableTypes_presult::~TCLIService_GetTableTypes_presult() throw()
uint32_t TCLIService_GetTableTypes_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1698,7 +1689,6 @@ TCLIService_GetColumns_args::~TCLIService_GetColumns_args() throw() {
uint32_t TCLIService_GetColumns_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1739,7 +1729,7 @@ uint32_t TCLIService_GetColumns_args::read(::apache::thrift::protocol::TProtocol
uint32_t TCLIService_GetColumns_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetColumns_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1748,6 +1738,7 @@ uint32_t TCLIService_GetColumns_args::write(::apache::thrift::protocol::TProtoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1758,7 +1749,7 @@ TCLIService_GetColumns_pargs::~TCLIService_GetColumns_pargs() throw() {
uint32_t TCLIService_GetColumns_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetColumns_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1767,6 +1758,7 @@ uint32_t TCLIService_GetColumns_pargs::write(::apache::thrift::protocol::TProtoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1777,7 +1769,6 @@ TCLIService_GetColumns_result::~TCLIService_GetColumns_result() throw() {
uint32_t TCLIService_GetColumns_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1839,7 +1830,6 @@ TCLIService_GetColumns_presult::~TCLIService_GetColumns_presult() throw() {
uint32_t TCLIService_GetColumns_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1885,7 +1875,6 @@ TCLIService_GetFunctions_args::~TCLIService_GetFunctions_args() throw() {
uint32_t TCLIService_GetFunctions_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -1926,7 +1915,7 @@ uint32_t TCLIService_GetFunctions_args::read(::apache::thrift::protocol::TProtoc
uint32_t TCLIService_GetFunctions_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetFunctions_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1935,6 +1924,7 @@ uint32_t TCLIService_GetFunctions_args::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1945,7 +1935,7 @@ TCLIService_GetFunctions_pargs::~TCLIService_GetFunctions_pargs() throw() {
uint32_t TCLIService_GetFunctions_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetFunctions_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -1954,6 +1944,7 @@ uint32_t TCLIService_GetFunctions_pargs::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -1964,7 +1955,6 @@ TCLIService_GetFunctions_result::~TCLIService_GetFunctions_result() throw() {
uint32_t TCLIService_GetFunctions_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2026,7 +2016,6 @@ TCLIService_GetFunctions_presult::~TCLIService_GetFunctions_presult() throw() {
uint32_t TCLIService_GetFunctions_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2072,7 +2061,6 @@ TCLIService_GetOperationStatus_args::~TCLIService_GetOperationStatus_args() thro
uint32_t TCLIService_GetOperationStatus_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2113,7 +2101,7 @@ uint32_t TCLIService_GetOperationStatus_args::read(::apache::thrift::protocol::T
uint32_t TCLIService_GetOperationStatus_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetOperationStatus_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2122,6 +2110,7 @@ uint32_t TCLIService_GetOperationStatus_args::write(::apache::thrift::protocol::
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2132,7 +2121,7 @@ TCLIService_GetOperationStatus_pargs::~TCLIService_GetOperationStatus_pargs() th
uint32_t TCLIService_GetOperationStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetOperationStatus_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2141,6 +2130,7 @@ uint32_t TCLIService_GetOperationStatus_pargs::write(::apache::thrift::protocol:
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2151,7 +2141,6 @@ TCLIService_GetOperationStatus_result::~TCLIService_GetOperationStatus_result()
uint32_t TCLIService_GetOperationStatus_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2213,7 +2202,6 @@ TCLIService_GetOperationStatus_presult::~TCLIService_GetOperationStatus_presult(
uint32_t TCLIService_GetOperationStatus_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2259,7 +2247,6 @@ TCLIService_CancelOperation_args::~TCLIService_CancelOperation_args() throw() {
uint32_t TCLIService_CancelOperation_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2300,7 +2287,7 @@ uint32_t TCLIService_CancelOperation_args::read(::apache::thrift::protocol::TPro
uint32_t TCLIService_CancelOperation_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CancelOperation_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2309,6 +2296,7 @@ uint32_t TCLIService_CancelOperation_args::write(::apache::thrift::protocol::TPr
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2319,7 +2307,7 @@ TCLIService_CancelOperation_pargs::~TCLIService_CancelOperation_pargs() throw()
uint32_t TCLIService_CancelOperation_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CancelOperation_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2328,6 +2316,7 @@ uint32_t TCLIService_CancelOperation_pargs::write(::apache::thrift::protocol::TP
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2338,7 +2327,6 @@ TCLIService_CancelOperation_result::~TCLIService_CancelOperation_result() throw(
uint32_t TCLIService_CancelOperation_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2400,7 +2388,6 @@ TCLIService_CancelOperation_presult::~TCLIService_CancelOperation_presult() thro
uint32_t TCLIService_CancelOperation_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2446,7 +2433,6 @@ TCLIService_CloseOperation_args::~TCLIService_CloseOperation_args() throw() {
uint32_t TCLIService_CloseOperation_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2487,7 +2473,7 @@ uint32_t TCLIService_CloseOperation_args::read(::apache::thrift::protocol::TProt
uint32_t TCLIService_CloseOperation_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CloseOperation_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2496,6 +2482,7 @@ uint32_t TCLIService_CloseOperation_args::write(::apache::thrift::protocol::TPro
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2506,7 +2493,7 @@ TCLIService_CloseOperation_pargs::~TCLIService_CloseOperation_pargs() throw() {
uint32_t TCLIService_CloseOperation_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CloseOperation_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2515,6 +2502,7 @@ uint32_t TCLIService_CloseOperation_pargs::write(::apache::thrift::protocol::TPr
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2525,7 +2513,6 @@ TCLIService_CloseOperation_result::~TCLIService_CloseOperation_result() throw()
uint32_t TCLIService_CloseOperation_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2587,7 +2574,6 @@ TCLIService_CloseOperation_presult::~TCLIService_CloseOperation_presult() throw(
uint32_t TCLIService_CloseOperation_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2633,7 +2619,6 @@ TCLIService_GetResultSetMetadata_args::~TCLIService_GetResultSetMetadata_args()
uint32_t TCLIService_GetResultSetMetadata_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2674,7 +2659,7 @@ uint32_t TCLIService_GetResultSetMetadata_args::read(::apache::thrift::protocol:
uint32_t TCLIService_GetResultSetMetadata_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetResultSetMetadata_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2683,6 +2668,7 @@ uint32_t TCLIService_GetResultSetMetadata_args::write(::apache::thrift::protocol
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2693,7 +2679,7 @@ TCLIService_GetResultSetMetadata_pargs::~TCLIService_GetResultSetMetadata_pargs(
uint32_t TCLIService_GetResultSetMetadata_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetResultSetMetadata_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2702,6 +2688,7 @@ uint32_t TCLIService_GetResultSetMetadata_pargs::write(::apache::thrift::protoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2712,7 +2699,6 @@ TCLIService_GetResultSetMetadata_result::~TCLIService_GetResultSetMetadata_resul
uint32_t TCLIService_GetResultSetMetadata_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2774,7 +2760,6 @@ TCLIService_GetResultSetMetadata_presult::~TCLIService_GetResultSetMetadata_pres
uint32_t TCLIService_GetResultSetMetadata_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2820,7 +2805,6 @@ TCLIService_FetchResults_args::~TCLIService_FetchResults_args() throw() {
uint32_t TCLIService_FetchResults_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2861,7 +2845,7 @@ uint32_t TCLIService_FetchResults_args::read(::apache::thrift::protocol::TProtoc
uint32_t TCLIService_FetchResults_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_FetchResults_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2870,6 +2854,7 @@ uint32_t TCLIService_FetchResults_args::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2880,7 +2865,7 @@ TCLIService_FetchResults_pargs::~TCLIService_FetchResults_pargs() throw() {
uint32_t TCLIService_FetchResults_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_FetchResults_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -2889,6 +2874,7 @@ uint32_t TCLIService_FetchResults_pargs::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -2899,7 +2885,6 @@ TCLIService_FetchResults_result::~TCLIService_FetchResults_result() throw() {
uint32_t TCLIService_FetchResults_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -2961,7 +2946,6 @@ TCLIService_FetchResults_presult::~TCLIService_FetchResults_presult() throw() {
uint32_t TCLIService_FetchResults_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3007,7 +2991,6 @@ TCLIService_GetDelegationToken_args::~TCLIService_GetDelegationToken_args() thro
uint32_t TCLIService_GetDelegationToken_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3048,7 +3031,7 @@ uint32_t TCLIService_GetDelegationToken_args::read(::apache::thrift::protocol::T
uint32_t TCLIService_GetDelegationToken_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetDelegationToken_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3057,6 +3040,7 @@ uint32_t TCLIService_GetDelegationToken_args::write(::apache::thrift::protocol::
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3067,7 +3051,7 @@ TCLIService_GetDelegationToken_pargs::~TCLIService_GetDelegationToken_pargs() th
uint32_t TCLIService_GetDelegationToken_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_GetDelegationToken_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3076,6 +3060,7 @@ uint32_t TCLIService_GetDelegationToken_pargs::write(::apache::thrift::protocol:
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3086,7 +3071,6 @@ TCLIService_GetDelegationToken_result::~TCLIService_GetDelegationToken_result()
uint32_t TCLIService_GetDelegationToken_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3148,7 +3132,6 @@ TCLIService_GetDelegationToken_presult::~TCLIService_GetDelegationToken_presult(
uint32_t TCLIService_GetDelegationToken_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3194,7 +3177,6 @@ TCLIService_CancelDelegationToken_args::~TCLIService_CancelDelegationToken_args(
uint32_t TCLIService_CancelDelegationToken_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3235,7 +3217,7 @@ uint32_t TCLIService_CancelDelegationToken_args::read(::apache::thrift::protocol
uint32_t TCLIService_CancelDelegationToken_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CancelDelegationToken_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3244,6 +3226,7 @@ uint32_t TCLIService_CancelDelegationToken_args::write(::apache::thrift::protoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3254,7 +3237,7 @@ TCLIService_CancelDelegationToken_pargs::~TCLIService_CancelDelegationToken_parg
uint32_t TCLIService_CancelDelegationToken_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_CancelDelegationToken_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3263,6 +3246,7 @@ uint32_t TCLIService_CancelDelegationToken_pargs::write(::apache::thrift::protoc
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3273,7 +3257,6 @@ TCLIService_CancelDelegationToken_result::~TCLIService_CancelDelegationToken_res
uint32_t TCLIService_CancelDelegationToken_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3335,7 +3318,6 @@ TCLIService_CancelDelegationToken_presult::~TCLIService_CancelDelegationToken_pr
uint32_t TCLIService_CancelDelegationToken_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3381,7 +3363,6 @@ TCLIService_RenewDelegationToken_args::~TCLIService_RenewDelegationToken_args()
uint32_t TCLIService_RenewDelegationToken_args::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3422,7 +3403,7 @@ uint32_t TCLIService_RenewDelegationToken_args::read(::apache::thrift::protocol:
uint32_t TCLIService_RenewDelegationToken_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_RenewDelegationToken_args");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3431,6 +3412,7 @@ uint32_t TCLIService_RenewDelegationToken_args::write(::apache::thrift::protocol
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3441,7 +3423,7 @@ TCLIService_RenewDelegationToken_pargs::~TCLIService_RenewDelegationToken_pargs(
uint32_t TCLIService_RenewDelegationToken_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+ oprot->incrementRecursionDepth();
xfer += oprot->writeStructBegin("TCLIService_RenewDelegationToken_pargs");
xfer += oprot->writeFieldBegin("req", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -3450,6 +3432,7 @@ uint32_t TCLIService_RenewDelegationToken_pargs::write(::apache::thrift::protoco
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
return xfer;
}
@@ -3460,7 +3443,6 @@ TCLIService_RenewDelegationToken_result::~TCLIService_RenewDelegationToken_resul
uint32_t TCLIService_RenewDelegationToken_result::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -3522,7 +3504,6 @@ TCLIService_RenewDelegationToken_presult::~TCLIService_RenewDelegationToken_pres
uint32_t TCLIService_RenewDelegationToken_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
- apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
@@ -5714,1602 +5695,5 @@ void TCLIServiceProcessor::process_RenewDelegationToken(int32_t seqid, ::apache:
::boost::shared_ptr< ::apache::thrift::TProcessor > processor(new TCLIServiceProcessor(handler));
return processor;
}
-
-void TCLIServiceConcurrentClient::OpenSession(TOpenSessionResp& _return, const TOpenSessionReq& req)
-{
- int32_t seqid = send_OpenSession(req);
- recv_OpenSession(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_OpenSession(const TOpenSessionReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("OpenSession", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_OpenSession_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_OpenSession(TOpenSessionResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("OpenSession") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_OpenSession_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "OpenSession failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::CloseSession(TCloseSessionResp& _return, const TCloseSessionReq& req)
-{
- int32_t seqid = send_CloseSession(req);
- recv_CloseSession(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_CloseSession(const TCloseSessionReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("CloseSession", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_CloseSession_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_CloseSession(TCloseSessionResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("CloseSession") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_CloseSession_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "CloseSession failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetInfo(TGetInfoResp& _return, const TGetInfoReq& req)
-{
- int32_t seqid = send_GetInfo(req);
- recv_GetInfo(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetInfo(const TGetInfoReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetInfo", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetInfo_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetInfo(TGetInfoResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetInfo") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetInfo_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetInfo failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::ExecuteStatement(TExecuteStatementResp& _return, const TExecuteStatementReq& req)
-{
- int32_t seqid = send_ExecuteStatement(req);
- recv_ExecuteStatement(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_ExecuteStatement(const TExecuteStatementReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("ExecuteStatement", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_ExecuteStatement_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_ExecuteStatement(TExecuteStatementResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("ExecuteStatement") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_ExecuteStatement_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "ExecuteStatement failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetTypeInfo(TGetTypeInfoResp& _return, const TGetTypeInfoReq& req)
-{
- int32_t seqid = send_GetTypeInfo(req);
- recv_GetTypeInfo(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetTypeInfo(const TGetTypeInfoReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetTypeInfo", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetTypeInfo_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetTypeInfo(TGetTypeInfoResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetTypeInfo") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetTypeInfo_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetTypeInfo failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetCatalogs(TGetCatalogsResp& _return, const TGetCatalogsReq& req)
-{
- int32_t seqid = send_GetCatalogs(req);
- recv_GetCatalogs(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetCatalogs(const TGetCatalogsReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetCatalogs", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetCatalogs_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetCatalogs(TGetCatalogsResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetCatalogs") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetCatalogs_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetCatalogs failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetSchemas(TGetSchemasResp& _return, const TGetSchemasReq& req)
-{
- int32_t seqid = send_GetSchemas(req);
- recv_GetSchemas(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetSchemas(const TGetSchemasReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetSchemas", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetSchemas_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetSchemas(TGetSchemasResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetSchemas") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetSchemas_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetSchemas failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetTables(TGetTablesResp& _return, const TGetTablesReq& req)
-{
- int32_t seqid = send_GetTables(req);
- recv_GetTables(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetTables(const TGetTablesReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetTables", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetTables_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetTables(TGetTablesResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetTables") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetTables_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetTables failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetTableTypes(TGetTableTypesResp& _return, const TGetTableTypesReq& req)
-{
- int32_t seqid = send_GetTableTypes(req);
- recv_GetTableTypes(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetTableTypes(const TGetTableTypesReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetTableTypes", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetTableTypes_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetTableTypes(TGetTableTypesResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetTableTypes") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetTableTypes_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetTableTypes failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetColumns(TGetColumnsResp& _return, const TGetColumnsReq& req)
-{
- int32_t seqid = send_GetColumns(req);
- recv_GetColumns(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetColumns(const TGetColumnsReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetColumns", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetColumns_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetColumns(TGetColumnsResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetColumns") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetColumns_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetColumns failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetFunctions(TGetFunctionsResp& _return, const TGetFunctionsReq& req)
-{
- int32_t seqid = send_GetFunctions(req);
- recv_GetFunctions(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetFunctions(const TGetFunctionsReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetFunctions", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetFunctions_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetFunctions(TGetFunctionsResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetFunctions") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetFunctions_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetFunctions failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::GetOperationStatus(TGetOperationStatusResp& _return, const TGetOperationStatusReq& req)
-{
- int32_t seqid = send_GetOperationStatus(req);
- recv_GetOperationStatus(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_GetOperationStatus(const TGetOperationStatusReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("GetOperationStatus", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_GetOperationStatus_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_GetOperationStatus(TGetOperationStatusResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("GetOperationStatus") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_GetOperationStatus_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetOperationStatus failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::CancelOperation(TCancelOperationResp& _return, const TCancelOperationReq& req)
-{
- int32_t seqid = send_CancelOperation(req);
- recv_CancelOperation(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_CancelOperation(const TCancelOperationReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("CancelOperation", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_CancelOperation_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_CancelOperation(TCancelOperationResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("CancelOperation") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_CancelOperation_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "CancelOperation failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will temporarily unlock the readMutex, and let other clients get work done
- this->sync_.waitForWork(seqid);
- } // end while(true)
-}
-
-void TCLIServiceConcurrentClient::CloseOperation(TCloseOperationResp& _return, const TCloseOperationReq& req)
-{
- int32_t seqid = send_CloseOperation(req);
- recv_CloseOperation(_return, seqid);
-}
-
-int32_t TCLIServiceConcurrentClient::send_CloseOperation(const TCloseOperationReq& req)
-{
- int32_t cseqid = this->sync_.generateSeqId();
- ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_);
- oprot_->writeMessageBegin("CloseOperation", ::apache::thrift::protocol::T_CALL, cseqid);
-
- TCLIService_CloseOperation_pargs args;
- args.req = &req;
- args.write(oprot_);
-
- oprot_->writeMessageEnd();
- oprot_->getTransport()->writeEnd();
- oprot_->getTransport()->flush();
-
- sentry.commit();
- return cseqid;
-}
-
-void TCLIServiceConcurrentClient::recv_CloseOperation(TCloseOperationResp& _return, const int32_t seqid)
-{
-
- int32_t rseqid = 0;
- std::string fname;
- ::apache::thrift::protocol::TMessageType mtype;
-
- // the read mutex gets dropped and reacquired as part of waitForWork()
- // The destructor of this sentry wakes up other clients
- ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid);
-
- while(true) {
- if(!this->sync_.getPending(fname, mtype, rseqid)) {
- iprot_->readMessageBegin(fname, mtype, rseqid);
- }
- if(seqid == rseqid) {
- if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
- ::apache::thrift::TApplicationException x;
- x.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- sentry.commit();
- throw x;
- }
- if (mtype != ::apache::thrift::protocol::T_REPLY) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
- }
- if (fname.compare("CloseOperation") != 0) {
- iprot_->skip(::apache::thrift::protocol::T_STRUCT);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- // in a bad state, don't commit
- using ::apache::thrift::protocol::TProtocolException;
- throw TProtocolException(TProtocolException::INVALID_DATA);
- }
- TCLIService_CloseOperation_presult result;
- result.success = &_return;
- result.read(iprot_);
- iprot_->readMessageEnd();
- iprot_->getTransport()->readEnd();
-
- if (result.__isset.success) {
- // _return pointer has now been filled
- sentry.commit();
- return;
- }
- // in a bad state, don't commit
- throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "CloseOperation failed: unknown result");
- }
- // seqid != rseqid
- this->sync_.updatePending(fname, mtype, rseqid);
-
- // this will tempo
<TRUNCATED>