Управление сайтом

Компаний

Пользователи

Фиксированные новости

Отзывы о фирмах

Пользователи

Банкоматы

Торговые точки

Доска объявлений

Курсы валют

организации Орла

организации области

сайты Орел

Поиск запросы

Статистика

Показы каталога организаций

Статистика клиенты

Пользователи

Управление сайтом

Каталоги >

Новости >

Организации >

Секрет фирмы >

Сервисы >

Файловый менеджер

Имя файла	AbstractLoopTest.php
Содержимое	<?php namespace React\Tests\EventLoop; abstract class AbstractLoopTest extends TestCase { /** * @var \React\EventLoop\LoopInterface / protected $loop; private $tickTimeout; public function setUp() { // HHVM is a bit slow, so give it more time $this->tickTimeout = defined('HHVM_VERSION') ? 0.02 : 0.005; $this->loop = $this->createLoop(); } abstract public function createLoop(); public function createSocketPair() { $domain = (DIRECTORY_SEPARATOR === '\\') ? STREAM_PF_INET : STREAM_PF_UNIX; $sockets = stream_socket_pair($domain, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP); foreach ($sockets as $socket) { if (function_exists('stream_set_read_buffer')) { stream_set_read_buffer($socket, 0); } } return $sockets; } public function testAddReadStream() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableExactly(2)); fwrite($output, "foo\n"); $this->loop->tick(); fwrite($output, "bar\n"); $this->loop->tick(); } public function testAddReadStreamIgnoresSecondCallable() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableExactly(2)); $this->loop->addReadStream($input, $this->expectCallableNever()); fwrite($output, "foo\n"); $this->loop->tick(); fwrite($output, "bar\n"); $this->loop->tick(); } public function testAddWriteStream() { list ($input) = $this->createSocketPair(); $this->loop->addWriteStream($input, $this->expectCallableExactly(2)); $this->loop->tick(); $this->loop->tick(); } public function testAddWriteStreamIgnoresSecondCallable() { list ($input) = $this->createSocketPair(); $this->loop->addWriteStream($input, $this->expectCallableExactly(2)); $this->loop->addWriteStream($input, $this->expectCallableNever()); $this->loop->tick(); $this->loop->tick(); } public function testRemoveReadStreamInstantly() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableNever()); $this->loop->removeReadStream($input); fwrite($output, "bar\n"); $this->loop->tick(); } public function testRemoveReadStreamAfterReading() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableOnce()); fwrite($output, "foo\n"); $this->loop->tick(); $this->loop->removeReadStream($input); fwrite($output, "bar\n"); $this->loop->tick(); } public function testRemoveWriteStreamInstantly() { list ($input) = $this->createSocketPair(); $this->loop->addWriteStream($input, $this->expectCallableNever()); $this->loop->removeWriteStream($input); $this->loop->tick(); } public function testRemoveWriteStreamAfterWriting() { list ($input) = $this->createSocketPair(); $this->loop->addWriteStream($input, $this->expectCallableOnce()); $this->loop->tick(); $this->loop->removeWriteStream($input); $this->loop->tick(); } public function testRemoveStreamInstantly() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableNever()); $this->loop->addWriteStream($input, $this->expectCallableNever()); $this->loop->removeStream($input); fwrite($output, "bar\n"); $this->loop->tick(); } public function testRemoveStreamForReadOnly() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableNever()); $this->loop->addWriteStream($output, $this->expectCallableOnce()); $this->loop->removeReadStream($input); fwrite($output, "foo\n"); $this->loop->tick(); } public function testRemoveStreamForWriteOnly() { list ($input, $output) = $this->createSocketPair(); fwrite($output, "foo\n"); $this->loop->addReadStream($input, $this->expectCallableOnce()); $this->loop->addWriteStream($output, $this->expectCallableNever()); $this->loop->removeWriteStream($output); $this->loop->tick(); } public function testRemoveStream() { list ($input, $output) = $this->createSocketPair(); $this->loop->addReadStream($input, $this->expectCallableOnce()); $this->loop->addWriteStream($input, $this->expectCallableOnce()); fwrite($output, "bar\n"); $this->loop->tick(); $this->loop->removeStream($input); fwrite($output, "bar\n"); $this->loop->tick(); } public function testRemoveInvalid() { list ($stream) = $this->createSocketPair(); // remove a valid stream from the event loop that was never added in the first place $this->loop->removeReadStream($stream); $this->loop->removeWriteStream($stream); $this->loop->removeStream($stream); } /* @test / public function emptyRunShouldSimplyReturn() { $this->assertRunFasterThan($this->tickTimeout); } /* @test / public function runShouldReturnWhenNoMoreFds() { list ($input, $output) = $this->createSocketPair(); $loop = $this->loop; $this->loop->addReadStream($input, function ($stream) use ($loop) { $loop->removeStream($stream); }); fwrite($output, "foo\n"); $this->assertRunFasterThan($this->tickTimeout 2); } /** @test / public function stopShouldStopRunningLoop() { list ($input, $output) = $this->createSocketPair(); $loop = $this->loop; $this->loop->addReadStream($input, function ($stream) use ($loop) { $loop->stop(); }); fwrite($output, "foo\n"); $this->assertRunFasterThan($this->tickTimeout 2); } public function testStopShouldPreventRunFromBlocking() { $this->loop->addTimer( 1, function () { $this->fail('Timer was executed.'); } ); $this->loop->nextTick( function () { $this->loop->stop(); } ); $this->assertRunFasterThan($this->tickTimeout * 2); } public function testIgnoreRemovedCallback() { // two independent streams, both should be readable right away list ($input1, $output1) = $this->createSocketPair(); list ($input2, $output2) = $this->createSocketPair(); $called = false; $loop = $this->loop; $loop->addReadStream($input1, function ($stream) use (& $called, $loop, $input2) { // stream1 is readable, remove stream2 as well => this will invalidate its callback $loop->removeReadStream($stream); $loop->removeReadStream($input2); $called = true; }); // this callback would have to be called as well, but the first stream already removed us $loop->addReadStream($input2, function () use (& $called) { if ($called) { $this->fail('Callback 2 must not be called after callback 1 was called'); } }); fwrite($output1, "foo\n"); fwrite($output2, "foo\n"); $loop->run(); $this->assertTrue($called); } public function testNextTick() { $called = false; $callback = function ($loop) use (&$called) { $this->assertSame($this->loop, $loop); $called = true; }; $this->loop->nextTick($callback); $this->assertFalse($called); $this->loop->tick(); $this->assertTrue($called); } public function testNextTickFiresBeforeIO() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () { echo 'stream' . PHP_EOL; } ); $this->loop->nextTick( function () { echo 'next-tick' . PHP_EOL; } ); $this->expectOutputString('next-tick' . PHP_EOL . 'stream' . PHP_EOL); $this->loop->tick(); } public function testRecursiveNextTick() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () { echo 'stream' . PHP_EOL; } ); $this->loop->nextTick( function () { $this->loop->nextTick( function () { echo 'next-tick' . PHP_EOL; } ); } ); $this->expectOutputString('next-tick' . PHP_EOL . 'stream' . PHP_EOL); $this->loop->tick(); } public function testRunWaitsForNextTickEvents() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () use ($stream) { $this->loop->removeStream($stream); $this->loop->nextTick( function () { echo 'next-tick' . PHP_EOL; } ); } ); $this->expectOutputString('next-tick' . PHP_EOL); $this->loop->run(); } public function testNextTickEventGeneratedByFutureTick() { list ($stream) = $this->createSocketPair(); $this->loop->futureTick( function () { $this->loop->nextTick( function () { echo 'next-tick' . PHP_EOL; } ); } ); $this->expectOutputString('next-tick' . PHP_EOL); $this->loop->run(); } public function testNextTickEventGeneratedByTimer() { $this->loop->addTimer( 0.001, function () { $this->loop->nextTick( function () { echo 'next-tick' . PHP_EOL; } ); } ); $this->expectOutputString('next-tick' . PHP_EOL); $this->loop->run(); } public function testFutureTick() { $called = false; $callback = function ($loop) use (&$called) { $this->assertSame($this->loop, $loop); $called = true; }; $this->loop->futureTick($callback); $this->assertFalse($called); $this->loop->tick(); $this->assertTrue($called); } public function testFutureTickFiresBeforeIO() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () { echo 'stream' . PHP_EOL; } ); $this->loop->futureTick( function () { echo 'future-tick' . PHP_EOL; } ); $this->expectOutputString('future-tick' . PHP_EOL . 'stream' . PHP_EOL); $this->loop->tick(); } public function testRecursiveFutureTick() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () use ($stream) { echo 'stream' . PHP_EOL; $this->loop->removeWriteStream($stream); } ); $this->loop->futureTick( function () { echo 'future-tick-1' . PHP_EOL; $this->loop->futureTick( function () { echo 'future-tick-2' . PHP_EOL; } ); } ); $this->expectOutputString('future-tick-1' . PHP_EOL . 'stream' . PHP_EOL . 'future-tick-2' . PHP_EOL); $this->loop->run(); } public function testRunWaitsForFutureTickEvents() { list ($stream) = $this->createSocketPair(); $this->loop->addWriteStream( $stream, function () use ($stream) { $this->loop->removeStream($stream); $this->loop->futureTick( function () { echo 'future-tick' . PHP_EOL; } ); } ); $this->expectOutputString('future-tick' . PHP_EOL); $this->loop->run(); } public function testFutureTickEventGeneratedByNextTick() { list ($stream) = $this->createSocketPair(); $this->loop->nextTick( function () { $this->loop->futureTick( function () { echo 'future-tick' . PHP_EOL; } ); } ); $this->expectOutputString('future-tick' . PHP_EOL); $this->loop->run(); } public function testFutureTickEventGeneratedByTimer() { $this->loop->addTimer( 0.001, function () { $this->loop->futureTick( function () { echo 'future-tick' . PHP_EOL; } ); } ); $this->expectOutputString('future-tick' . PHP_EOL); $this->loop->run(); } private function assertRunFasterThan($maxInterval) { $start = microtime(true); $this->loop->run(); $end = microtime(true); $interval = $end - $start; $this->assertLessThan($maxInterval, $interval); } }

/cron/instagram/vendor/react/event-loop/tests/

Имя	Дата	Размер
..	2019-01-15
Timer	2019-01-15
AbstractLoopTest.php	2019-01-15	14 кб.
CallableStub.php	2019-01-15	107 байт
ExtEventLoopTest.php	2019-01-15	2 кб.
LibEvLoopTest.php	2019-01-15	442 байт
LibEventLoopTest.php	2019-01-15	1 кб.
StreamSelectLoopTest.php	2019-01-15	5 кб.
TestCase.php	2019-01-15	891 байт
bootstrap.php	2019-01-15	205 байт

/cron/instagram/vendor/react/event-loop/tests