return True
# We filter duplicates. Go through the chains and rules, letting
- # the *last* occurrence take precendence since it could have a
+ # the *last* occurrence take precedence since it could have a
# non-zero [packet:byte] count we want to preserve. We also filter
# out anything in the "remove" list.
new_filter.reverse()
:param which_service: The name of the service for which the WSGI resources
are being created. This name will be used to pass
the appropriate plugin to the WSGI resource.
- It can be set to None or "CORE"to create WSGI
- resources for the the core plugin
+ It can be set to None or "CORE" to create WSGI
+ resources for the core plugin
:param action_map: custom resource actions
:param register_quota: it can be set to True to register quotas for the
resource(s) being created
def parse_mappings(mapping_list, unique_values=True):
- """Parse a list of of mapping strings into a dictionary.
+ """Parse a list of mapping strings into a dictionary.
:param mapping_list: a list of strings of the form '<key>:<value>'
:param unique_values: values must be unique if True
super(L3_NAT_db_mixin, self)._update_router_gw_info(
context, router_id, info, router=router)
# Returning the router might come back useful if this
- # method is overriden in child classes
+ # method is overridden in child classes
return router
def _build_routers_list(self, context, routers, gw_ports):
def _determine_port_security_and_has_ip(self, context, port):
"""Returns a tuple of booleans (port_security_enabled, has_ip).
- Port_security is the value assocated with the port if one is present
+ Port_security is the value associated with the port if one is present
otherwise the value associated with the network is returned. has_ip is
if the port is associated with an ip or not.
"""
# remote_group_id. Therefore it is not possible to do this
# query unless the behavior of _get_collection()
# is changed which cannot be because other methods are already
- # relying on this behavor. Therefore, we do the filtering
+ # relying on this behavior. Therefore, we do the filtering
# below to check for these corner cases.
for db_rule in db_rules:
# need to remove id from db_rule for matching
class ProviderResourceAssociation(model_base.BASEV2):
provider_name = sa.Column(sa.String(255),
nullable=False, primary_key=True)
- # should be manualy deleted on resource deletion
+ # should be manually deleted on resource deletion
resource_id = sa.Column(sa.String(36), nullable=False, primary_key=True,
unique=True)
@property
def _plugin(self):
# NOTE(arosen): this cannot be set in __init__ currently since
- # this class is initalized at the same time as NeutronManager()
+ # this class is initialized at the same time as NeutronManager()
# which is decorated with synchronized()
if not hasattr(self, '_plugin_ref'):
self._plugin_ref = manager.NeutronManager.get_plugin()
:param external: The external keyword argument denotes whether this lock
should work across multiple processes. This means that if two different
- workers both run a a method decorated with @synchronized('mylock',
+ workers both run a method decorated with @synchronized('mylock',
external=True), only one of them will execute at a time.
:param lock_path: The lock_path keyword argument is used to specify a
@put_context_in_serverpool
def create_port(self, context, port):
"""Create a port, which is a connection point of a device
- (e.g., a VM NIC) to attach to a L2 Neutron network.
+ (e.g., a VM NIC) to attach an L2 Neutron network.
:param context: neutron api request context
:param port: dictionary describing the port
:returns:
{
- "id": uuid represeting the port.
+ "id": uuid representing the port.
"network_id": uuid of network.
"tenant_id": tenant_id
"mac_address": mac address to use on this port.
does not forward packets.
"status": dicates whether port is currently operational
(limit values to "ACTIVE", "DOWN", "BUILD", and "ERROR")
- "fixed_ips": list of subnet ID"s and IP addresses to be used on
+ "fixed_ips": list of subnet IDs and IP addresses to be used on
this port
"device_id": identifies the device (e.g., virtual server) using
this port.
:returns: a mapping sequence with the following signature:
{
- "id": uuid represeting the port.
+ "id": uuid representing the port.
"network_id": uuid of network.
"tenant_id": tenant_id
"mac_address": mac address to use on this port.
does not forward packets.
"status": dicates whether port is currently operational
(limit values to "ACTIVE", "DOWN", "BUILD", and "ERROR")
- "fixed_ips": list of subnet ID's and IP addresses to be used on
+ "fixed_ips": list of subnet IDs and IP addresses to be used on
this port
"device_id": identifies the device (e.g., virtual server) using
this port.
subclass of :class:`~HTTPClientError`
- This indicates that the server could not update the port state to
+ This indicates that the server could not update the port state
to the request value
code: 431, title: Requested State Invalid
"""
Setup Cisco Nexus 1000V related parameters and pull policy profiles.
- Retrieve all the policy profiles from the VSM when the plugin is
+ Retrieve all the policy profiles from the VSM when the plugin
is instantiated for the first time and then continue to poll for
policy profile updates.
"""
try:
self._rpc.delete_this_region()
msg = _('No Tenants configured in Neutron DB. But %d '
- 'tenants disovered in EOS during synchronization.'
- 'Enitre EOS region is cleared') % len(eos_tenants)
+ 'tenants discovered in EOS during synchronization.'
+ 'Entire EOS region is cleared') % len(eos_tenants)
LOG.info(msg)
# Re-register with EOS so that the timestamp is updated.
self._rpc.register_with_eos()
# Region has been completely cleaned. So there is nothing to
- # syncronize
+ # synchronize
self._force_sync = False
except arista_exc.AristaRpcError:
LOG.warning(EOS_UNREACHABLE_MSG)
class AristaDriver(driver_api.MechanismDriver):
"""Ml2 Mechanism driver for Arista networking hardware.
- Remebers all networks and VMs that are provisioned on Arista Hardware.
+ Remembers all networks and VMs that are provisioned on Arista Hardware.
Does not send network provisioning request if the network has already been
provisioned before for the given port.
"""
apic_conf = cfg.CONF.ml2_cisco_apic
self.switch_dict = config.create_switch_dictionary()
- # Connect to the the APIC
+ # Connect to the APIC
self.apic = apic_client.RestClient(
apic_conf.apic_host,
apic_conf.apic_port,
# possible (but unlikely) that the port's state could change
# concurrently while these calls are being made. If another
# thread or process succeeds in binding the port before this
- # thread commits its results, the already commited results are
+ # thread commits its results, the already committed results are
# used. If attributes such as binding:host_id,
# binding:profile, or binding:vnic_type are updated
# concurrently, this loop retries binding using the new
self.delete_port(context, result['id'])
# REVISIT(rkukura): Is there any point in calling this before
- # a binding has been succesfully established?
+ # a binding has been successfully established?
self.notify_security_groups_member_updated(context, result)
try:
subnet_uuid = ips['subnet_id']
ldm = self.local_dvr_map[subnet_uuid]
if not ldm.is_dvr_owned():
- # well this is csnat stuff, let dvr come in
+ # well this is CSNAT stuff, let dvr come in
# and do plumbing for this vm later
continue
# This confirms that this compute port belongs
# to a dvr hosted subnet.
- # Accomodate this VM Port into the existing rule in
+ # Accommodate this VM Port into the existing rule in
# the integration bridge
LOG.debug("DVR: Plumbing compute port %s", port.vif_id)
subnet_info = ldm.get_subnet_info()
ovsport = self.local_ports[port.vif_id]
# This confirms that this compute port being removed belonged
# to a dvr hosted subnet.
- # Accomodate this VM Port into the existing rule in
+ # Accommodate this VM Port into the existing rule in
# the integration bridge
LOG.debug("DVR: Removing plumbing for compute port %s", port)
subnet_ids = ovsport.get_subnets()
def _unbind_centralized_snat_port_on_dvr_subnet(self, port, local_vlan):
ovsport = self.local_ports[port.vif_id]
- # This comfirms that this compute port being removed belonged
+ # This confirms that this compute port being removed belonged
# to a dvr hosted subnet.
- # Accomodate this VM Port into the existing rule in
+ # Accommodate this VM Port into the existing rule in
# the integration bridge
LOG.debug("DVR: Removing plumbing for csnat port %s", port)
sub_uuid = list(ovsport.get_subnets())[0]
raise plum_excep.PLUMgridException(err_msg=err_message)
"""
- Internal PLUMgrid Fuctions
+ Internal PLUMgrid Functions
"""
def _get_plugin_version(self):
if cookie is None and self._url != "/ws.v1/login":
# The connection still has no valid cookie despite
- # attemps to authenticate and the request has failed
+ # attempts to authenticate and the request has failed
# with unauthorized status code. If this isn't a
# a request to authenticate, we should abort the
# request since there is no point in retrying.
port['device_owner'].startswith('network:')):
return
- # Check if there is a queue assocated with the network
+ # Check if there is a queue associated with the network
filters = {'network_id': [port['network_id']]}
network_queue_id = self._get_network_queue_bindings(
context, filters, ['queue_id'])
if network_queue_id:
- # get networks that queue is assocated with
+ # get networks that queue is associated with
filters = {'queue_id': [network_queue_id[0]['queue_id']]}
networks_with_same_queue = self._get_network_queue_bindings(
context, filters)
nsx_device_id = self._get_nsx_device_id(context, device_id)
super(NsxPluginV2, self).delete_gateway_device(
context, device_id)
- # DB operation was successful, peform NSX operation
+ # DB operation was successful, perform NSX operation
# TODO(salv-orlando): State consistency with neutron DB
# should be ensured even in case of backend failures
try:
return service_name
def _get_available_service(self, service_name):
- """Check if service exsists and return its name if it does."""
+ """Check if service exists and return its name if it does."""
resource = '/api/service/' + service_name
try:
_rest_wrapper(self.rest_client.call('GET',
:param host: hostname. This is needed for rpc
Each devices will stays as processes.
- They will communiate with
+ They will communicate with
server side service plugin using rpc with
device specific rpc topic.
:returns: None
This class is designed for use with L3-agent now.
However this driver will be used with another agent in future.
so the use of "Router" is kept minimul now.
- Insted of router_id, we are using process_id in this code.
+ Instead of router_id, we are using process_id in this code.
"""
# history
This class is designed for use with L3-agent now.
However this driver will be used with another agent in future.
so the use of "Router" is kept minimul now.
- Insted of router_id, we are using process_id in this code.
+ Instead of router_id, we are using process_id in this code.
"""
# history
class AgentMechanismBaseTestCase(base.BaseTestCase):
- # These following must be overriden for the specific mechanism
+ # The following must be overridden for the specific mechanism
# driver being tested:
VIF_TYPE = None
CAP_PORT_FILTER = None
# Build notification message
(service1_data,
service2_data) = self.notification_for_two_services_with_two_conns()
- # Simulate plugin returning notifcation, when requested
+ # Simulate plugin returning notification, when requested
self.driver.agent_rpc.get_vpn_services_on_host.return_value = [
service1_data, service2_data]
vpn_services = self.driver.update_all_services_and_connections(
l3_agent.L3NATAgent,
'internal_network_added') as internal_network_added:
# raise RuntimeError to simulate that an unexpected exception
- # occurrs
+ # occurs
internal_network_added.side_effect = RuntimeError
self.assertRaises(RuntimeError, agent.process_router, ri)
self.assertNotIn(
l3_agent.L3NATAgent,
'internal_network_removed') as internal_net_removed:
# raise RuntimeError to simulate that an unexpected exception
- # occurrs
+ # occurs
internal_net_removed.side_effect = RuntimeError
ri.internal_ports[0]['admin_state_up'] = False
# The above port is set to down state, remove it.
res.status_int)
def test_router_add_gateway_invalid_network_returns_404(self):
- # NOTE(salv-orlando): This unit test has been overriden
+ # NOTE(salv-orlando): This unit test has been overridden
# as the nsx plugin support the ext_gw_mode extension
# which mandates a uuid for the external network identifier
with self.router() as r:
Code Review / openstack-build / neutron-build.git / commitdiff