X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=ofproto%2Fconnmgr.h;h=2869ba7880cd6a477d36ef9e4426d17fee232140;hb=12bb621f563c2644ce20922e641848c35ede98c0;hp=ea39b724edaa4db6823d7351cbfcd105e6046314;hpb=747b434cd8adc3f4ef26f456ffd45873dd748c0d;p=openvswitch diff --git a/ofproto/connmgr.h b/ofproto/connmgr.h index ea39b724..2869ba78 100644 --- a/ofproto/connmgr.h +++ b/ofproto/connmgr.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2009, 2010, 2011 Nicira Networks. + * Copyright (c) 2009, 2010, 2011, 2012 Nicira Networks. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -19,14 +19,17 @@ #include "hmap.h" #include "list.h" +#include "ofp-errors.h" #include "ofproto.h" #include "openflow/nicira-ext.h" #include "openvswitch/types.h" +struct nlattr; struct ofconn; struct ofopgroup; struct ofputil_flow_removed; struct ofputil_packet_in; +struct ofputil_phy_port; struct sset; /* ofproto supports two kinds of OpenFlow connections: @@ -49,6 +52,14 @@ enum ofconn_type { OFCONN_SERVICE /* A service connection, e.g. "ovs-ofctl". */ }; +/* The type of an OpenFlow asynchronous message. */ +enum ofconn_async_msg_type { + OAM_PACKET_IN, /* OFPT_PACKET_IN or NXT_PACKET_IN. */ + OAM_PORT_STATUS, /* OFPT_PORT_STATUS. */ + OAM_FLOW_REMOVED, /* OFPT_FLOW_REMOVED or NXT_FLOW_REMOVED. */ + OAM_N_TYPES +}; + /* Basics. */ struct connmgr *connmgr_create(struct ofproto *ofproto, const char *dpif_name, const char *local_name); @@ -81,22 +92,31 @@ enum ofconn_type ofconn_get_type(const struct ofconn *); enum nx_role ofconn_get_role(const struct ofconn *); void ofconn_set_role(struct ofconn *, enum nx_role); -enum nx_flow_format ofconn_get_flow_format(struct ofconn *); -void ofconn_set_flow_format(struct ofconn *, enum nx_flow_format); +enum ofputil_protocol ofconn_get_protocol(struct ofconn *); +void ofconn_set_protocol(struct ofconn *, enum ofputil_protocol); + +enum nx_packet_in_format ofconn_get_packet_in_format(struct ofconn *); +void ofconn_set_packet_in_format(struct ofconn *, enum nx_packet_in_format); -bool ofconn_get_flow_mod_table_id(const struct ofconn *); -void ofconn_set_flow_mod_table_id(struct ofconn *, bool enable); +void ofconn_set_controller_id(struct ofconn *, uint16_t controller_id); + +void ofconn_set_invalid_ttl_to_controller(struct ofconn *, bool); +bool ofconn_get_invalid_ttl_to_controller(struct ofconn *); int ofconn_get_miss_send_len(const struct ofconn *); void ofconn_set_miss_send_len(struct ofconn *, int miss_send_len); +void ofconn_set_async_config(struct ofconn *, + const uint32_t master_masks[OAM_N_TYPES], + const uint32_t slave_masks[OAM_N_TYPES]); + void ofconn_send_reply(const struct ofconn *, struct ofpbuf *); void ofconn_send_replies(const struct ofconn *, struct list *); void ofconn_send_error(const struct ofconn *, const struct ofp_header *request, - int error); + enum ofperr); -int ofconn_pktbuf_retrieve(struct ofconn *, uint32_t id, - struct ofpbuf **bufferp, uint16_t *in_port); +enum ofperr ofconn_pktbuf_retrieve(struct ofconn *, uint32_t id, + struct ofpbuf **bufferp, uint16_t *in_port); bool ofconn_has_pending_opgroups(const struct ofconn *); void ofconn_add_opgroup(struct ofconn *, struct list *); @@ -104,12 +124,12 @@ void ofconn_remove_opgroup(struct ofconn *, struct list *, const struct ofp_header *request, int error); /* Sending asynchronous messages. */ -void connmgr_send_port_status(struct connmgr *, const struct ofp_phy_port *, - uint8_t reason); +void connmgr_send_port_status(struct connmgr *, + const struct ofputil_phy_port *, uint8_t reason); void connmgr_send_flow_removed(struct connmgr *, const struct ofputil_flow_removed *); void connmgr_send_packet_in(struct connmgr *, const struct ofputil_packet_in *, - const struct flow *, struct ofpbuf *rw_packet); + const struct flow *); /* Fail-open settings. */ enum ofproto_fail_mode connmgr_get_fail_mode(const struct connmgr *);