Skip to content

M
mongo-php-library
Commit 003e5eb8 authored by Jeremy Mikola's avatar Jeremy Mikola
Browse files
Options

Use smaller maxAwaitTimeMS to speed up change stream tests

parent 2c87d398
Hide whitespace changes
Inline Side-by-side
Showing with 8 additions and 8 deletions
tests/Operation/WatchFunctionalTest.php
View file @ 003e5eb8
...@@ -33,7 +33,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -33,7 +33,7 @@ class WatchFunctionalTest extends FunctionalTestCase
{ {
$this->insertDocument(['_id' => 1, 'x' => 'foo']); $this->insertDocument(['_id' => 1, 'x' => 'foo']);
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$changeStream->rewind(); $changeStream->rewind();
...@@ -130,7 +130,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -130,7 +130,7 @@ class WatchFunctionalTest extends FunctionalTestCase
{ {
$this->insertDocument(['_id' => 1, 'x' => 'foo']); $this->insertDocument(['_id' => 1, 'x' => 'foo']);
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$changeStream->rewind(); $changeStream->rewind();
...@@ -172,7 +172,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -172,7 +172,7 @@ class WatchFunctionalTest extends FunctionalTestCase
public function testResumeAfterKillThenNoOperations() public function testResumeAfterKillThenNoOperations()
{ {
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->killChangeStreamCursor($changeStream); $this->killChangeStreamCursor($changeStream);
...@@ -183,7 +183,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -183,7 +183,7 @@ class WatchFunctionalTest extends FunctionalTestCase
public function testResumeAfterKillThenOperation() public function testResumeAfterKillThenOperation()
{ {
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->killChangeStreamCursor($changeStream); $this->killChangeStreamCursor($changeStream);
...@@ -196,7 +196,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -196,7 +196,7 @@ class WatchFunctionalTest extends FunctionalTestCase
public function testKey() public function testKey()
{ {
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->assertNull($changeStream->key()); $this->assertNull($changeStream->key());
...@@ -226,7 +226,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -226,7 +226,7 @@ class WatchFunctionalTest extends FunctionalTestCase
{ {
$pipeline = [['$project' => ['foo' => [0]]]]; $pipeline = [['$project' => ['foo' => [0]]]];
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline, ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->insertDocument(['_id' => 1]); $this->insertDocument(['_id' => 1]);
...@@ -243,7 +243,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -243,7 +243,7 @@ class WatchFunctionalTest extends FunctionalTestCase
public function testCursorWithEmptyBatchNotClosed() public function testCursorWithEmptyBatchNotClosed()
{ {
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->assertNotNull($changeStream); $this->assertNotNull($changeStream);
...@@ -256,7 +256,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -256,7 +256,7 @@ class WatchFunctionalTest extends FunctionalTestCase
{ {
$pipeline = [['$project' => ['_id' => 0 ]]]; $pipeline = [['$project' => ['_id' => 0 ]]];
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline, ['maxAwaitTimeMS' => 100]);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->insertDocument(['x' => 1]); $this->insertDocument(['x' => 1]);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment