| /aosp_15_r20/external/pytorch/torch/cuda/ |
| H A D | _sanitizer.py | 38 StreamId = int variable
225 def _ensure_stream_exists(self, stream: StreamId) -> None:
256 def create_stream(self, stream: StreamId) -> None:
276 def update_seq_num(self, stream: StreamId, seq_num: SeqNum) -> None:
280 def record_state(self, event: EventId, stream: StreamId) -> None:
286 self, state: Dict[StreamId, SeqNum], other: Dict[StreamId, SeqNum]
291 def stream_wait_for_event(self, stream: StreamId, event: EventId) -> None:
307 def all_streams_wait_for_stream(self, stream: StreamId) -> None:
324 self, current_stream: StreamId, seq_num: SeqNum, other_stream: StreamId
346 stream: StreamId,
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/frame/ |
| D | stream_id.rs | 14 pub struct StreamId(u32); struct
21 impl StreamId { implementation
30 pub fn parse(buf: &[u8]) -> (StreamId, bool) { in parse()
69 pub fn next_id(&self) -> Result<StreamId, StreamIdOverflow> { in next_id()
79 impl From<u32> for StreamId { implementation
92 impl PartialEq<u32> for StreamId { implementation
|
| D | go_away.rs | 15 pub fn new(last_stream_id: StreamId, reason: Reason) -> Self { in new()
23 pub fn with_debug_data(last_stream_id: StreamId, reason: Reason, debug_data: Bytes) -> Self { in with_debug_data()
31 pub fn last_stream_id(&self) -> StreamId { in last_stream_id()
|
| D | headers.rs | 117 pub fn new(stream_id: StreamId, pseudo: Pseudo, fields: HeaderMap) -> Self { in new()
131 pub fn trailers(stream_id: StreamId, fields: HeaderMap) -> Self { in trailers()
224 pub fn stream_id(&self) -> StreamId { in stream_id()
352 stream_id: StreamId, in new()
353 promised_id: StreamId, in new()
471 pub fn stream_id(&self) -> StreamId { in stream_id()
475 pub fn promised_id(&self) -> StreamId { in promised_id()
|
| D | reset.rs | 12 pub fn new(stream_id: StreamId, error: Reason) -> Reset { in new()
19 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| D | window_update.rs | 14 pub fn new(stream_id: StreamId, size_increment: u32) -> WindowUpdate { in new()
21 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| D | priority.rs | 47 pub fn new(dependency_id: StreamId, weight: u8, is_exclusive: bool) -> Self { in new()
69 pub fn dependency_id(&self) -> StreamId { in dependency_id()
|
| D | data.rs | 28 pub fn new(stream_id: StreamId, payload: T) -> Self { in new()
42 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| D | head.rs | 50 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/video/decoder/ |
| H A D | mod.rs | 41 type StreamId = u32; typedef
136 stream_id: StreamId, in dequeue_frame_buffer()
204 stream_id: StreamId, in new()
477 stream_id: StreamId, in create_stream()
495 fn destroy_stream(&mut self, stream_id: StreamId) { in destroy_stream()
505 stream_id: StreamId, in create_session()
533 stream_id: StreamId, in create_resource()
623 stream_id: StreamId, in destroy_all_resources()
642 stream_id: StreamId, in queue_input_resource()
684 stream_id: StreamId, in queue_output_resource()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/ |
| D | share.rs | 112 pub struct StreamId(u32); struct
380 pub fn stream_id(&self) -> StreamId { in stream_id()
387 impl StreamId { implementation
458 pub fn stream_id(&self) -> StreamId { in stream_id()
500 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| D | server.rs | 1184 pub fn stream_id(&self) -> crate::StreamId { in stream_id()
1256 pub fn stream_id(&self) -> crate::StreamId { in stream_id()
1419 id: StreamId, in convert_send_message()
1448 stream_id: StreamId, in convert_push_message()
1449 promised_id: StreamId, in convert_push_message()
1511 stream_id: StreamId, in convert_poll_message()
|
| D | client.rs | 1465 pub fn stream_id(&self) -> crate::StreamId { in stream_id()
1560 pub fn stream_id(&self) -> crate::StreamId { in stream_id()
1569 id: StreamId, in convert_send_message()
1650 stream_id: StreamId, in convert_poll_message()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/streams/ |
| D | recv.rs | 119 pub fn last_processed_id(&self) -> StreamId { in last_processed_id()
128 id: StreamId, in open()
131 ) -> Result<Option<StreamId>, Error> { in open()
831 pub fn go_away(&mut self, last_processed_id: StreamId) { in go_away()
851 pub fn max_stream_id(&self) -> StreamId { in max_stream_id()
855 pub fn next_stream_id(&self) -> Result<StreamId, Error> { in next_stream_id()
873 pub(super) fn maybe_reset_next_stream_id(&mut self, id: StreamId) { in maybe_reset_next_stream_id()
|
| D | send.rs | 68 pub fn open(&mut self) -> Result<StreamId, UserError> { in open()
74 pub fn reserve_local(&mut self) -> Result<StreamId, UserError> { in reserve_local()
557 pub fn ensure_next_stream_id(&self) -> Result<StreamId, UserError> { in ensure_next_stream_id()
572 pub(super) fn maybe_reset_next_stream_id(&mut self, id: StreamId) { in maybe_reset_next_stream_id()
|
| D | streams.rs | 352 pub fn handle_error(&mut self, err: proto::Error) -> StreamId { in handle_error()
362 pub fn last_processed_id(&self) -> StreamId { in last_processed_id()
381 pub fn send_reset(&mut self, id: StreamId, reason: Reason) { in send_reset()
386 pub fn send_go_away(&mut self, last_processed_id: StreamId) { in send_go_away()
672 fn handle_error<B>(&mut self, send_buffer: &SendBuffer<B>, err: proto::Error) -> StreamId { in handle_error()
897 fn send_reset<B>(&mut self, send_buffer: &SendBuffer<B>, id: StreamId, reason: Reason) { in send_reset()
1268 pub fn stream_id(&self) -> StreamId { in stream_id()
1387 pub fn stream_id(&self) -> StreamId { in stream_id()
|
| D | store.rs | 105 pub fn insert(&mut self, id: StreamId, val: Stream) -> Ptr { in insert()
393 pub fn remove(self) -> StreamId { in remove()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/ |
| D | peer.rs | 22 stream_id: StreamId, in convert_poll_message()
64 stream_id: StreamId, in convert_poll_message()
76 pub fn ensure_can_open(&self, id: StreamId, mode: Open) -> Result<(), Error> { in ensure_can_open()
|
| D | error.rs | 35 pub(crate) fn library_reset(stream_id: StreamId, reason: Reason) -> Self { in library_reset()
47 pub(crate) fn remote_reset(stream_id: StreamId, reason: Reason) -> Self { in remote_reset()
|
| /aosp_15_r20/external/pytorch/test/ |
| H A D | test_cuda_sanitizer.py | 139 stream: StreamId,
158 stream: StreamId,
167 stream: StreamId,
|
| /aosp_15_r20/prebuilts/gcc/linux-x86/host/x86_64-w64-mingw32-4.8/x86_64-w64-mingw32/include/ |
| D | sbe.h | 12 DWORD StreamId; member
|
| /aosp_15_r20/external/pytorch/c10/core/ |
| H A D | Stream.h | 22 using StreamId = int64_t; variable
|
| /aosp_15_r20/frameworks/av/services/camera/libcameraservice/device3/ |
| H A D | Camera3BufferManager.h | 223 typedef int StreamId; typedef
|
| /aosp_15_r20/external/cronet/net/test/embedded_test_server/ |
| H A D | http2_connection.h | 26 using StreamId = http2::adapter::Http2StreamId; variable
|
| /aosp_15_r20/external/googleapis/google/devtools/build/v1/ |
| H A D | build_events.proto | 149 message StreamId { message
|