modularization/src/driver/driver_cloud_grpc_pc_thread/grpcpc.h

#ifndef GRPCPC_H
#define GRPCPC_H

#include <QThread>

#include <yaml-cpp/yaml.h>

#include <QDateTime>

#include <iostream>

#include <vector>

#include <memory>

#include <QMutex>

#include <thread>

#include "modulecomm.h"


#include "cloud.pb.h"

#include <iostream>
#include <memory>
#include <string>

#include <grpcpp/grpcpp.h>

#include "uploadthreadmsg.grpc.pb.h"

#ifndef NUM_CAM
#define NUM_CAM 4
#endif

#ifndef NUM_THREAD_PERCAM
#define NUM_THREAD_PERCAM 1
//int NUM_THREAD_PERCAM = 1;
#endif

using grpc::Channel;
using grpc::ClientContext;
using grpc::Status;

namespace iv {
struct msgunit
{
    char mstrmsgname[256];
    int mnBufferSize = 10000;
    int mnBufferCount = 1;
    void * mpa;
    std::shared_ptr<char> mpstrmsgdata;
    int mndatasize = 0;
    bool mbRefresh = false;
    bool mbImportant = false;
    int mnkeeptime = 100;
};
}

class grpcpc : public QThread
{
public:
    grpcpc(std::string stryamlpath);

private:
    void run();

private:
    std::string gstrserverip = "192.168.14.98";//"111.33.136.149";//"127.0.0.1";// "140.143.237.38";
    std::string gstrserverport = "50051";//"9000";
    std::string gstruploadinterval = "100";
    void * gpa;
    QMutex gMutexMsg;
    std::vector<iv::msgunit> mvectormsgunit;

    std::vector<iv::msgunit> mvectorctrlmsgunit;


    std::string gstrVIN = "AAAAAAAAAAAAAAAAA";
    std::string gstrqueryMD5 = "5d41402abc4b2a76b9719d911017c592";
    std::string gstrctrlMD5 = "5d41402abc4b2a76b9719d911017c592";




    int gindex = 0;


private:
    void dec_yaml(const char * stryamlpath);
    void sharequerymsg(iv::cloud::cloudmsg * pxmsg);

public:
    void UpdateData(const char * strdata,const unsigned int nSize,const char * strmemname);
    std::string GetVIN();

private:
    void threadpicdownload(int nCamPos);
    void * mpaPic[NUM_CAM];
    std::string mstrpicmsgname[NUM_CAM];

    std::thread * mpThread[NUM_CAM * NUM_THREAD_PERCAM];

    QMutex mMutexPic[NUM_CAM];

    qint64 mnPicUpLatency[NUM_CAM];
    int mnFrameRate[NUM_CAM];
    int mnPicDownLatency[NUM_CAM];


public:
    qint64 GetPicLatency(int nCamPos);
    int GetFrameRate(int nCamPos);
    qint64 GetPicDownLatency(int nCamPos);


public:
    void setserverip(std::string strip);
    void setserverport(std::string strport);
    void setqueryinterval(std::string strinterval);
    void setVIN(std::string strVIN);
    void setqueryMD5(std::string strmd5);
    void setctrlMD5(std::string strmd5);


};

#endif // GRPCPC_H