Commit | Line | Data |
---|---|---|
ebabbf58 MD |
1 | /* SPDX-License-Identifier: (GPL-2.0-only or LGPL-2.1-only) |
2 | * | |
3 | * lttng-counter-client-percpu-64-modular.c | |
4 | * | |
5 | * LTTng lib counter client. Per-cpu 64-bit counters in modular | |
6 | * arithmetic. | |
7 | * | |
8 | * Copyright (C) 2020 Mathieu Desnoyers <mathieu.desnoyers@efficios.com> | |
9 | */ | |
10 | ||
11 | #include <lttng/ust-events.h> | |
12 | #include "../libcounter/counter.h" | |
13 | #include "../libcounter/counter-api.h" | |
14 | ||
15 | static const struct lib_counter_config client_config = { | |
16 | .alloc = COUNTER_ALLOC_PER_CPU, | |
17 | .sync = COUNTER_SYNC_PER_CPU, | |
18 | .arithmetic = COUNTER_ARITHMETIC_MODULAR, | |
19 | .counter_size = COUNTER_SIZE_64_BIT, | |
20 | }; | |
21 | ||
22 | static struct lib_counter *counter_create(size_t nr_dimensions, | |
23 | const struct lttng_counter_dimension *dimensions, | |
24 | int64_t global_sum_step, | |
25 | int global_counter_fd, | |
26 | int nr_counter_cpu_fds, | |
27 | const int *counter_cpu_fds, | |
28 | bool is_daemon) | |
29 | { | |
30 | size_t max_nr_elem[LTTNG_COUNTER_DIMENSION_MAX], i; | |
31 | ||
32 | if (nr_dimensions > LTTNG_COUNTER_DIMENSION_MAX) | |
33 | return NULL; | |
34 | for (i = 0; i < nr_dimensions; i++) { | |
35 | if (dimensions[i].has_underflow || dimensions[i].has_overflow) | |
36 | return NULL; | |
37 | max_nr_elem[i] = dimensions[i].size; | |
38 | } | |
39 | return lttng_counter_create(&client_config, nr_dimensions, max_nr_elem, | |
40 | global_sum_step, global_counter_fd, nr_counter_cpu_fds, | |
41 | counter_cpu_fds, is_daemon); | |
42 | } | |
43 | ||
44 | static void counter_destroy(struct lib_counter *counter) | |
45 | { | |
46 | lttng_counter_destroy(counter); | |
47 | } | |
48 | ||
49 | static int counter_add(struct lib_counter *counter, const size_t *dimension_indexes, int64_t v) | |
50 | { | |
51 | return lttng_counter_add(&client_config, counter, dimension_indexes, v); | |
52 | } | |
53 | ||
54 | static int counter_read(struct lib_counter *counter, const size_t *dimension_indexes, int cpu, | |
55 | int64_t *value, bool *overflow, bool *underflow) | |
56 | { | |
57 | return lttng_counter_read(&client_config, counter, dimension_indexes, cpu, value, | |
58 | overflow, underflow); | |
59 | } | |
60 | ||
61 | static int counter_aggregate(struct lib_counter *counter, const size_t *dimension_indexes, | |
62 | int64_t *value, bool *overflow, bool *underflow) | |
63 | { | |
64 | return lttng_counter_aggregate(&client_config, counter, dimension_indexes, value, | |
65 | overflow, underflow); | |
66 | } | |
67 | ||
68 | static int counter_clear(struct lib_counter *counter, const size_t *dimension_indexes) | |
69 | { | |
70 | return lttng_counter_clear(&client_config, counter, dimension_indexes); | |
71 | } | |
72 | ||
73 | static struct lttng_counter_transport lttng_counter_transport = { | |
74 | .name = "counter-per-cpu-64-modular", | |
75 | .ops = { | |
76 | .counter_create = counter_create, | |
77 | .counter_destroy = counter_destroy, | |
78 | .counter_add = counter_add, | |
79 | .counter_read = counter_read, | |
80 | .counter_aggregate = counter_aggregate, | |
81 | .counter_clear = counter_clear, | |
82 | }, | |
83 | .client_config = &client_config, | |
84 | }; | |
85 | ||
86 | void lttng_counter_client_percpu_64_modular_init(void) | |
87 | { | |
88 | lttng_counter_transport_register(<tng_counter_transport); | |
89 | } | |
90 | ||
91 | void lttng_counter_client_percpu_64_modular_exit(void) | |
92 | { | |
93 | lttng_counter_transport_unregister(<tng_counter_transport); | |
94 | } |