Code Duplication    Length = 31-31 lines in 2 locations

src/Socket/Socket.php 1 location

@@ 511-541 (lines=31) @@
508
        $name = stream_socket_get_name($this->resource, $wantPeer);
509
        $type = $this->getStreamType();
510
511
        switch ($type)
512
        {
513
            case Socket::TYPE_UNIX:
514
                $transport = 'unix://';
515
                $endpoint = $transport . $name;
516
                break;
517
518
            case Socket::TYPE_TCP:
519
                $transport = 'tcp://';
520
                if (substr_count($name, ':') > 1)
521
                {
522
                    $parts = explode(':', $name);
523
                    $count = count($parts);
524
                    $port = $parts[$count - 1];
525
                    unset($parts[$count - 1]);
526
                    $endpoint = $transport.'[' . implode(':', $parts) . ']:' . $port;
527
                }
528
                else
529
                {
530
                    $endpoint = $transport . $name;
531
                }
532
                break;
533
534
            case Socket::TYPE_UDP:
535
                $transport = 'udp://';
536
                $endpoint = $transport . $name;
537
                break;
538
539
            default:
540
                $endpoint = '';
541
        }
542
543
        $this->cachedEndpoint[$wantIndex] = $endpoint;
544

src/Socket/SocketListener.php 1 location

@@ 560-590 (lines=31) @@
557
            $name = stream_socket_get_name($this->socket, false);
558
            $type = $this->getStreamType();
559
560
            switch ($type)
561
            {
562
                case Socket::TYPE_UNIX:
563
                    $transport = 'unix://';
564
                    $endpoint = $transport . $name;
565
                    break;
566
567
                case Socket::TYPE_TCP:
568
                    $transport = 'tcp://';
569
                    if (substr_count($name, ':') > 1)
570
                    {
571
                        $parts = explode(':', $name);
572
                        $count = count($parts);
573
                        $port = $parts[$count - 1];
574
                        unset($parts[$count - 1]);
575
                        $endpoint = $transport.'[' . implode(':', $parts) . ']:' . $port;
576
                    }
577
                    else
578
                    {
579
                        $endpoint = $transport . $name;
580
                    }
581
                    break;
582
583
                case Socket::TYPE_UDP:
584
                    $transport = 'udp://';
585
                    $endpoint = $transport . $name;
586
                    break;
587
588
                default:
589
                    $endpoint = '';
590
            }
591
592
            return $endpoint;
593
        }