summaryrefslogtreecommitdiff
path: root/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php
diff options
context:
space:
mode:
authorAndrew Dolgov <[email protected]>2023-10-20 17:12:29 +0300
committerAndrew Dolgov <[email protected]>2023-10-20 21:13:39 +0300
commitcdd7ad020e165fe680703b6d3319b908b682fb7a (patch)
treeb51eb09b7b4587e8fbc5624ac8d88d28cfcd0b04 /vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php
parent45a9ff0c88cbd33892ff16ab837e9059937d656e (diff)
jaeger-client -> opentelemetry
Diffstat (limited to 'vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php')
-rw-r--r--vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php166
1 files changed, 0 insertions, 166 deletions
diff --git a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php b/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php
deleted file mode 100644
index abc4e32aa..000000000
--- a/vendor/jonahgeorge/jaeger-client-php/tests/Jaeger/ThriftUdpTransportTest.php
+++ /dev/null
@@ -1,166 +0,0 @@
-<?php
-
-namespace Jaeger\Tests;
-
-use Jaeger\Config;
-use Jaeger\Tests\Logger\StackLogger;
-use Jaeger\ThriftUdpTransport;
-use Jaeger\Tracer;
-use PHPUnit\Framework\TestCase;
-use Thrift\Exception\TTransportException;
-
-class ThriftUdpTransportTest extends TestCase
-{
- /**
- * @var ThriftUdpTransport
- */
- private $transport;
-
- /**
- * @var StackLogger
- */
- private $logger;
-
- public function setUp(): void
- {
- $this->logger = new StackLogger();
- $this->transport = new ThriftUdpTransport('127.0.0.1', 12345, $this->logger);
- }
-
- public function testisOpenWhenOpen()
- {
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->assertTrue($this->transport->isOpen());
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- }
-
- public function testisOpenWhenClosed()
- {
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->close();
- $this->assertFalse($this->transport->isOpen());
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- }
-
- public function testClose()
- {
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->close();
-
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->write('hello');
- $this->assertEquals($this->logger->getMessagesCount(), 1);
- $this->assertEquals($this->logger->getLastMessage(), 'transport is closed');
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- }
-
- public function testDoubleClose()
- {
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->close();
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->close();
- $this->assertEquals($this->logger->getMessagesCount(), 1);
- $this->assertEquals(
- $this->logger->getLastMessage(),
- "can't close empty socket"
- );
- }
-
- public function testException()
- {
- $this->assertEquals($this->logger->getMessagesCount(), 0);
- $this->transport->open();
- $this->assertEquals($this->logger->getMessagesCount(), 0);
-
- $this->transport->write(str_repeat("some string", 10000));
-
- $this->assertEquals($this->logger->getMessagesCount(), 1);
- $msg = $this->logger->getLastMessage();
- $pattern = "/socket_write failed: \[code - \d+\] Message too long/";
-
- if (method_exists($this, "assertMatchesRegularExpression")) {
- $this->assertMatchesRegularExpression($pattern, $msg);
- } else {
- $this->assertRegExp($pattern, $msg);
- }
- }
-
- public function testProtocolVersionIPv4()
- {
- $config = new Config([
- Config::IP_VERSION => Config::IPV4
- ], "testServiceName");
-
- $transport = new ThriftUdpTransport('127.0.0.1', 12345, $this->logger, $config);
-
- $reflectionTransport = new \ReflectionClass($transport);
- $ipProtocolVersionMethod = $reflectionTransport->getMethod("ipProtocolVersion");
- $ipProtocolVersionMethod->setAccessible(true);
-
- $this->assertEquals(Config::IPV4, $ipProtocolVersionMethod->invoke($transport));
- }
-
- public function testProtocolVersionIPv6()
- {
- $config = new Config([
- Config::IP_VERSION => Config::IPV6
- ], "testServiceName");
-
- $transport = new ThriftUdpTransport('127.0.0.1', 12345, $this->logger, $config);
-//
- $reflectionTransport = new \ReflectionClass($transport);
- $ipProtocolVersionMethod = $reflectionTransport->getMethod("ipProtocolVersion");
- $ipProtocolVersionMethod->setAccessible(true);
-//
- $this->assertEquals(Config::IPV6, $ipProtocolVersionMethod->invoke($transport));
- }
-
- public function testProtocolVersionDefault()
- {
- $config = new Config([
- ], "testServiceName");
-
- $transport = new ThriftUdpTransport('127.0.0.1', 12345, $this->logger, $config);
-
- $reflectionTransport = new \ReflectionClass($transport);
- $ipProtocolVersionMethod = $reflectionTransport->getMethod("ipProtocolVersion");
- $ipProtocolVersionMethod->setAccessible(true);
-
- $this->assertEquals(Config::IPV4, $ipProtocolVersionMethod->invoke($transport));
- }
-
- public function testCreateSocket()
- {
- $transport = $this->getMockBuilder(ThriftUdpTransport::class)
- ->disableOriginalConstructor()
- ->getMock();
-
- $reflectionClass = new \ReflectionClass($transport);
- $method = $reflectionClass->getMethod("setLogger");
- $method->setAccessible(true);
- $method->invokeArgs($transport, [$this->logger]);
-
- $method = $reflectionClass->getMethod("createSocket");
- $method->setAccessible(true);
- $res = $method->invokeArgs($transport, [Config::IPV6]);
-
- $this->assertNotFalse($res);
-
-
- $transport = $this->getMockBuilder(ThriftUdpTransport::class)
- ->disableOriginalConstructor()
- ->getMock();
-
- $reflectionClass = new \ReflectionClass($transport);
- $method = $reflectionClass->getMethod("setLogger");
- $method->setAccessible(true);
- $method->invokeArgs($transport, [$this->logger]);
-
- $method = $reflectionClass->getMethod("createSocket");
- $method->setAccessible(true);
- $res = $method->invokeArgs($transport, [Config::IPV4]);
-
- $this->assertNotFalse($res);
- }
-}