OpenDDS通訊rtps_discovery對等發現模式的pub和sub匹配的日志

OpenDDS的通訊體系中,提供了豐富的日志輸出,通過日志輸出可以清晰的看到pub和sub方的主題匹配的過程,是加深對OpenDDS過程了解的一個好方法。
下面的日志,以OpenDDS3.8為基礎,增加了部分日志和時間戳輸出。
rtps_discovery對等發現模式下,通過單播地址進行發布方和訂閱方的匹配過程。

(1)sub方

配置文件

[common]
DCPSGlobalTransportConfig=$file
ORBDebugLevel=0
DCPSDebugLevel=10
DCPSTransportDebugLevel=0
ORBLogFile=sub.log[domain/2]
DiscoveryConfig=fast_rtps[rtps_discovery/fast_rtps]
ResendPeriod=2
InteropMulticastOverride=239.255.0.11SpdpSendAddrs=192.168.102.1:7910
##PB=30000
##DX=0
##D1=0
SedpMulticast=0
SedpLocalAddress=192.168.102.1:
TTL=20[transport/the_rtps_transport]
transport_type=rtps_udp
use_multicast=0
local_address=192.168.179.1:
ttl=20

sub方日志

(13532|6612) NOTICE: using DCPSDebugLevel value from command option (overrides value if it's in config file).
(13532|6612) NOTICE: using DCPSTransportDebugLevel value from command option (overrides value if it's in config file).
(13532|6612) NOTICE: using ORBLogFile value from command option, overriding config file
Configuration InteropMulticastOverride=239.255.0.11
Configuration SedpMulticast=0
Configuration ResendPeriod=2
Configuration SedpLocalAddress=192.168.102.1:
Configuration SpdpSendAddrs=192.168.102.1:7910
Configuration TTL=20
Configuration transport_type=rtps_udp
Configuration use_multicast=0
Configuration local_address=192.168.179.1:
Configuration ttl=20
Configuration DiscoveryConfig=fast_rtps
2018-02-09 17:18:35.997322 (13532|6612) Service_Participant::set_repo_domain: Domain[ 2] = Repo[ fast_rtps].
(13532|6612) NOTICE: StaticDiscovery::parse_topics no [topic] sections.
(13532|6612) NOTICE: StaticDiscovery::parse_datawriterqos no [datawriterqos] sections.
(13532|6612) NOTICE: StaticDiscovery::parse_datareaderqos no [datareaderqos] sections.
(13532|6612) NOTICE: StaticDiscovery::parse_publisherqos no [publisherqos] sections.
(13532|6612) NOTICE: StaticDiscovery::parse_subscriberqos no [subscriberqos] sections.
(13532|6612) NOTICE: StaticDiscovery::parse_endpoints no [endpoint] sections.
(13532|6612) NOTICE: Service_Participant::intializeScheduling() - no scheduling policy specified, not setting policy.
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) WARNING:open_appropriate_socket_type: socket open not successful:errno: 10048
(13532|6612) Spdp::SpdpTransport::open_unicast_socket() - failed to open_appropriate_socket_type unicast socket on port 7910 ACE_SOCK_Dgram::open: address already in use.  Trying next participantId...
2018-02-09 17:18:36.036022 (13532|6612) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 488, local[0.0.0.0:7912], port=7912
2018-02-09 17:18:36.036022 (13532|6612) Spdp::SpdpTransport::open_unicast_socket() - opened unicast socket on port 7912
(13532|6612) Spdp::SpdpTransport::SpdpTransport joining group  239.255.0.11:7900
2018-02-09 17:18:36.082822 (13532|6612) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 692, local[192.168.102.1:0], port=50699
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) DDS::ParticipantBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 1f0c6f0 with 20 chunks
(13532|6612) DataReaderImpl::enable Cached_Allocator_With_Overflow 1f0c738 with 20 chunks
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSParticipant) enabled
(13532|6612) DDS::TopicBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 1f0c780 with 20 chunks
(13532|6612) DataReaderImpl::enable Cached_Allocator_With_Overflow 1f0c7c8 with 20 chunks
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSTopic) enabled
(13532|6612) DDS::PublicationBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 1f0c810 with 20 chunks
(13532|6612) DataReaderImpl::enable Cached_Allocator_With_Overflow 1f0c858 with 20 chunks
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSPublication) enabled
(13532|6612) DDS::SubscriptionBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 1f0c8a0 with 20 chunks
(13532|6612) DataReaderImpl::enable Cached_Allocator_With_Overflow 1f0c8e8 with 20 chunks
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSSubscription) enabled
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) Ocean::OceanMsgDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 1f0c930 with 20 chunks
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7910(unicast or multicast), socketid=488
(13532|6612) DataReaderImpl::enable Cached_Allocator_With_Overflow 1f0c9c0 with 20 chunks
(13532|6612) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.11:7900(unicast or multicast), socketid=488
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7912->0.0.0.0:7900)
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13532|6612) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 1184, local[192.168.179.1:0], port=50700
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.102.1:7910->0.0.0.0:7912)
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13532|8344) Spdp::data_received() - add a new participant local <01030050.37c00008.34dc0000.000001c1(b8f0199)> discovered remote <01030050.37c00008.35c40000.000001c1(9314d3ae)> createTime=1518167916, leaseDuration=20s.
(13532|8344) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|8344) ConditionImpl::signal_all()
(13532|8344) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x200.
(13532|8344) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13532|8344) ConditionImpl::signal_all()
(13532|8344) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x400.
(13532|8344) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13532|8344) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.34dc0000.000003c7(d0dac62e) <--> with remote publication  01030050.37c00008.35c40000.000003c2(382be096).
(13532|8344) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.34dc0000.000004c7(9f9b50e9) <--> with remote publication  01030050.37c00008.35c40000.000004c2(776a7651).
(13532|8344) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.34dc0000.000200c7(f8734183) <--> with remote publication  01030050.37c00008.35c40000.000200c2(1082673b).
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7910(unicast or multicast), socketid=488
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.11:7900(unicast or multicast), socketid=488
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7912->0.0.0.0:7900)
2018-02-09 17:18:36.114022 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13532|13428) Sedp::Task::svc got message from queue type 0
(13532|13428) DataLink::make_reservation() - creating association local publication  01030050.37c00008.34dc0000.000003c2(a0b032a1) <--> with remote subscription 01030050.37c00008.35c40000.000003c7(48411419).
(13532|13428) DataLink::make_reservation() - creating association local publication  01030050.37c00008.34dc0000.000004c2(eff1a466) <--> with remote subscription 01030050.37c00008.35c40000.000004c7(70082de).
(13532|13428) DataLink::make_reservation() - creating association local publication  01030050.37c00008.34dc0000.000200c2(8819b50c) <--> with remote subscription 01030050.37c00008.35c40000.000200c7(60e893b4).
(13532|13428) Sedp::Task::svc done with message
(13532|6612) Cached_Allocator_With_Overflow::malloc 03B6B5B4 1 heap allocs with 1 outstanding
(13532|6612) Cached_Allocator_With_Overflow::malloc 03B6B5F0 1 heap allocs with 1 outstanding
(13532|6612) Cached_Allocator_With_Overflow::malloc 03B6B644 1 heap allocs with 1 outstanding
2018-02-09 17:18:36.114022 (13532|6612) Sedp::write_subscription_data - subscriptions_writer_.write_sample.result=0
(13532|6612) EndpointManager::add_subscription - calling match_endpoints
(13532|6612) SubscriberImpl::reader_enabled, datareader(topic_name=DCHJData) enabled
(13532|6612) ConditionImpl::signal_all()
(13532|6612) StatusConditionImpl::get_trigger_value() - mask==0x4000, changes==0x0.
(13532|6612) StatusConditionImpl::get_trigger_value() - mask==0x4000, changes==0x0.
(13532|6612) StatusConditionImpl::get_trigger_value() - mask==0x4000, changes==0x0.
(13532|13444) DataLink::data_received_i: from publication 01030050.37c00008.35c40000.000003c2(382be096) received sample: SAMPLE_DATA (0x00), Length: 124, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x01, Timestamp: 1518167916.114022000, Publication: 01030050.37c00008.35c40000.000003c2(382be096) to readerId 01030050.37c00008.34dc0000.000003c7(d0dac62e) (SET_EXCLUDED).
2018-02-09 17:18:36.618222 (13532|13428) Sedp::Task::svc got message from queue type 1
(13532|13428) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|13428) ConditionImpl::signal_all()
(13532|13428) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x200.
(13532|13428) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13532|13428) ConditionImpl::signal_all()
(13532|13428) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x400.
(13532|13428) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
2018-02-09 17:18:36.618222 (13532|13428) Sedp::data_received(dwd) - calling match_endpoints new
2018-02-09 17:18:36.618222 (13532|13428) EndpointManager::match - adding reader association
(13532|13428) DataReaderImpl::add_new_association - bit 0 local 01030050.37c00008.34dc0000.00000004(f99a06e7) remote 01030050.37c00008.35c40000.00000003(ff654173)
(13532|13428) WriterInfo::WriterInfo: writer 01030050.37c00008.35c40000.00000003(ff654173) added to reader 01030050.37c00008.34dc0000.00000004(f99a06e7).
(13532|13428) DataReaderImpl::add_association: inserted writer 01030050.37c00008.35c40000.00000003(ff654173).return 1 
(13532|13428) DataReaderImpl::add_association: reader 01030050.37c00008.34dc0000.00000004(f99a06e7) is associated with writer 01030050.37c00008.35c40000.00000003(ff654173).
(13532|13428) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.34dc0000.00000004(f99a06e7) <--> with remote publication  01030050.37c00008.35c40000.00000003(ff654173).
(13532|13428) DataReaderImpl::transport_assoc_done: id_to_handle_map_[ 01030050.37c00008.35c40000.00000003(ff654173)] = 0x4.
(13532|13428) ConditionImpl::signal_all()
(13532|13428) StatusConditionImpl::get_trigger_value() - mask==0x4000, changes==0x4000.
(13532|13428) ConditionImpl::signal_all() - number of sets: 1, locally: 1.
(13532|13428) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13532|6612) StatusConditionImpl::get_trigger_value() - mask==0x4000, changes==0x0.
2018-02-09 17:18:36.633822 (13532|13428) Sedp::write_subscription_data - subscriptions_writer_.write_sample.result=0
(13532|13428) Sedp::Task::svc done with message
2018-02-09 17:18:38.011622 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.102.1:7910->0.0.0.0:7912)
2018-02-09 17:18:38.011622 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:38.011622 (13532|8344) Spdp::data received() - update an existing remote participant <01030050.37c00008.35c40000.000001c1(9314d3ae)> last_seen_.sec=1518167918
2018-02-09 17:18:38.120822 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7910(unicast or multicast), socketid=488
2018-02-09 17:18:38.120822 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.11:7900(unicast or multicast), socketid=488
2018-02-09 17:18:38.120822 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7912->0.0.0.0:7900)
2018-02-09 17:18:38.120822 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:40.115622 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7910(unicast or multicast), socketid=488
2018-02-09 17:18:40.115622 (13532|8344) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.11:7900(unicast or multicast), socketid=488
2018-02-09 17:18:40.115622 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=-1, (192.168.102.1:7910->0.0.0.0:7912)
2018-02-09 17:18:40.115622 (13532|8344) ERROR: Spdp::SpdpTransport::handle_input() - error reading (192.168.102.1:7910->0.0.0.0:7912) for unicast socket ACE_SOCK_Dgram::recv: connection reset, attempt to receive again
2018-02-09 17:18:40.115622 (13532|8344) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7912->0.0.0.0:7900)
2018-02-09 17:18:40.115622 (13532|8344) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21

