/dports/www/firefox/firefox-99.0/third_party/rust/audioipc/src/rpc/ |
H A D | server.rs | 98 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 D | server.rs | 98 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 D | server.rs | 98 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 D | server.rs | 98 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 D | server.rs | 98 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 D | server.rs | 90 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 D | server.rs | 90 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 D | osiris_bench.erl | 58 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 D | server.rs | 104 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 D | server.rs | 104 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 D | packet_sender.h | 152 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 D | inflight.rs | 15 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 D | packet_sender.h | 163 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 D | packet_sender.h | 163 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 D | packet_sender.h | 163 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 D | dispatch.go | 36 InFlight int member 54 in_flight := d.InFlight
|
/dports/net/rclone/rclone-1.57.0/vendor/github.com/prometheus/procfs/sysfs/ |
H A D | class_scsitape.go | 36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member 112 counters.InFlight = *vp.PUInt64()
|
H A D | class_scsitape_test.go | 46 InFlight: 1,
|
/dports/dns/prometheus-dnssec-exporter/prometheus-dnssec-exporter-caa7d89/vendor/github.com/prometheus/procfs/sysfs/ |
H A D | class_scsitape.go | 36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member 112 counters.InFlight = *vp.PUInt64()
|
H A D | class_scsitape_test.go | 46 InFlight: 1,
|
/dports/sysutils/node_exporter/node_exporter-1.2.2/vendor/github.com/prometheus/procfs/sysfs/ |
H A D | class_scsitape.go | 36 InFlight uint64 // /sys/class/scsi_tape/<Name>/stats/in_flight member 112 counters.InFlight = *vp.PUInt64()
|
H A D | class_scsitape_test.go | 46 InFlight: 1,
|
/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/prometheus/procfs/sysfs/ |
H A D | class_scsitape.go | 36 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 D | class_scsitape.go | 36 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 D | tcp-bbr.cc | 235 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()
|