1 files changed, 111 insertions, 0 deletions
diff --git a/ipc/ipdl/test/cxx/TestLatency.h b/ipc/ipdl/test/cxx/TestLatency.h
new file mode 100644
index 000000000..d179213db
--- /dev/null
+++ b/ipc/ipdl/test/cxx/TestLatency.h
@@ -0,0 +1,111 @@
+#ifndef mozilla__ipdltest_TestLatency_h
+#define mozilla__ipdltest_TestLatency_h 1
+
+#include "mozilla/_ipdltest/IPDLUnitTests.h"
+
+#include "mozilla/_ipdltest/PTestLatencyParent.h"
+#include "mozilla/_ipdltest/PTestLatencyChild.h"
+
+#include "mozilla/TimeStamp.h"
+
+#define NR_TRIALS 10000
+#define NR_SPAMS  25000
+
+namespace mozilla {
+namespace _ipdltest {
+
+class TestLatencyParent :
+    public PTestLatencyParent
+{
+private:
+    typedef mozilla::TimeStamp TimeStamp;
+    typedef mozilla::TimeDuration TimeDuration;
+
+public:
+    TestLatencyParent();
+    virtual ~TestLatencyParent();
+
+    static bool RunTestInProcesses() { return true; }
+    static bool RunTestInThreads() { return true; }
+
+    void Main();
+
+protected:
+    virtual bool RecvPong() override;
+    virtual bool RecvPong5() override;
+
+    virtual void ActorDestroy(ActorDestroyReason why) override
+    {
+        if (NormalShutdown != why)
+            fail("unexpected destruction!");  
+
+        passed("\n"
+               "  average #ping-pong/sec:        %g\n"
+               "  average #ping5-pong5/sec:      %g\n"
+               "  average #RPC call-answer/sec:  %g\n"
+               "  average #spams/sec:            %g\n"
+               "  pct. spams compressed away:    %g\n",
+               double(NR_TRIALS) / mPPTimeTotal.ToSecondsSigDigits(),
+               double(NR_TRIALS) / mPP5TimeTotal.ToSecondsSigDigits(),
+               double(NR_TRIALS) / mRpcTimeTotal.ToSecondsSigDigits(),
+               double(NR_SPAMS) / mSpamTimeTotal.ToSecondsSigDigits(),
+               100.0 * (double(NR_SPAMS - mNumChildProcessedCompressedSpams) /
+                        double(NR_SPAMS)));
+
+        QuitParent();
+    }
+
+private:
+    void PingPongTrial();
+    void Ping5Pong5Trial();
+    void RpcTrials();
+    void SpamTrial();
+    void CompressedSpamTrial();
+    void Exit();
+
+    TimeStamp mStart;
+    TimeDuration mPPTimeTotal;
+    TimeDuration mPP5TimeTotal;
+    TimeDuration mRpcTimeTotal;
+    TimeDuration mSpamTimeTotal;
+
+    int mPPTrialsToGo;
+    int mPP5TrialsToGo;
+    uint32_t mNumChildProcessedCompressedSpams;
+};
+
+
+class TestLatencyChild :
+    public PTestLatencyChild
+{
+public:
+    TestLatencyChild();
+    virtual ~TestLatencyChild();
+
+protected:
+    virtual bool RecvPing() override;
+    virtual bool RecvPing5() override;
+    virtual bool AnswerRpc() override;
+    virtual bool RecvSpam() override;
+    virtual bool AnswerSynchro() override;
+    virtual bool RecvCompressedSpam(const uint32_t& seqno) override;
+    virtual bool AnswerSynchro2(uint32_t* lastSeqno,
+                                uint32_t* numMessagesDispatched) override;
+
+    virtual void ActorDestroy(ActorDestroyReason why) override
+    {
+        if (NormalShutdown != why)
+            fail("unexpected destruction!");
+        QuitChild();
+    }
+
+    uint32_t mLastSeqno;
+    uint32_t mNumProcessedCompressedSpams;
+};
+
+
+} // namespace _ipdltest
+} // namespace mozilla
+
+
+#endif // ifndef mozilla__ipdltest_TestLatency_h