(2)pub方
配置文件

[common]
DCPSGlobalTransportConfig=$file
ORBDebugLevel=0
DCPSDebugLevel=10
DCPSTransportDebugLevel=0
ORBLogFile=pub.log[domain/2]
DiscoveryConfig=fast_rtps[rtps_discovery/fast_rtps]
ResendPeriod=2
InteropMulticastOverride=239.255.0.12#SpdpSendAddrs=10.1.4.32:7910
SpdpSendAddrs=192.168.102.1:7912
##PB=30000
##DX=0
##D1=0
SedpMulticast=0
SedpLocalAddress=192.168.102.1:
TTL=20[transport/the_rtps_transport]
transport_type=rtps_udp
use_multicast=0
local_address=192.168.179.1:
ttl=20

日志文件

(13764|15312) NOTICE: using DCPSDebugLevel value from command option (overrides value if it's in config file).
(13764|15312) NOTICE: using DCPSTransportDebugLevel value from command option (overrides value if it's in config file).
(13764|15312) NOTICE: using ORBLogFile value from command option, overriding config file
Configuration InteropMulticastOverride=239.255.0.12
Configuration SedpMulticast=0
Configuration ResendPeriod=2
Configuration SedpLocalAddress=192.168.102.1:
Configuration SpdpSendAddrs=192.168.102.1:7912
Configuration TTL=20
Configuration transport_type=rtps_udp
Configuration use_multicast=0
Configuration local_address=192.168.179.1:
Configuration ttl=20
Configuration DiscoveryConfig=fast_rtps
2018-02-09 17:18:33.928322 (13764|15312) Service_Participant::set_repo_domain: Domain[ 2] = Repo[ fast_rtps].
(13764|15312) NOTICE: StaticDiscovery::parse_topics no [topic] sections.
(13764|15312) NOTICE: StaticDiscovery::parse_datawriterqos no [datawriterqos] sections.
(13764|15312) NOTICE: StaticDiscovery::parse_datareaderqos no [datareaderqos] sections.
(13764|15312) NOTICE: StaticDiscovery::parse_publisherqos no [publisherqos] sections.
(13764|15312) NOTICE: StaticDiscovery::parse_subscriberqos no [subscriberqos] sections.
(13764|15312) NOTICE: StaticDiscovery::parse_endpoints no [endpoint] sections.
(13764|15312) NOTICE: Service_Participant::intializeScheduling() - no scheduling policy specified, not setting policy.
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
2018-02-09 17:18:33.943922 (13764|15312) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 488, local[0.0.0.0:7910], port=7910
2018-02-09 17:18:33.943922 (13764|15312) Spdp::SpdpTransport::open_unicast_socket() - opened unicast socket on port 7910
(13764|15312) Spdp::SpdpTransport::SpdpTransport joining group  239.255.0.12:7900
2018-02-09 17:18:33.990722 (13764|15312) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 692, local[192.168.102.1:0], port=50697
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) DDS::ParticipantBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 54c6f0 with 20 chunks
(13764|15312) DataReaderImpl::enable Cached_Allocator_With_Overflow 54c738 with 20 chunks
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSParticipant) enabled
(13764|15312) DDS::TopicBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 54c780 with 20 chunks
(13764|15312) DataReaderImpl::enable Cached_Allocator_With_Overflow 54c7c8 with 20 chunks
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSTopic) enabled
(13764|15312) DDS::PublicationBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 54c810 with 20 chunks
(13764|15312) DataReaderImpl::enable Cached_Allocator_With_Overflow 54c858 with 20 chunks
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSPublication) enabled
(13764|15312) DDS::SubscriptionBuiltinTopicDataDataReaderImpl::enable_specific-data Cached_Allocator_With_Overflow 54c8a0 with 20 chunks
(13764|15312) DataReaderImpl::enable Cached_Allocator_With_Overflow 54c8e8 with 20 chunks
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) SubscriberImpl::reader_enabled, datareader(topic_name=DCPSSubscription) enabled
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|15312) Ocean::OceanMsgDataWriterImpl::enable_specific is unbounded data - allocate from heap
(13764|15312) Ocean::OceanMsgDataWriterImpl::enable_specific-mb Cached_Allocator_With_Overflow 5aee60 with 10 chunks
(13764|15312) Ocean::OceanMsgDataWriterImpl::enable_specific-db Cached_Allocator_With_Overflow 5af058 with 1 chunks
(13764|15312) WriteDataContainer sample_list_element_allocator 5af21c with 1 chunks
(13764|15312) WriteDataContainer transport_send_element_allocator 5af258 with 1 chunks
(13764|15312) DataWriterImpl::enable-mb Cached_Allocator_With_Overflow 5af598 with 1 chunks
(13764|15312) DataWriterImpl::enable-db Cached_Allocator_With_Overflow 5af790 with 1 chunks
(13764|15312) DataWriterImpl::enable-header Cached_Allocator_With_Overflow 54c930 with 1 chunks
2018-02-09 17:18:34.006322 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7912(unicast or multicast), socketid=488
2018-02-09 17:18:34.006322 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.12:7900(unicast or multicast), socketid=488
2018-02-09 17:18:34.006322 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=-1, (192.168.102.1:7912->0.0.0.0:7910)
2018-02-09 17:18:34.006322 (13764|14332) ERROR: Spdp::SpdpTransport::handle_input() - error reading (192.168.102.1:7912->0.0.0.0:7910) for unicast socket ACE_SOCK_Dgram::recv: connection reset, attempt to receive again
(13764|15312) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
2018-02-09 17:18:34.006322 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7910->0.0.0.0:7900)
2018-02-09 17:18:34.006322 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:34.006322 (13764|15312) SUCCESS:open_appropriate_socket_type: socket open successful(SPDP or SEDP or transport): socketid: 1180, local[192.168.179.1:0], port=50698
(13764|15312) Sedp::write_publication_data - not currently associated, dropping msg.
(13764|15312) EndpointManager::add_publication - calling match_endpoints
2018-02-09 17:18:36.020422 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7912(unicast or multicast), socketid=488
2018-02-09 17:18:36.020422 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.12:7900(unicast or multicast), socketid=488
2018-02-09 17:18:36.020422 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=-1, (192.168.102.1:7912->0.0.0.0:7910)
2018-02-09 17:18:36.020422 (13764|14332) ERROR: Spdp::SpdpTransport::handle_input() - error reading (192.168.102.1:7912->0.0.0.0:7910) for unicast socket ACE_SOCK_Dgram::recv: connection reset, attempt to receive again
2018-02-09 17:18:36.020422 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7910->0.0.0.0:7900)
2018-02-09 17:18:36.020422 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.102.1:7912->0.0.0.0:7910)
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13764|14332) Spdp::data_received() - add a new participant local <01030050.37c00008.35c40000.000001c1(9314d3ae)> discovered remote <01030050.37c00008.34dc0000.000001c1(b8f0199)> createTime=1518167916, leaseDuration=20s.
(13764|14332) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|14332) ConditionImpl::signal_all()
(13764|14332) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x200.
(13764|14332) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13764|14332) ConditionImpl::signal_all()
(13764|14332) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x400.
(13764|14332) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13764|14332) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.35c40000.000003c7(48411419) <--> with remote publication  01030050.37c00008.34dc0000.000003c2(a0b032a1).
(13764|14332) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.35c40000.000004c7(70082de) <--> with remote publication  01030050.37c00008.34dc0000.000004c2(eff1a466).
(13764|14332) DataLink::make_reservation() - creating association local subscription 01030050.37c00008.35c40000.000200c7(60e893b4) <--> with remote publication  01030050.37c00008.34dc0000.000200c2(8819b50c).
2018-02-09 17:18:36.114022 (13764|9740) Sedp::Task::svc got message from queue type 0
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7912(unicast or multicast), socketid=488
(13764|9740) DataLink::make_reservation() - creating association local publication  01030050.37c00008.35c40000.000003c2(382be096) <--> with remote subscription 01030050.37c00008.34dc0000.000003c7(d0dac62e).
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.12:7900(unicast or multicast), socketid=488
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7910->0.0.0.0:7900)
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
(13764|9740) DataLink::make_reservation() - creating association local publication  01030050.37c00008.35c40000.000004c2(776a7651) <--> with remote subscription 01030050.37c00008.34dc0000.000004c7(9f9b50e9).
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.102.1:7912->0.0.0.0:7910)
2018-02-09 17:18:36.114022 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:36.114022 (13764|14332) Spdp::data received() - update an existing remote participant <01030050.37c00008.34dc0000.000001c1(b8f0199)> last_seen_.sec=1518167916
(13764|9740) DataLink::make_reservation() - creating association local publication  01030050.37c00008.35c40000.000200c2(1082673b) <--> with remote subscription 01030050.37c00008.34dc0000.000200c7(f8734183).
2018-02-09 17:18:36.114022 (13764|9740) Sedp::write_publication_data - publications_writer_.write_sample. result=0
(13764|9740) Sedp::Task::svc done with message
(13764|2808) DataLink::data_received_i: from publication 01030050.37c00008.34dc0000.000004c2(eff1a466) received sample: SAMPLE_DATA (0x00), Length: 112, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x02, Timestamp: 1518167916.114022000, Publication: 01030050.37c00008.34dc0000.000004c2(eff1a466) to readerId 00000000.00000000.00000000.00000000(ecbb4b55) (SET_INCLUDED).
(13764|2808) DataLink::data_received_i - normal data received to each subscription in listener_set include ids:
(13764|2808) DataLink::data_received_i: from publication 01030050.37c00008.34dc0000.000004c2(eff1a466) received sample: SAMPLE_DATA (0x00), Length: 132, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x03, Timestamp: 1518167916.633822000, Publication: 01030050.37c00008.34dc0000.000004c2(eff1a466) to readerId 00000000.00000000.00000000.00000000(ecbb4b55) (SET_INCLUDED).
(13764|2808) DataLink::data_received_i - normal data received to each subscription in listener_set include ids:
(13764|2808) DataLink::data_received_i: from publication 01030050.37c00008.34dc0000.000004c2(eff1a466) received sample: SAMPLE_DATA (0x00), Length: 112, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x02, Timestamp: 1518167916.114022000, Publication: 01030050.37c00008.34dc0000.000004c2(eff1a466) to readerId 00000000.00000000.00000000.00000000(ecbb4b55) (SET_INCLUDED).
(13764|2808) DataLink::data_received_i - normal data received to each subscription in listener_set include ids:
(13764|2808) DataLink::data_received_i: from publication 01030050.37c00008.34dc0000.000004c2(eff1a466) received sample: SAMPLE_DATA (0x00), Length: 112, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x02, Timestamp: 1518167916.114022000, Publication: 01030050.37c00008.34dc0000.000004c2(eff1a466) to readerId 01030050.37c00008.35c40000.000004c7(70082de) (SET_EXCLUDED).
(13764|2808) DataLink::data_received_i: from publication 01030050.37c00008.34dc0000.000004c2(eff1a466) received sample: SAMPLE_DATA (0x00), Length: 132, Byte order: Little Endian, CDR Encapsulation, Sequence: 0x03, Timestamp: 1518167916.633822000, Publication: 01030050.37c00008.34dc0000.000004c2(eff1a466) to readerId 01030050.37c00008.35c40000.000004c7(70082de) (SET_EXCLUDED).
2018-02-09 17:18:36.821022 (13764|9740) Sedp::Task::svc got message from queue type 2
(13764|9740) Service_Participant::get_discovery: returning repository for domain 2, repo fast_rtps.
(13764|9740) ConditionImpl::signal_all()
(13764|9740) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x200.
(13764|9740) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13764|9740) ConditionImpl::signal_all()
(13764|9740) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x400.
(13764|9740) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
2018-02-09 17:18:36.821022 (13764|9740) Sedp::data_received(drd) - calling match_endpoints new
2018-02-09 17:18:36.821022 (13764|9740) EndpointManager::match - adding writer association
2018-02-09 17:18:36.821022 (13764|9740) DataWriterImpl::add_new_association - bit 0 local 01030050.37c00008.35c40000.00000003(ff654173) remote 01030050.37c00008.34dc0000.00000004(f99a06e7)
(13764|9740) DataWriterImpl::add_association(): adding subscription to publication 01030050.37c00008.35c40000.00000003(ff654173) with priority 0.
(13764|9740) DataLink::make_reservation() - creating association local publication  01030050.37c00008.35c40000.00000003(ff654173) <--> with remote subscription 01030050.37c00008.34dc0000.00000004(f99a06e7).
(13764|9740) DataWriterImpl::transport_assoc_done:  writer 01030050.37c00008.35c40000.00000003(ff654173) succeeded in associating with reader 01030050.37c00008.34dc0000.00000004(f99a06e7)
(13764|9740) DataWriterImpl::transport_assoc_done: marked remote reader 01030050.37c00008.34dc0000.00000004(f99a06e7) as pending.
(13764|9740) Sedp::Task::svc done with message
2018-02-09 17:18:36.821022 (13764|9740) Sedp::Task::svc got message from queue type 2
(13764|9740) DataWriterImpl::association_complete - bit 0 local 01030050.37c00008.35c40000.00000003(ff654173) remote 01030050.37c00008.34dc0000.00000004(f99a06e7)
(13764|9740) DataWriterImpl::association_complete_i - bit 0 local 01030050.37c00008.35c40000.00000003(ff654173) remote 01030050.37c00008.34dc0000.00000004(f99a06e7)
(13764|9740) DataWriterImpl::association_complete_i: id_to_handle_map_01030050.37c00008.34dc0000.00000004(f99a06e7) = 0x4.
(13764|9740) ConditionImpl::signal_all()
(13764|9740) StatusConditionImpl::get_trigger_value() - mask==0xffffffff, changes==0x2000.
(13764|9740) ConditionImpl::signal_all() - number of sets: 0, locally: 0.
(13764|9740) Sedp::Task::svc done with message
2018-02-09 17:18:38.011622 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 192.168.102.1:7912(unicast or multicast), socketid=488
2018-02-09 17:18:38.011622 (13764|14332) Spdp::SpdpTransport::write_i send SPDPdiscoveredParticipantData to 239.255.0.12:7900(unicast or multicast), socketid=488
2018-02-09 17:18:38.011622 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.179.1:7910->0.0.0.0:7900)
2018-02-09 17:18:38.011622 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:38.120822 (13764|14332) Spdp::SpdpTransport::handle_input() - recvBytes=208, (192.168.102.1:7912->0.0.0.0:7910)
2018-02-09 17:18:38.120822 (13764|14332) Spdp::SpdpTransport::handle_input() - received subMsgType[DATA]=21
2018-02-09 17:18:38.120822 (13764|14332) Spdp::data received() - update an existing remote participant <01030050.37c00008.34dc0000.000001c1(b8f0199)> last_seen_.sec=1518167918

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/448274.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/448274.shtml
英文地址,請注明出處:http://en.pswp.cn/news/448274.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Developing Web Applications with Apache, MySQL, memcached, and Perl

