Thrift之QT远程调用（银河麒麟高级服务器版V10操作系统）

/** * Autogenerated by Thrift Compiler (0.17.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ #include "CaoShangPa.h" CaoShangPa_put_args::~CaoShangPa_put_args() noexcept { } uint32_t CaoShangPa_put_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; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->s.read(iprot); this->__isset.s = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t CaoShangPa_put_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("CaoShangPa_put_args"); xfer += oprot->writeFieldBegin("s", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->s.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } CaoShangPa_put_pargs::~CaoShangPa_put_pargs() noexcept { } uint32_t CaoShangPa_put_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("CaoShangPa_put_pargs"); xfer += oprot->writeFieldBegin("s", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->s)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } CaoShangPa_put_result::~CaoShangPa_put_result() noexcept { } uint32_t CaoShangPa_put_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; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } xfer += iprot->skip(ftype); xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t CaoShangPa_put_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("CaoShangPa_put_result"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } CaoShangPa_put_presult::~CaoShangPa_put_presult() noexcept { } uint32_t CaoShangPa_put_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; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } xfer += iprot->skip(ftype); xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } void CaoShangPaClient::put(const Student& s) { send_put(s); recv_put(); } void CaoShangPaClient::send_put(const Student& s) { int32_t cseqid = 0; oprot_->writeMessageBegin("put", ::apache::thrift::protocol::T_CALL, cseqid); CaoShangPa_put_pargs args; args.s = &s; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void CaoShangPaClient::recv_put() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("put") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } CaoShangPa_put_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); return; } bool CaoShangPaProcessor::dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext) { ProcessMap::iterator pfn; pfn = processMap_.find(fname); if (pfn == processMap_.end()) { iprot->skip(::apache::thrift::protocol::T_STRUCT); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); ::apache::thrift::TApplicationException x(::apache::thrift::TApplicationException::UNKNOWN_METHOD, "Invalid method name: '"+fname+"'"); oprot->writeMessageBegin(fname, ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return true; } (this->*(pfn->second))(seqid, iprot, oprot, callContext); return true; } void CaoShangPaProcessor::process_put(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = nullptr; if (this->eventHandler_.get() != nullptr) { ctx = this->eventHandler_->getContext("CaoShangPa.put", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "CaoShangPa.put"); if (this->eventHandler_.get() != nullptr) { this->eventHandler_->preRead(ctx, "CaoShangPa.put"); } CaoShangPa_put_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != nullptr) { this->eventHandler_->postRead(ctx, "CaoShangPa.put", bytes); } CaoShangPa_put_result result; try { iface_->put(args.s); } catch (const std::exception& e) { if (this->eventHandler_.get() != nullptr) { this->eventHandler_->handlerError(ctx, "CaoShangPa.put"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("put", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != nullptr) { this->eventHandler_->preWrite(ctx, "CaoShangPa.put"); } oprot->writeMessageBegin("put", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != nullptr) { this->eventHandler_->postWrite(ctx, "CaoShangPa.put", bytes); } } ::std::shared_ptr< ::apache::thrift::TProcessor > CaoShangPaProcessorFactory::getProcessor(const ::apache::thrift::TConnectionInfo& connInfo) { ::apache::thrift::ReleaseHandler< CaoShangPaIfFactory > cleanup(handlerFactory_); ::std::shared_ptr< CaoShangPaIf > handler(handlerFactory_->getHandler(connInfo), cleanup); ::std::sha