static struct ofconn *ofconn_create(struct ofproto *, struct rconn *,
enum ofconn_type);
static void ofconn_destroy(struct ofconn *);
-static void ofconn_run(struct ofconn *, struct ofproto *);
+static void ofconn_run(struct ofconn *);
static void ofconn_wait(struct ofconn *);
static bool ofconn_receives_async_msgs(const struct ofconn *);
static char *ofconn_make_name(const struct ofproto *, const char *target);
static void handle_odp_msg(struct ofproto *, struct ofpbuf *);
-static void handle_openflow(struct ofconn *, struct ofproto *,
- struct ofpbuf *);
+static void handle_openflow(struct ofconn *, struct ofpbuf *);
static struct ofport *get_port(const struct ofproto *, uint16_t odp_port);
static void update_port(struct ofproto *, const char *devname);
}
LIST_FOR_EACH_SAFE (ofconn, next_ofconn, node, &p->all_conns) {
- ofconn_run(ofconn, p);
+ ofconn_run(ofconn);
}
/* Fail-open maintenance. Do this after processing the ofconns since
}
static void
-ofconn_run(struct ofconn *ofconn, struct ofproto *p)
+ofconn_run(struct ofconn *ofconn)
{
+ struct ofproto *p = ofconn->ofproto;
int iteration;
size_t i;
if (p->fail_open) {
fail_open_maybe_recover(p->fail_open);
}
- handle_openflow(ofconn, p, of_msg);
+ handle_openflow(ofconn, of_msg);
ofpbuf_delete(of_msg);
}
}
}
static int
-handle_features_request(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_header *oh)
+handle_features_request(struct ofconn *ofconn, struct ofp_header *oh)
{
struct ofp_switch_features *osf;
struct ofpbuf *buf;
struct ofport *port;
osf = make_openflow_xid(sizeof *osf, OFPT_FEATURES_REPLY, oh->xid, &buf);
- osf->datapath_id = htonll(p->datapath_id);
+ osf->datapath_id = htonll(ofconn->ofproto->datapath_id);
osf->n_buffers = htonl(pktbuf_capacity());
osf->n_tables = 2;
osf->capabilities = htonl(OFPC_FLOW_STATS | OFPC_TABLE_STATS |
(1u << OFPAT_SET_TP_DST) |
(1u << OFPAT_ENQUEUE));
- HMAP_FOR_EACH (port, hmap_node, &p->ports) {
+ HMAP_FOR_EACH (port, hmap_node, &ofconn->ofproto->ports) {
hton_ofp_phy_port(ofpbuf_put(buf, &port->opp, sizeof port->opp));
}
}
static int
-handle_get_config_request(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_header *oh)
+handle_get_config_request(struct ofconn *ofconn, struct ofp_header *oh)
{
struct ofpbuf *buf;
struct ofp_switch_config *osc;
bool drop_frags;
/* Figure out flags. */
- dpif_get_drop_frags(p->dpif, &drop_frags);
+ dpif_get_drop_frags(ofconn->ofproto->dpif, &drop_frags);
flags = drop_frags ? OFPC_FRAG_DROP : OFPC_FRAG_NORMAL;
/* Send reply. */
}
static int
-handle_set_config(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_switch_config *osc)
+handle_set_config(struct ofconn *ofconn, struct ofp_switch_config *osc)
{
uint16_t flags;
int error;
if (ofconn->type == OFCONN_PRIMARY && ofconn->role != NX_ROLE_SLAVE) {
switch (flags & OFPC_FRAG_MASK) {
case OFPC_FRAG_NORMAL:
- dpif_set_drop_frags(p->dpif, false);
+ dpif_set_drop_frags(ofconn->ofproto->dpif, false);
break;
case OFPC_FRAG_DROP:
- dpif_set_drop_frags(p->dpif, true);
+ dpif_set_drop_frags(ofconn->ofproto->dpif, true);
break;
default:
VLOG_WARN_RL(&rl, "requested bad fragment mode (flags=%"PRIx16")",
}
static int
-handle_packet_out(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_header *oh)
+handle_packet_out(struct ofconn *ofconn, struct ofp_header *oh)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofp_packet_out *opo;
struct ofpbuf payload, *buffer;
struct odp_actions actions;
}
static int
-handle_port_mod(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_header *oh)
+handle_port_mod(struct ofconn *ofconn, struct ofp_header *oh)
{
+ struct ofproto *p = ofconn->ofproto;
const struct ofp_port_mod *opm;
struct ofport *port;
int error;
}
static int
-handle_desc_stats_request(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_stats_request *request)
+handle_desc_stats_request(struct ofconn *ofconn,
+ struct ofp_stats_request *request)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofp_desc_stats *ods;
struct ofpbuf *msg;
}
static int
-handle_table_stats_request(struct ofproto *p, struct ofconn *ofconn,
+handle_table_stats_request(struct ofconn *ofconn,
struct ofp_stats_request *request)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofp_table_stats *ots;
struct ofpbuf *msg;
struct rule *rule;
}
static int
-handle_port_stats_request(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_stats_request *osr,
+handle_port_stats_request(struct ofconn *ofconn, struct ofp_stats_request *osr,
size_t arg_size)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofp_port_stats_request *psr;
struct ofp_port_stats *ops;
struct ofpbuf *msg;
}
struct flow_stats_cbdata {
- struct ofproto *ofproto;
struct ofconn *ofconn;
ovs_be16 out_port;
struct ofpbuf *msg;
act_len = sizeof *rule->actions * rule->n_actions;
len = offsetof(struct ofp_flow_stats, actions) + act_len;
- query_stats(cbdata->ofproto, rule, &packet_count, &byte_count);
+ query_stats(cbdata->ofconn->ofproto, rule, &packet_count, &byte_count);
ofs = append_stats_reply(len, cbdata->ofconn, &cbdata->msg);
ofs->length = htons(len);
}
static int
-handle_flow_stats_request(struct ofproto *p, struct ofconn *ofconn,
- const struct ofp_stats_request *osr,
- size_t arg_size)
+handle_flow_stats_request(struct ofconn *ofconn,
+ const struct ofp_stats_request *osr, size_t arg_size)
{
struct ofp_flow_stats_request *fsr;
struct flow_stats_cbdata cbdata;
fsr = (struct ofp_flow_stats_request *) osr->body;
COVERAGE_INC(ofproto_flows_req);
- cbdata.ofproto = p;
cbdata.ofconn = ofconn;
cbdata.out_port = fsr->out_port;
cbdata.msg = start_stats_reply(osr, 1024);
cls_rule_from_match(&fsr->match, 0, NXFF_OPENFLOW10, 0, &target);
- classifier_for_each_match(&p->cls, &target,
+ classifier_for_each_match(&ofconn->ofproto->cls, &target,
table_id_to_include(fsr->table_id),
flow_stats_cb, &cbdata);
queue_tx(cbdata.msg, ofconn, ofconn->reply_counter);
}
static int
-handle_aggregate_stats_request(struct ofproto *p, struct ofconn *ofconn,
+handle_aggregate_stats_request(struct ofconn *ofconn,
const struct ofp_stats_request *osr,
size_t arg_size)
{
asr = (struct ofp_aggregate_stats_request *) osr->body;
COVERAGE_INC(ofproto_agg_request);
- cbdata.ofproto = p;
+ cbdata.ofproto = ofconn->ofproto;
cbdata.out_port = asr->out_port;
cbdata.packet_count = 0;
cbdata.byte_count = 0;
cbdata.n_flows = 0;
cls_rule_from_match(&asr->match, 0, NXFF_OPENFLOW10, 0, &target);
- classifier_for_each_match(&p->cls, &target,
+ classifier_for_each_match(&ofconn->ofproto->cls, &target,
table_id_to_include(asr->table_id),
aggregate_stats_cb, &cbdata);
}
static int
-handle_queue_stats_request(struct ofproto *ofproto, struct ofconn *ofconn,
+handle_queue_stats_request(struct ofconn *ofconn,
const struct ofp_stats_request *osr,
size_t arg_size)
{
+ struct ofproto *ofproto = ofconn->ofproto;
struct ofp_queue_stats_request *qsr;
struct queue_stats_cbdata cbdata;
struct ofport *port;
}
static int
-handle_stats_request(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_header *oh)
+handle_stats_request(struct ofconn *ofconn, struct ofp_header *oh)
{
struct ofp_stats_request *osr;
size_t arg_size;
switch (ntohs(osr->type)) {
case OFPST_DESC:
- return handle_desc_stats_request(p, ofconn, osr);
+ return handle_desc_stats_request(ofconn, osr);
case OFPST_FLOW:
- return handle_flow_stats_request(p, ofconn, osr, arg_size);
+ return handle_flow_stats_request(ofconn, osr, arg_size);
case OFPST_AGGREGATE:
- return handle_aggregate_stats_request(p, ofconn, osr, arg_size);
+ return handle_aggregate_stats_request(ofconn, osr, arg_size);
case OFPST_TABLE:
- return handle_table_stats_request(p, ofconn, osr);
+ return handle_table_stats_request(ofconn, osr);
case OFPST_PORT:
- return handle_port_stats_request(p, ofconn, osr, arg_size);
+ return handle_port_stats_request(ofconn, osr, arg_size);
case OFPST_QUEUE:
- return handle_queue_stats_request(p, ofconn, osr, arg_size);
+ return handle_queue_stats_request(ofconn, osr, arg_size);
case OFPST_VENDOR:
return ofp_mkerr(OFPET_BAD_REQUEST, OFPBRC_BAD_VENDOR);
* in which no matching flow already exists in the flow table.
*
* Adds the flow specified by 'ofm', which is followed by 'n_actions'
- * ofp_actions, to 'p''s flow table. Returns 0 on success or an OpenFlow error
- * code as encoded by ofp_mkerr() on failure.
+ * ofp_actions, to ofconn->ofproto's flow table. Returns 0 on success or an
+ * OpenFlow error code as encoded by ofp_mkerr() on failure.
*
* 'ofconn' is used to retrieve the packet buffer specified in ofm->buffer_id,
* if any. */
static int
-add_flow(struct ofproto *p, struct ofconn *ofconn,
- const struct ofp_flow_mod *ofm, size_t n_actions)
+add_flow(struct ofconn *ofconn, const struct ofp_flow_mod *ofm,
+ size_t n_actions)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofpbuf *packet;
struct rule *rule;
uint16_t in_port;
}
static struct rule *
-find_flow_strict(struct ofproto *p, struct ofconn *ofconn,
- const struct ofp_flow_mod *ofm)
+find_flow_strict(struct ofconn *ofconn, const struct ofp_flow_mod *ofm)
{
+ struct ofproto *p = ofconn->ofproto;
struct cls_rule target;
cls_rule_from_match(&ofm->match, ntohs(ofm->priority),
}
static int
-send_buffered_packet(struct ofproto *ofproto, struct ofconn *ofconn,
+send_buffered_packet(struct ofconn *ofconn,
struct rule *rule, const struct ofp_flow_mod *ofm)
{
struct ofpbuf *packet;
}
flow_extract(packet, 0, in_port, &flow);
- rule_execute(ofproto, rule, packet, &flow);
+ rule_execute(ofconn->ofproto, rule, packet, &flow);
return 0;
}
* 'ofconn' is used to retrieve the packet buffer specified in ofm->buffer_id,
* if any. */
static int
-modify_flows_loose(struct ofproto *p, struct ofconn *ofconn,
+modify_flows_loose(struct ofconn *ofconn,
const struct ofp_flow_mod *ofm, size_t n_actions)
{
struct modify_flows_cbdata cbdata;
struct cls_rule target;
- cbdata.ofproto = p;
+ cbdata.ofproto = ofconn->ofproto;
cbdata.ofm = ofm;
cbdata.n_actions = n_actions;
cbdata.match = NULL;
cls_rule_from_match(&ofm->match, 0, ofconn->flow_format,
ofm->cookie, &target);
- classifier_for_each_match(&p->cls, &target, CLS_INC_ALL,
+ classifier_for_each_match(&ofconn->ofproto->cls, &target, CLS_INC_ALL,
modify_flows_cb, &cbdata);
if (cbdata.match) {
/* This credits the packet to whichever flow happened to happened to
* match last. That's weird. Maybe we should do a lookup for the
* flow that actually matches the packet? Who knows. */
- send_buffered_packet(p, ofconn, cbdata.match, ofm);
+ send_buffered_packet(ofconn, cbdata.match, ofm);
return 0;
} else {
- return add_flow(p, ofconn, ofm, n_actions);
+ return add_flow(ofconn, ofm, n_actions);
}
}
* 'ofconn' is used to retrieve the packet buffer specified in ofm->buffer_id,
* if any. */
static int
-modify_flow_strict(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_flow_mod *ofm, size_t n_actions)
+modify_flow_strict(struct ofconn *ofconn, struct ofp_flow_mod *ofm,
+ size_t n_actions)
{
- struct rule *rule = find_flow_strict(p, ofconn, ofm);
+ struct rule *rule = find_flow_strict(ofconn, ofm);
if (rule && !rule_is_hidden(rule)) {
- modify_flow(p, ofm, n_actions, rule);
- return send_buffered_packet(p, ofconn, rule, ofm);
+ modify_flow(ofconn->ofproto, ofm, n_actions, rule);
+ return send_buffered_packet(ofconn, rule, ofm);
} else {
- return add_flow(p, ofconn, ofm, n_actions);
+ return add_flow(ofconn, ofm, n_actions);
}
}
/* Implements OFPFC_DELETE. */
static void
-delete_flows_loose(struct ofproto *p, struct ofconn *ofconn,
- const struct ofp_flow_mod *ofm)
+delete_flows_loose(struct ofconn *ofconn, const struct ofp_flow_mod *ofm)
{
struct delete_flows_cbdata cbdata;
struct cls_rule target;
- cbdata.ofproto = p;
+ cbdata.ofproto = ofconn->ofproto;
cbdata.out_port = ofm->out_port;
cls_rule_from_match(&ofm->match, 0, ofconn->flow_format,
ofm->cookie, &target);
- classifier_for_each_match(&p->cls, &target, CLS_INC_ALL,
+ classifier_for_each_match(&ofconn->ofproto->cls, &target, CLS_INC_ALL,
delete_flows_cb, &cbdata);
}
/* Implements OFPFC_DELETE_STRICT. */
static void
-delete_flow_strict(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_flow_mod *ofm)
+delete_flow_strict(struct ofconn *ofconn, struct ofp_flow_mod *ofm)
{
- struct rule *rule = find_flow_strict(p, ofconn, ofm);
+ struct rule *rule = find_flow_strict(ofconn, ofm);
if (rule) {
- delete_flow(p, rule, ofm->out_port);
+ delete_flow(ofconn->ofproto, rule, ofm->out_port);
}
}
}
\f
static int
-handle_flow_mod(struct ofproto *p, struct ofconn *ofconn,
- struct ofp_flow_mod *ofm)
+handle_flow_mod(struct ofconn *ofconn, struct ofp_flow_mod *ofm)
{
struct ofp_match orig_match;
size_t n_actions;
}
error = validate_actions((const union ofp_action *) ofm->actions,
- n_actions, p->max_ports);
+ n_actions, ofconn->ofproto->max_ports);
if (error) {
return error;
}
switch (ntohs(ofm->command)) {
case OFPFC_ADD:
- return add_flow(p, ofconn, ofm, n_actions);
+ return add_flow(ofconn, ofm, n_actions);
case OFPFC_MODIFY:
- return modify_flows_loose(p, ofconn, ofm, n_actions);
+ return modify_flows_loose(ofconn, ofm, n_actions);
case OFPFC_MODIFY_STRICT:
- return modify_flow_strict(p, ofconn, ofm, n_actions);
+ return modify_flow_strict(ofconn, ofm, n_actions);
case OFPFC_DELETE:
- delete_flows_loose(p, ofconn, ofm);
+ delete_flows_loose(ofconn, ofm);
return 0;
case OFPFC_DELETE_STRICT:
- delete_flow_strict(p, ofconn, ofm);
+ delete_flow_strict(ofconn, ofm);
return 0;
default:
}
static int
-handle_role_request(struct ofproto *ofproto,
- struct ofconn *ofconn, struct nicira_header *msg)
+handle_role_request(struct ofconn *ofconn, struct nicira_header *msg)
{
struct nx_role_request *nrr;
struct nx_role_request *reply;
if (role == NX_ROLE_MASTER) {
struct ofconn *other;
- HMAP_FOR_EACH (other, hmap_node, &ofproto->controllers) {
+ HMAP_FOR_EACH (other, hmap_node, &ofconn->ofproto->controllers) {
if (other->role == NX_ROLE_MASTER) {
other->role = NX_ROLE_SLAVE;
}
}
static int
-handle_vendor(struct ofproto *p, struct ofconn *ofconn, void *msg)
+handle_vendor(struct ofconn *ofconn, void *msg)
{
+ struct ofproto *p = ofconn->ofproto;
struct ofp_vendor_header *ovh = msg;
struct nicira_header *nh;
return handle_tun_id_from_cookie(ofconn, msg);
case NXT_ROLE_REQUEST:
- return handle_role_request(p, ofconn, msg);
+ return handle_role_request(ofconn, msg);
}
return ofp_mkerr(OFPET_BAD_REQUEST, OFPBRC_BAD_SUBTYPE);
}
static void
-handle_openflow(struct ofconn *ofconn, struct ofproto *p,
- struct ofpbuf *ofp_msg)
+handle_openflow(struct ofconn *ofconn, struct ofpbuf *ofp_msg)
{
struct ofp_header *oh = ofp_msg->data;
int error;
break;
case OFPT_FEATURES_REQUEST:
- error = handle_features_request(p, ofconn, oh);
+ error = handle_features_request(ofconn, oh);
break;
case OFPT_GET_CONFIG_REQUEST:
- error = handle_get_config_request(p, ofconn, oh);
+ error = handle_get_config_request(ofconn, oh);
break;
case OFPT_SET_CONFIG:
- error = handle_set_config(p, ofconn, ofp_msg->data);
+ error = handle_set_config(ofconn, ofp_msg->data);
break;
case OFPT_PACKET_OUT:
- error = handle_packet_out(p, ofconn, ofp_msg->data);
+ error = handle_packet_out(ofconn, ofp_msg->data);
break;
case OFPT_PORT_MOD:
- error = handle_port_mod(p, ofconn, oh);
+ error = handle_port_mod(ofconn, oh);
break;
case OFPT_FLOW_MOD:
- error = handle_flow_mod(p, ofconn, ofp_msg->data);
+ error = handle_flow_mod(ofconn, ofp_msg->data);
break;
case OFPT_STATS_REQUEST:
- error = handle_stats_request(p, ofconn, oh);
+ error = handle_stats_request(ofconn, oh);
break;
case OFPT_VENDOR:
- error = handle_vendor(p, ofconn, ofp_msg->data);
+ error = handle_vendor(ofconn, ofp_msg->data);
break;
case OFPT_BARRIER_REQUEST: