← Back to branch summary

~ubuntu-branches/ubuntu/raring/nova/raring-proposed

« back to all changes in this revision

Viewing changes to nova/cells/rpcapi.py

  • Committer: Package Import Robot
  • Author(s): Chuck Short, Chuck Short, James Page
  • Date: 2013-03-20 12:59:22 UTC
  • mfrom: (1.1.69)
  • Revision ID: package-import@ubuntu.com-20130320125922-ohvfav96lemn9wlz
Tags: 1:2013.1~rc1-0ubuntu1
[ Chuck Short ]
* New upstream release.
* debian/patches/avoid_setuptools_git_dependency.patch: Refreshed.
* debian/control: Clean up dependencies:
  - Dropped python-gflags no longer needed.
  - Dropped python-daemon no longer needed.
  - Dropped python-glance no longer needed.
  - Dropped python-lockfile no longer needed.
  - Dropped python-simplejson no longer needed.
  - Dropped python-tempita no longer needed.
  - Dropped python-xattr no longer needed.
  - Add sqlite3 required for the testsuite.

[ James Page ]
* d/watch: Update uversionmangle to deal with upstream versioning
  changes, remove tarballs.openstack.org. 

Show diffs side-by-side

added added

removed removed

Lines of Context:
nova/cells/rpcapi.py
24
24
 
25
25
from oslo.config import cfg
26
26
 
 
27
from nova import exception
27
28
from nova.openstack.common import jsonutils
28
29
from nova.openstack.common import log as logging
29
30
from nova.openstack.common.rpc import proxy as rpc_proxy
47
48
        1.3 - Adds task_log_get_all()
48
49
        1.4 - Adds compute_node_get(), compute_node_get_all(), and
49
50
              compute_node_stats()
 
51
        1.5 - Adds actions_get(), action_get_by_request_id(), and
 
52
              action_events_get()
 
53
        1.6 - Adds consoleauth_delete_tokens() and validate_console_port()
50
54
    '''
51
55
    BASE_RPC_API_VERSION = '1.0'
52
56
 
219
223
        """Return compute node stats from all cells."""
220
224
        return self.call(ctxt, self.make_msg('compute_node_stats'),
221
225
                         version='1.4')
 
226
 
 
227
    def actions_get(self, ctxt, instance):
 
228
        if not instance['cell_name']:
 
229
            raise exception.InstanceUnknownCell(instance_uuid=instance['uuid'])
 
230
        return self.call(ctxt, self.make_msg('actions_get',
 
231
                                             cell_name=instance['cell_name'],
 
232
                                             instance_uuid=instance['uuid']),
 
233
                         version='1.5')
 
234
 
 
235
    def action_get_by_request_id(self, ctxt, instance, request_id):
 
236
        if not instance['cell_name']:
 
237
            raise exception.InstanceUnknownCell(instance_uuid=instance['uuid'])
 
238
        return self.call(ctxt, self.make_msg('action_get_by_request_id',
 
239
                                             cell_name=instance['cell_name'],
 
240
                                             instance_uuid=instance['uuid'],
 
241
                                             request_id=request_id),
 
242
                         version='1.5')
 
243
 
 
244
    def action_events_get(self, ctxt, instance, action_id):
 
245
        if not instance['cell_name']:
 
246
            raise exception.InstanceUnknownCell(instance_uuid=instance['uuid'])
 
247
        return self.call(ctxt, self.make_msg('action_events_get',
 
248
                                             cell_name=instance['cell_name'],
 
249
                                             action_id=action_id),
 
250
                         version='1.5')
 
251
 
 
252
    def consoleauth_delete_tokens(self, ctxt, instance_uuid):
 
253
        """Delete consoleauth tokens for an instance in API cells."""
 
254
        self.cast(ctxt, self.make_msg('consoleauth_delete_tokens',
 
255
                                      instance_uuid=instance_uuid),
 
256
                  version='1.6')
 
257
 
 
258
    def validate_console_port(self, ctxt, instance_uuid, console_port,
 
259
                              console_type):
 
260
        """Validate console port with child cell compute node."""
 
261
        return self.call(ctxt,
 
262
                self.make_msg('validate_console_port',
 
263
                              instance_uuid=instance_uuid,
 
264
                              console_port=console_port,
 
265
                              console_type=console_type),
 
266
                version='1.6')