Home
last modified time | relevance | path

Searched refs:stream_id (Results 1 – 17 of 17) sorted by relevance

/packages/modules/DnsResolver/doh/connection/
Ddriver.rs411 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/
Dclient.rs92 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 …]
Dffi.rs172 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/
Drfcomm.py124 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/
DGrpcPrebuiltGraphService.proto30 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/
DFactory.cpp36 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/
DEvsInputManager.cpp85 std::make_unique<AnalyzeCallback>(mInputConfig.input_stream(i).stream_id()); in initializeCameras()
90 int streamId = mInputConfig.input_stream(i).stream_id(); in initializeCameras()
DVideoDecoder.cpp324 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/
DOutputConfig.proto16 optional int32 stream_id = 3; field
DConfigurationCommand.proto20 optional int32 stream_id = 1; field
DInputConfig.proto71 optional int32 stream_id = 9; field
/packages/services/Car/cpp/computepipe/tests/runner/graph/includes/
DGrpcGraphServerImpl.h129 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/
DClientInterfaceTest.cc165 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/
Dlib.rs.h109 bool frontend_set_reset_stream_id(DohFrontend* doh, uint64_t stream_id);
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/volume/
DCarAudioZoneVolumeAdapter.java56 vh.id = convertView.findViewById(R.id.stream_id); in getView()
/packages/services/Car/cpp/computepipe/runner/client_interface/
DPipeOptionsConverter.cpp178 aidlConfig.outputId = proto.stream_id(); in ConvertOutputConfigProto()
/packages/services/Car/cpp/computepipe/runner/engine/
DDefaultEngine.cpp102 command.set_output_stream().stream_id(), in processClientConfigUpdate()
517 if (optionIt.stream_id() == streamId) { in populateStreamManagers()