Developing Web Applications with Apache, MySQL, memcached, and Perl轉載于:https://www.cnblogs.com/gavinhughhu/archive/2009/11/02/1594290.html

awk 中 {print $1} 什么意思

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 舉個例子 echo "aa bb cc" | awk -F {print $1} 結果就是aa&#xff0c;意思是把字符串按空格分割&#xff0c;取第一個。aw…

有駕照不等于會開車,教你開車技巧27招

當今有車的人真的是越來越多了&#xff0c;不要以為自己有駕照就是會開車了哦&#xff0c;其實開車還是有很多技巧的。下面就跟小編看下學會那些招數才真算會開車吧。 1、上車先看車 上車前繞車轉一圈&#xff0c;看車的外況、輪胎、車底下有沒有漏油漏水。一個星期還得揭開蓋子…

OpenDDS通訊中rtps_discovery對等發現的基本配置和說明

OpenDDS的對等發現模式中&#xff0c;可以采用組播或單播方式進行發現和基于主題的DataReader和DataWriter的匹配&#xff0c;下面是一個簡單的配置樣例&#xff1a; [common] DCPSGlobalTransportConfig$file ORBDebugLevel0 DCPSDebugLevel3 DCPSTransportDebugLevel0 ORBLo…

用戶使用協議

知乎協議&#xff08;草案&#xff09; 歡迎您來到知乎。 請您仔細閱讀以下條款&#xff0c;如果您對本協議的任何條款表示異議&#xff0c;您可以選擇不進入知乎。當您注冊成功&#xff0c;無論是進入知乎&#xff0c;還是在知乎上發布任何內容&#xff08;即「內容」&#xf…

