@@ -147,12 +147,13 @@ public function test_getQueueIdForVisitor_shouldMoveVisitorIntoQueueBasedOnFirst
147147 $ a = 10 % $ numQueues ; // 10, 11, 12 is a internal mapping see {Manager::$mappingLettersToNumeric}
148148 $ b = 11 % $ numQueues ;
149149 $ c = 12 % $ numQueues ;
150+ $ d = 0 ;
150151
151152 $ this ->assertQueueIdForVisitorIdEquals ($ a , 'a ' );
152153 $ this ->assertQueueIdForVisitorIdEquals ($ b , 'b ' );
153154 $ this ->assertQueueIdForVisitorIdEquals ($ c , 'c ' );
154- $ this ->assertQueueIdForVisitorIdEquals ($ a , 'abcdef ' );
155- $ this ->assertQueueIdForVisitorIdEquals ($ b , 'bbcdef ' );
155+ $ this ->assertQueueIdForVisitorIdEquals ($ d , 'abcdef ' );
156+ $ this ->assertQueueIdForVisitorIdEquals ($ d , 'bbcdef ' );
156157 $ this ->assertQueueIdForVisitorIdEquals ($ c , 'cbcdef ' );
157158 }
158159
@@ -267,10 +268,10 @@ public function test_addRequestSetToQueues_getNumberOfRequestSetsInAllQueues_sho
267268 }
268269
269270 $ this ->assertSame (26 , $ this ->manager ->getNumberOfRequestSetsInAllQueues ());
270- $ this ->assertNumberOfRequestSetsInQueueEquals (5 , $ queueId = 0 );
271+ $ this ->assertNumberOfRequestSetsInQueueEquals (3 , $ queueId = 0 );
271272 $ this ->assertNumberOfRequestSetsInQueueEquals (9 , $ queueId = 1 );
272- $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 2 );
273- $ this ->assertNumberOfRequestSetsInQueueEquals (11 , $ queueId = 3 );
273+ $ this ->assertNumberOfRequestSetsInQueueEquals (7 , $ queueId = 2 );
274+ $ this ->assertNumberOfRequestSetsInQueueEquals (7 , $ queueId = 3 );
274275 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 4 ); // this queue is not available
275276 }
276277
@@ -287,12 +288,12 @@ public function test_addRequestSetToQueues_getNumberOfRequestSetsInAllQueues_sho
287288
288289 $ this ->assertSame (26 , $ this ->manager ->getNumberOfRequestSetsInAllQueues ());
289290 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 0 );
290- $ this ->assertNumberOfRequestSetsInQueueEquals (26 , $ queueId = 1 );
291- $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 2 );
291+ $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 1 );
292+ $ this ->assertNumberOfRequestSetsInQueueEquals (26 , $ queueId = 2 );
292293 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 3 );
293294
294295 // verify all 26 written into queue
295- $ this ->assertRequestSetsInQueueEquals ($ expectedRequestSets , 1 );
296+ $ this ->assertRequestSetsInQueueEquals ($ expectedRequestSets , 2 );
296297 }
297298
298299 public function test_addRequestSetToQueues_shouldMoveAllInSameQueue_IfAllHaveSameUidAndTheyAreInOneRequestSet ()
@@ -303,12 +304,12 @@ public function test_addRequestSetToQueues_shouldMoveAllInSameQueue_IfAllHaveSam
303304
304305 $ this ->assertSame (1 , $ this ->manager ->getNumberOfRequestSetsInAllQueues ());
305306 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 0 );
306- $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 1 );
307- $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 2 );
307+ $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 1 );
308+ $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 2 );
308309 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 3 );
309310
310311 // verify all 15 written into queue
311- $ this ->assertRequestSetsInQueueEquals (array ($ requestSet ), 1 );
312+ $ this ->assertRequestSetsInQueueEquals (array ($ requestSet ), 2 );
312313 }
313314
314315 public function test_addRequestSetToQueues_shouldMoveIntoDifferentQueues_IfThereAreManyDifferentRequestsInOneSet ()
@@ -328,21 +329,24 @@ public function test_addRequestSetToQueues_shouldMoveIntoDifferentQueues_IfThere
328329
329330 $ this ->manager ->addRequestSetToQueues ($ req );
330331
331- $ this ->assertSame (3 , $ this ->manager ->getNumberOfRequestSetsInAllQueues ()); // 3 different uid
332+ $ this ->assertSame (4 , $ this ->manager ->getNumberOfRequestSetsInAllQueues ()); // 4 different uid
332333
333- $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 0 );
334+ $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 0 );
334335 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 1 );
335336 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 2 );
336337 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 3 );
337338 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 4 );
338339
339340 $ req ->setRequests (array ($ requests [1 ]));
341+ $ this ->assertRequestSetsInQueueEquals ([$ req ], 0 );
342+
343+ $ req ->setRequests (array ($ requests [2 ], $ requests [5 ]));
340344 $ this ->assertRequestSetsInQueueEquals ([$ req ], 1 );
341345
342- $ req ->setRequests (array ($ requests [3 ]));
346+ $ req ->setRequests (array ($ requests [0 ], $ requests [ 4 ]));
343347 $ this ->assertRequestSetsInQueueEquals ([$ req ], 2 );
344348
345- $ req ->setRequests (array ($ requests [0 ], $ requests [ 2 ], $ requests [ 4 ], $ requests [ 5 ]));
349+ $ req ->setRequests (array ($ requests [3 ]));
346350 $ this ->assertRequestSetsInQueueEquals ([$ req ], 3 );
347351 }
348352
@@ -391,11 +395,11 @@ public function test_moveSomeQueuesIfNeeded_ShouldActuallyMoveQueues()
391395
392396 $ this ->manager ->moveSomeQueuesIfNeeded ($ newNumWorkers , $ oldNumWorkers );
393397
394- $ this ->assertNumberOfRequestSetsInQueueEquals (6 , $ queueId = 0 );
398+ $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 0 );
395399 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 1 );
396400 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 2 );
397401 $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 3 );
398- $ this ->assertNumberOfRequestSetsInQueueEquals (1 , $ queueId = 4 );
402+ $ this ->assertNumberOfRequestSetsInQueueEquals (6 , $ queueId = 4 );
399403 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 5 );
400404 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 6 );
401405 $ this ->assertNumberOfRequestSetsInQueueEquals (0 , $ queueId = 7 );
0 commit comments