1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
# Copyright 2017 Huawei Technologies Co.,LTD.
# All Rights Reserved.
#
# 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 oslo_messaging as messaging
from cyborg import objects
from cyborg.conf import CONF
from oslo_log import log as logging
LOG = logging.getLogger(__name__)
class ConductorManager(object):
"""Cyborg Conductor manager main class."""
RPC_API_VERSION = '1.0'
target = messaging.Target(version=RPC_API_VERSION)
def __init__(self, topic, host=None):
super(ConductorManager, self).__init__()
self.topic = topic
self.host = host or CONF.host
def periodic_tasks(self, context, raise_on_error=False):
pass
def accelerator_create(self, context, obj_acc):
"""Create a new accelerator.
:param context: request context.
:param obj_acc: a changed (but not saved) accelerator object.
:returns: created accelerator object.
"""
base_options={
'project_id' : context.tenant,
'user_id' : context.user
}
obj_acc.update(base_options)
obj_acc.create(context)
return obj_acc
def accelerator_update(self, context, acc_obj):
"""Update an accelerator.
:param context: request context.
:param acc_obj: an accelerator object to update.
:return: updated accelerator objects."""
acc_obj.save(context)
return acc_obj
def accelerator_delete(self, context, acc_obj):
"""Delete an accelerator.
:param context: request context.
:param acc_obj: an accelerator object to delete."""
acc_obj.destory(context)
def port_create(self, context, port_obj):
"""Create a new port.
:param context: request context.
:param port_obj: a changed (but not saved) port object.
:returns: created port object.
"""
port_obj.create(context)
return port_obj
def port_bulk_create(self, context, port_list):
"""Create a new port.
:param context: request context.
:param port_list: port list need to be create and save.
:returns: request result.
"""
try:
for port in list(port_list):
port_obj = objects.Port(context, **port)
port = self.check_port_exist(context, port_obj)
if not port:
port_obj.create(context)
LOG.info('Update port resource %s ' % (port_list))
return True
except Exception as e:
LOG.error("Failed to port bulk create with error: %s" % (e))
LOG.error("Failed to port bulk create: %s" % (port_list))
def port_update(self, context, port_obj):
"""Update a port.
:param context: request context.
:param port_obj: a port object to update.
:return: updated port objects."""
port_obj.save(context)
return port_obj
def port_delete(self, context, port_obj):
"""Delete a port.
:param context: request context.
:param port_obj: a port object to delete."""
port_obj.destory(context)
def check_port_exist(self, context, port_obj):
"""Delete a port.
:param port_obj: a port object to delete.
:returns: True/False exist or not exist.
"""
return objects.Port.get(context=context, phy_port_name=port_obj.phy_port_name, \
pci_slot=port_obj.pci_slot, computer_node=port_obj.computer_node)
# deployable object
def deployable_create(self, context, obj_dep):
"""Create a new deployable.
:param context: request context.
:param obj_dep: a changed (but not saved) obj_dep object.
:returns: created obj_dep object.
"""
obj_dep.create(context)
return obj_dep
def deployable_update(self, context, obj_dep):
"""Update a deployable.
:param context: request context.
:param obj_dep: a deployable object to update.
:returns: updated deployable object.
"""
obj_dep.save(context)
return obj_dep
def deployable_delete(self, context, obj_dep):
"""Delete a deployable.
:param context: request context.
:param obj_dep: a deployable object to delete.
"""
obj_dep.destroy(context)
def deployable_get(self, context, uuid):
"""Retrieve a deployable.
:param context: request context.
:param uuid: UUID of a deployable.
:returns: requested deployable object.
"""
return objects.Deployable.get(context, uuid)
def deployable_get_by_host(self, context, host):
"""Retrieve a deployable.
:param context: request context.
:param host: host on which the deployable is located.
:returns: requested deployable object.
"""
return objects.Deployable.get_by_host(context, host)
def deployable_list(self, context):
"""Retrieve a list of deployables.
:param context: request context.
:returns: a list of deployable objects.
"""
return objects.Deployable.list(context)
|