解決: bash: unzip: command not found、linux 安裝 zip 命令

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 1. 執行解壓命令報錯&#xff1a; bash: unzip: command not found 2. 安裝 zip&#xff1a; yum install -y unzip zip 3. 重試成功…

基于OpenDDS開發發布訂閱HelloMsg程序的過程(Windows)

基于OpenDDS的應用開發&#xff0c;主要分兩個部分的工作&#xff1a; &#xff08;1&#xff09;定義自己的IDL文件&#xff0c;并編譯成消息數據類型通訊動態庫&#xff1b; &#xff08;2&#xff09;分別編寫pub和sub程序&#xff0c;運行 具體步驟&#xff0c;有以下幾…

面試后的總結

面試中的收獲&#xff1a; 優點&#xff1a; 1. 設計用例考慮較為全面。 2. 自動化&#xff0c;性能都有涉獵&#xff0c;但不深入。 3. 對業務理解較深入。 缺點&#xff1a; 1. 接口自動化停留在初級階段。 2. UI自動化了解較少。 3. 性能壓測缺少數據清洗等步驟。 4. 算法還…

怎樣正確使用車燈?

當我們被對面來車明晃晃的遠光燈照得意識模糊時&#xff0c;當你快速接近一輛摩托車卻發現那是一輛壞了一盞尾燈的卡車時&#xff0c;或是當你前方的小車忽然亮起倒車燈卻在往前行駛&#xff0c;最后意識到那只是因為剎車燈與倒車燈線路顛倒時&#xff0c;你就會發現在人們都認…

