@@ -528,19 +528,13 @@ TEST_P(TransportTCP, TCPLocalhost)
528
528
// Test == operator for TCPv4/v6
529
529
TEST_P (TransportTCP, TCP_equal_operator)
530
530
{
531
- <<<<<<< HEAD
532
- // TCPv4TransportDescriptor
533
- TCPv4TransportDescriptor tcpv4_transport_1;
534
- TCPv4TransportDescriptor tcpv4_transport_2;
535
- =======
536
531
if (use_ipv6)
537
532
{
538
533
// TCPv6TransportDescriptor
539
534
TCPv6TransportDescriptor transport1;
540
535
TCPv6TransportDescriptor transport2;
541
536
// Compare equal in defult values
542
537
ASSERT_EQ (transport1, transport2);
543
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
544
538
545
539
// Modify some default values in 1
546
540
transport1.enable_tcp_nodelay = !transport1.enable_tcp_nodelay ; // change default value
@@ -575,18 +569,6 @@ TEST_P(TransportTCP, TCP_equal_operator)
575
569
// Test copy constructor and copy assignment for TCPv4/v6
576
570
TEST_P (TransportTCP, TCP_copy)
577
571
{
578
- <<<<<<< HEAD
579
- TCPv4TransportDescriptor tcpv4_transport;
580
- tcpv4_transport.set_WAN_address (" 80.80.99.45" );
581
-
582
- // Copy constructor
583
- TCPv4TransportDescriptor tcpv4_transport_copy_constructor (tcpv4_transport);
584
- EXPECT_EQ (tcpv4_transport, tcpv4_transport_copy_constructor);
585
-
586
- // Copy assignment
587
- TCPv4TransportDescriptor tcpv4_transport_copy = tcpv4_transport;
588
- EXPECT_EQ (tcpv4_transport_copy, tcpv4_transport);
589
- =======
590
572
if (use_ipv6)
591
573
{
592
574
// Change some varibles in order to check the non default creation
@@ -615,7 +597,6 @@ TEST_P(TransportTCP, TCP_copy)
615
597
TCPv4TransportDescriptor tcpv4_transport_copy = tcpv4_transport;
616
598
EXPECT_EQ (tcpv4_transport_copy, tcpv4_transport);
617
599
}
618
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
619
600
}
620
601
621
602
// Test get_WAN_address member function
@@ -627,53 +608,6 @@ TEST(TransportTCP, TCPv4_get_WAN_address)
627
608
ASSERT_EQ (tcpv4_transport.get_WAN_address (), " 80.80.99.45" );
628
609
}
629
610
630
- <<<<<<< HEAD
631
- // Test == operator for TCPv6
632
- TEST_P (TransportTCP, TCPv6_equal_operator)
633
- {
634
- // TCPv6TransportDescriptor
635
- TCPv6TransportDescriptor tcpv6_transport_1;
636
- TCPv6TransportDescriptor tcpv6_transport_2;
637
-
638
- // Compare equal in defult values
639
- ASSERT_EQ (tcpv6_transport_1, tcpv6_transport_2);
640
-
641
- // Modify some default values in 1
642
- tcpv6_transport_1.enable_tcp_nodelay = !tcpv6_transport_1.enable_tcp_nodelay ; // change default value
643
- tcpv6_transport_1.max_logical_port = tcpv6_transport_1.max_logical_port + 10 ; // change default value
644
- tcpv6_transport_1.add_listener_port (123u * 98u );
645
-
646
- ASSERT_FALSE (tcpv6_transport_1 == tcpv6_transport_2); // operator== != operator!=, using operator== == false instead
647
-
648
-
649
- // Modify some default values in 2
650
- tcpv6_transport_2.enable_tcp_nodelay = !tcpv6_transport_2.enable_tcp_nodelay ; // change default value
651
- tcpv6_transport_2.max_logical_port = tcpv6_transport_2.max_logical_port + 10 ; // change default value
652
- tcpv6_transport_2.add_listener_port (123u * 98u );
653
-
654
- ASSERT_EQ (tcpv6_transport_1, tcpv6_transport_2);
655
- }
656
-
657
- // Test copy constructor and copy assignment for TCPv6
658
- TEST_P (TransportTCP, TCPv6_copy)
659
- {
660
- // Change some varibles in order to check the non default creation
661
- TCPv6TransportDescriptor tcpv6_transport;
662
- tcpv6_transport.enable_tcp_nodelay = !tcpv6_transport.enable_tcp_nodelay ; // change default value
663
- tcpv6_transport.max_logical_port = tcpv6_transport.max_logical_port + 10 ; // change default value
664
- tcpv6_transport.add_listener_port (123u * 98u );
665
-
666
- // Copy constructor
667
- TCPv6TransportDescriptor tcpv6_transport_copy_constructor (tcpv6_transport);
668
- EXPECT_EQ (tcpv6_transport, tcpv6_transport_copy_constructor);
669
-
670
- // Copy assignment
671
- TCPv6TransportDescriptor tcpv6_transport_copy = tcpv6_transport;
672
- EXPECT_EQ (tcpv6_transport_copy, tcpv6_transport);
673
- }
674
-
675
- =======
676
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
677
611
// Test connection is successfully restablished after dropping and relaunching a TCP client (requester)
678
612
// Issue -> https://github.com/eProsima/Fast-DDS/issues/2409
679
613
TEST_P (TransportTCP, Client_reconnection)
@@ -757,51 +691,13 @@ TEST_P(TransportTCP, TCP_autofill_port)
757
691
}
758
692
759
693
// Add TCP Transport with listening port 0
760
- <<<<<<< HEAD
761
- auto p1_transport = std::make_shared<TCPv4TransportDescriptor>();
762
- =======
763
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
764
694
p1_transport->add_listener_port (0 );
765
695
p1.disable_builtin_transport ().add_user_transport_to_pparams (p1_transport);
766
696
p1.init ();
767
697
ASSERT_TRUE (p1.isInitialized ());
768
698
769
699
// Add TCP Transport with listening port different from 0
770
700
uint16_t port = 12345 ;
771
- <<<<<<< HEAD
772
- auto p2_transport = std::make_shared<TCPv4TransportDescriptor>();
773
- p2_transport->add_listener_port (port);
774
- p2.disable_builtin_transport ().add_user_transport_to_pparams (p2_transport);
775
- p2.init ();
776
- ASSERT_TRUE (p2.isInitialized ());
777
-
778
- LocatorList_t p1_locators;
779
- p1.get_native_reader ().get_listening_locators (p1_locators);
780
- EXPECT_TRUE (IPLocator::getPhysicalPort (p1_locators.begin ()[0 ]) != 0 );
781
-
782
- LocatorList_t p2_locators;
783
- p2.get_native_reader ().get_listening_locators (p2_locators);
784
- EXPECT_TRUE (IPLocator::getPhysicalPort (p2_locators.begin ()[0 ]) == port);
785
- }
786
-
787
- // Test zero listening port for TCPv6
788
- TEST_P (TransportTCP, TCPv6_autofill_port)
789
- {
790
- PubSubReader<HelloWorldPubSubType> p1 (TEST_TOPIC_NAME);
791
- PubSubReader<HelloWorldPubSubType> p2 (TEST_TOPIC_NAME);
792
-
793
- // Add TCP Transport with listening port 0
794
- auto p1_transport = std::make_shared<TCPv6TransportDescriptor>();
795
- p1_transport->add_listener_port (0 );
796
- p1.disable_builtin_transport ().add_user_transport_to_pparams (p1_transport);
797
- p1.init ();
798
- ASSERT_TRUE (p1.isInitialized ());
799
-
800
- // Add TCP Transport with listening port different from 0
801
- uint16_t port = 12345 ;
802
- auto p2_transport = std::make_shared<TCPv6TransportDescriptor>();
803
- =======
804
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
805
701
p2_transport->add_listener_port (port);
806
702
p2.disable_builtin_transport ().add_user_transport_to_pparams (p2_transport);
807
703
p2.init ();
@@ -933,24 +829,9 @@ TEST_P(TransportTCP, multiple_listening_ports)
933
829
uint16_t server_port_1 = 10000 ;
934
830
uint16_t server_port_2 = 10001 ;
935
831
936
- <<<<<<< HEAD
937
- std::shared_ptr<TCPTransportDescriptor> server_transport;
938
- if (use_ipv6)
939
- {
940
- server_transport = std::make_shared<TCPv6TransportDescriptor>();
941
- }
942
- else
943
- {
944
- server_transport = std::make_shared<TCPv4TransportDescriptor>();
945
- }
946
- server_transport->add_listener_port (server_port_1);
947
- server_transport->add_listener_port (server_port_2);
948
- server->disable_builtin_transport ().add_user_transport_to_pparams (server_transport).init ();
949
- =======
950
832
test_transport_->add_listener_port (server_port_1);
951
833
test_transport_->add_listener_port (server_port_2);
952
834
server->disable_builtin_transport ().add_user_transport_to_pparams (test_transport_).init ();
953
- >>>>>>> 0c799f4ca (Improve Blackbox TCP tests suite (#5467 ))
954
835
ASSERT_TRUE (server->isInitialized ());
955
836
956
837
// Create two clients each one connecting to a different port
0 commit comments