#ifndef GRPCFWCLIENT_H #define GRPCFWCLIENT_H #include #include #include #include #include #include "commonrpc.grpc.pb.h" #include "commonrpc.pb.h" using grpc::Channel; using grpc::ClientContext; using grpc::Status; class grpcfwclient { public: grpcfwclient(); ~grpcfwclient(); private: void threadrpc(); private: std::thread * mpthread = NULL; bool mbRun = true; std::string mstrserverip = "127.0.0.1"; std::string mstrserverport = "19111"; std::condition_variable mcv; std::mutex mmutexcv; std::mutex mmutexReq; std::mutex mmutexReply; iv::queryrpcReq mReq; bool mbReqUpdate = false; int mnConnectFail = 0; //4 14 fail; iv::queryrpcReply mReply; bool mbReplyUpdate = false; public: void SetReq(iv::queryrpcReq & xreq); int GetReply(iv::queryrpcReply & xReply); }; #endif // GRPCFWCLIENT_H