ba27042d65
A custom parser is needed for sorting of
custom type columns like the 'Size' columns.
The 'KB', 'MB', 'GB'... values break the sorter
logic and need to be parsed manually.
The custom parser works on all 'Size'/'RAM'/'Memory'
columns. It works also on flavor-info columns like:
`m1.tiny | 512MB RAM | 1 VCPU | 0 Disk`
The custom parser sorts these lines based on the RAM value.
Note: as seen in horizon.tables.js file, an workaround was
added as there is one more <th> in the <thead> (incl. the table_caption)
than the <td>'s in <tbody>. Thus the custom parser needs
to be added to [i-1] header, while the header itself needs [i],
as the parser is processed in <tbody>, while headers are processed
including the table_caption... This might be a problem at some time,
although currently it works...
Fixes bug 1013475
Change-Id: I793ae330c33fde4e625f96e55fdda3748c84b8c3
299 lines
9.4 KiB
Python
299 lines
9.4 KiB
Python
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
|
|
|
# Copyright 2012 Nebula, Inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import logging
|
|
|
|
from django import template
|
|
from django.core import urlresolvers
|
|
from django.template.defaultfilters import title
|
|
from django.utils.http import urlencode
|
|
from django.utils.translation import ugettext_lazy as _
|
|
|
|
from horizon import api
|
|
from horizon import tables
|
|
from horizon.templatetags import sizeformat
|
|
from horizon.utils.filters import replace_underscores
|
|
|
|
from horizon.dashboards.nova.access_and_security \
|
|
.floating_ips.workflows import IPAssociationWorkflow
|
|
from .tabs import InstanceDetailTabs, LogTab, VNCTab
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
ACTIVE_STATES = ("ACTIVE",)
|
|
|
|
POWER_STATES = {
|
|
0: "NO STATE",
|
|
1: "RUNNING",
|
|
2: "BLOCKED",
|
|
3: "PAUSED",
|
|
4: "SHUTDOWN",
|
|
5: "SHUTOFF",
|
|
6: "CRASHED",
|
|
7: "SUSPENDED",
|
|
8: "FAILED",
|
|
9: "BUILDING",
|
|
}
|
|
|
|
PAUSE = 0
|
|
UNPAUSE = 1
|
|
SUSPEND = 0
|
|
RESUME = 1
|
|
|
|
|
|
class TerminateInstance(tables.BatchAction):
|
|
name = "terminate"
|
|
action_present = _("Terminate")
|
|
action_past = _("Scheduled termination of")
|
|
data_type_singular = _("Instance")
|
|
data_type_plural = _("Instances")
|
|
classes = ('btn-danger', 'btn-terminate')
|
|
|
|
def allowed(self, request, instance=None):
|
|
if instance:
|
|
return instance.status != "PAUSED"
|
|
return True
|
|
|
|
def action(self, request, obj_id):
|
|
api.server_delete(request, obj_id)
|
|
|
|
|
|
class RebootInstance(tables.BatchAction):
|
|
name = "reboot"
|
|
action_present = _("Reboot")
|
|
action_past = _("Rebooted")
|
|
data_type_singular = _("Instance")
|
|
data_type_plural = _("Instances")
|
|
classes = ('btn-danger', 'btn-reboot')
|
|
|
|
def allowed(self, request, instance=None):
|
|
return instance.status in ACTIVE_STATES or instance.status == 'SHUTOFF'
|
|
|
|
def action(self, request, obj_id):
|
|
api.server_reboot(request, obj_id)
|
|
|
|
|
|
class TogglePause(tables.BatchAction):
|
|
name = "pause"
|
|
action_present = (_("Pause"), _("Unpause"))
|
|
action_past = (_("Paused"), _("Unpaused"))
|
|
data_type_singular = _("Instance")
|
|
data_type_plural = _("Instances")
|
|
classes = ("btn-pause",)
|
|
|
|
def allowed(self, request, instance=None):
|
|
self.paused = False
|
|
if not instance:
|
|
return self.paused
|
|
self.paused = instance.status == "PAUSED"
|
|
if self.paused:
|
|
self.current_present_action = UNPAUSE
|
|
else:
|
|
self.current_present_action = PAUSE
|
|
return instance.status in ACTIVE_STATES or self.paused
|
|
|
|
def action(self, request, obj_id):
|
|
if self.paused:
|
|
api.server_unpause(request, obj_id)
|
|
self.current_past_action = UNPAUSE
|
|
else:
|
|
api.server_pause(request, obj_id)
|
|
self.current_past_action = PAUSE
|
|
|
|
|
|
class ToggleSuspend(tables.BatchAction):
|
|
name = "suspend"
|
|
action_present = (_("Suspend"), _("Resume"))
|
|
action_past = (_("Suspended"), _("Resumed"))
|
|
data_type_singular = _("Instance")
|
|
data_type_plural = _("Instances")
|
|
classes = ("btn-suspend",)
|
|
|
|
def allowed(self, request, instance=None):
|
|
self.suspended = False
|
|
if not instance:
|
|
self.suspended
|
|
self.suspended = instance.status == "SUSPENDED"
|
|
if self.suspended:
|
|
self.current_present_action = RESUME
|
|
else:
|
|
self.current_present_action = SUSPEND
|
|
return instance.status in ACTIVE_STATES or self.suspended
|
|
|
|
def action(self, request, obj_id):
|
|
if self.suspended:
|
|
api.server_resume(request, obj_id)
|
|
self.current_past_action = RESUME
|
|
else:
|
|
api.server_suspend(request, obj_id)
|
|
self.current_past_action = SUSPEND
|
|
|
|
|
|
class LaunchLink(tables.LinkAction):
|
|
name = "launch"
|
|
verbose_name = _("Launch Instance")
|
|
url = "horizon:nova:instances:launch"
|
|
classes = ("btn-launch", "ajax-modal")
|
|
|
|
|
|
class EditInstance(tables.LinkAction):
|
|
name = "edit"
|
|
verbose_name = _("Edit Instance")
|
|
url = "horizon:nova:instances:update"
|
|
classes = ("ajax-modal", "btn-edit")
|
|
|
|
|
|
class SnapshotLink(tables.LinkAction):
|
|
name = "snapshot"
|
|
verbose_name = _("Snapshot")
|
|
url = "horizon:nova:images_and_snapshots:snapshots:create"
|
|
classes = ("ajax-modal", "btn-camera")
|
|
|
|
def allowed(self, request, instance=None):
|
|
return instance.status in ACTIVE_STATES
|
|
|
|
|
|
class ConsoleLink(tables.LinkAction):
|
|
name = "console"
|
|
verbose_name = _("VNC Console")
|
|
url = "horizon:nova:instances:detail"
|
|
classes = ("btn-console",)
|
|
|
|
def allowed(self, request, instance=None):
|
|
return instance.status in ACTIVE_STATES
|
|
|
|
def get_link_url(self, datum):
|
|
base_url = super(ConsoleLink, self).get_link_url(datum)
|
|
tab_query_string = VNCTab(InstanceDetailTabs).get_query_string()
|
|
return "?".join([base_url, tab_query_string])
|
|
|
|
|
|
class LogLink(tables.LinkAction):
|
|
name = "log"
|
|
verbose_name = _("View Log")
|
|
url = "horizon:nova:instances:detail"
|
|
classes = ("btn-log",)
|
|
|
|
def allowed(self, request, instance=None):
|
|
return instance.status in ACTIVE_STATES
|
|
|
|
def get_link_url(self, datum):
|
|
base_url = super(LogLink, self).get_link_url(datum)
|
|
tab_query_string = LogTab(InstanceDetailTabs).get_query_string()
|
|
return "?".join([base_url, tab_query_string])
|
|
|
|
|
|
class AssociateIP(tables.LinkAction):
|
|
name = "associate"
|
|
verbose_name = _("Associate Floating IP")
|
|
url = "horizon:nova:access_and_security:floating_ips:associate"
|
|
classes = ("ajax-modal", "btn-associate")
|
|
|
|
def get_link_url(self, datum):
|
|
base_url = urlresolvers.reverse(self.url)
|
|
next = urlresolvers.reverse("horizon:nova:instances:index")
|
|
params = {"instance_id": self.table.get_object_id(datum),
|
|
IPAssociationWorkflow.redirect_param_name: next}
|
|
params = urlencode(params)
|
|
return "?".join([base_url, params])
|
|
|
|
|
|
class UpdateRow(tables.Row):
|
|
ajax = True
|
|
|
|
def get_data(self, request, instance_id):
|
|
instance = api.server_get(request, instance_id)
|
|
instance.full_flavor = api.flavor_get(request, instance.flavor["id"])
|
|
return instance
|
|
|
|
|
|
def get_ips(instance):
|
|
template_name = 'nova/instances/_instance_ips.html'
|
|
context = {"instance": instance}
|
|
return template.loader.render_to_string(template_name, context)
|
|
|
|
|
|
def get_size(instance):
|
|
if hasattr(instance, "full_flavor"):
|
|
size_string = _("%(name)s | %(RAM)s RAM | %(VCPU)s VCPU "
|
|
"| %(disk)s Disk")
|
|
vals = {'name': instance.full_flavor.name,
|
|
'RAM': sizeformat.mbformat(instance.full_flavor.ram),
|
|
'VCPU': instance.full_flavor.vcpus,
|
|
'disk': sizeformat.diskgbformat(instance.full_flavor.disk)}
|
|
return size_string % vals
|
|
return _("Not available")
|
|
|
|
|
|
def get_keyname(instance):
|
|
if hasattr(instance, "key_name"):
|
|
keyname = instance.key_name
|
|
return keyname
|
|
return _("Not available")
|
|
|
|
|
|
def get_power_state(instance):
|
|
return POWER_STATES.get(getattr(instance, "OS-EXT-STS:power_state", 0), '')
|
|
|
|
|
|
class InstancesTable(tables.DataTable):
|
|
TASK_STATUS_CHOICES = (
|
|
(None, True),
|
|
("none", True)
|
|
)
|
|
STATUS_CHOICES = (
|
|
("active", True),
|
|
("suspended", True),
|
|
("paused", True),
|
|
("error", False),
|
|
)
|
|
TASK_DISPLAY_CHOICES = (
|
|
("image_snapshot", "Snapshotting"),
|
|
)
|
|
name = tables.Column("name",
|
|
link=("horizon:nova:instances:detail"),
|
|
verbose_name=_("Instance Name"))
|
|
ip = tables.Column(get_ips, verbose_name=_("IP Address"))
|
|
size = tables.Column(get_size,
|
|
verbose_name=_("Size"),
|
|
attrs={'data-type': 'size'})
|
|
keypair = tables.Column(get_keyname, verbose_name=_("Keypair"))
|
|
status = tables.Column("status",
|
|
filters=(title, replace_underscores),
|
|
verbose_name=_("Status"),
|
|
status=True,
|
|
status_choices=STATUS_CHOICES)
|
|
task = tables.Column("OS-EXT-STS:task_state",
|
|
verbose_name=_("Task"),
|
|
filters=(title, replace_underscores),
|
|
status=True,
|
|
status_choices=TASK_STATUS_CHOICES,
|
|
display_choices=TASK_DISPLAY_CHOICES)
|
|
state = tables.Column(get_power_state,
|
|
filters=(title, replace_underscores),
|
|
verbose_name=_("Power State"))
|
|
|
|
class Meta:
|
|
name = "instances"
|
|
verbose_name = _("Instances")
|
|
status_columns = ["status", "task"]
|
|
row_class = UpdateRow
|
|
table_actions = (LaunchLink, TerminateInstance)
|
|
row_actions = (SnapshotLink, AssociateIP, EditInstance, ConsoleLink,
|
|
LogLink, TogglePause, ToggleSuspend, RebootInstance,
|
|
TerminateInstance)
|