← Back to branch summary

~ubuntu-branches/ubuntu/saucy/quantum/saucy

« back to all changes in this revision

Viewing changes to quantum/plugins/nicira/nicira_db.py

  • Committer: Package Import Robot
  • Author(s): Chuck Short
  • Date: 2013-05-31 09:37:25 UTC
  • mfrom: (2.1.22)
  • Revision ID: package-import@ubuntu.com-20130531093725-bf9jom93l7jm57iv
Tags: 1:2013.2~b1-0ubuntu1
* New upstream release.
* debian/patches/fix-quantum-configuration.patch: Refreshed
* debian/control: Add testrepository.
* debian/control: Add subunit.
* debian/control: Add python-d21o1 and python-pbr as build-depends.
* debian/control: Add python-stevedore.

Show diffs side-by-side

added added

removed removed

Lines of Context:
quantum/plugins/nicira/nicira_db.py
 
1
# vim: tabstop=4 shiftwidth=4 softtabstop=4
 
2
 
 
3
# Copyright 2012 Nicira, Inc.
 
4
# All Rights Reserved.
 
5
#
 
6
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
 
7
#    not use this file except in compliance with the License. You may obtain
 
8
#    a copy of the License at
 
9
#
 
10
#         http://www.apache.org/licenses/LICENSE-2.0
 
11
#
 
12
#    Unless required by applicable law or agreed to in writing, software
 
13
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 
14
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 
15
#    License for the specific language governing permissions and limitations
 
16
#    under the License.
 
17
 
 
18
from sqlalchemy.orm import exc
 
19
 
 
20
import quantum.db.api as db
 
21
from quantum.openstack.common import log as logging
 
22
from quantum.plugins.nicira import nicira_models
 
23
from quantum.plugins.nicira import nicira_networkgw_db
 
24
 
 
25
LOG = logging.getLogger(__name__)
 
26
 
 
27
 
 
28
def get_network_binding(session, network_id):
 
29
    session = session or db.get_session()
 
30
    try:
 
31
        binding = (session.query(nicira_models.NvpNetworkBinding).
 
32
                   filter_by(network_id=network_id).
 
33
                   one())
 
34
        return binding
 
35
    except exc.NoResultFound:
 
36
        return
 
37
 
 
38
 
 
39
def get_network_binding_by_vlanid(session, vlan_id):
 
40
    session = session or db.get_session()
 
41
    try:
 
42
        binding = (session.query(nicira_models.NvpNetworkBinding).
 
43
                   filter_by(vlan_id=vlan_id).
 
44
                   one())
 
45
        return binding
 
46
    except exc.NoResultFound:
 
47
        return
 
48
 
 
49
 
 
50
def get_network_binding_by_vlanid_and_phynet(session, vlan_id,
 
51
                                             physical_network):
 
52
    session = session or db.get_session()
 
53
    try:
 
54
        binding = (session.query(nicira_models.NvpNetworkBinding).
 
55
                   filter_by(vlan_id=vlan_id, phy_uuid=physical_network).
 
56
                   one())
 
57
        return binding
 
58
    except exc.NoResultFound:
 
59
        return
 
60
 
 
61
 
 
62
def add_network_binding(session, network_id, binding_type, phy_uuid, vlan_id):
 
63
    with session.begin(subtransactions=True):
 
64
        binding = nicira_models.NvpNetworkBinding(network_id, binding_type,
 
65
                                                  phy_uuid, vlan_id)
 
66
        session.add(binding)
 
67
    return binding
 
68
 
 
69
 
 
70
def add_quantum_nvp_port_mapping(session, quantum_id, nvp_id):
 
71
    with session.begin(subtransactions=True):
 
72
        mapping = nicira_models.QuantumNvpPortMapping(quantum_id, nvp_id)
 
73
        session.add(mapping)
 
74
        return mapping
 
75
 
 
76
 
 
77
def get_nvp_port_id(session, quantum_id):
 
78
    try:
 
79
        mapping = (session.query(nicira_models.QuantumNvpPortMapping).
 
80
                   filter_by(quantum_id=quantum_id).
 
81
                   one())
 
82
        return mapping['nvp_id']
 
83
    except exc.NoResultFound:
 
84
        return
 
85
 
 
86
 
 
87
def unset_default_network_gateways(session):
 
88
    with session.begin(subtransactions=True):
 
89
        session.query(nicira_networkgw_db.NetworkGateway).update(
 
90
            {nicira_networkgw_db.NetworkGateway.default: False})
 
91
 
 
92
 
 
93
def set_default_network_gateway(session, gw_id):
 
94
    with session.begin(subtransactions=True):
 
95
        gw = (session.query(nicira_networkgw_db.NetworkGateway).
 
96
              filter_by(id=gw_id).one())
 
97
        gw['default'] = True