grpcdbclient.h 755 B

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. #ifndef GRPCDBCLIENT_H
  2. #define GRPCDBCLIENT_H
  3. #include <QMutex>
  4. #include <QThread>
  5. #include <QWaitCondition>
  6. #include <grpcpp/grpcpp.h>
  7. #include "../../driver/driver_db_grpc_server/grpcdb.grpc.pb.h"
  8. using grpc::Channel;
  9. using grpc::ClientContext;
  10. using grpc::Status;
  11. class grpcdbclient : public QThread
  12. {
  13. Q_OBJECT
  14. public:
  15. grpcdbclient();
  16. signals:
  17. void reqres(int);
  18. private:
  19. std::string mstrserverip = "127.0.0.1";
  20. std::string mstrserverport = "31011";
  21. iv::db::listRequest mlistreq;
  22. bool mblistrequpdate = false;
  23. QMutex mMutexReq;
  24. QMutex mWaitMutex;
  25. QWaitCondition mwc;
  26. private:
  27. void run();
  28. public:
  29. void requestlist(qint64 timefrom, qint64 timeto,std::string strvehid);
  30. };
  31. #endif // GRPCDBCLIENT_H