如何配置DDS以使用多個網絡接口?How do I configure DDS to work with multiple network interfaces?

最近在使用OpenDDS的時候遇到一個問題&#xff1a;存在多個虛擬網卡時&#xff0c;發布&#xff08;訂閱&#xff09;端重新連接時會阻塞幾分鐘&#xff0c;在外網找到一篇與此相關的文章。 You cannot specify which NICs DDS will use to send data. You can restrict the NI…

oracle賦予一個用戶查詢另一個用戶中所有表

說明&#xff1a;讓用戶selame能夠查詢用戶ame中的所有表&#xff08;不能添加和刪除&#xff09;1.創建用戶selamecreate user selame identified by Password;2.設置用戶selame系統權限grant connect,resource to selame; 3.設置用戶selame對象權限 grant select any table t…

使用可靠多播與OPENDDS進行數據分發

介紹 也許應用程序設計人員在創建分布式系統時面臨的最關鍵決策之一是如何在感興趣的各方之間交換數據。通常&#xff0c;這涉及選擇一個或多個通信協議并確定向每個端點分派數據的最有效手段。實現較低級別的通信軟件可能是耗時的&#xff0c;昂貴的并且容易出錯。很多時候&a…

考試 駕校

您的孩子在車里安全么&#xff1f;兒童座椅那點事兒 兒童安全座椅用最最普通的話來解釋就是一種系于汽車座位上,供小童乘坐,有束縛設備,并能在發生車禍時,束縛著小童以保障小童安全的座椅。 兒童安全座椅在歐美發達國家已經得到了普遍使用&#xff0c;這些國家基本上都制定了相…

