Lines Matching refs:meter
42 static void ovs_meter_free(struct dp_meter *meter) in ovs_meter_free() argument
44 if (!meter) in ovs_meter_free()
47 kfree_rcu(meter, rcu); in ovs_meter_free()
60 struct dp_meter *meter; in lookup_meter() local
64 hlist_for_each_entry_rcu(meter, head, dp_hash_node) { in lookup_meter()
65 if (meter->id == meter_id) in lookup_meter()
66 return meter; in lookup_meter()
71 static void attach_meter(struct datapath *dp, struct dp_meter *meter) in attach_meter() argument
73 struct hlist_head *head = meter_hash_bucket(dp, meter->id); in attach_meter()
75 hlist_add_head_rcu(&meter->dp_hash_node, head); in attach_meter()
78 static void detach_meter(struct dp_meter *meter) in detach_meter() argument
81 if (meter) in detach_meter()
82 hlist_del_rcu(&meter->dp_hash_node); in detach_meter()
109 struct dp_meter *meter) in ovs_meter_cmd_reply_stats() argument
118 if (!meter) in ovs_meter_cmd_reply_stats()
122 sizeof(struct ovs_flow_stats), &meter->stats) || in ovs_meter_cmd_reply_stats()
123 nla_put_u64_64bit(reply, OVS_METER_ATTR_USED, meter->used, in ovs_meter_cmd_reply_stats()
131 band = meter->bands; in ovs_meter_cmd_reply_stats()
133 for (i = 0; i < meter->n_bands; ++i, ++band) { in ovs_meter_cmd_reply_stats()
193 struct dp_meter *meter; in dp_meter_create() local
206 meter = kzalloc(struct_size(meter, bands, n_bands), GFP_KERNEL); in dp_meter_create()
207 if (!meter) in dp_meter_create()
210 meter->id = nla_get_u32(a[OVS_METER_ATTR_ID]); in dp_meter_create()
211 meter->used = div_u64(ktime_get_ns(), 1000 * 1000); in dp_meter_create()
212 meter->kbps = a[OVS_METER_ATTR_KBPS] ? 1 : 0; in dp_meter_create()
213 meter->keep_stats = !a[OVS_METER_ATTR_CLEAR]; in dp_meter_create()
214 spin_lock_init(&meter->lock); in dp_meter_create()
215 if (meter->keep_stats && a[OVS_METER_ATTR_STATS]) { in dp_meter_create()
216 meter->stats = *(struct ovs_flow_stats *) in dp_meter_create()
219 meter->n_bands = n_bands; in dp_meter_create()
222 band = meter->bands; in dp_meter_create()
256 if (band_max_delta_t > meter->max_delta_t) in dp_meter_create()
257 meter->max_delta_t = band_max_delta_t; in dp_meter_create()
261 return meter; in dp_meter_create()
264 kfree(meter); in dp_meter_create()
271 struct dp_meter *meter, *old_meter; in ovs_meter_cmd_set() local
284 meter = dp_meter_create(a); in ovs_meter_cmd_set()
285 if (IS_ERR_OR_NULL(meter)) in ovs_meter_cmd_set()
286 return PTR_ERR(meter); in ovs_meter_cmd_set()
307 attach_meter(dp, meter); in ovs_meter_cmd_set()
333 kfree(meter); in ovs_meter_cmd_set()
346 struct dp_meter *meter; in ovs_meter_cmd_get() local
367 meter = lookup_meter(dp, meter_id); in ovs_meter_cmd_get()
368 if (!meter) { in ovs_meter_cmd_get()
373 spin_lock_bh(&meter->lock); in ovs_meter_cmd_get()
374 err = ovs_meter_cmd_reply_stats(reply, meter_id, meter); in ovs_meter_cmd_get()
375 spin_unlock_bh(&meter->lock); in ovs_meter_cmd_get()
445 struct dp_meter *meter; in ovs_meter_execute() local
454 meter = lookup_meter(dp, meter_id); in ovs_meter_execute()
456 if (!meter) in ovs_meter_execute()
460 spin_lock(&meter->lock); in ovs_meter_execute()
462 long_delta_ms = (now_ms - meter->used); /* ms */ in ovs_meter_execute()
467 delta_ms = (long_delta_ms > (long long int)meter->max_delta_t) in ovs_meter_execute()
468 ? meter->max_delta_t : (u32)long_delta_ms; in ovs_meter_execute()
472 meter->used = now_ms; in ovs_meter_execute()
473 meter->stats.n_packets += 1; in ovs_meter_execute()
474 meter->stats.n_bytes += skb->len; in ovs_meter_execute()
486 cost = (meter->kbps) ? skb->len * 8 : 1000; in ovs_meter_execute()
489 for (i = 0; i < meter->n_bands; ++i) { in ovs_meter_execute()
492 band = &meter->bands[i]; in ovs_meter_execute()
509 band = &meter->bands[band_exceeded_max]; in ovs_meter_execute()
515 spin_unlock(&meter->lock); in ovs_meter_execute()
520 spin_unlock(&meter->lock); in ovs_meter_execute()
592 struct dp_meter *meter; in ovs_meters_exit() local
595 hlist_for_each_entry_safe(meter, n, head, dp_hash_node) in ovs_meters_exit()
596 kfree(meter); in ovs_meters_exit()