Lines Matching refs:subscriber
90 auto subscriber = std::make_shared<Subscriber>(subscribeId, sess, switchType);
91 InsertSubScriber(std::move(subscriber));
120 for (const auto &subscriber : subscribers_) {
121 if (subscriber->switchType_ == switchEvent->GetSwitchType() ||
122 (subscriber->switchType_ == SwitchEvent::SwitchType::SWITCH_DEFAULT &&
124 NotifySubscriber(switchEvent, subscriber);
169 const std::shared_ptr<Subscriber> &subscriber)
173 CHKPV(subscriber);
178 if (subscriber->sess_ == nullptr) {
182 int32_t fd = subscriber->sess_->GetFd();
183 pkt << fd << subscriber->id_;
184 MMI_HILOGI("Notify subscriber id:%{public}d, switchValue:%{public}d, pid:%{public}d",
185 subscriber->id_, switchEvent->GetSwitchValue(), subscriber->sess_->GetPid());
187 MMI_HILOGE("Packet write dispatch subscriber failed");
191 MMI_HILOGE("Leave, server dispatch subscriber failed");
217 std::shared_ptr<Subscriber> subscriber = item;
218 CHKPV(subscriber);
221 mprintf(fd, "subscriber id:%d | Pid:%d | Uid:%d | Fd:%d\t",
222 subscriber->id_, session->GetPid(), session->GetUid(), session->GetFd());