1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
--TEST--
MongoConnection::parallelCollectionScan() with MultipleIterator
--SKIPIF--
<?php $needs = "2.5.5"; ?>
<?php require_once "tests/utils/standalone.inc"; ?>
--FILE--
<?php
require_once "tests/utils/server.inc";
$dsn = MongoShellServer::getStandaloneInfo();
$mc = new MongoClient($dsn);
$c = $mc->selectCollection(dbname(), collname(__FILE__));
$c->drop();
$notFoundNumbers = array();
foreach (range(1,5000) as $x) {
$c->insert(array('x' => $x));
$notFoundNumbers[$x] = true;
}
$document = $c->parallelCollectionScan(8);
$mi = new MultipleIterator(MultipleIterator::MIT_NEED_ANY);
foreach($document as $cursor) {
$mi->attachIterator( $cursor );
}
foreach($mi as $entries) {
foreach ($entries as $entry) {
if ($entry !== NULL) {
unset( $notFoundNumbers[$entry['x']] );
}
}
}
var_dump($notFoundNumbers);
?>
--EXPECTF--
array(0) {
}
|
