@@ -117,11 +117,11 @@ testAgentPrioritisation result = do
117
117
testAgentMailboxHandling :: TestResult (Maybe () ) -> Process ()
118
118
testAgentMailboxHandling result = do
119
119
(sp, rp) <- newChan
120
- agent <- mxAgent (MxAgentId " listener -agent" ) () [
120
+ agent <- mxAgent (MxAgentId " mailbox -agent" ) () [
121
121
mxSink $ \ () -> (liftMX $ sendChan sp () ) >> mxReady
122
122
]
123
123
124
- nsend " listener -agent" ()
124
+ nsend " mailbox -agent" ()
125
125
126
126
stash result =<< receiveChanTimeout 1000000 rp
127
127
kill agent " finished"
@@ -184,7 +184,7 @@ testMxRegEvents = do
184
184
behaviour of the node controller are contained in the CH test suite. -}
185
185
186
186
let label = " testMxRegEvents"
187
- let agentLabel = " listener -agent"
187
+ let agentLabel = " mxRegEvents -agent"
188
188
let delay = 1000000
189
189
(regChan, regSink) <- newChan
190
190
(unRegChan, unRegSink) <- newChan
@@ -231,8 +231,8 @@ testMxRegMon remoteNode = do
231
231
232
232
let label1 = " aaaaa"
233
233
let label2 = " bbbbb"
234
- let isValid l = l == label1 || l == label2
235
- let agentLabel = " listener -agent"
234
+ let isValid l = l == label1 || l == label2
235
+ let agentLabel = " mxRegMon -agent"
236
236
let delay = 1000000
237
237
(regChan, regSink) <- newChan
238
238
(unRegChan, unRegSink) <- newChan
@@ -273,8 +273,12 @@ testMxRegMon remoteNode = do
273
273
unreg1 <- receiveChanTimeout delay unRegSink
274
274
unreg2 <- receiveChanTimeout delay unRegSink
275
275
276
- sort [unreg1, unreg2]
277
- `shouldBe` equalTo [Just (label1, p1), Just (label2, p1)]
276
+ let evts = [unreg1, unreg2]
277
+ -- we can't rely on the order of the values in the node controller's
278
+ -- map (it's either racy to do so, or no such guarantee exists for Data.Map),
279
+ -- so we simply verify that we received the un-registration events we expect
280
+ evts `shouldContain` (Just (label1, p1))
281
+ evts `shouldContain` (Just (label2, p1))
278
282
279
283
kill agent " test-complete"
280
284
0 commit comments