diff options
author | Justin Pettit <jpettit@ovn.org> | 2018-02-27 10:44:13 -0800 |
---|---|---|
committer | Justin Pettit <jpettit@ovn.org> | 2018-02-28 14:53:19 -0800 |
commit | 7ed58d4a0daeffec52d603ad034a85d0d3011c8d (patch) | |
tree | 5ae48dfbddc1ee3b35dc3293106d86e43d2e2fec | |
parent | 1139c77dffe6217a118ec2bd9009cbee06e588fb (diff) | |
download | openvswitch-7ed58d4a0daeffec52d603ad034a85d0d3011c8d.tar.gz |
Don't shadow global VLOG "rl" definition.
Signed-off-by: Justin Pettit <jpettit@ovn.org>
Acked-by: Ben Pfaff <blp@ovn.org>
-rw-r--r-- | lib/netdev-linux.c | 8 | ||||
-rw-r--r-- | lib/ofp-actions.c | 18 | ||||
-rw-r--r-- | lib/ofp-port.c | 4 | ||||
-rw-r--r-- | ofproto/connmgr.c | 4 | ||||
-rw-r--r-- | ofproto/ofproto-dpif-upcall.c | 15 | ||||
-rw-r--r-- | ofproto/ofproto-dpif.c | 12 | ||||
-rw-r--r-- | ofproto/ofproto.c | 4 |
7 files changed, 33 insertions, 32 deletions
diff --git a/lib/netdev-linux.c b/lib/netdev-linux.c index 4e0473cf3..b3ef0f7c0 100644 --- a/lib/netdev-linux.c +++ b/lib/netdev-linux.c @@ -635,7 +635,6 @@ netdev_linux_run(const struct netdev_class *netdev_class OVS_UNUSED) } do { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); uint64_t buf_stub[4096 / 8]; struct ofpbuf buf; @@ -686,7 +685,8 @@ netdev_linux_run(const struct netdev_class *netdev_class OVS_UNUSED) } shash_destroy(&device_shash); } else if (error != EAGAIN) { - VLOG_WARN_RL(&rl, "error reading or parsing netlink (%s)", + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_WARN_RL(&rll, "error reading or parsing netlink (%s)", ovs_strerror(error)); } ofpbuf_uninit(&buf); @@ -789,8 +789,8 @@ netdev_linux_common_construct(struct netdev *netdev_) struct netdev_linux *netdev = netdev_linux_cast(netdev_); const char *name = netdev_->name; if (!strcmp(name, "default") || !strcmp(name, "all")) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); - VLOG_WARN_RL(&rl, "%s: Linux forbids network device with this name", + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 1); + VLOG_WARN_RL(&rll, "%s: Linux forbids network device with this name", name); return EINVAL; } diff --git a/lib/ofp-actions.c b/lib/ofp-actions.c index 7c076f65f..db857162e 100644 --- a/lib/ofp-actions.c +++ b/lib/ofp-actions.c @@ -1318,7 +1318,7 @@ decode_bundle(bool load, const struct nx_action_bundle *nab, const struct vl_mff_map *vl_mff_map, uint64_t *tlv_bitmap, struct ofpbuf *ofpacts) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); struct ofpact_bundle *bundle; uint32_t slave_type; size_t slaves_size, i; @@ -1335,20 +1335,20 @@ decode_bundle(bool load, const struct nx_action_bundle *nab, error = OFPERR_OFPBAC_BAD_ARGUMENT; if (!flow_hash_fields_valid(bundle->fields)) { - VLOG_WARN_RL(&rl, "unsupported fields %d", (int) bundle->fields); + VLOG_WARN_RL(&rll, "unsupported fields %d", (int) bundle->fields); } else if (bundle->n_slaves > BUNDLE_MAX_SLAVES) { - VLOG_WARN_RL(&rl, "too many slaves"); + VLOG_WARN_RL(&rll, "too many slaves"); } else if (bundle->algorithm != NX_BD_ALG_HRW && bundle->algorithm != NX_BD_ALG_ACTIVE_BACKUP) { - VLOG_WARN_RL(&rl, "unsupported algorithm %d", (int) bundle->algorithm); + VLOG_WARN_RL(&rll, "unsupported algorithm %d", (int) bundle->algorithm); } else if (slave_type != mf_nxm_header(MFF_IN_PORT)) { - VLOG_WARN_RL(&rl, "unsupported slave type %"PRIu32, slave_type); + VLOG_WARN_RL(&rll, "unsupported slave type %"PRIu32, slave_type); } else { error = 0; } if (!is_all_zeros(nab->zero, sizeof nab->zero)) { - VLOG_WARN_RL(&rl, "reserved field is nonzero"); + VLOG_WARN_RL(&rll, "reserved field is nonzero"); error = OFPERR_OFPBAC_BAD_ARGUMENT; } @@ -1362,19 +1362,19 @@ decode_bundle(bool load, const struct nx_action_bundle *nab, } if (bundle->dst.n_bits < 16) { - VLOG_WARN_RL(&rl, "bundle_load action requires at least 16 bit " + VLOG_WARN_RL(&rll, "bundle_load action requires at least 16 bit " "destination."); error = OFPERR_OFPBAC_BAD_ARGUMENT; } } else { if (nab->ofs_nbits || nab->dst) { - VLOG_WARN_RL(&rl, "bundle action has nonzero reserved fields"); + VLOG_WARN_RL(&rll, "bundle action has nonzero reserved fields"); error = OFPERR_OFPBAC_BAD_ARGUMENT; } } if (slaves_size < bundle->n_slaves * sizeof(ovs_be16)) { - VLOG_WARN_RL(&rl, "Nicira action %s only has %"PRIuSIZE" bytes " + VLOG_WARN_RL(&rll, "Nicira action %s only has %"PRIuSIZE" bytes " "allocated for slaves. %"PRIuSIZE" bytes are required " "for %u slaves.", load ? "bundle_load" : "bundle", slaves_size, diff --git a/lib/ofp-port.c b/lib/ofp-port.c index 86562c9b4..cff37290e 100644 --- a/lib/ofp-port.c +++ b/lib/ofp-port.c @@ -91,8 +91,8 @@ ofputil_port_from_ofp11(ovs_be32 ofp11_port, ofp_port_t *ofp10_port) } else { *ofp10_port = OFPP_NONE; - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); - VLOG_WARN_RL(&rl, "port %"PRIu32" is outside the supported " + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_WARN_RL(&rll, "port %"PRIu32" is outside the supported " "range 0 through %d or 0x%"PRIx32" through 0x%"PRIx32, ofp11_port_h, ofp_to_u16(OFPP_MAX) - 1, ofp11_to_u32(OFPP11_MAX), UINT32_MAX); diff --git a/ofproto/connmgr.c b/ofproto/connmgr.c index e0e78a1e1..bf43fbd73 100644 --- a/ofproto/connmgr.c +++ b/ofproto/connmgr.c @@ -1761,9 +1761,9 @@ do_send_packet_ins(struct ofconn *ofconn, struct ovs_list *txq) LIST_FOR_EACH_POP (pin, list_node, txq) { if (rconn_send_with_limit(ofconn->rconn, pin, ofconn->packet_in_counter, 100) == EAGAIN) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 5); + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(5, 5); - VLOG_INFO_RL(&rl, "%s: dropping packet-in due to queue overflow", + VLOG_INFO_RL(&rll, "%s: dropping packet-in due to queue overflow", rconn_get_name(ofconn->rconn)); } } diff --git a/ofproto/ofproto-dpif-upcall.c b/ofproto/ofproto-dpif-upcall.c index 23e459b06..e282a437e 100644 --- a/ofproto/ofproto-dpif-upcall.c +++ b/ofproto/ofproto-dpif-upcall.c @@ -1252,7 +1252,6 @@ upcall_cb(const struct dp_packet *packet, const struct flow *flow, ovs_u128 *ufi const struct nlattr *userdata, struct ofpbuf *actions, struct flow_wildcards *wc, struct ofpbuf *put_actions, void *aux) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); struct udpif *udpif = aux; struct upcall upcall; bool megaflow; @@ -1287,7 +1286,8 @@ upcall_cb(const struct dp_packet *packet, const struct flow *flow, ovs_u128 *ufi } if (upcall.ukey && !ukey_install(udpif, upcall.ukey)) { - VLOG_WARN_RL(&rl, "upcall_cb failure: ukey installation fails"); + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 1); + VLOG_WARN_RL(&rll, "upcall_cb failure: ukey installation fails"); error = ENOSPC; } out: @@ -2355,9 +2355,8 @@ push_dp_ops(struct udpif *udpif, struct ukey_op *ops, size_t n_ops) error = xlate_key(udpif, key, key_len, push, &ctx); if (error) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); - - VLOG_WARN_RL(&rl, "xlate_key failed (%s)!", + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_WARN_RL(&rll, "xlate_key failed (%s)!", ovs_strerror(error)); } else { xlate_out_uninit(&ctx.xout); @@ -2390,13 +2389,15 @@ push_ukey_ops(struct udpif *udpif, struct umap *umap, static void log_unexpected_flow(const struct dpif_flow *flow, int error) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(10, 60); struct ds ds = DS_EMPTY_INITIALIZER; ds_put_format(&ds, "Failed to acquire udpif_key corresponding to " "unexpected flow (%s): ", ovs_strerror(error)); odp_format_ufid(&flow->ufid, &ds); - VLOG_WARN_RL(&rl, "%s", ds_cstr(&ds)); + + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(10, 60); + VLOG_WARN_RL(&rll, "%s", ds_cstr(&ds)); + ds_destroy(&ds); } diff --git a/ofproto/ofproto-dpif.c b/ofproto/ofproto-dpif.c index 0fee6f9c5..e28ce64c1 100644 --- a/ofproto/ofproto-dpif.c +++ b/ofproto/ofproto-dpif.c @@ -3210,7 +3210,6 @@ bundle_remove(struct ofport *port_) static void send_pdu_cb(void *port_, const void *pdu, size_t pdu_size) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 10); struct ofport_dpif *port = port_; struct eth_addr ea; int error; @@ -3228,7 +3227,8 @@ send_pdu_cb(void *port_, const void *pdu, size_t pdu_size) ofproto_dpif_send_packet(port, false, &packet); dp_packet_uninit(&packet); } else { - VLOG_ERR_RL(&rl, "port %s: cannot obtain Ethernet address of iface " + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 10); + VLOG_ERR_RL(&rll, "port %s: cannot obtain Ethernet address of iface " "%s (%s)", port->bundle->name, netdev_get_name(port->up.netdev), ovs_strerror(error)); } @@ -3275,8 +3275,8 @@ bundle_send_learning_packets(struct ofbundle *bundle) } if (n_errors) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); - VLOG_WARN_RL(&rl, "bond %s: %d errors sending %d gratuitous learning " + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_WARN_RL(&rll, "bond %s: %d errors sending %d gratuitous learning " "packets, last error was: %s", bundle->name, n_errors, n_packets, ovs_strerror(error)); } else { @@ -4296,8 +4296,8 @@ check_mask(struct ofproto_dpif *ofproto, const struct miniflow *flow) static void report_unsupported_act(const char *action, const char *detail) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); - VLOG_WARN_RL(&rl, "Rejecting %s action because datapath does not support" + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_WARN_RL(&rll, "Rejecting %s action because datapath does not support" "%s%s (your kernel module may be out of date)", action, detail ? " " : "", detail ? detail : ""); } diff --git a/ofproto/ofproto.c b/ofproto/ofproto.c index a982de9d8..0e73d4e82 100644 --- a/ofproto/ofproto.c +++ b/ofproto/ofproto.c @@ -5131,8 +5131,8 @@ ofproto_flow_mod_learn(struct ofproto_flow_mod *ofm, bool keep_ref, ofproto_flow_mod_learn_finish(ofm, NULL); } } else { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); - VLOG_INFO_RL(&rl, "Learn limit for flow %"PRIu64" reached.", + static struct vlog_rate_limit rll = VLOG_RATE_LIMIT_INIT(1, 5); + VLOG_INFO_RL(&rll, "Learn limit for flow %"PRIu64" reached.", rule->flow_cookie); ofproto_flow_mod_uninit(ofm); |