Lines Matching refs:req
77 protos::InitializeConnectionRequest req;
78 req.set_producer_name(name_);
79 producer_port_.InitializeConnection(req, std::move(on_init));
112 const auto& req = cmd.start_data_source();
113 const DataSourceInstanceID dsid = req.new_instance_id();
115 cfg.FromProto(req.config());
166 protos::RegisterDataSourceRequest req;
167 descriptor.ToProto(req.mutable_data_source_descriptor());
174 producer_port_.RegisterDataSource(req, std::move(async_response));
184 protos::UnregisterDataSourceRequest req;
185 req.set_data_source_name(name);
187 req, ipc::Deferred<protos::UnregisterDataSourceResponse>());
190 void ProducerIPCClientImpl::CommitData(const CommitDataRequest& req,
198 req.ToProto(&proto_req);
