assistantLatencyReportMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2024 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/

#pragma once


// PLEASE NOTE: This class is duplicated as DtLatencyReportMsg.
//  Any changes made to this class should also be made there.

#include "assistantMsg.h"
#include "netAssistantLatencyReportMsg.h"

#include <averagedLatencyTestReport.h>

#include <vlutil/vlString.h>
#include <vlutil/vlUtil.h>

#include <map>

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAssistantLatencyReportMsg;

typedef void (*DtAssistantLatencyReportCb)(const DtAssistantLatencyReportMsg& report, void* usr);

class DT_DLL_ASSISTANT DtAssistantLatencyReportMsg : public DtAssistantMsg
{
public:


   DtAssistantLatencyReportMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtAssistantLatencyReportMsg(const DtAveragedLatencyTestReport& rep, DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtAssistantLatencyReportMsg(const DtNetAssistantLatencyReportMsg* netRepMsg, DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtAssistantLatencyReportMsg();

   virtual DtAssistantMsg* clone(bool copy = true) const;

   virtual void printData() const;

   virtual void get(DtAveragedLatencyTestReport& report) const;

   virtual void set(const DtAveragedLatencyTestReport& report);

public:


   static DtAssistantMsg* create(const DtNetAssistantMsgHeader* initial, DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   static DtAssistantMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);


   static void addCallback(DtRtiAssistantServer* conn, DtAssistantLatencyReportCb cb, void* usr);
   static void removeCallback(DtRtiAssistantServer* conn, DtAssistantLatencyReportCb cb, void* usr);


   static void addCallback(DtRtiAssistantPeer* conn, DtAssistantLatencyReportCb cb, void* usr);
   static void removeCallback(DtRtiAssistantPeer* conn, DtAssistantLatencyReportCb cb, void* usr);

protected:


   virtual DtNetAssistantLatencyReportMsg* netAssistantLatencyReportMsg();
   virtual const DtNetAssistantLatencyReportMsg* netAssistantLatencyReportMsg() const;

   virtual DtAssistantMsgKind internalMsgKind();

   virtual int minSize(DtAveragedLatencyTestReport const* report=nullptr) const;

   virtual void resize(unsigned int reportSize);


   virtual unsigned int reportSize() const;
   virtual void setReportSize(unsigned int times);

   virtual unsigned char* reportPtr() const;


//    virtual unsigned char* payload();
//    virtual const unsigned char* payload() const;

};