#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