Lines Matching refs:dispatcher
70 SHARING_LOGE("BufferReceiver read failed null dispatcher.");
291 void DataNotifier::SetListenDispatcher(IBufferReader::Ptr dispatcher)
294 dispatcher_ = dispatcher;
322 auto dispatcher = dispatcher_.lock();
323 if (dispatcher == nullptr) {
324 SHARING_LOGE("target dispatcher NOT exist.");
330 (audioIndex < dispatcher->GetLatestAudioIndex() || !dispatcher->IsRead(GetReceiverId(), audioIndex + 1));
333 (videoIndex < dispatcher->GetLatestVideoIndex() || !dispatcher->IsRead(GetReceiverId(), videoIndex + 1));
336 (videoIndex < dispatcher->GetBufferSize() - 1 || !dispatcher->IsRead(GetReceiverId(), videoIndex + 1));
449 writingTimer_ = std::make_unique<TimeoutTimer>("dispatcher-writing-timer");
739 SHARING_LOGI("buffer dispatcher: Detach receiver in.");
741 SHARING_LOGE("buffer dispatcher: Detach receiver failed - null receiver.");
752 SHARING_LOGE("buffer dispatcher: Detach receiver failed - no find receiver in notifiers.");
769 SHARING_LOGI("buffer dispatcher: Detach notifier in.");
771 SHARING_LOGE("buffer dispatcher: Detach receiver failed - null notifier.");
808 SHARING_LOGE("buffer dispatcher: Detach receiver failed - no find receiver in notifiers.");
1062 ", cur_size: %{public}zu, capacity: %{public}zu dispatcher[%{public}u].",
1466 BufferDispatcher *dispatcher = (BufferDispatcher *)userParam;
1467 while (dispatcher->running_) {
1468 std::unique_lock<std::mutex> locker(dispatcher->notifyMutex_);
1469 uint32_t notifyRef = dispatcher->dataBitRef_ & dispatcher->recvBitRef_;
1471 dispatcher->dataBitRef_.load(), dispatcher->recvBitRef_.load(), notifyRef);
1473 for (auto &[recvId, notifier] : dispatcher->notifiers_) {
1490 dispatcher->dataCV_.wait(locker, [&dispatcher]() { return dispatcher->continueNotify_.load(); });
1491 dispatcher->continueNotify_ = false;