margin為負值的幾種情況

1、margin-top為負值像素 margin-top為負值像素&#xff0c;偏移值相對于自身&#xff0c;其后元素受影響&#xff0c;見如下代碼&#xff1a; 1 <!DOCTYPE html>2 <html lang"zh">3 <head>4 <meta charset"UTF-8" />5 &l…

事件EVENT,WaitForSingleObject(),WaitForMultipleObjecct()和SignalObjectAndWait() 的使用(上)

用戶模式的線程同步機制效率高&#xff0c;如果需要考慮線程同步問題&#xff0c;應該首先考慮用戶模式的線程同步方法。但是&#xff0c;用戶模式的線程同步有限制&#xff0c;對于多個進程之間的線程同步&#xff0c;用戶模式的線程同步方法無能為力。這時&#xff0c;只能考…

axios 中文文檔、使用說明

以下內容全文轉自 Axios 文檔&#xff1a;https://www.kancloud.cn/yunye/axios/234845 ##Axios Axios 是一個基于 promise 的 HTTP 庫&#xff0c;可以用在瀏覽器和 node.js 中。 Features 從瀏覽器中創建 XMLHttpRequests從 node.js 創建 http 請求支持 Promise API攔截請…

汽車熄火是什么原因?

汽車熄火是什么原因&#xff1f; 近來看見很多車主被車子熄火所困擾&#xff0c;駕校一點通幫助您從以下也許可以找出原因。 1、自動檔車型&#xff1a; 自動檔的車型不會輕易出現熄火的現象&#xff0c;而手動檔的車型由于駕駛水平不高&#xff0c;可能會經常出現熄火的現象。…

數據庫 -- 02

引擎介紹 1.什么是引擎 MySQL中的數據用各種不同的技術存儲在文件&#xff08;或者內存&#xff09;中。這些技術中的每一種技術都使用不同的存儲機制、索引技巧、鎖定水平并且最終提供廣泛的不同的功能和能力。通過選擇不同的技術&…

事件EVENT,WaitForSingleObject(),WaitForMultipleObjecct()和SignalObjectAndWait() 的使用(下)

注意&#xff1a;當WaitForMultipleObjects等待多個內核對象的時候&#xff0c;如果它的bWaitAll 參數設置為false。其返回值減去WAIT_OBJECT_0 就是參數lpHandles數組的序號。如果同時有多個內核對象被觸發&#xff0c;這個函數返回的只是其中序號最小的那個。 如果bWaitAll …

設置 shell 腳本中 echo 顯示內容帶顏色

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 shell腳本中echo顯示內容帶顏色顯示,echo顯示帶顏色&#xff0c;需要使用參數 -e 格式如下&#xff1a; echo -e "\033[字背景顏…