/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/cronet/transport/ |
H A D | cronet_transport.cc | 1225 &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 D | cronet_transport.cc | 1195 &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 D | cronet_transport.cc | 879 } 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 D | cronet_transport.cc | 880 } 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 D | cronet_transport.cc | 886 } 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 D | cubeb_aaudio.cpp | 92 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 D | cubeb_aaudio.cpp | 92 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 D | cubeb_aaudio.cpp | 93 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 D | cubeb_aaudio.cpp | 93 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 D | cubeb_aaudio.cpp | 92 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 D | cubeb_aaudio.cpp | 93 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 D | cubeb_aaudio.cpp | 92 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 D | cubeb_aaudio.cpp | 92 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 D | cubeb_aaudio.cpp | 92 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 D | AmRtpMuxStream.cpp | 271 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 D | scommon.h | 41 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 D | scommon.h | 41 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 D | gxcllzw.c | 29 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 D | scommon.h | 50 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 D | scommon.h | 43 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 D | scommon.h | 43 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 D | scommon.h | 50 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 D | scommon.h | 46 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 D | scommon.h | 46 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 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 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 …]
|