| /external/liburing/examples/ |
| D | link-cp.c | 29 static int inflight; variable
99 inflight += 2; in handle_cqe()
123 int has_inflight = inflight; in copy_file()
126 while (insize && inflight < QD) { in copy_file()
133 inflight += 2; in copy_file()
136 if (has_inflight != inflight) in copy_file()
143 while (inflight >= depth) { in copy_file()
153 inflight--; in copy_file()
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_hammerhead_MRA59G_3.4.0/events/kgsl/adreno_cmdbatch_submitted/ |
| D | format | 12 field:unsigned int inflight; offset:20; size:4; signed:0;
14 print fmt: "ctx=%u ts=%u inflight=%u", REC->id, REC->timestamp, REC->inflight
|
| /external/oss-fuzz/infra/cifuzz/ |
| D | package-lock.json | 77 "inflight": "^1.0.4", string
90 "node_modules/inflight": {
92 "resolved": "https://registry.npmjs.org/inflight/-/inflight-1.0.6.tgz",
239 "inflight": "^1.0.4", string
246 "inflight": { object
248 "resolved": "https://registry.npmjs.org/inflight/-/inflight-1.0.6.tgz",
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/page_pool/page_pool_release/ |
| D | format | 10 field:s32 inflight; offset:16; size:4; signed:1;
15 print fmt: "page_pool=%p inflight=%d hold=%u release=%u cnt=%llu", REC->pool, REC->inflight, REC->h…
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| D | HttpStreamsClientHandler.java | 62 private int inFlight = 0; field in HttpStreamsClientHandler
98 if (inFlight == 0) { in close()
107 inFlight--; in consumedInMessage()
109 if (inFlight == 0 && closeOnZeroInFlight != null) { in consumedInMessage()
116 inFlight++; in receivedOutMessage()
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_seed_N2F62_3.10.49/events/kgsl/adreno_cmdbatch_submitted/ |
| D | format | 11 field:int inflight; offset:16; size:4; signed:1;
17 print fmt: "ctx=%u ts=%u inflight=%d flags=%s ticks=%lld time=%lu.%0lu", REC->id, REC->timestamp, R…
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_hammerhead_MRA59G_3.4.0/events/kgsl/adreno_cmdbatch_retired/ |
| D | format | 12 field:unsigned int inflight; offset:20; size:4; signed:0;
15 print fmt: "ctx=%u ts=%u inflight=%u recovery=%s", REC->id, REC->timestamp, REC->inflight, REC->rec…
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_seed_N2F62_3.10.49/events/kgsl/adreno_cmdbatch_retired/ |
| D | format | 11 field:int inflight; offset:16; size:4; signed:1;
17 print fmt: "ctx=%u ts=%u inflight=%d recovery=%s flags=%s start=%lld retire=%lld", REC->id, REC->ti…
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_walleye_OPM5.171019.017.A1_4.4.88/events/kgsl/adreno_cmdbatch_submitted/ |
| D | format | 11 field:int inflight; offset:16; size:4; signed:1;
22 …o=%d ts=%u inflight=%d flags=%s ticks=%lld time=%lu.%0lu rb_id=%d r/w=%x/%x, q_inflight=%d", REC->…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | FlatMapStressTest.kt | 48 val inFlight = inFlightElements.get() in <lambda>() constant
49 assertTrue(inFlight <= bufferSize + 1, in <lambda>()
50 "Expected less in flight elements than ${bufferSize + 1}, but had $inFlight") in <lambda>()
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_walleye_OPM5.171019.017.A1_4.4.88/events/kgsl/adreno_cmdbatch_retired/ |
| D | format | 11 field:int inflight; offset:16; size:4; signed:1;
23 …s=%u inflight=%d recovery=%s flags=%s start=%lld retire=%lld rb_id=%d, r/w=%x/%x, q_inflight=%d", …
|
| /external/libwebsockets/lib/tls/ |
| D | tls-jit-trust.c | 206 * No... let's make an inflight entry for this host, then in lws_tls_jit_trust_sort_kids()
221 * multiple (the inflight accepts up to 2) CAs needed. in lws_tls_jit_trust_sort_kids()
283 * Let's make an inflight for this, it will create the vhost when it in lws_tls_jit_trust_vhost_bind()
431 * inflight, that may cause different CA certs to apply to a connection, in lws_tls_jit_trust_got_cert_cb()
478 * We accept up to three valid CA, and then end the inflight early. in lws_tls_jit_trust_got_cert_cb()
480 * use. Up to two valid CA would be held in the inflight and the other in lws_tls_jit_trust_got_cert_cb()
483 * If we did not already fill up the inflight, keep waiting for any in lws_tls_jit_trust_got_cert_cb()
519 /* copy the SKIDs from the inflight and params into the cache item */ in lws_tls_jit_trust_got_cert_cb()
569 * if we have a params one, use that so the rest are all from inflight in lws_tls_jit_trust_got_cert_cb()
597 * Do we need to add more trusted certs from inflight? in lws_tls_jit_trust_got_cert_cb()
|
| D | private-jit-trust.h | 77 * The cert copies and this inflight object are then freed.
81 * separate inflight tracking objects are needed.
|
| /external/cronet/net/nqe/ |
| D | throughput_analyzer.h | 120 // Returns the sum of expected response content size in bytes for all inflight
144 // for that request. The map tracks all inflight requests. If the expected
228 // Container that holds inflight request sizes. These requests are used in
229 // computing the total of response content size for all inflight requests.
232 // The running total of response content size for all inflight requests.
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | ping_callbacks.cc | 53 InflightPing inflight; in StartPing() local
54 inflight.on_ack.swap(on_ack_); in StartPing()
56 inflight_.emplace(id, std::move(inflight)); in StartPing()
|
| /external/rust/crates/vhost-user-backend/tests/ |
| D | vhost-user-server.rs | 261 let inflight = VhostUserInflight { in vhost_user_set_inflight() localVariable
268 .set_inflight_fd(&inflight, eventfd.as_raw_fd()) in vhost_user_set_inflight()
280 let inflight = VhostUserInflight { in vhost_user_get_inflight() localVariable
286 assert!(master.get_inflight_fd(&inflight).is_err()); in vhost_user_get_inflight()
|
| /external/rust/crates/vhost-user-backend/src/vhost_user/ |
| D | master.rs | 58 /// Retrieve shared buffer for inflight I/O tracking.
61 inflight: &VhostUserInflight, in get_inflight_fd()
64 /// Set shared buffer for inflight I/O tracking.
65 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, fd: RawFd) -> Result<()>; in set_inflight_fd()
455 inflight: &VhostUserInflight, in get_inflight_fd()
460 let hdr = node.send_request_with_body(MasterReq::GET_INFLIGHT_FD, inflight, None)?; in get_inflight_fd()
461 let (inflight, files) = node.recv_reply_with_files::<VhostUserInflight>(&hdr)?; in get_inflight_fd()
464 Some(file) => Ok((inflight, file)), in get_inflight_fd()
469 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, fd: RawFd) -> Result<()> { in set_inflight_fd()
473 if inflight.mmap_size == 0 || inflight.num_queues == 0 || inflight.queue_size == 0 || fd < 0 in set_inflight_fd()
[all …]
|
| D | slave_req_handler.rs | 68 fn get_inflight_fd(&self, inflight: &VhostUserInflight) -> Result<(VhostUserInflight, File)>; in get_inflight_fd()
69 fn set_inflight_fd(&self, inflight: &VhostUserInflight, file: File) -> Result<()>; in set_inflight_fd()
115 inflight: &VhostUserInflight, in get_inflight_fd()
117 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, file: File) -> Result<()>; in set_inflight_fd()
210 fn get_inflight_fd(&self, inflight: &VhostUserInflight) -> Result<(VhostUserInflight, File)> { in get_inflight_fd()
211 self.lock().unwrap().get_inflight_fd(inflight) in get_inflight_fd()
214 fn set_inflight_fd(&self, inflight: &VhostUserInflight, file: File) -> Result<()> { in set_inflight_fd()
215 self.lock().unwrap().set_inflight_fd(inflight, file) in set_inflight_fd()
484 let (inflight, file) = self.backend.get_inflight_fd(&msg)?; in handle_request()
487 .send_message(&reply_hdr, &inflight, Some(&[file.as_raw_fd()]))?; in handle_request()
|
| D | message.rs | 127 /// Send the shared inflight buffer back to slave.
420 /// Support inflight shmfd.
835 /// Size of the area to track inflight I/O.
975 /// Inflight I/O descriptor state for split virtqueues
979 /// Indicate whether this descriptor (only head) is inflight or not.
980 pub inflight: u8, field
996 /// Inflight I/O queue region for split virtqueues
1027 /// Inflight I/O descriptor state for packed virtqueues
1031 /// Indicate whether this descriptor (only head) is inflight or not.
1032 pub inflight: u8, field
[all …]
|
| /external/rust/crates/vhost/src/vhost_user/ |
| D | master.rs | 58 /// Retrieve shared buffer for inflight I/O tracking.
61 inflight: &VhostUserInflight, in get_inflight_fd()
64 /// Set shared buffer for inflight I/O tracking.
65 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, fd: RawFd) -> Result<()>; in set_inflight_fd()
455 inflight: &VhostUserInflight, in get_inflight_fd()
460 let hdr = node.send_request_with_body(MasterReq::GET_INFLIGHT_FD, inflight, None)?; in get_inflight_fd()
461 let (inflight, files) = node.recv_reply_with_files::<VhostUserInflight>(&hdr)?; in get_inflight_fd()
464 Some(file) => Ok((inflight, file)), in get_inflight_fd()
469 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, fd: RawFd) -> Result<()> { in set_inflight_fd()
473 if inflight.mmap_size == 0 || inflight.num_queues == 0 || inflight.queue_size == 0 || fd < 0 in set_inflight_fd()
[all …]
|
| D | slave_req_handler.rs | 68 fn get_inflight_fd(&self, inflight: &VhostUserInflight) -> Result<(VhostUserInflight, File)>; in get_inflight_fd()
69 fn set_inflight_fd(&self, inflight: &VhostUserInflight, file: File) -> Result<()>; in set_inflight_fd()
115 inflight: &VhostUserInflight, in get_inflight_fd()
117 fn set_inflight_fd(&mut self, inflight: &VhostUserInflight, file: File) -> Result<()>; in set_inflight_fd()
210 fn get_inflight_fd(&self, inflight: &VhostUserInflight) -> Result<(VhostUserInflight, File)> { in get_inflight_fd()
211 self.lock().unwrap().get_inflight_fd(inflight) in get_inflight_fd()
214 fn set_inflight_fd(&self, inflight: &VhostUserInflight, file: File) -> Result<()> { in set_inflight_fd()
215 self.lock().unwrap().set_inflight_fd(inflight, file) in set_inflight_fd()
484 let (inflight, file) = self.backend.get_inflight_fd(&msg)?; in handle_request()
487 .send_message(&reply_hdr, &inflight, Some(&[file.as_raw_fd()]))?; in handle_request()
|
| D | message.rs | 127 /// Send the shared inflight buffer back to slave.
420 /// Support inflight shmfd.
835 /// Size of the area to track inflight I/O.
975 /// Inflight I/O descriptor state for split virtqueues
979 /// Indicate whether this descriptor (only head) is inflight or not.
980 pub inflight: u8, field
996 /// Inflight I/O queue region for split virtqueues
1027 /// Inflight I/O descriptor state for packed virtqueues
1031 /// Indicate whether this descriptor (only head) is inflight or not.
1032 pub inflight: u8, field
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/congestion_control/ |
| D | bbr2_misc.h | 301 // Total bytes inflight before the processing of the ack/loss events.
304 // Total bytes inflight after the processing of the ack/loss events.
325 // acknowledged inflight packets.
359 // Update inflight/bandwidth short-term lower bounds.
581 // Max inflight in the current round. Updated once per congestion event.
583 // Max inflight of recent rounds. Updated once per round.
|
| /external/crosvm/third_party/vmm_vhost/src/ |
| D | backend_client.rs | 449 /// Retrieve shared buffer for inflight I/O tracking.
452 inflight: &VhostUserInflight, in get_inflight_fd()
458 let hdr = self.send_request_with_body(FrontendReq::GET_INFLIGHT_FD, inflight, None)?; in get_inflight_fd()
459 let (inflight, files) = self.recv_reply_with_files::<VhostUserInflight>(&hdr)?; in get_inflight_fd()
462 Some(file) => Ok((inflight, file)), in get_inflight_fd()
467 /// Set shared buffer for inflight I/O tracking.
468 pub fn set_inflight_fd(&self, inflight: &VhostUserInflight, fd: RawDescriptor) -> Result<()> { in set_inflight_fd()
473 if inflight.mmap_size == 0 in set_inflight_fd()
474 || inflight.num_queues == 0 in set_inflight_fd()
475 || inflight.queue_size == 0 in set_inflight_fd()
[all …]
|
| D | message.rs | 125 /// Send the shared inflight buffer back to backend.
432 /// Support inflight shmfd.
787 /// Size of the area to track inflight I/O.
1059 /// Inflight I/O descriptor state for split virtqueues
1063 /// Indicate whether this descriptor (only head) is inflight or not.
1064 pub inflight: u8, field
1080 /// Inflight I/O queue region for split virtqueues
1111 /// Inflight I/O descriptor state for packed virtqueues
1115 /// Indicate whether this descriptor (only head) is inflight or not.
1116 pub inflight: u8, field
[all …]
|