Home
last modified time | relevance | path

Searched refs:flows (Results 1 – 25 of 87) sorted by relevance

1234

/external/perfetto/src/trace_processor/importers/common/
Dflow_tracker_unittest.cc57 const auto& flows = context.storage->flow_table(); in TEST() local
58 EXPECT_EQ(flows.row_count(), 1u); in TEST()
59 EXPECT_EQ(flows.slice_out()[0], out_slice_id); in TEST()
60 EXPECT_EQ(flows.slice_in()[0], in_slice_id); in TEST()
86 const auto& flows = context.storage->flow_table(); in TEST() local
88 EXPECT_EQ(flows.row_count(), 0u); in TEST()
94 EXPECT_EQ(flows.row_count(), 1u); in TEST()
95 EXPECT_EQ(flows.slice_out()[0], out_slice_id); in TEST()
96 EXPECT_EQ(flows.slice_in()[0], in_slice_id); in TEST()
122 const auto& flows = context.storage->flow_table(); in TEST() local
[all …]
/external/boringssl/src/ssl/test/runner/
Drecordingconn.go49 flows []flow member
58 …if l := len(r.flows); flowType == specialFlow || r.isDatagram || l == 0 || r.flows[l-1].flowType !…
61 r.flows = append(r.flows, flow{flowType, message, buf})
63 r.flows[l-1].data = append(r.flows[l-1].data, data...)
91 for i, flow := range r.flows {
111 for _, flow := range r.flows {
124 func parseTestData(r io.Reader) (flows [][]byte, err error) {
133 if len(currentFlow) > 0 || len(flows) > 0 {
134 flows = append(flows, currentFlow)
167 flows = append(flows, currentFlow)
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DZip.kt235 vararg flows: Flow<T>, in combine()
238 combineInternal(flows, { arrayOfNulls(flows.size) }, { emit(transform(it)) }) in combine()
248 vararg flows: Flow<T>, in combineTransform()
251 combineInternal(flows, { arrayOfNulls(flows.size) }, { transform(it) }) in combineTransform()
259 vararg flows: Flow<T>, in combineUnsafe()
262 combineInternal(flows, nullArrayFactory(), { emit(transform(it)) }) in combineUnsafe()
270 vararg flows: Flow<T>, in combineTransformUnsafe()
273 combineInternal(flows, nullArrayFactory(), { transform(it) }) in combineTransformUnsafe()
284 flows: Iterable<Flow<T>>, in combine()
287 val flowArray = flows.toList().toTypedArray() in combine()
[all …]
DMerge.kt118 public fun <T> merge(vararg flows: Flow<T>): Flow<T> = flows.asIterable().merge() in merge()
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/
DFlowFlattenMergeBenchmark.kt25 … private var flowsNumberStrategy: FlowsNumberStrategy = FlowsNumberStrategy.`10xConcurrency flows` in <lambda>()
54 `10xConcurrency flows`({ concurrency -> concurrency * 10 }), in concurrency()
55 `1xConcurrency flows`({ it }), in <lambda>()
56 `100 flows`({ 100 }), in <lambda>()
57 `500 flows`({ 500 }) in <lambda>()
/external/perfetto/ui/src/controller/
Dflow_events_controller.ts45 queryFlowEvents(query: string, callback: (flows: Flow[]) => void) {
47 const flows: Flow[] = []; constant
75 flows.push({
99 callback(flows);
125 query, (flows: Flow[]) => globals.publish('ConnectedFlows', flows));
182 query, (flows: Flow[]) => globals.publish('SelectedFlows', flows));
/external/adhd/cras/src/tests/
Ddsp_ini_unittest.cc42 EXPECT_EQ(0, ARRAY_COUNT(&ini->flows)); in TEST_F()
64 EXPECT_EQ(0, ARRAY_COUNT(&ini->flows)); in TEST_F()
89 EXPECT_EQ(0, ARRAY_COUNT(&ini->flows)); in TEST_F()
104 EXPECT_EQ(0, ARRAY_COUNT(&ini->flows)); in TEST_F()
154 EXPECT_EQ(2, ARRAY_COUNT(&ini->flows)); in TEST_F()
155 struct flow* flow0 = ARRAY_ELEMENT(&ini->flows, 0); in TEST_F()
156 struct flow* flow1 = ARRAY_ELEMENT(&ini->flows, 1); in TEST_F()
263 struct flow* flow_a0 = ARRAY_ELEMENT(&ini->flows, 0); in TEST_F()
264 struct flow* flow_a1 = ARRAY_ELEMENT(&ini->flows, 1); in TEST_F()
265 struct flow* flow_b0 = ARRAY_ELEMENT(&ini->flows, 2); in TEST_F()
[all …]
/external/kotlinx.coroutines/benchmarks/scripts/
Dgenerate_plots_flow_flatten_merge.py47 for flows in data.flows.unique():
50 res = data[(data.flows == flows)]
53 label="flows={}".format(flows), capsize=4, color=gen_colour, linewidth=2.2)
/external/iproute2/tc/
Dq_fq_codel.c63 unsigned int flows = 0; in fq_codel_parse_opt() local
81 if (get_unsigned(&flows, *argv, 0)) { in fq_codel_parse_opt()
134 if (flows) in fq_codel_parse_opt()
135 addattr_l(n, 1024, TCA_FQ_CODEL_FLOWS, &flows, sizeof(flows)); in fq_codel_parse_opt()
159 unsigned int flows; in fq_codel_print_opt() local
181 flows = rta_getattr_u32(tb[TCA_FQ_CODEL_FLOWS]); in fq_codel_print_opt()
182 fprintf(f, "flows %u ", flows); in fq_codel_print_opt()
Dq_sfq.c82 if (get_u32(&opt.v0.flows, *argv, 0)) { in sfq_parse_opt()
228 fprintf(f, "flows %u/%u ", qopt->flows, qopt->divisor); in sfq_print_opt()
/external/libnl/lib/cli/qdisc/
Dfq_codel.c37 int limit, flows; in fq_codel_parse_argv() local
79 flows = nl_cli_parse_u32(optarg); in fq_codel_parse_argv()
80 rtnl_qdisc_fq_codel_set_flows(qdisc, flows); in fq_codel_parse_argv()
/external/adhd/cras/src/server/
Dcras_dsp_ini.c75 ARRAY_ELEMENT_FOREACH (&ini->flows, i, flow) { in lookup_flow()
89 i = ARRAY_COUNT(&ini->flows); in lookup_or_add_flow()
90 flow = ARRAY_APPEND_ZERO(&ini->flows); in lookup_or_add_flow()
182 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in fill_flow_info()
235 i = ARRAY_COUNT(&ini->flows); in add_new_flow()
236 flow = ARRAY_APPEND_ZERO(&ini->flows); in add_new_flow()
417 ARRAY_FREE(&ini->flows); in cras_dsp_ini_free()
484 dumpf(d, "number of flows = %d\n", ARRAY_COUNT(&ini->flows)); in cras_dsp_ini_dump()
485 ARRAY_ELEMENT_FOREACH (&ini->flows, i, flow) { in cras_dsp_ini_dump()
Dcras_dsp_ini.h70 flow_array flows; member
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DCombine.kt19 flows: Array<out Flow<T>>, in <lambda>()
23 val size = flows.size in <lambda>()
34 flows[i].collect { value -> in <lambda>()
DMerge.kt81 private val flows: Iterable<Flow<T>>, in additionalToStringProps() constant in ChannelLimitedFlowMerge
87 ChannelLimitedFlowMerge(flows, context, capacity, onBufferOverflow) in additionalToStringProps()
95 flows.forEach { flow -> in additionalToStringProps()
/external/kotlinx.coroutines/
Dcoroutines-guide.md51 * <a name='flows'></a>[Flows](docs/flow.md#flows)
52 * <a name='flows-are-cold'></a>[Flows are cold](docs/flow.md#flows-are-cold)
59 * <a name='flows-are-sequential'></a>[Flows are sequential](docs/flow.md#flows-are-sequential)
66 …* <a name='composing-multiple-flows'></a>[Composing multiple flows](docs/flow.md#composing-multipl…
69 * <a name='flattening-flows'></a>[Flattening flows](docs/flow.md#flattening-flows)
/external/iptables/extensions/
Dlibxt_connbytes.man2 flows constituting the connection) has transferred so far, or by
16 flows will not be gaining/losing a/the accounting structure when be sysctl flag
Dlibip6t_SNPT.man30 target to disable connection tracking for translated flows.
Dlibip6t_DNPT.man30 target to disable connection tracking for translated flows.
/external/arm-trusted-firmware/docs/design/
Dindex.rst9 alt-boot-flows
/external/ukey2/src/main/proto/
Ddevice_to_device_messages.proto72 // Some (but not all) SPAKE flows send a point on an elliptic curve
75 // Some (but not all) SPAKE flows send a hash value
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DCombineParametersTestBase.kt170 val flows = List(flowsCount) { (1..flowSize).asFlow() } in <lambda>() constant
171 val combined = combine(flows) { it.joinToString(separator = "") }.toList() in <lambda>()
/external/libnl/lib/route/qdisc/
Dfq_codel.c290 int rtnl_qdisc_fq_codel_set_flows(struct rtnl_qdisc *qdisc, int flows) in rtnl_qdisc_fq_codel_set_flows() argument
297 fq_codel->fq_flows = flows; in rtnl_qdisc_fq_codel_set_flows()
Dsfq.c59 sfq->qs_flows = opts->flows; in sfq_msg_parser()
/external/llvm-project/llvm/docs/
DCFIVerify.rst39 implemented around all indirect control flows by analysing the output machine
45 review. These unexpected control flows may simply have not been accounted for in

1234