| /external/libchrome/mojo/public/js/lib/ |
| D | router.js | 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();
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 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 …]
|
| D | multiplex_router.h | 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
|
| D | connector.cc | 59 const base::WeakPtr<Connector> connector_; member in mojo::Connector::ActiveDispatchTracker
117 : connector_(connector), nesting_observer_(connector_->nesting_observer_) { in ActiveDispatchTracker()
136 if (connector_ && connector_->handle_watcher_) in NotifyBeginNesting()
137 connector_->handle_watcher_->ArmOrNotify(); in NotifyBeginNesting()
|
| /external/drm_hwcomposer/ |
| D | DrmHwcTwo.cpp | 139 << "- Display on: " << connector_->name() << "\n" in Dump()
267 connector_ = drm_->GetConnectorForDisplay(display); in Init()
268 if (!connector_) { in Init()
295 return SetActiveConfig(connector_->get_preferred_mode_id()); in ChosePreferredConfig()
336 DrmMode const &mode = connector_->active_mode(); in GetActiveConfig()
400 auto mode = std::find_if(connector_->modes().begin(), in GetDisplayAttribute()
401 connector_->modes().end(), in GetDisplayAttribute()
405 if (mode == connector_->modes().end()) { in GetDisplayAttribute()
411 uint32_t mm_width = connector_->mm_width(); in GetDisplayAttribute()
412 uint32_t mm_height = connector_->mm_height(); in GetDisplayAttribute()
[all …]
|
| D | DrmHwcTwo.h | 293 return connector_; in connector()
329 DrmConnector *connector_ = NULL; variable
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_bootstrap.cc | 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 …]
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | connector_unittest.cc | 56 : connector_(connector) {} in ConnectorDeletingMessageAccumulator()
59 delete *connector_; in Accept()
60 *connector_ = nullptr; in Accept()
65 Connector** connector_; member in mojo::test::__anon75a8b6360111::ConnectorDeletingMessageAccumulator
71 : connector_(connector), number_of_calls_(0) {} in ReentrantMessageAccumulator()
78 return connector_->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE); in Accept()
86 Connector* connector_; member in mojo::test::__anon75a8b6360111::ReentrantMessageAccumulator
|
| D | validation_unittest.cc | 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::__anon252b09560111::ValidationIntegrationTest::TestMessageReceiver
|
| /external/libchrome/mojo/public/js/ |
| D | bindings.js | 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;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 85 RefCountedPtr<grpc_security_connector> connector_; member in grpc_core::__anon4738b3f50111::SecurityHandshaker
113 connector_(connector->Ref(DEBUG_LOCATION, "handshake")), in SecurityHandshaker()
143 connector_.reset(DEBUG_LOCATION, "handshake"); in ~SecurityHandshaker()
280 connector_->check_peer(peer, args_->endpoint, &auth_context_, in CheckPeerLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 654 connector_(std::move(connector)), in Subchannel()
705 connector_.reset(); in ~Subchannel()
1043 connector_->Connect(args, &connecting_result_, &on_connecting_finished_); in ContinueConnectingLocked()
1136 connector_.reset(); in Disconnect()
|
| D | subchannel.h | 395 OrphanablePtr<SubchannelConnector> connector_; variable
|