/packages/modules/DnsResolver/doh/connection/ |
D | driver.rs | 411 let stream_id = in handle_request() localVariable 429 stream_id, in handle_request() 431 self.driver.quiche_conn.stream_capacity(stream_id) in handle_request() 433 self.requests.insert(stream_id, request); in handle_request() 437 async fn recv_body(&mut self, stream_id: u64) -> Result<()> { in recv_body() 439 if let Some(stream) = self.streams.get_mut(&stream_id) { in recv_body() 445 stream_id, in recv_body() 461 recvd, stream_id, self.driver.net_id in recv_body() 467 warn!("Received body for untracked stream ID {}", stream_id); in recv_body() 488 Ok((stream_id, event)) => self.process_h3_event(stream_id, event).await?, in flush_h3() [all …]
|
/packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
D | client.rs | 92 Ok((stream_id, quiche::h3::Event::Headers { list, has_body })) => { in handle_http3_request() 95 list, stream_id, has_body in handle_http3_request() 104 self.in_flight_queries.insert([decoded[0], decoded[1]], stream_id); in handle_http3_request() 108 Ok((stream_id, quiche::h3::Event::Data)) => { in handle_http3_request() 111 if let Ok(read) = h3_conn.recv_body(&mut self.conn, stream_id, &mut buf) { in handle_http3_request() 112 warn!("Got {} bytes of response data on stream {}", read, stream_id); in handle_http3_request() 148 let stream_id = self in handle_backend_message() localVariable 154 if send_reset_stream == stream_id { in handle_backend_message() 156 self.conn.stream_shutdown(stream_id, quiche::Shutdown::Write, 99)?; in handle_backend_message() 157 info!("Preparing RESET_STREAM on stream {}", stream_id); in handle_backend_message() [all …]
|
D | ffi.rs | 172 pub extern "C" fn frontend_set_reset_stream_id(doh: &mut DohFrontend, stream_id: u64) -> bool { in frontend_set_reset_stream_id() 173 doh.set_reset_stream_id(stream_id).or_else(logging_and_return_err).is_ok() in frontend_set_reset_stream_id()
|
/packages/modules/Bluetooth/floss/pandora/server/ |
D | rfcomm.py | 124 stream_id = self.new_stream_id() 126 self.streams[stream_id] = stream 130 return rfcomm_pb2.ConnectionResponse(connection=rfcomm_pb2.RfcommConnection(id=stream_id)) 135 stream_id = request.connection.id 136 if stream_id in self.streams: 137 stream = self.streams[stream_id] 141 del self.streams[stream_id] 145 logging.error('No stream found with ID %s', stream_id) 295 stream_id = self.new_stream_id() 297 self.streams[stream_id] = stream [all …]
|
/packages/services/Car/cpp/computepipe/runner/graph/proto/ |
D | GrpcPrebuiltGraphService.proto | 30 optional int32 stream_id = 1; field 34 optional int32 stream_id = 1; field 56 optional int32 stream_id = 3; field
|
/packages/services/Car/cpp/computepipe/runner/stream_manager/ |
D | Factory.cpp | 36 std::make_unique<SemanticManager>(config.stream_name(), config.stream_id(), config.type()); in buildSemanticManager() 48 std::make_unique<PixelStreamManager>(config.stream_name(), config.stream_id()); in buildPixelStreamManager()
|
/packages/services/Car/cpp/computepipe/runner/input_manager/ |
D | EvsInputManager.cpp | 85 std::make_unique<AnalyzeCallback>(mInputConfig.input_stream(i).stream_id()); in initializeCameras() 90 int streamId = mInputConfig.input_stream(i).stream_id(); in initializeCameras()
|
D | VideoDecoder.cpp | 324 mEngine->dispatchInputFrame(mConfig.stream_id(), frameTimeMicros, inputFrame); in readDecodedFrame() 342 mEngine->dispatchInputFrame(mConfig.stream_id(), 0, inputFrame); in sendEosFlag()
|
/packages/services/Car/cpp/computepipe/proto/ |
D | OutputConfig.proto | 16 optional int32 stream_id = 3; field
|
D | ConfigurationCommand.proto | 20 optional int32 stream_id = 1; field
|
D | InputConfig.proto | 71 optional int32 stream_id = 9; field
|
/packages/services/Car/cpp/computepipe/tests/runner/graph/includes/ |
D | GrpcGraphServerImpl.h | 129 for (int i = 0; i < request->stream_id(); i++) { in ObserveOutputStream() 131 if (request->stream_id() % 2 == 0) { in ObserveOutputStream()
|
/packages/services/Car/cpp/computepipe/tests/runner/client_interface/ |
D | ClientInterfaceTest.cc | 165 EXPECT_EQ(command.set_output_stream().stream_id(), 0); in TEST_F() 210 EXPECT_EQ(command.set_output_stream().stream_id(), 0); in TEST_F() 380 EXPECT_EQ(command.set_output_stream().stream_id(), 0); in TEST_F()
|
/packages/modules/DnsResolver/doh/tests/doh_frontend/include/ |
D | lib.rs.h | 109 bool frontend_set_reset_stream_id(DohFrontend* doh, uint64_t stream_id);
|
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/volume/ |
D | CarAudioZoneVolumeAdapter.java | 56 vh.id = convertView.findViewById(R.id.stream_id); in getView()
|
/packages/services/Car/cpp/computepipe/runner/client_interface/ |
D | PipeOptionsConverter.cpp | 178 aidlConfig.outputId = proto.stream_id(); in ConvertOutputConfigProto()
|
/packages/services/Car/cpp/computepipe/runner/engine/ |
D | DefaultEngine.cpp | 102 command.set_output_stream().stream_id(), in processClientConfigUpdate() 517 if (optionIt.stream_id() == streamId) { in populateStreamManagers()
|