Home
last modified time | relevance | path

Searched refs:InFlight (Results 1 – 25 of 98) sorted by relevance

1234

/dports/www/firefox/firefox-99.0/third_party/rust/audioipc/src/rpc/
H A Dserver.rs98 in_flight: VecDeque<InFlight<S::Future>>,
118 self.in_flight.push_back(InFlight::Active(response)); in consume()
135 Some(&InFlight::Done(_)) => {} in produce()
144 Some(InFlight::Done(res)) => { in produce()
167 enum InFlight<F: Future<Error = ()>> { enum
172 impl<F: Future<Error = ()>> InFlight<F> { implementation
175 InFlight::Active(ref mut f) => match f.poll() { in poll()
182 *self = InFlight::Done(res); in poll()
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/audioipc/src/rpc/
H A Dserver.rs98 in_flight: VecDeque<InFlight<S::Future>>,
118 self.in_flight.push_back(InFlight::Active(response)); in consume()
135 Some(&InFlight::Done(_)) => {} in produce()
144 Some(InFlight::Done(res)) => { in produce()
167 enum InFlight<F: Future<Error = ()>> { enum
172 impl<F: Future<Error = ()>> InFlight<F> { implementation
175 InFlight::Active(ref mut f) => match f.poll() { in poll()
182 *self = InFlight::Done(res); in poll()
/dports/lang/spidermonkey60/firefox-60.9.0/media/audioipc/audioipc/src/rpc/
H A Dserver.rs98 in_flight: VecDeque<InFlight<S::Future>>,
118 self.in_flight.push_back(InFlight::Active(response)); in consume()
135 Some(&InFlight::Done(_)) => {} in produce()
144 Some(InFlight::Done(res)) => { in produce()
160 enum InFlight<F: Future<Error = ()>> { enum
165 impl<F: Future<Error = ()>> InFlight<F> { implementation
168 InFlight::Active(ref mut f) => match f.poll() { in poll()
175 *self = InFlight::Done(res); in poll()
/dports/www/firefox-esr/firefox-91.8.0/third_party/rust/audioipc/src/rpc/
H A Dserver.rs98 in_flight: VecDeque<InFlight<S::Future>>,
118 self.in_flight.push_back(InFlight::Active(response)); in consume()
135 Some(&InFlight::Done(_)) => {} in produce()
144 Some(InFlight::Done(res)) => { in produce()
167 enum InFlight<F: Future<Error = ()>> { enum
172 impl<F: Future<Error = ()>> InFlight<F> { implementation
175 InFlight::Active(ref mut f) => match f.poll() { in poll()
182 *self = InFlight::Done(res); in poll()
/dports/lang/spidermonkey78/firefox-78.9.0/media/audioipc/audioipc/src/rpc/
H A Dserver.rs98 in_flight: VecDeque<InFlight<S::Future>>,
118 self.in_flight.push_back(InFlight::Active(response)); in consume()
135 Some(&InFlight::Done(_)) => {} in produce()
144 Some(InFlight::Done(res)) => { in produce()
167 enum InFlight<F: Future<Error = ()>> { enum
172 impl<F: Future<Error = ()>> InFlight<F> { implementation
175 InFlight::Active(ref mut f) => match f.poll() { in poll()
182 *self = InFlight::Done(res); in poll()
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-proto-0.1.1/src/streaming/pipeline/
H A Dserver.rs90 in_flight: VecDeque<InFlight<S::Future>>,
93 enum InFlight<F: Future> { enum
125 self.in_flight.push_back(InFlight::Active(response)); in dispatch()
139 Some(&InFlight::Done(_)) => {} in poll()
144 Some(InFlight::Done(res)) => Ok(Async::Ready(Some(res))), in poll()
154 impl<F: Future> InFlight<F> { impl
157 InFlight::Active(ref mut f) => { in poll()
166 *self = InFlight::Done(res); in poll()
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-proto-0.1.1/src/streaming/pipeline/
H A Dserver.rs90 in_flight: VecDeque<InFlight<S::Future>>,
93 enum InFlight<F: Future> {
125 self.in_flight.push_back(InFlight::Active(response));
139 Some(&InFlight::Done(_)) => {}
144 Some(InFlight::Done(res)) => Ok(Async::Ready(Some(res))),
154 impl<F: Future> InFlight<F> {
157 InFlight::Active(ref mut f) => {
166 *self = InFlight::Done(res);
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/osiris/src/
H A Dosiris_bench.erl58 InFlight = maps:get(in_flight, Spec, 1000),
60 #{leader => Leader, in_flight => InFlight}),
62 #{leader => Leader2, in_flight => InFlight}),
71 do_publish(#{in_flight := InFlight} = Conf) ->
72 do_publish0(Conf, InFlight).
81 do_publish0(#{leader := Leader} = Conf, InFlight) ->
84 do_publish0(Conf, InFlight - 1).
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-proto-0.1.1/src/streaming/multiplex/
H A Dserver.rs104 in_flight: Vec<(RequestId, InFlight<S::Future>)>,
107 enum InFlight<F: Future> { enum
170 self.in_flight.push((id, InFlight::Active(response))); in dispatch()
198 impl<F> InFlight<F> impl
204 InFlight::Active(ref mut f) => { in poll()
215 *self = InFlight::Done(res); in poll()
221 InFlight::Done(res) => res, in unwrap_done()
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-proto-0.1.1/src/streaming/multiplex/
H A Dserver.rs104 in_flight: Vec<(RequestId, InFlight<S::Future>)>,
107 enum InFlight<F: Future> { enum
170 self.in_flight.push((id, InFlight::Active(response))); in dispatch()
198 impl<F> InFlight<F> impl
204 InFlight::Active(ref mut f) => { in poll()
215 *self = InFlight::Done(res); in poll()
221 InFlight::Done(res) => res, in unwrap_done()
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/modules/remote_bitrate_estimator/test/
H A Dpacket_sender.h152 struct InFlight { struct
154 explicit InFlight(const MediaPacket& packet) in InFlight() argument
158 InFlight(uint16_t seq_num, int64_t now_ms) in InFlight() function
161 bool operator<(const InFlight& rhs) const {
180 std::set<InFlight> in_flight_; argument
/dports/net/proby/proby-1.0.2/cargo-crates/actix-utils-1.0.6/src/
H A Dinflight.rs15 pub struct InFlight { struct
19 impl InFlight { impl
25 impl Default for InFlight { implementation
31 impl<S> Transform<S> for InFlight implementation
158 let srv = apply(InFlight::new(1), fn_factory(|| ok(SleepService(wait_time)))); in test_newtransform()
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/modules/remote_bitrate_estimator/test/
H A Dpacket_sender.h163 struct InFlight { struct
165 explicit InFlight(const MediaPacket& packet) in InFlight() function
169 InFlight(uint16_t seq_num, int64_t now_ms) in InFlight() argument
172 bool operator<(const InFlight& rhs) const {
191 std::set<InFlight> in_flight_; argument
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/modules/remote_bitrate_estimator/test/
H A Dpacket_sender.h163 struct InFlight { struct
165 explicit InFlight(const MediaPacket& packet) in InFlight() argument
169 InFlight(uint16_t seq_num, int64_t now_ms) in InFlight() function
172 bool operator<(const InFlight& rhs) const {
191 std::set<InFlight> in_flight_; argument
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/modules/remote_bitrate_estimator/test/
H A Dpacket_sender.h163 struct InFlight { struct
165 explicit InFlight(const MediaPacket& packet) in InFlight() argument
169 InFlight(uint16_t seq_num, int64_t now_ms) in InFlight() function
172 bool operator<(const InFlight& rhs) const {
191 std::set<InFlight> in_flight_; argument
/dports/net/storj/storj-1.45.3/vendor/github.com/zeebo/admission/v3/
H A Ddispatch.go36 InFlight int member
54 in_flight := d.InFlight
/dports/net/rclone/rclone-1.57.0/vendor/github.com/prometheus/procfs/sysfs/
H A Dclass_scsitape.go36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member
112 counters.InFlight = *vp.PUInt64()
H A Dclass_scsitape_test.go46 InFlight: 1,
/dports/dns/prometheus-dnssec-exporter/prometheus-dnssec-exporter-caa7d89/vendor/github.com/prometheus/procfs/sysfs/
H A Dclass_scsitape.go36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member
112 counters.InFlight = *vp.PUInt64()
H A Dclass_scsitape_test.go46 InFlight: 1,
/dports/sysutils/node_exporter/node_exporter-1.2.2/vendor/github.com/prometheus/procfs/sysfs/
H A Dclass_scsitape.go36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member
112 counters.InFlight = *vp.PUInt64()
H A Dclass_scsitape_test.go46 InFlight: 1,
/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/prometheus/procfs/sysfs/
H A Dclass_scsitape.go36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member
112 counters.InFlight = *vp.PUInt64()
/dports/irc/soju/soju-0.3.0/vendor/github.com/prometheus/procfs/sysfs/
H A Dclass_scsitape.go36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member
112 counters.InFlight = *vp.PUInt64()
/dports/net/ns3/ns-allinone-3.35/ns-3.35/src/internet/model/
H A Dtcp-bbr.cc235 TcpBbr::InFlight (Ptr<TcpSocketState> tcb, double gain) in InFlight() function in ns3::TcpBbr
272 … return isFullLength && (rs.m_bytesLoss > 0 || rs.m_priorInFlight >= InFlight (tcb, m_pacingGain)); in IsNextCyclePhase()
276 return isFullLength || rs.m_priorInFlight <= InFlight (tcb, 1); in IsNextCyclePhase()
342 tcb->m_ssThresh = InFlight (tcb, 1); in CheckDrain()
345 if (m_state == BbrMode_t::BBR_DRAIN && tcb->m_bytesInFlight <= InFlight (tcb, 1)) in CheckDrain()
467 m_targetCWnd = InFlight (tcb, m_cWndGain) + AckAggregationCwnd (); in UpdateTargetCwnd()

1234