Mirrors/overte-HifiExperiments
3
0
Fork 0
mirror of https://github.com/HifiExperiments/overte.git synced 2025-08-10 01:36:26 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

split logstash stash methods to stat types

Browse source
This commit is contained in:
Stephen Birarda 2013-07-02 12:10:46 -07:00
parent 2a4d9c98ee
commit 64f3b55aaa
4 changed files with 26 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
audio-mixer/src/main.cpp
View file

@ -138,7 +138,7 @@ int main(int argc, const char* argv[]) {
const char MIXER_LOGSTASH_METRIC_NAME[] = "audio-mixer-frame-time-usage"; const char MIXER_LOGSTASH_METRIC_NAME[] = "audio-mixer-frame-time-usage";
float averageFrameTimePercentage = sumFrameTimePercentages / numStatCollections; float averageFrameTimePercentage = sumFrameTimePercentages / numStatCollections;
Logstash::stashValue(MIXER_LOGSTASH_METRIC_NAME, averageFrameTimePercentage); Logstash::stashGaugeValue(MIXER_LOGSTASH_METRIC_NAME, averageFrameTimePercentage);
sumFrameTimePercentages = 0.0f; sumFrameTimePercentages = 0.0f;
numStatCollections = 0; numStatCollections = 0;

2
interface/src/Application.cpp
View file

@ -349,7 +349,7 @@ void Application::initializeGL() {
const char LOGSTASH_INTERFACE_START_TIME_KEY[] = "interface-start-time"; const char LOGSTASH_INTERFACE_START_TIME_KEY[] = "interface-start-time";
// ask the Logstash class to record the startup time // ask the Logstash class to record the startup time
Logstash::stashValue(LOGSTASH_INTERFACE_START_TIME_KEY, startupTime); Logstash::stashTimerValue(LOGSTASH_INTERFACE_START_TIME_KEY, startupTime);
} }
// update before the first render // update before the first render

22
libraries/shared/src/Logstash.cpp
View file

@ -45,16 +45,32 @@ bool Logstash::shouldSendStats() {
return shouldSendStats; return shouldSendStats;
} }
void Logstash::stashValue(const char* key, float value) { void Logstash::stashValue(char valueType, const char* key, float value) {
static char logstashPacket[MAX_PACKET_SIZE]; static char logstashPacket[MAX_PACKET_SIZE];
// load up the logstash packet with the key and the passed float value // load up the logstash packet with the key and the passed float value
// send it to 4 decimal places // send it to 4 decimal places
int numPacketBytes = sprintf(logstashPacket, "%s %.4f", key, value); int numPacketBytes = sprintf(logstashPacket, "%c %s %.4f", valueType, key, value);
AgentList *agentList = AgentList::getInstance(); AgentList *agentList = AgentList::getInstance();
if (agentList) { if (agentList) {
agentList->getAgentSocket()->send(socket(), logstashPacket, numPacketBytes); agentList->getAgentSocket()->send(socket(), logstashPacket, numPacketBytes);
} }
} }
void Logstash::stashTimerValue(const char* key, float value) {
const char STAT_TYPE_TIMER = 't';
stashValue(STAT_TYPE_TIMER, key, value);
}
void Logstash::stashCounterValue(const char* key, float value) {
const char STAT_TYPE_COUNTER = 'c';
stashValue(STAT_TYPE_COUNTER, key, value);
}
void Logstash::stashGaugeValue(const char* key, float value) {
const char STAT_TYPE_GAUGE = 'g';
stashValue(STAT_TYPE_GAUGE, key, value);
}

6
libraries/shared/src/Logstash.h
View file

@ -18,8 +18,12 @@ class Logstash {
public: public:
static sockaddr* socket(); static sockaddr* socket();
static bool shouldSendStats(); static bool shouldSendStats();
static void stashValue(const char* key, float value); static void stashTimerValue(const char* key, float value);
static void stashCounterValue(const char* key, float value);
static void stashGaugeValue(const char* key, float value);
private: private:
static void stashValue(char valueType, const char* key, float value);
static sockaddr_in logstashSocket; static sockaddr_in logstashSocket;
}; };