Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Wrong local pubsub consumer release #38

Closed
giangndm opened this issue Nov 3, 2023 · 2 comments
Closed

Wrong local pubsub consumer release #38

giangndm opened this issue Nov 3, 2023 · 2 comments

Comments

@giangndm
Copy link
Contributor

giangndm commented Nov 3, 2023

When multi times consumer create/destroy cause warning about Consumer not found

[2023-11-03T04:12:49.112Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on added local channel 4086742429 => set Hashmap field
[2023-11-03T04:12:49.128Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] will sub hashmap 4086742429
[2023-11-03T04:12:49.128Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 4086742429 add source 1
[2023-11-03T04:12:49.128Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 4086742429 added source 1
[2023-11-03T04:12:49.128Z DEBUG pub_sub::relay] [PubsubRelay] channel 4086742429 added source  1 => auto sub for local subs [0]
[2023-11-03T04:12:49.128Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 4086742429/1 event from 0 pushed to list, new relay
[2023-11-03T04:12:49.153Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on added local channel 2861764290 => set Hashmap field
[2023-11-03T04:12:49.155Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] will sub hashmap 2861764290
[2023-11-03T04:12:49.155Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 2861764290 add source 1
[2023-11-03T04:12:49.155Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 2861764290 added source 1
[2023-11-03T04:12:49.155Z DEBUG pub_sub::relay] [PubsubRelay] channel 2861764290 added source  1 => auto sub for local subs [1]
[2023-11-03T04:12:49.155Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 2861764290/1 event from 1 pushed to list, new relay






[2023-11-03T04:12:53.465Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on removed local channel 2861764290 => del Hashmap field
[2023-11-03T04:12:53.465Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on removed local channel 4086742429 => del Hashmap field
[2023-11-03T04:12:53.471Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 2861764290 remove source 1
[2023-11-03T04:12:53.471Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 4086742429 remove source 1
[2023-11-03T04:12:53.471Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 2861764290 removed source 1
[2023-11-03T04:12:53.471Z DEBUG pub_sub::relay] [PubsubRelay] channel 2861764290 removed source 1 => auto unsub for local subs [1]
[2023-11-03T04:12:53.471Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 2861764290/1 event from 1 removed from list
[2023-11-03T04:12:53.471Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 2861764290/1 event from 1 list empty in source node => removed
[2023-11-03T04:12:53.471Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 4086742429 removed source 1
[2023-11-03T04:12:53.471Z DEBUG pub_sub::relay] [PubsubRelay] channel 4086742429 removed source 1 => auto unsub for local subs [0]
[2023-11-03T04:12:53.471Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 4086742429/1 event from 0 removed from list
[2023-11-03T04:12:53.471Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 4086742429/1 event from 0 list empty in source node => removed






[2023-11-03T04:12:57.650Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on added local channel 4086742429 => set Hashmap field
[2023-11-03T04:12:57.659Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 4086742429 add source 1
[2023-11-03T04:12:57.659Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 4086742429 added source 1
[2023-11-03T04:12:57.659Z DEBUG pub_sub::relay] [PubsubRelay] channel 4086742429 added source  1 => auto sub for local subs [0]
[2023-11-03T04:12:57.659Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 4086742429/1 event from 0 pushed to list, new relay
[2023-11-03T04:12:57.665Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 4086742429/1 event from 2 pushed to list
[2023-11-03T04:12:57.666Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on added local channel 2861764290 => set Hashmap field
[2023-11-03T04:12:57.666Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 2861764290 add source 1
[2023-11-03T04:12:57.666Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 2861764290 added source 1
[2023-11-03T04:12:57.666Z DEBUG pub_sub::relay] [PubsubRelay] channel 2861764290 added source  1 => auto sub for local subs [1]
[2023-11-03T04:12:57.666Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 2861764290/1 event from 1 pushed to list, new relay
[2023-11-03T04:12:57.668Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local sub 2861764290/1 event from 3 pushed to list
[2023-11-03T04:12:57.687Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.696Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.702Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.740Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.741Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.763Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.764Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.769Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.795Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.795Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.813Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.829Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.835Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.858Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.862Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.863Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.896Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.900Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.903Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.930Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.941Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.964Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.964Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:57.990Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.990Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:57.996Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.004Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.026Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.029Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.051Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.063Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.064Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.096Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.097Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.104Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.132Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.133Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.155Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.162Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.164Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.195Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.199Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.217Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.229Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 4086742429 from 1 to local 0 consumer not found
[2023-11-03T04:12:58.239Z WARN  pub_sub::relay::local] [LocalRelay] relay channel 2861764290 from 1 to local 1 consumer not found
[2023-11-03T04:12:58.239Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on removed local channel 2861764290 => del Hashmap field
[2023-11-03T04:12:58.239Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on removed local channel 4086742429 => del Hashmap field
[2023-11-03T04:12:58.239Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 2861764290 remove source 1
[2023-11-03T04:12:58.239Z DEBUG pub_sub::behaviour] [PubSubServiceBehaviour 1] channel 4086742429 remove source 1
[2023-11-03T04:12:58.239Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 2861764290 removed source 1
[2023-11-03T04:12:58.239Z DEBUG pub_sub::relay] [PubsubRelay] channel 2861764290 removed source 1 => auto unsub for local subs [1, 3]
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 2861764290/1 event from 1 removed from list
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 2861764290/1 event from 3 removed from list
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 2861764290/1 event from 3 list empty in source node => removed
[2023-11-03T04:12:58.239Z INFO  pub_sub::behaviour] [PubSubServiceBehaviour 1] on channel 4086742429 removed source 1
[2023-11-03T04:12:58.239Z DEBUG pub_sub::relay] [PubsubRelay] channel 4086742429 removed source 1 => auto unsub for local subs [0, 2]
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 4086742429/1 event from 0 removed from list
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 4086742429/1 event from 2 removed from list
[2023-11-03T04:12:58.239Z INFO  pub_sub::relay::logic] [PubsubRelayLogic 1] local unsub 4086742429/1 event from 2 list empty in source node => removed
@giangndm
Copy link
Contributor Author

giangndm commented Nov 3, 2023

https://github.com/8xFF/decentralized-sdn/blob/f178586c71b090d53fbd3bbccf703789700f4615/packages/services/pub_sub/src/sdk/consumer.rs#L81-L85

Above code should call on_local_unsub not on_local_sub

@giangndm giangndm closed this as completed Nov 4, 2023
@giangndm
Copy link
Contributor Author

giangndm commented Nov 4, 2023

Fixed in #39

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

When branches are created from issues, their pull requests are automatically linked.

38-wrong-local-pubsub-consumer-release giangndm/8xFF-decentralized-sdn
1 participant
@giangndm