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>
