Remote.h

Go to the documentation of this file.

 
#ifndef _Remote_h_
#define _Remote_h_
 
namespace XPMP2 {
 
//
// MARK: ENQUEUE Data Structure for Caching and Passing from main to network thread
//
 
struct RmtAcCacheTy {
    const unsigned  fullUpdGrp;         
    float ts;                           
    double lat;                         
    double lon;                         
    double alt_ft;                      
    XPLMDrawInfo_t  drawInfo;           
    std::vector<float> v;               
    bool bValid     : 1;                
    bool bVisible   : 1;                
    bool bRender    : 1;                
    const CSLModel* pCSLMdl;            
 
    RmtAcCacheTy (const Aircraft& ac, double _lat, double _lon, double _alt_ft);
    void UpdateFrom (const Aircraft& ac, double _lat, double _lon, double _alt_ft);
};
 
typedef std::map<XPMPPlaneID,RmtAcCacheTy> mapRmtAcCacheTy;
 
 
 
class RmtDataBaseTy {
public:
    RemoteMsgTy     msgTy;          
public:
    RmtDataBaseTy (RemoteMsgTy _ty) : msgTy(_ty) {}
    virtual ~RmtDataBaseTy() {}
};
 
typedef std::unique_ptr<RmtDataBaseTy> ptrRmtDataBaseTy;
typedef std::queue<ptrRmtDataBaseTy,std::list<ptrRmtDataBaseTy> > queueRmtDataTy;
 
 
template <class ElemTy, RemoteMsgTy MsgTy>
class RmtDataEnqeueTy : public RmtDataBaseTy {
public:
    ElemTy data;
public:
    RmtDataEnqeueTy () : RmtDataBaseTy(MsgTy) {}
    RmtDataEnqeueTy (const ElemTy& _elem) : RmtDataBaseTy(MsgTy), data(_elem) {}
};
 
// predefine required template instances
typedef RmtDataEnqeueTy<RemoteAcDetailTy,RMT_MSG_AC_DETAILED> RmtDataAcDetailTy;            
typedef RmtDataEnqeueTy<RemoteAcPosUpdateTy,RMT_MSG_AC_POS_UPDATE> RmtDataAcPosUpdateTy;    
typedef RmtDataEnqeueTy<RemoteAcRemoveTy,RMT_MSG_AC_REMOVE> RmtDataAcRemoveTy;                   
 
class RmtDataAcAnimTy : public RmtDataBaseTy {
public:
    union {
        RemoteAcAnimTy  data;
        char            bufSize[RemoteAcAnimTy::msgSize(V_COUNT)];
    };
public:
    RmtDataAcAnimTy (XPMPPlaneID _id) : RmtDataBaseTy(RMT_MSG_AC_ANIM), data(_id) {}
    void add (DR_VALS idx, float f);
};
 
typedef std::unique_ptr<RmtDataAcAnimTy> ptrRmtDataAcAnimTy;
 
//
// MARK: SENDING Data Structures
//
 
template <class ElemTy, RemoteMsgTy MsgTy, std::uint8_t msgVer>
class RmtMsgBufTy {
public:
    void*           pMsg = nullptr;     
    size_t          elemCount = 0;      
    size_t          size = 0;           
public:
    RmtMsgBufTy () {}
    ~RmtMsgBufTy() { RmtMsgBufTy::free(); }
    void free ();
    void init ();
    bool add (const ElemTy& _elem);
    bool empty () const { return !elemCount; }
    void send (UDPMulticast& _mc);
    bool add_send (const ElemTy& _elem, UDPMulticast& _mc);
};
 
 
//
// MARK: Global Functions
//
 
void RemoteInit ();
 
void RemoteCleanup ();
 
void RemoteSenderUpdateStatus ();
 
 
void RemoteAcEnqueueStarts (float now);
 
void RemoteAcEnqueue (const Aircraft& ac);
 
void RemoteAcEnqueueDone ();
 
void RemoteAcRemove (const Aircraft& ac);
 
void RemoteAcClearAll ();
 
}
#endif