Searched defs:its_subscription (Results 1 – 6 of 6) sorted by relevance
254 auto its_subscription = found_eventgroup->second; in subscribe() local289 std::shared_ptr<subscription> its_subscription in subscribe() local426 auto its_subscription = found_eventgroup->second; in unsubscribe() local499 auto its_subscription = its_eventgroup.second; in unsubscribe_all() local540 auto its_subscription = its_eventgroup.second; in unsubscribe_all_on_suspend() local1512 auto its_subscription = its_eventgroup.second; in process_offerservice_serviceentry() local1649 std::shared_ptr<subscription> its_subscription(its_eventgroup.second); in on_endpoint_connected() local2407 auto its_subscription = std::make_shared<remote_subscription>(); in handle_eventgroup_subscription() local2458 auto its_subscription = found_eventgroup->second; in handle_eventgroup_subscription_nack() local3247 for (const auto &its_subscription : _acknowledgement->get_subscriptions()) in update_acknowledgement() local[all …]
61 for (const auto& its_subscription : subscriptions_) { in is_pending() local
2682 for (auto its_subscription in expire_subscriptions() local2944 auto its_subscription = its_eventgroup->get_remote_subscription(_id); in on_subscribe_ack() local3033 auto its_subscription = its_eventgroup->get_remote_subscription(_id); in on_subscribe_nack() local3270 const auto its_subscription = its_info->get_remote_subscription(its_id); in expire_subscriptions() local4225 const auto its_subscription = its_info->get_remote_subscription(_id); in on_unsubscribe_ack() local
183 auto its_subscription = s.second; in get_unreliable_target_count() local
1035 for (auto its_subscription : _subscribed_eventgroups) { in remove_local() local
120 std::uint8_t its_subscription[] = { in subscribe_at_master() local