X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=ofproto%2Fofproto-sflow.c;h=3739911d1e1a0f1a2c695e2326393abf1ecd9314;hb=f1588b1f;hp=076bd79c474a9ac21650e67636a50a306b0995e7;hpb=0cc96e48ab2fc573c3b7b69fe5a034bb29dde578;p=openvswitch diff --git a/ofproto/ofproto-sflow.c b/ofproto/ofproto-sflow.c index 076bd79c..3739911d 100644 --- a/ofproto/ofproto-sflow.c +++ b/ofproto/ofproto-sflow.c @@ -1,6 +1,6 @@ /* - * Copyright (c) 2009, 2010 InMon Corp. - * Copyright (c) 2009 Nicira Networks. + * Copyright (c) 2009, 2010 Nicira Networks. + * Copyright (c) 2009 InMon Corp. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -140,7 +140,7 @@ ofproto_sflow_find_port(const struct ofproto_sflow *os, uint16_t odp_port) { struct ofproto_sflow_port *osp; - HMAP_FOR_EACH_IN_BUCKET (osp, struct ofproto_sflow_port, hmap_node, + HMAP_FOR_EACH_IN_BUCKET (osp, hmap_node, hash_int(odp_port, 0), &os->ports) { if (osp->odp_port == odp_port) { return osp; @@ -297,8 +297,7 @@ ofproto_sflow_destroy(struct ofproto_sflow *os) struct ofproto_sflow_port *osp, *next; ofproto_sflow_clear(os); - HMAP_FOR_EACH_SAFE (osp, next, struct ofproto_sflow_port, hmap_node, - &os->ports) { + HMAP_FOR_EACH_SAFE (osp, next, hmap_node, &os->ports) { ofproto_sflow_del_port__(os, osp); } hmap_destroy(&os->ports); @@ -463,7 +462,7 @@ ofproto_sflow_set_options(struct ofproto_sflow *os, MAX(1, UINT32_MAX / options->sampling_rate)); /* Add samplers and pollers for the currently known ports. */ - HMAP_FOR_EACH (osp, struct ofproto_sflow_port, hmap_node, &os->ports) { + HMAP_FOR_EACH (osp, hmap_node, &os->ports) { ofproto_sflow_add_poller(os, osp, osp->odp_port); ofproto_sflow_add_sampler(os, osp); } @@ -574,12 +573,6 @@ ofproto_sflow_received(struct ofproto_sflow *os, struct odp_msg *msg) n_outputs++; break; - case ODPAT_OUTPUT_GROUP: - n_outputs += (a->output_group.group == DP_GROUP_FLOOD ? os->n_flood - : a->output_group.group == DP_GROUP_ALL ? os->n_all - : 0); - break; - case ODPAT_SET_VLAN_VID: switchElem.flowType.sw.dst_vlan = ntohs(a->vlan_vid.vlan_vid); break; @@ -610,14 +603,6 @@ ofproto_sflow_received(struct ofproto_sflow *os, struct odp_msg *msg) sfl_sampler_writeFlowSample(sampler, &fs); } -void -ofproto_sflow_set_group_sizes(struct ofproto_sflow *os, - size_t n_flood, size_t n_all) -{ - os->n_flood = n_flood; - os->n_all = n_all; -} - void ofproto_sflow_run(struct ofproto_sflow *os) {