Lines Matching refs:meter
21 #include "meter.h"
46 static void ovs_meter_free(struct dp_meter *meter)
48 if (!meter)
51 kfree_rcu(meter, rcu);
60 struct dp_meter *meter;
62 meter = rcu_dereference_ovsl(ti->dp_meters[hash]);
63 if (meter && likely(meter->id == meter_id))
64 return meter;
120 struct dp_meter *meter)
124 hash = meter_hash(ti, meter->id);
125 rcu_assign_pointer(ti->dp_meters[hash], meter);
129 struct dp_meter *meter)
133 hash = meter_hash(ti, meter->id);
137 static int attach_meter(struct dp_meter_table *tbl, struct dp_meter *meter)
140 u32 hash = meter_hash(ti, meter->id);
149 dp_meter_instance_insert(ti, meter);
167 dp_meter_instance_remove(ti, meter);
172 static int detach_meter(struct dp_meter_table *tbl, struct dp_meter *meter)
177 if (!meter)
181 dp_meter_instance_remove(ti, meter);
185 /* Shrink the meter array if necessary. */
207 dp_meter_instance_insert(ti, meter);
236 struct dp_meter *meter)
246 sizeof(struct ovs_flow_stats), &meter->stats))
249 if (nla_put_u64_64bit(reply, OVS_METER_ATTR_USED, meter->used,
257 band = meter->bands;
259 for (i = 0; i < meter->n_bands; ++i, ++band) {
334 struct dp_meter *meter;
346 /* Allocate and set up the meter before locking anything. */
347 meter = kzalloc(struct_size(meter, bands, n_bands), GFP_KERNEL);
348 if (!meter)
351 meter->id = nla_get_u32(a[OVS_METER_ATTR_ID]);
352 meter->used = div_u64(ktime_get_ns(), 1000 * 1000);
353 meter->kbps = a[OVS_METER_ATTR_KBPS] ? 1 : 0;
354 meter->keep_stats = !a[OVS_METER_ATTR_CLEAR];
355 spin_lock_init(&meter->lock);
356 if (meter->keep_stats && a[OVS_METER_ATTR_STATS]) {
357 meter->stats = *(struct ovs_flow_stats *)
360 meter->n_bands = n_bands;
362 /* Set up meter bands. */
363 band = meter->bands;
397 if (band_max_delta_t > meter->max_delta_t)
398 meter->max_delta_t = band_max_delta_t;
402 return meter;
405 kfree(meter);
412 struct dp_meter *meter, *old_meter;
425 meter = dp_meter_create(a);
426 if (IS_ERR_OR_NULL(meter))
427 return PTR_ERR(meter);
451 err = attach_meter(meter_tbl, meter);
458 * the old meter, if any.
482 kfree(meter);
491 struct dp_meter *meter;
515 /* Locate meter, copy stats. */
516 meter = lookup_meter(&dp->meter_tbl, meter_id);
517 if (!meter) {
522 spin_lock_bh(&meter->lock);
523 err = ovs_meter_cmd_reply_stats(reply, meter_id, meter);
524 spin_unlock_bh(&meter->lock);
601 struct dp_meter *meter;
607 meter = lookup_meter(&dp->meter_tbl, meter_id);
608 /* Do not drop the packet when there is no meter. */
609 if (!meter)
612 /* Lock the meter while using it. */
613 spin_lock(&meter->lock);
615 long_delta_ms = (now_ms - meter->used); /* ms */
618 * for a meter lock, and the one who received the packets a
628 delta_ms = (long_delta_ms > (long long int)meter->max_delta_t)
629 ? meter->max_delta_t : (u32)long_delta_ms;
631 /* Update meter statistics.
633 meter->used = now_ms;
634 meter->stats.n_packets += 1;
635 meter->stats.n_bytes += skb->len;
647 cost = (meter->kbps) ? skb->len * 8 : 1000;
650 for (i = 0; i < meter->n_bands; ++i) {
653 band = &meter->bands[i];
670 band = &meter->bands[band_exceeded_max];
676 spin_unlock(&meter->lock);
681 spin_unlock(&meter->lock);