1 files changed, 94 insertions, 0 deletions
diff --git a/ipc/ipdl/test/cxx/TestRacyInterruptReplies.cpp b/ipc/ipdl/test/cxx/TestRacyInterruptReplies.cpp
new file mode 100644
index 0000000000..cda950b1a1
--- /dev/null
+++ b/ipc/ipdl/test/cxx/TestRacyInterruptReplies.cpp
@@ -0,0 +1,94 @@
+#include "TestRacyInterruptReplies.h"
+
+#include "IPDLUnitTests.h"  // fail etc.
+
+namespace mozilla {
+namespace _ipdltest {
+
+//-----------------------------------------------------------------------------
+// parent
+
+TestRacyInterruptRepliesParent::TestRacyInterruptRepliesParent()
+    : mReplyNum(0) {
+  MOZ_COUNT_CTOR(TestRacyInterruptRepliesParent);
+}
+
+TestRacyInterruptRepliesParent::~TestRacyInterruptRepliesParent() {
+  MOZ_COUNT_DTOR(TestRacyInterruptRepliesParent);
+}
+
+void TestRacyInterruptRepliesParent::Main() {
+  int replyNum = -1;
+  if (!CallR_(&replyNum)) fail("calling R()");
+
+  if (1 != replyNum) fail("this should have been the first reply to R()");
+
+  if (!SendChildTest()) fail("sending ChildStart");
+}
+
+mozilla::ipc::IPCResult TestRacyInterruptRepliesParent::RecvA_() {
+  int replyNum = -1;
+  // this R() call races with the reply being generated by the other
+  // side to the R() call from Main().  This is a pretty nasty edge
+  // case for which one could argue we're breaking in-order message
+  // delivery, since this side will process the second reply to R()
+  // before the first.
+  if (!CallR_(&replyNum)) fail("calling R()");
+
+  if (2 != replyNum) fail("this should have been the second reply to R()");
+
+  return IPC_OK();
+}
+
+mozilla::ipc::IPCResult TestRacyInterruptRepliesParent::Answer_R(
+    int* replyNum) {
+  *replyNum = ++mReplyNum;
+
+  if (1 == *replyNum)
+    if (!Send_A()) fail("sending _A()");
+
+  return IPC_OK();
+}
+
+//-----------------------------------------------------------------------------
+// child
+
+TestRacyInterruptRepliesChild::TestRacyInterruptRepliesChild() : mReplyNum(0) {
+  MOZ_COUNT_CTOR(TestRacyInterruptRepliesChild);
+}
+
+TestRacyInterruptRepliesChild::~TestRacyInterruptRepliesChild() {
+  MOZ_COUNT_DTOR(TestRacyInterruptRepliesChild);
+}
+
+mozilla::ipc::IPCResult TestRacyInterruptRepliesChild::AnswerR_(int* replyNum) {
+  *replyNum = ++mReplyNum;
+
+  if (1 == *replyNum) SendA_();
+
+  return IPC_OK();
+}
+
+mozilla::ipc::IPCResult TestRacyInterruptRepliesChild::RecvChildTest() {
+  int replyNum = -1;
+  if (!Call_R(&replyNum)) fail("calling R()");
+
+  if (1 != replyNum) fail("this should have been the first reply to R()");
+
+  Close();
+
+  return IPC_OK();
+}
+
+mozilla::ipc::IPCResult TestRacyInterruptRepliesChild::Recv_A() {
+  int replyNum = -1;
+
+  if (!Call_R(&replyNum)) fail("calling _R()");
+
+  if (2 != replyNum) fail("this should have been the second reply to R()");
+
+  return IPC_OK();
+}
+
+}  // namespace _ipdltest
+}  // namespace mozilla