Searched refs:connector_ (Results 1 – 10 of 10) sorted by relevance
38 return this.router_.connector_.accept(message);49 this.connector_ = new internal.Connector(handle);51 this.connector_.setIncomingReceiver({54 this.connector_.setErrorHandler({64 new internal.PipeControlMessageProxy(this.connector_);136 this.connector_.resumeIncomingMethodCallProcessing();142 this.connector_.handleError(true, true);226 this.connector_.pauseIncomingMethodCallProcessing();236 this.connector_.close();300 this.connector_.resumeIncomingMethodCallProcessing();
132 return router_->connector_.Accept(message); in SendMessage()321 connector_(std::move(message_pipe), in MultiplexRouter()326 control_message_proxy_(&connector_) { in MultiplexRouter()338 connector_.AllowWokenUpBySyncWatchOnSameThread(); in MultiplexRouter()340 connector_.set_incoming_receiver(&filters_); in MultiplexRouter()341 connector_.set_connection_error_handler(base::Bind( in MultiplexRouter()371 connector_.SetWatcherHeapProfilerTag(name); in SetMasterInterfaceName()491 connector_.RaiseError(); in RaiseError()500 return connector_.PrefersSerializedMessages(); in PrefersSerializedMessages()505 connector_.CloseMessagePipe(); in CloseMessagePipe()[all …]
123 return connector_.PassMessagePipe(); in PassMessagePipe()130 return connector_.WaitForIncomingMessage(deadline); in WaitForIncomingMessage()148 return connector_.is_valid(); in is_valid()154 return connector_.handle(); in handle()250 Connector connector_; variable
59 const base::WeakPtr<Connector> connector_; member in mojo::Connector::ActiveDispatchTracker117 : connector_(connector), nesting_observer_(connector_->nesting_observer_) { in ActiveDispatchTracker()136 if (connector_ && connector_->handle_watcher_) in NotifyBeginNesting()137 connector_->handle_watcher_->ArmOrNotify(); in NotifyBeginNesting()
127 connector_.reset(new mojo::Connector( in Bind()130 connector_->set_incoming_receiver(&filters_); in Bind()131 connector_->set_connection_error_handler( in Bind()134 connector_->set_enforce_errors_from_incoming_receiver(false); in Bind()135 connector_->SetWatcherHeapProfilerTag("IPC Channel"); in Bind()191 connector_->CloseMessagePipe(); in ShutDown()193 connector_.reset(); in ShutDown()628 DCHECK(!connector_); in ~ChannelAssociatedGroupController()655 if (!connector_ || paused_) { in SendMessage()662 return connector_->Accept(message); in SendMessage()[all …]
226 connector_ = drm_->GetConnectorForDisplay(display); in Init()227 if (!connector_) { in Init()248 return SetActiveConfig(connector_->get_preferred_mode_id()); in ChosePreferredConfig()282 DrmMode const &mode = connector_->active_mode(); in GetActiveConfig()346 auto mode = std::find_if(connector_->modes().begin(), in GetDisplayAttribute()347 connector_->modes().end(), in GetDisplayAttribute()351 if (mode == connector_->modes().end()) { in GetDisplayAttribute()357 uint32_t mm_width = connector_->mm_width(); in GetDisplayAttribute()358 uint32_t mm_height = connector_->mm_height(); in GetDisplayAttribute()395 int ret = connector_->UpdateModes(); in GetDisplayConfigs()[all …]
204 DrmConnector *connector_ = NULL; variable
56 : connector_(connector) {} in ConnectorDeletingMessageAccumulator()59 delete *connector_; in Accept()60 *connector_ = nullptr; in Accept()65 Connector** connector_; member in mojo::test::__anon6aa2695f0111::ConnectorDeletingMessageAccumulator71 : connector_(connector), number_of_calls_(0) {} in ReentrantMessageAccumulator()78 return connector_->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE); in Accept()86 Connector* connector_; member in mojo::test::__anon6aa2695f0111::ReentrantMessageAccumulator
261 connector_(std::move(handle), in TestMessageReceiver()264 connector_.set_enforce_errors_from_incoming_receiver(false); in TestMessageReceiver()269 return connector_.Accept(message); in Accept()274 mojo::Connector connector_; member in mojo::test::__anonb95b219f0111::ValidationIntegrationTest::TestMessageReceiver
114 this.router_.connector_.handle_, this.version);115 this.router_.connector_.handle_ = null;257 var result = new mojo.InterfaceRequest(this.router_.connector_.handle_);258 this.router_.connector_.handle_ = null;