From: Dan Wendlandt <dan@nicira.com>
Date: Wed, 17 Aug 2011 02:11:48 +0000 (-0700)
Subject: merge trunk
X-Git-Url: https://review.fuel-infra.org/gitweb?a=commitdiff_plain;h=ac5a8c8a9c133e83af9bc99b60ba4f2e403c41ec;p=openstack-build%2Fneutron-build.git

merge trunk
---

ac5a8c8a9c133e83af9bc99b60ba4f2e403c41ec
diff --cc quantum/plugins/openvswitch/ovs_quantum_plugin.py
index 4765804c5,1b46fca7c..d58b39de8
--- a/quantum/plugins/openvswitch/ovs_quantum_plugin.py
+++ b/quantum/plugins/openvswitch/ovs_quantum_plugin.py
@@@ -19,11 -19,13 +19,12 @@@
  
  import ConfigParser
  import logging as LOG
+ from optparse import OptionParser
  import os
  import sys
 -import unittest
  
+ from quantum.common import exceptions as q_exc
  from quantum.quantum_plugin_base import QuantumPluginBase
- from optparse import OptionParser
  
  import quantum.db.api as db
  import ovs_db
@@@ -187,22 -182,59 +181,21 @@@ class OVSQuantumPlugin(QuantumPluginBas
          Updates the state of a port on the specified Virtual Network.
          """
          LOG.debug("update_port() called\n")
-         port = db.port_get(port_id)
-         port['port-state'] = port_state
-         return port
+         port = db.port_get(port_id, net_id)
+         db.port_set_state(port_id, net_id, port_state)
+         return self._make_port_dict(str(port.uuid), port.state, None, None)
  
      def get_port_details(self, tenant_id, net_id, port_id):
-         port = db.port_get(port_id)
-         rv = {"port-id": port.uuid, "attachment": port.interface_id,
-           "net-id": port.network_id, "port-state": "UP"}
-         return rv
+         port = db.port_get(port_id, net_id)
+         return self._make_port_dict(str(port.uuid), port.state,
+                                 port.network_id, port.interface_id)
  
      def plug_interface(self, tenant_id, net_id, port_id, remote_iface_id):
-         db.port_set_attachment(port_id, remote_iface_id)
+         db.port_set_attachment(port_id, net_id, remote_iface_id)
  
      def unplug_interface(self, tenant_id, net_id, port_id):
-         db.port_set_attachment(port_id, "")
+         db.port_set_attachment(port_id, net_id, "")
  
      def get_interface_details(self, tenant_id, net_id, port_id):
-         res = db.port_get(port_id)
+         res = db.port_get(port_id, net_id)
          return res.interface_id
 -
 -
 -class VlanMapTest(unittest.TestCase):
 -
 -    def setUp(self):
 -        self.vmap = VlanMap()
 -
 -    def tearDown(self):
 -        pass
 -
 -    def testAddVlan(self):
 -        vlan_id = self.vmap.acquire("foobar")
 -        self.assertTrue(vlan_id == 2)
 -
 -    def testReleaseVlan(self):
 -        vlan_id = self.vmap.acquire("foobar")
 -        self.vmap.release("foobar")
 -        self.assertTrue(self.vmap.get(vlan_id) == None)
 -
 -
 -if __name__ == "__main__":
 -    usagestr = "Usage: %prog [OPTIONS] <command> [args]"
 -    parser = OptionParser(usage=usagestr)
 -    parser.add_option("-v", "--verbose", dest="verbose",
 -      action="store_true", default=False, help="turn on verbose logging")
 -
 -    options, args = parser.parse_args()
 -
 -    if options.verbose:
 -        LOG.basicConfig(level=LOG.DEBUG)
 -    else:
 -        LOG.basicConfig(level=LOG.WARN)
 -
 -    # Make sqlalchemy quieter
 -    LOG.getLogger('sqlalchemy.engine').setLevel(LOG.WARN)
 -    # Run the tests
 -    suite = unittest.TestLoader().loadTestsFromTestCase(VlanMapTest)
 -    unittest.TextTestRunner(verbosity=2).run(suite)
diff --cc tests/unit/test_api.py
index e56a2cdd7,aee8f73f3..cb57a104a
--- a/tests/unit/test_api.py
+++ b/tests/unit/test_api.py
@@@ -20,13 -20,13 +20,13 @@@
  import logging
  import unittest
  
- import tests.unit.testlib_api as testlib
  
+ import tests.unit.testlib_api as testlib
  from quantum import api as server
  from quantum.db import api as db
 +from quantum.common.test_lib import test_config
  from quantum.common.wsgi import Serializer
  
 -
  LOG = logging.getLogger('quantum.tests.test_api')