Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Timer	[ DIR ]	drwxr-xr-x	2018-07-11 09:00
AbstractLoopTest.php	17.24 KB	-rw-r--r--	2018-07-11 09:00
CallableStub.php	107 B	-rw-r--r--	2018-07-11 09:00
ExtEvLoopTest.php	355 B	-rw-r--r--	2018-07-11 09:00
ExtEventLoopTest.php	2.33 KB	-rw-r--r--	2018-07-11 09:00
ExtLibevLoopTest.php	454 B	-rw-r--r--	2018-07-11 09:00
ExtLibeventLoopTest.php	1.38 KB	-rw-r--r--	2018-07-11 09:00
SignalsHandlerTest.php	1.33 KB	-rw-r--r--	2018-07-11 09:00
StreamSelectLoopTest.php	3.96 KB	-rw-r--r--	2018-07-11 09:00
TestCase.php	1.11 KB	-rw-r--r--	2018-07-11 09:00
bootstrap.php	118 B	-rw-r--r--	2018-07-11 09:00

Rename

<?php

namespace React\Tests\EventLoop;

use React\EventLoop\ExtEventLoop;

class ExtEventLoopTest extends AbstractLoopTest
{
    public function createLoop($readStreamCompatible = false)
    {
        if ('Linux' === PHP_OS && !extension_loaded('posix')) {
            $this->markTestSkipped('libevent tests skipped on linux due to linux epoll issues.');
        }

if (!extension_loaded('event')) {
            $this->markTestSkipped('ext-event tests skipped because ext-event is not installed.');
        }

return new ExtEventLoop();
    }

public function createStream()
    {
        // Use a FIFO on linux to get around lack of support for disk-based file
        // descriptors when using the EPOLL back-end.
        if ('Linux' === PHP_OS) {
            $this->fifoPath = tempnam(sys_get_temp_dir(), 'react-');

unlink($this->fifoPath);

posix_mkfifo($this->fifoPath, 0600);

$stream = fopen($this->fifoPath, 'r+');

// ext-event (as of 1.8.1) does not yet support in-memory temporary
        // streams. Setting maxmemory:0 and performing a write forces PHP to
        // back this temporary stream with a real file.
        //
        // This problem is mentioned at https://bugs.php.net/bug.php?id=64652&edit=3
        // but remains unresolved (despite that issue being closed).
        } else {
            $stream = fopen('php://temp/maxmemory:0', 'r+');

fwrite($stream, 'x');
            ftruncate($stream, 0);
        }

return $stream;
    }

public function writeToStream($stream, $content)
    {
        if ('Linux' !== PHP_OS) {
            return parent::writeToStream($stream, $content);
        }

fwrite($stream, $content);
    }

/**
     * @group epoll-readable-error
     */
    public function testCanUseReadableStreamWithFeatureFds()
    {
        if (PHP_VERSION_ID > 70000) {
            $this->markTestSkipped('Memory stream not supported');
        }

$this->loop = $this->createLoop(true);

$input = fopen('php://temp/maxmemory:0', 'r+');

fwrite($input, 'x');
        ftruncate($input, 0);

$this->loop->addReadStream($input, $this->expectCallableExactly(2));

fwrite($input, "foo\n");
        $this->tickLoop($this->loop);

fwrite($input, "bar\n");
        $this->tickLoop($this->loop);
    }
}