Justin Marshall
97 lines
2.4 KiB
C++
97 lines
2.4 KiB
C++
#pragma once
|
|
|
|
#include "idlib/networking/amqp/mqmessaging.h"
|
|
#include "idlib/networking/protocols/reports.pb.h"
|
|
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
struct mapLoadEvent_t {
|
|
const char* timestamp;
|
|
idreports::MapReport message;
|
|
};
|
|
|
|
struct viewNoteEvent_t {
|
|
const char* timestamp;
|
|
idreports::ViewNoteReport message;
|
|
};
|
|
|
|
struct assertEvent_t {
|
|
const char* timestmap; // Original spelling retained for recovered ABI users.
|
|
idreports::AssertReport message;
|
|
};
|
|
|
|
struct idUniqueWarning {
|
|
idStr message;
|
|
unsigned int count;
|
|
};
|
|
|
|
struct viewNoteData_t {
|
|
idStr bugTitle;
|
|
idStr taskType;
|
|
idStr reproSteps;
|
|
idStr details;
|
|
idStr severity;
|
|
idStr priority;
|
|
idStr attachmentFilename;
|
|
idStr gameName;
|
|
bool isMultiplayer;
|
|
int buildNumberMajor;
|
|
int buildNumberMinor;
|
|
idStr vt_filePath;
|
|
idStr vt_filePathOverride;
|
|
idStr mapName;
|
|
};
|
|
|
|
class idAnalysisClient : public idMQClientThread {
|
|
public:
|
|
idAnalysisClient();
|
|
~idAnalysisClient() override;
|
|
|
|
void StartMessageSystem() override;
|
|
void StopMessageSystem() override;
|
|
void PreRun() override;
|
|
void ThreadSlice() override;
|
|
void OnThreadTerminate() override;
|
|
|
|
void SetCurrentMap(const char* mapName);
|
|
void QueueAssert(const idreports::AssertReport& report,
|
|
const char* timestamp = 0);
|
|
void QueueMapLoad(const idreports::MapReport& report,
|
|
const char* timestamp = 0);
|
|
void QueueViewNote(const idreports::ViewNoteReport& report,
|
|
const char* timestamp = 0);
|
|
|
|
int NumPendingAsserts();
|
|
int NumPendingMapLoads();
|
|
int NumPendingViewNotes();
|
|
|
|
int reportTime;
|
|
idMQChannel* channel;
|
|
idStrStatic<1024> currentMap;
|
|
idSysMutex assertMutex;
|
|
idSysMutex mapLoadMutex;
|
|
idSysMutex viewNoteMutex;
|
|
|
|
private:
|
|
template<class T>
|
|
struct pendingEvent_t {
|
|
std::string timestamp;
|
|
T message;
|
|
};
|
|
|
|
std::vector<pendingEvent_t<idreports::AssertReport> > pendingAsserts;
|
|
std::vector<pendingEvent_t<idreports::MapReport> > pendingMapLoads;
|
|
std::vector<pendingEvent_t<idreports::ViewNoteReport> > pendingViewNotes;
|
|
};
|
|
|
|
extern idCVar mq_enable;
|
|
extern idCVar mq_analysisReportRate;
|
|
extern idAnalysisClient analysisClient;
|
|
|
|
void PublishEvent(idreports::LogEvent& logEvent, const char* timestamp,
|
|
idreports::LogEvent_Severity severity, const char* message,
|
|
google::protobuf::MessageLite& outgoing, const char* messageType,
|
|
idMQChannel* channel, const char* routingKey);
|
|
|