| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 808 struct op_state* stream_state = &s->state; in op_can_be_run() local
814 bool is_canceled_or_failed = stream_state->state_op_done[OP_CANCEL_ERROR] || in op_can_be_run()
815 stream_state->state_callback_received[OP_FAILED]; in op_can_be_run()
835 stream_state->state_op_done[OP_RECV_INITIAL_METADATA]) { in op_can_be_run()
844 stream_state->state_op_done[OP_RECV_TRAILING_METADATA]) { in op_can_be_run()
854 !(stream_state->state_callback_received[OP_FAILED] || in op_can_be_run()
855 stream_state->state_callback_received[OP_CANCELED] || in op_can_be_run()
856 stream_state->state_callback_received[OP_SUCCEEDED] || in op_can_be_run()
857 !stream_state->state_op_done[OP_SEND_INITIAL_METADATA])) { in op_can_be_run()
863 if (stream_state->state_op_done[OP_SEND_INITIAL_METADATA]) result = false; in op_can_be_run()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 826 struct op_state* stream_state = &s->state; in op_can_be_run() local
832 bool is_canceled_or_failed = stream_state->state_op_done[OP_CANCEL_ERROR] || in op_can_be_run()
833 stream_state->state_callback_received[OP_FAILED]; in op_can_be_run()
853 stream_state->state_op_done[OP_RECV_INITIAL_METADATA]) { in op_can_be_run()
862 stream_state->state_op_done[OP_RECV_TRAILING_METADATA]) { in op_can_be_run()
872 !(stream_state->state_callback_received[OP_FAILED] || in op_can_be_run()
873 stream_state->state_callback_received[OP_CANCELED] || in op_can_be_run()
874 stream_state->state_callback_received[OP_SUCCEEDED] || in op_can_be_run()
875 !stream_state->state_op_done[OP_SEND_INITIAL_METADATA])) { in op_can_be_run()
881 if (stream_state->state_op_done[OP_SEND_INITIAL_METADATA]) result = false; in op_can_be_run()
[all …]
|
| /external/webrtc/test/fuzzers/utils/ |
| D | rtp_replayer.cc | 35 auto stream_state = std::make_unique<StreamState>(); in Replay() local
37 ReadConfigFromFile(replay_config_filepath, &(stream_state->transport)); in Replay()
38 return Replay(std::move(stream_state), std::move(receive_stream_configs), in Replay()
43 std::unique_ptr<StreamState> stream_state, in Replay() argument
71 SetupVideoStreams(&receive_stream_configs, stream_state.get(), call.get()); in Replay()
74 for (const auto& receive_stream : stream_state->receive_streams) { in Replay()
80 for (const auto& receive_stream : stream_state->receive_streams) { in Replay()
108 StreamState* stream_state, in SetupVideoStreams() argument
110 stream_state->decoder_factory = std::make_unique<InternalDecoderFactory>(); in SetupVideoStreams()
116 decoder.decoder_factory = stream_state->decoder_factory.get(); in SetupVideoStreams()
[all …]
|
| D | rtp_replayer.h | 59 std::unique_ptr<StreamState> stream_state,
73 StreamState* stream_state,
|
| /external/webrtc/rtc_tools/ |
| D | video_replay.cc | 273 std::unique_ptr<StreamState> stream_state; in Replay() local
276 stream_state = ConfigureFromFlags(rtp_dump_path, call.get()); in Replay()
278 stream_state = ConfigureFromFile(replay_config_path, call.get()); in Replay()
280 if (stream_state == nullptr) { in Replay()
290 for (const auto& receive_stream : stream_state->receive_streams) { in Replay()
294 for (const auto& receive_stream : stream_state->receive_streams) { in Replay()
314 auto stream_state = std::make_unique<StreamState>(); in ConfigureFromFile() local
328 stream_state->decoder_factory = std::make_unique<InternalDecoderFactory>(); in ConfigureFromFile()
333 ParseVideoReceiveStreamJsonConfig(&(stream_state->transport), json); in ConfigureFromFile()
338 decoder.decoder_factory = stream_state->decoder_factory.get(); in ConfigureFromFile()
[all …]
|
| /external/flac/src/libFLAC/ |
| D | ogg_decoder_aspect.c | 53 if(ogg_stream_init(&aspect->stream_state, aspect->serial_number) != 0) in FLAC__ogg_decoder_aspect_init()
73 (void)ogg_stream_clear(&aspect->stream_state); in FLAC__ogg_decoder_aspect_finish()
89 (void)ogg_stream_reset(&aspect->stream_state); in FLAC__ogg_decoder_aspect_flush()
158 const int ret = ogg_stream_packetout(&aspect->stream_state, &aspect->working_packet); in FLAC__ogg_decoder_aspect_read_callback_wrapper()
200 … aspect->stream_state.serialno = aspect->serial_number = ogg_page_serialno(&aspect->working_page); in FLAC__ogg_decoder_aspect_read_callback_wrapper()
203 if(ogg_stream_pagein(&aspect->stream_state, &aspect->working_page) == 0) { in FLAC__ogg_decoder_aspect_read_callback_wrapper()
|
| D | ogg_encoder_aspect.c | 54 if(ogg_stream_init(&aspect->stream_state, aspect->serial_number) != 0) in FLAC__ogg_encoder_aspect_init()
66 (void)ogg_stream_clear(&aspect->stream_state); in FLAC__ogg_encoder_aspect_finish()
192 if(ogg_stream_packetin(&aspect->stream_state, &packet) != 0) in FLAC__ogg_encoder_aspect_write_callback_wrapper()
197 while(ogg_stream_flush(&aspect->stream_state, &aspect->page) != 0) { in FLAC__ogg_encoder_aspect_write_callback_wrapper()
205 while(ogg_stream_pageout(&aspect->stream_state, &aspect->page) != 0) { in FLAC__ogg_encoder_aspect_write_callback_wrapper()
|
| /external/webrtc/test/fuzzers/ |
| D | vp9_replay_fuzzer.cc | 21 auto stream_state = std::make_unique<test::RtpReplayer::StreamState>(); in FuzzOneInput() local
22 VideoReceiveStream::Config vp9_config(&(stream_state->transport)); in FuzzOneInput()
38 test::RtpReplayer::Replay(std::move(stream_state), std::move(replay_configs), in FuzzOneInput()
|
| D | vp8_replay_fuzzer.cc | 21 auto stream_state = std::make_unique<test::RtpReplayer::StreamState>(); in FuzzOneInput() local
22 VideoReceiveStream::Config vp8_config(&(stream_state->transport)); in FuzzOneInput()
39 test::RtpReplayer::Replay(std::move(stream_state), std::move(replay_configs), in FuzzOneInput()
|
| /external/libvpx/libvpx/ |
| D | vpxenc.c | 615 struct stream_state { struct
617 struct stream_state *next; argument
768 static struct stream_state *new_stream(struct VpxEncoderConfig *global, in new_stream()
769 struct stream_state *prev) { in new_stream()
770 struct stream_state *stream; in new_stream()
826 struct stream_state *stream, char **argv) { in parse_stream_params()
1013 struct stream_state *stream; \
1019 static void validate_stream_config(const struct stream_state *stream, in validate_stream_config()
1021 const struct stream_state *streami; in validate_stream_config()
1075 static void set_stream_dimensions(struct stream_state *stream, unsigned int w, in set_stream_dimensions()
[all …]
|
| /external/mesa3d/src/gallium/drivers/iris/ |
| D | iris_blorp.c | 49 stream_state(struct iris_batch *batch, in stream_state() function
138 return stream_state(batch, ice->state.dynamic_uploader, in blorp_alloc_dynamic_state()
159 surface_maps[i] = stream_state(batch, ice->state.surface_uploader, in blorp_alloc_binding_table()
180 void *map = stream_state(batch, ice->ctx.stream_uploader, size, 64, in blorp_alloc_vertex_buffer()
|
| D | iris_state.c | 330 stream_state(struct iris_batch *batch, in stream_state() function
365 stream_state(batch, uploader, out_res, size, alignment, &offset); in emit_state()
823 stream_state(batch, ice->state.dynamic_uploader, &tmp, in iris_upload_slice_hashing_state()
5498 stream_state(batch, ice->state.dynamic_uploader, in iris_upload_dirty_render_state()
5529 stream_state(batch, ice->state.dynamic_uploader, in iris_upload_dirty_render_state()
5620 stream_state(batch, ice->state.dynamic_uploader, in iris_upload_dirty_render_state()
5646 stream_state(batch, ice->state.dynamic_uploader, in iris_upload_dirty_render_state()
6766 stream_state(batch, ice->state.dynamic_uploader, in iris_upload_gpgpu_walker()
|
| /external/libaom/libaom/apps/ |
| D | aomenc.c | 1100 struct stream_state { struct
1102 struct stream_state *next; argument
1319 static struct stream_state *new_stream(struct AvxEncoderConfig *global, in new_stream()
1320 struct stream_state *prev) { in new_stream()
1321 struct stream_state *stream; in new_stream()
1413 struct stream_state *stream, char **argv) { in parse_stream_params()
1629 for (struct stream_state *iterator = list; iterator; \
1632 static void validate_stream_config(const struct stream_state *stream, in validate_stream_config()
1634 const struct stream_state *streami; in validate_stream_config()
1675 static void set_stream_dimensions(struct stream_state *stream, unsigned int w, in set_stream_dimensions()
[all …]
|
| /external/autotest/client/common_lib/cros/manual/ |
| D | audio_helper.py | 86 stream_state = []
90 stream_state = dut.run(cmd, ignore_status=True).stdout.split()
93 return stream_state
|
| /external/flac/src/libFLAC/include/private/ |
| D | ogg_encoder_aspect.h | 47 ogg_stream_state stream_state; member
|
| D | ogg_decoder_aspect.h | 47 ogg_stream_state stream_state; member
|
| /external/webrtc/sdk/android/src/jni/audio_device/ |
| D | aaudio_wrapper.h | 100 aaudio_stream_state_t stream_state() const;
|
| D | aaudio_wrapper.cc | 344 aaudio_stream_state_t AAudioWrapper::stream_state() const { in stream_state() function in webrtc::jni::AAudioWrapper
427 << AAudio_convertStreamStateToText(stream_state()); in LogStreamState()
|
| D | aaudio_recorder.cc | 150 if (aaudio_.stream_state() == AAUDIO_STREAM_STATE_DISCONNECTED) { in OnErrorCallback()
|
| D | aaudio_player.cc | 158 if (aaudio_.stream_state() == AAUDIO_STREAM_STATE_DISCONNECTED) { in OnErrorCallback()
|
| /external/webrtc/modules/audio_device/android/ |
| D | aaudio_wrapper.h | 100 aaudio_stream_state_t stream_state() const;
|
| D | aaudio_wrapper.cc | 344 aaudio_stream_state_t AAudioWrapper::stream_state() const { in stream_state() function in webrtc::AAudioWrapper
427 << AAudio_convertStreamStateToText(stream_state()); in LogStreamState()
|
| D | aaudio_player.cc | 142 if (aaudio_.stream_state() == AAUDIO_STREAM_STATE_DISCONNECTED) { in OnErrorCallback()
|
| D | aaudio_recorder.cc | 138 if (aaudio_.stream_state() == AAUDIO_STREAM_STATE_DISCONNECTED) { in OnErrorCallback()
|
| /external/webrtc/test/pc/e2e/analyzer/video/ |
| D | default_video_quality_analyzer.cc | 525 const StreamState& stream_state = state_entry.second; in Stop() local
527 if (i == static_cast<size_t>(stream_state.owner())) { in Stop()
531 InternalStatsKey stats_key(stream_index, stream_state.owner(), i); in Stop()
538 if (stream_state.last_rendered_frame_time(i)) { in Stop()
540 stream_state.last_rendered_frame_time(i).value().ms() - in Stop()
|