summaryrefslogtreecommitdiff
path: root/vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.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/src/Jaeger/ThriftUdpTransport.php
parent45a9ff0c88cbd33892ff16ab837e9059937d656e (diff)
jaeger-client -> opentelemetry
Diffstat (limited to 'vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.php')
-rw-r--r--vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.php151
1 files changed, 0 insertions, 151 deletions
diff --git a/vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.php b/vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.php
deleted file mode 100644
index babc689dc..000000000
--- a/vendor/jonahgeorge/jaeger-client-php/src/Jaeger/ThriftUdpTransport.php
+++ /dev/null
@@ -1,151 +0,0 @@
-<?php
-
-namespace Jaeger;
-
-use Psr\Log\LoggerInterface;
-use Psr\Log\NullLogger;
-use Thrift\Transport\TTransport;
-
-class ThriftUdpTransport extends TTransport
-{
- private $socket;
-
- /**
- * @var string
- */
- private $host;
-
- /**
- * @var int
- */
- private $port;
-
- /**
- * @var LoggerInterface
- */
- private $logger;
-
- /**
- * @var Config
- */
- private $config;
-
- /**
- * ThriftUdpTransport constructor.
- * @param string $host
- * @param int $port
- * @param LoggerInterface $logger
- */
- public function __construct(string $host, int $port, LoggerInterface $logger = null, Config $config = null)
- {
- $this->setLogger($logger);
-
- $this->config = $config;
-
- $ipProtocol = $this->ipProtocolVersion();
- $this->socket = $this->createSocket($ipProtocol);
-
- $this->host = $host;
- $this->port = $port;
- }
-
- protected function setLogger($logger)
- {
- $this->logger = $logger ?? new NullLogger();
- }
-
- protected function createSocket(string $ipProtocol)
- {
- $socketDomain = AF_INET;
- if ($ipProtocol === Config::IPV6) {
- $socketDomain = AF_INET6;
- }
-
- $socket = @socket_create($socketDomain, SOCK_DGRAM, SOL_UDP);
- if ($socket === false) {
- $this->handleSocketError("socket_create failed");
- }
- return $socket;
- }
-
- protected function ipProtocolVersion()
- {
- if (!empty($this->config)) {
- return $this->config->ipProtocolVersion();
- }
- return "";
- }
-
- /**
- * Whether this transport is open.
- *
- * @return boolean true if open
- */
- public function isOpen()
- {
- return $this->socket !== null;
- }
-
- /**
- * Open the transport for reading/writing
- */
- public function open()
- {
- $ok = @socket_connect($this->socket, $this->host, $this->port);
- if ($ok === false) {
- $this->handleSocketError('socket_connect failed');
- }
- }
-
- /**
- * Close the transport.
- */
- public function close()
- {
- if (is_null($this->socket)) {
- $this->logger->warning("can't close empty socket");
- return ;
- }
-
- @socket_close($this->socket);
- $this->socket = null;
- }
-
- /**
- * Read some data into the array.
- *
- * @todo
- *
- * @param int $len How much to read
- * @return string The data that has been read
- */
- public function read($len)
- {
- }
-
- /**
- * Writes the given data out.
- *
- * @param string $buf The data to write
- */
- public function write($buf)
- {
- if (!$this->isOpen()) {
- $this->logger->warning('transport is closed');
- return ;
- }
-
- $ok = @socket_write($this->socket, $buf);
- if ($ok === false) {
- $this->handleSocketError("socket_write failed");
- }
- }
-
- public function handleSocketError($msg)
- {
- $errorCode = socket_last_error($this->socket);
- $errorMsg = socket_strerror($errorCode);
-
- $this->logger->warning(sprintf('%s: [code - %d] %s', $msg, $errorCode, $errorMsg));
- }
-}