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

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