123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 |
- #ifndef GRPCFWCLIENT_H
- #define GRPCFWCLIENT_H
- #include <mutex>
- #include <thread>
- #include <condition_variable>
- #include <iostream>
- #include <grpcpp/grpcpp.h>
- #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
|