X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=ofproto%2Fconnmgr.c;h=ea7979570aebf8a95807f68044b5a0961824e7c4;hb=4b0424809b823101c969a0691fc1db0c880ae64a;hp=a06277262f46f7c879d5a569521c831806c07cce;hpb=c7be3f559349882c0e835a37834cfe257138e8c3;p=sliver-openvswitch.git diff --git a/ofproto/connmgr.c b/ofproto/connmgr.c index a06277262..ea7979570 100644 --- a/ofproto/connmgr.c +++ b/ofproto/connmgr.c @@ -1550,8 +1550,13 @@ do_send_packet_ins(struct ofconn *ofconn, struct list *txq) LIST_FOR_EACH_SAFE (pin, next_pin, list_node, txq) { list_remove(&pin->list_node); - rconn_send_with_limit(ofconn->rconn, pin, - ofconn->packet_in_counter, 100); + 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); + + VLOG_INFO_RL(&rl, "%s: dropping packet-in due to queue overflow", + rconn_get_name(ofconn->rconn)); + } } } @@ -1966,7 +1971,7 @@ ofmonitor_report(struct connmgr *mgr, struct rule *rule, default: case NXFME_ABBREV: - NOT_REACHED(); + OVS_NOT_REACHED(); } LIST_FOR_EACH (ofconn, node, &mgr->all_conns) {