celix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Roy Lenferink (JIRA)" <j...@apache.org>
Subject [jira] [Created] (CELIX-463) [PSA] UDP mc subscriber is not receiving data
Date Wed, 26 Jun 2019 06:18:00 GMT
Roy Lenferink created CELIX-463:
-----------------------------------

             Summary: [PSA] UDP mc subscriber is not receiving data
                 Key: CELIX-463
                 URL: https://issues.apache.org/jira/browse/CELIX-463
             Project: Celix
          Issue Type: Bug
          Components: PubSubAdmin
            Reporter: Roy Lenferink


Using the UDP MC PSA, a subscriber is not receiving any data when a publisher has been started.

*How to reproduce:*
Start a publisher: \{{./pubsub_publisher_udp_mc}}
Start a subscriber: \{{./pubsub_subscriber_udp_mc}}

*Output:*
Subscriber is started, but is not receiving data. When stopping the publisher, the subscriber
prints:
-> [PSA UPDMC] Error got endpoint without udpmc socket address/port or endpoint type
[PSA UPDMC] Error got endpoint without udpmc socket address/port or endpoint type
[PSA UPDMC] Error got endpoint without udpmc socket address/port or endpoint type
[PSA UPDMC] Error got endpoint without udpmc socket address/port or endpoint type

When executing \{{pstm}} from the subscriber its shell, it prints that the discovered (publisher)
endpoint is found:
-> pstm 

Discovered Endpoints: 
|- Discovered Endpoint 43af3fa0-36c9-426b-94b7-57494c16e6fd:
   |- container name = pubsub_publisher_udp_mc
   |- fw uuid        = ab9fdf5d-040e-403a-8a2b-a434cb2011a0
   |- type           = publisher
   |- scope          = default
   |- topic          = poi1
   |- admin type     = udp_mc
   |- serializer     = json
   |- psa svc id     = 21
   |- usage count    = 1
|- Discovered Endpoint 9aee44cb-b977-4691-817b-9af9e4c8a9bd:
   |- container name = pubsub_publisher_udp_mc
   |- fw uuid        = ab9fdf5d-040e-403a-8a2b-a434cb2011a0
   |- type           = publisher
   |- scope          = default
   |- topic          = poi2
   |- admin type     = udp_mc
   |- serializer     = json
   |- psa svc id     = 21
   |- usage count    = 1
|- Discovered Endpoint a0c91f64-f417-48f3-99ea-762f0ecf2f85:
   |- container name = pubsub_subscriber_udp_mc
   |- fw uuid        = add5cb02-b71c-40d2-bd28-406d39142a85
   |- type           = subscriber
   |- scope          = default
   |- topic          = poi1
   |- admin type     = udp_mc
   |- serializer     = json
   |- psa svc id     = 21
   |- usage count    = 1
|- Discovered Endpoint 507013da-5d11-44c5-b214-c009cdb44aba:
   |- container name = pubsub_subscriber_udp_mc
   |- fw uuid        = add5cb02-b71c-40d2-bd28-406d39142a85
   |- type           = subscriber
   |- scope          = default
   |- topic          = poi2
   |- admin type     = udp_mc
   |- serializer     = json
   |- psa svc id     = 21
   |- usage count    = 1

Active Topic Senders:

Active Topic Receivers:
|- Topic Receiver for endpoint a0c91f64-f417-48f3-99ea-762f0ecf2f85:
   |- scope       = default
   |- topic       = poi1
   |- admin type  = udp_mc
   |- serializer  = json
    |- psa svc id  = 21
    |- ser svc id  = 15
    |- usage count = 1
|- Topic Receiver for endpoint 507013da-5d11-44c5-b214-c009cdb44aba:
   |- scope       = default
   |- topic       = poi2
   |- admin type  = udp_mc
   |- serializer  = json
    |- psa svc id  = 21
    |- ser svc id  = 15
    |- usage count = 1

*Expected output:*
Subscriber should be receiving data, e.g.:
Recv (poi1): [88.577834, -20.782625] (Bundle#7, fw-0e7364cf [TID=140599636256512], extra value,
len data 66614)
Recv (poi2): [-13.995416, -156.721468] (Bundle#7, fw-0e7364cf [TID=140599625766656], extra
value, len data 56598)
Recv (poi2): [78.951401, -19.207992] (Bundle#8, fw-0e7364cf [TID=140599615276800], extra value,
len data 26546)
Recv (poi1): [19.185080, -133.307785] (Bundle#8, fw-0e7364cf [TID=140599594297088], extra
value, len data 63000)
Recv (poi1): [-17.941152, -78.254207] (Bundle#7, fw-0e7364cf [TID=140599636256512], extra
value, len data 77599)
Recv (poi2): [-57.826559, -88.669464] (Bundle#7, fw-0e7364cf [TID=140599625766656], extra
value, len data 62086)
Recv (poi1): [71.557002, -6.762624] (Bundle#8, fw-0e7364cf [TID=140599594297088], extra value,
len data 9788)
Recv (poi2): [31.348949, 145.685591] (Bundle#8, fw-0e7364cf [TID=140599615276800], extra value,
len data 83130)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message