Lines Matching refs:bus_
118 : bus_(bus), in ObjectProxy()
137 bus_->AssertOnDBusThread(); in CallMethodAndBlockWithErrorDetails()
139 if (!bus_->Connect() || in CallMethodAndBlockWithErrorDetails()
149 bus_->SendWithReplyAndBlock(request_message, timeout_ms, error->get()); in CallMethodAndBlockWithErrorDetails()
194 bus_->AssertOnOriginThread(); in CallMethodWithErrorResponse()
198 ReplyCallbackHolder callback_holder(bus_->GetOriginTaskRunner(), in CallMethodWithErrorResponse()
208 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, std::move(task)); in CallMethodWithErrorResponse()
226 bus_->GetDBusTaskRunner()->PostTask(FROM_HERE, std::move(task)); in CallMethodWithErrorResponse()
252 bus_->AssertOnOriginThread(); in ConnectToSignal()
254 if (bus_->HasDBusThread()) { in ConnectToSignal()
256 bus_->GetDBusTaskRunner(), FROM_HERE, in ConnectToSignal()
273 bus_->AssertOnOriginThread(); in SetNameOwnerChangedCallback()
280 bus_->AssertOnOriginThread(); in WaitForServiceToBeAvailable()
283 bus_->GetDBusTaskRunner()->PostTask( in WaitForServiceToBeAvailable()
289 bus_->AssertOnDBusThread(); in Detach()
291 if (bus_->is_connected()) in Detach()
292 bus_->RemoveFilterFunction(&ObjectProxy::HandleMessageThunk, this); in Detach()
296 bus_->RemoveMatch(match_rule, error.get()); in Detach()
315 bus_->AssertOnDBusThread(); in StartAsyncMethodCall()
317 if (!bus_->Connect() || !bus_->SetUpAsyncOperations()) { in StartAsyncMethodCall()
323 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, std::move(task)); in StartAsyncMethodCall()
330 bus_->SendWithReply(request_message, &dbus_pending_call, timeout_ms); in StartAsyncMethodCall()
355 bus_->AssertOnDBusThread(); in OnPendingCallIsComplete()
391 bus_->GetOriginTaskRunner()->PostTaskAndReply( in OnPendingCallIsComplete()
410 bus_->AssertOnOriginThread(); in RunResponseOrErrorCallback()
424 bus_->AssertOnDBusThread(); in ConnectToNameOwnerChangedSignal()
426 if (!bus_->Connect() || !bus_->SetUpAsyncOperations()) in ConnectToNameOwnerChangedSignal()
429 bus_->AddFilterFunction(&ObjectProxy::HandleMessageThunk, this); in ConnectToNameOwnerChangedSignal()
456 bus_->AssertOnDBusThread(); in ConnectToSignalInternal()
475 bus_->AssertOnDBusThread(); in WaitForServiceToBeAvailableInternal()
479 bus_->GetOriginTaskRunner()->PostTask( in WaitForServiceToBeAvailableInternal()
488 bus_->GetOriginTaskRunner()->PostTask( in WaitForServiceToBeAvailableInternal()
499 bus_->AssertOnDBusThread(); in HandleMessage()
544 if (bus_->HasDBusThread()) { in HandleMessage()
549 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, in HandleMessage()
571 bus_->AssertOnOriginThread(); in RunMethod()
579 bus_->GetDBusTaskRunner()->PostTask( in RunMethod()
651 bus_->AssertOnDBusThread(); in AddMatchRuleWithCallback()
655 bus_->AddMatch(match_rule, error.get()); in AddMatchRuleWithCallback()
679 bus_->AssertOnDBusThread(); in AddMatchRuleWithoutCallback()
685 bus_->AddMatch(match_rule, error.get()); in AddMatchRuleWithoutCallback()
697 bus_->AssertOnDBusThread(); in UpdateNameOwnerAndBlock()
703 bus_->GetServiceOwnerAndBlock(service_name_, Bus::SUPPRESS_ERRORS); in UpdateNameOwnerAndBlock()
709 bus_->AssertOnDBusThread(); in HandleNameOwnerChanged()
722 bus_->GetOriginTaskRunner()->PostTask( in HandleNameOwnerChanged()
729 bus_->GetOriginTaskRunner()->PostTask( in HandleNameOwnerChanged()
744 bus_->AssertOnOriginThread(); in RunNameOwnerChangedCallback()
751 bus_->AssertOnOriginThread(); in RunWaitForServiceToBeAvailableCallbacks()