Merge pull request #186 from code-mancers/add-cpu-sampling-event

Add cpu sampling event

rbkit-lib/mpparser.cpp

@@ -87,7 +87,6 @@ RBKit::ObjectDetail& operator>>(msgpack::object obj, RBKit::ObjectDetail& object
     return object;
 }
 
-
 RBKit::ObjectDetailPtr& operator>>(msgpack::object obj, RBKit::ObjectDetailPtr& ptr)
 {
     if (obj.type != msgpack::type::MAP) { throw msgpack::type_error(); }

rbkit-lib/rbeventparser.cpp

@@ -58,6 +58,10 @@ RBKit::EventParser::eventFromMsgpackObject(const msgpack::object& object) const
         event = new RBKit::EvtHandshake(timestamp, eventType, payload.as<QVariantMap>());
         break;
 
+    case RBKit::EtCpuSample:
+        event = new RBKit::EvtCpuSample(timestamp, eventType, payload.as<QList<QMap<int, QVariant>>>());
+        break;
+
     default:
         qDebug() << "Unable to parse event of type: " << eventType;
     }

rbkit-lib/rbevents.cpp

@@ -121,3 +121,14 @@ void RBKit::EvtHandshake::process(Subscriber &processor) const
 {
     processor.processEvent(*this);
 }
+
+RBKit::EvtCpuSample::EvtCpuSample(QDateTime ts, RBKit::EventType eventType, QList<QMap<int, QVariant> > payload)
+    : EventDataBase(ts, eventType)
+{
+    qDebug() << payload;
+}
+
+void RBKit::EvtCpuSample::process(Subscriber &processor) const
+{
+    processor.processEvent(*this);
+}

rbkit-lib/rbevents.h

@@ -25,7 +25,8 @@ namespace RBKit
         EtObjectSpaceDump  = 5,
         EtGcStats          = 6,
         EtEventCollection  = 7,
-        EtHandshake        = 8
+        EtHandshake        = 8,
+        EtCpuSample        = 9
     };
 
 
@@ -128,6 +129,13 @@ namespace RBKit
         quint32 pid;
         bool tracingFlag;
     };
+
+    class EvtCpuSample : public EventDataBase
+    {
+    public:
+        EvtCpuSample(QDateTime ts, EventType eventType, QList<QMap<int, QVariant>> payload);
+        void process(Subscriber& processor) const;
+    };
 }
 
 

rbkit-lib/subscriber.cpp

@@ -235,6 +235,10 @@ void Subscriber::processEvent(const RBKit::EvtHandshake &handShake)
     qDebug() << "Should not have come here";
 }
 
+void Subscriber::processEvent(const RBKit::EvtCpuSample &cpuSample) {
+    qDebug() << cpuSample.eventType << "===";
+}
+
 void Subscriber::performHandshake()
 {
     context->start();

rbkit-lib/subscriber.h

@@ -59,6 +59,7 @@ class Subscriber : public QObject
     void processEvent(const RBKit::EvtObjectDump&);
     void processEvent(const RBKit::EvtCollection&);
     void processEvent(const RBKit::EvtHandshake&handShake);
+    void processEvent(const RBKit::EvtCpuSample&);
     void performHandshake();
     void handShakeCompleted();
     void emitConnectionError(QString message);

tests/testrbevents.cpp

@@ -98,3 +98,19 @@ void TestRbEvents::testParseObjectDumpEvent()
     EvtObjectDump* event = dynamic_cast<EvtObjectDump*>(collection->events[0].data());
     QVERIFY(event);
 }
+
+
+void TestRbEvents::testParseCpuSampleEvent()
+{
+    QByteArray data = msgpackDataFromFile(":/tests/msgpack/cpusample");
+    RBKit::EventParser eventParser(data);
+
+    auto base = eventParser.parseEvent();
+    QVERIFY(base);
+
+    auto collection = dynamic_cast<EvtCollection*>(base);
+    QVERIFY(collection);
+
+    EvtCpuSample* event = dynamic_cast<EvtCpuSample*>(collection->events[0].data());
+    QVERIFY(event);
+}

tests/testrbevents.h

@@ -14,6 +14,7 @@ private slots:
     void testParseGcStatsEvent();
     void testParseGCStartEvent();
     void testParseObjectDumpEvent();
+    void testParseCpuSampleEvent();
 };
 
 #endif // TEST_RBKIT_EVENTS_H

tests/tests.qrc

@@ -7,6 +7,7 @@
         <file>msgpack/objectdump</file>
         <file>msgpack/hugedump</file>
         <file>msgpack/split_dump</file>
+        <file>msgpack/cpusample</file>
     </qresource>
     <qresource prefix="/"/>
 </RCC>