Home
last modified time | relevance | path

Searched refs:stream_state (Results 1 – 25 of 1253) sorted by relevance

12345678910>>...51

/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/cronet/transport/
H A Dcronet_transport.cc1225 &stream_state->rs.length_field, &stream_state->rs.compressed); in execute_stream_op()
1232 stream_state->rs.remaining_bytes = stream_state->rs.length_field; in execute_stream_op()
1252 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1263 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1278 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1306 if (stream_state->rs.compressed) { in execute_stream_op()
1309 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1311 stream_state->rs.sbs.get()); in execute_stream_op()
1319 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1362 if (!stream_state->cancel_error) { in execute_stream_op()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/transport/cronet/transport/
H A Dcronet_transport.cc1195 &stream_state->rs.length_field, &stream_state->rs.compressed); in execute_stream_op()
1202 stream_state->rs.remaining_bytes = stream_state->rs.length_field; in execute_stream_op()
1222 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1232 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1247 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1275 if (stream_state->rs.compressed) { in execute_stream_op()
1278 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1280 stream_state->rs.sbs.get()); in execute_stream_op()
1287 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
1329 if (!stream_state->cancel_error) { in execute_stream_op()
[all …]
/dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/cronet/transport/
H A Dcronet_transport.cc879 } else if (!stream_state in op_can_be_run()
883 } else if (!stream_state in op_can_be_run()
894 } else if (!stream_state in op_can_be_run()
903 } else if (!stream_state in op_can_be_run()
917 } else if (!stream_state in op_can_be_run()
929 } else if (!stream_state in op_can_be_run()
1219 &stream_state->rs.length_field, &stream_state->rs.compressed); in execute_stream_op()
1226 stream_state->rs.remaining_bytes = stream_state->rs.length_field; in execute_stream_op()
1245 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1264 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
[all …]
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/cronet/transport/
H A Dcronet_transport.cc880 } else if (!stream_state in op_can_be_run()
884 } else if (!stream_state in op_can_be_run()
895 } else if (!stream_state in op_can_be_run()
904 } else if (!stream_state in op_can_be_run()
918 } else if (!stream_state in op_can_be_run()
930 } else if (!stream_state in op_can_be_run()
1220 &stream_state->rs.length_field, &stream_state->rs.compressed); in execute_stream_op()
1227 stream_state->rs.remaining_bytes = stream_state->rs.length_field; in execute_stream_op()
1246 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1265 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/cronet/transport/
H A Dcronet_transport.cc886 } else if (!stream_state in op_can_be_run()
890 } else if (!stream_state in op_can_be_run()
901 } else if (!stream_state in op_can_be_run()
910 } else if (!stream_state in op_can_be_run()
924 } else if (!stream_state in op_can_be_run()
936 } else if (!stream_state in op_can_be_run()
1227 &stream_state->rs.length_field, &stream_state->rs.compressed); in execute_stream_op()
1234 stream_state->rs.remaining_bytes = stream_state->rs.length_field; in execute_stream_op()
1253 stream_state->rs.sbs.Init(&stream_state->rs.read_slice_buffer, flags); in execute_stream_op()
1272 stream_state->rs.read_buffer = stream_state->rs.grpc_header_bytes; in execute_stream_op()
[all …]
/dports/emulators/yuzu/yuzu-0b47f7a46/externals/cubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/www/firefox-esr/firefox-91.8.0/media/libcubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/emulators/citra-qt5/citra-ac98458e0/externals/cubeb/src/
H A Dcubeb_aaudio.cpp93 enum class stream_state { enum
110 std::atomic<stream_state> state{stream_state::INIT};
177 case stream_state::DRAINING: in waiting_state()
191 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
207 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1043 case stream_state::ERROR: in aaudio_stream_start()
1046 case stream_state::INIT: in aaudio_stream_start()
1144 case stream_state::ERROR: in aaudio_stream_stop()
1147 case stream_state::INIT: in aaudio_stream_stop()
1237 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/emulators/citra/citra-ac98458e0/externals/cubeb/src/
H A Dcubeb_aaudio.cpp93 enum class stream_state { enum
110 std::atomic<stream_state> state{stream_state::INIT};
177 case stream_state::DRAINING: in waiting_state()
191 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
207 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1043 case stream_state::ERROR: in aaudio_stream_start()
1046 case stream_state::INIT: in aaudio_stream_start()
1144 case stream_state::ERROR: in aaudio_stream_stop()
1147 case stream_state::INIT: in aaudio_stream_stop()
1237 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/www/firefox/firefox-99.0/third_party/rust/cubeb-sys/libcubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/www/firefox/firefox-99.0/media/libcubeb/src/
H A Dcubeb_aaudio.cpp93 enum class stream_state { enum
110 std::atomic<stream_state> state{stream_state::INIT};
177 case stream_state::DRAINING: in waiting_state()
191 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
207 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1043 case stream_state::ERROR: in aaudio_stream_start()
1046 case stream_state::INIT: in aaudio_stream_start()
1144 case stream_state::ERROR: in aaudio_stream_stop()
1147 case stream_state::INIT: in aaudio_stream_stop()
1237 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/cubeb-sys/libcubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/www/firefox-esr/firefox-91.8.0/third_party/rust/cubeb-sys/libcubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/media/libcubeb/src/
H A Dcubeb_aaudio.cpp92 enum class stream_state { enum
109 std::atomic<stream_state> state{stream_state::INIT};
176 case stream_state::DRAINING: in waiting_state()
190 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
206 if (old_state == stream_state::INIT || old_state == stream_state::STARTED || in update_state()
1040 case stream_state::ERROR: in aaudio_stream_start()
1043 case stream_state::INIT: in aaudio_stream_start()
1141 case stream_state::ERROR: in aaudio_stream_stop()
1144 case stream_state::INIT: in aaudio_stream_stop()
1234 case stream_state::ERROR: in aaudio_stream_get_position()
[all …]
/dports/net/sems/sems-f89581a/core/
H A DAmRtpMuxStream.cpp271 MuxStreamState& stream_state = streamstates[stream_id]; in send() local
278 stream_state.setup_frame_ctr = MUX_SETUP_FRAME_REPEAT; in send()
279 stream_state.ts_increment = DEFAULT_TS_INCREMENT; in send()
284 stream_state.setup_frame_ctr && (stream_state.last_mux_packet_id != mux_packet_id)) { in send()
285 stream_state.setup_frame_ctr--; in send()
291 (stream_state.last_mux_packet_id != mux_packet_id) && in send()
302 if (rtp_hdr_len != stream_state.rtp_hdr_len) { in send()
309 u_int16 old_ts_increment = stream_state.ts_increment; in send()
378 stream_state.last_mux_packet_id = mux_packet_id; in send()
381 stream_state.rtp_hdr_len = get_rtp_hdr_len(rtp_hdr); in send()
[all …]
/dports/print/ghostscript8-x11/ghostscript-8.71/base/
H A Dscommon.h41 typedef struct stream_state_s stream_state; typedef
109 int proc(stream_state *)
113 int proc(stream_state *, stream_cursor_read *,\
118 void proc(stream_state *)
122 void proc(stream_state *)
128 int proc(stream_state *)
133 int proc(stream_state *, const char *)
171 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript8-base/ghostscript-8.71/base/
H A Dscommon.h41 typedef struct stream_state_s stream_state; typedef
109 int proc(stream_state *)
113 int proc(stream_state *, stream_cursor_read *,\
118 void proc(stream_state *)
122 void proc(stream_state *)
128 int proc(stream_state *)
133 int proc(stream_state *, const char *)
171 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
H A Dgxcllzw.c29 s_LZW_set_defaults((stream_state *) & cl_LZWE_state); in gs_cl_lzw_init()
31 s_LZW_set_defaults((stream_state *) & cl_LZWD_state); in gs_cl_lzw_init()
37 const stream_state *
40 return (const stream_state *)&cl_LZWE_state; in clist_compressor_state()
42 const stream_state *
45 return (const stream_state *)&cl_LZWD_state; in clist_decompressor_state()
/dports/print/ghostscript9-agpl-base/ghostscript-9.52/base/
H A Dscommon.h50 typedef struct stream_state_s stream_state; typedef
118 int proc(stream_state *)
122 int proc(stream_state *, stream_cursor_read *,\
127 void proc(stream_state *)
131 void proc(stream_state *)
137 int proc(stream_state *)
142 int proc(stream_state *, const char *)
180 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript9-x11/ghostscript-9.06/base/
H A Dscommon.h43 typedef struct stream_state_s stream_state; typedef
111 int proc(stream_state *)
115 int proc(stream_state *, stream_cursor_read *,\
120 void proc(stream_state *)
124 void proc(stream_state *)
130 int proc(stream_state *)
135 int proc(stream_state *, const char *)
173 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript9-base/ghostscript-9.06/base/
H A Dscommon.h43 typedef struct stream_state_s stream_state; typedef
111 int proc(stream_state *)
115 int proc(stream_state *, stream_cursor_read *,\
120 void proc(stream_state *)
124 void proc(stream_state *)
130 int proc(stream_state *)
135 int proc(stream_state *, const char *)
173 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript9-agpl-x11/ghostscript-9.52/base/
H A Dscommon.h50 typedef struct stream_state_s stream_state; typedef
118 int proc(stream_state *)
122 int proc(stream_state *, stream_cursor_read *,\
127 void proc(stream_state *)
131 void proc(stream_state *)
137 int proc(stream_state *)
142 int proc(stream_state *, const char *)
180 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript7-base/ghostscript-7.07/src/
H A Dscommon.h46 typedef struct stream_state_s stream_state; typedef
106 int proc(P1(stream_state *))
110 int proc(P4(stream_state *, stream_cursor_read *,\
115 void proc(P1(stream_state *))
119 void proc(P1(stream_state *))
125 int proc(P1(stream_state *))
130 int proc(P2(stream_state *, const char *))
168 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/print/ghostscript7-x11/ghostscript-7.07/src/
H A Dscommon.h46 typedef struct stream_state_s stream_state; typedef
106 int proc(P1(stream_state *))
110 int proc(P4(stream_state *, stream_cursor_read *,\
115 void proc(P1(stream_state *))
119 void proc(P1(stream_state *))
125 int proc(P1(stream_state *))
130 int proc(P2(stream_state *, const char *))
168 gs_public_st_simple(st_stream_state, stream_state, "stream_state")
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/test/fuzzers/utils/
H A Drtp_replayer.cc35 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
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
119 stream_state->sinks.emplace_back( in SetupVideoStreams()
122 receive_config.renderer = stream_state->sinks.back().get(); in SetupVideoStreams()
123 receive_config.decoder_factory = stream_state->decoder_factory.get(); in SetupVideoStreams()
[all …]

12345678910>>...51