X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fzerorpc%2Fcompute.py;h=5e5d0de1f36cebdf92e41368111c88fdf22ea275;hb=0d98d75450be28bba00ebabcd9041b4ae541f964;hp=39ccec29a86a2086b5d5b9c39f4039a7c6142b60;hpb=5b37641a26aef3691b6f5ad2e3d1b768841eee8f;p=osm%2Fvim-emu.git diff --git a/src/emuvim/api/zerorpc/compute.py b/src/emuvim/api/zerorpc/compute.py old mode 100644 new mode 100755 index 39ccec2..5e5d0de --- a/src/emuvim/api/zerorpc/compute.py +++ b/src/emuvim/api/zerorpc/compute.py @@ -1,4 +1,31 @@ """ +Copyright (c) 2015 SONATA-NFV and Paderborn University +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. + +Neither the name of the SONATA-NFV [, ANY ADDITIONAL AFFILIATION] +nor the names of its contributors may be used to endorse or promote +products derived from this software without specific prior written +permission. + +This work has been performed in the framework of the SONATA project, +funded by the European Commission under Grant number 671517 through +the Horizon 2020 and 5G-PPP programmes. The authors would like to +acknowledge the contributions of their colleagues of the SONATA +partner consortium (www.sonata-nfv.eu). +""" +""" Distributed Cloud Emulator (dcemulator) (c) 2015 by Manuel Peuster """ @@ -7,6 +34,11 @@ import logging import threading import zerorpc +import paramiko +import ipaddress +import time +import gevent + logging.basicConfig(level=logging.INFO) @@ -113,24 +145,107 @@ class MultiDatacenterApi(object): logging.exception("RPC error.") return ex.message - def compute_profile(self, dc_label, compute_name, image, kwargs): + @zerorpc.stream + def compute_profile(self, dc_label, compute_name, kwargs): # note: zerorpc does not support keyword arguments ## VIM/dummy gatekeeper's tasks: # start vnf - vnf_status = self.compute_action_start(self, dc_label, compute_name, image, + vnf_status = self.compute_action_start( dc_label, compute_name, + kwargs.get('image'), kwargs.get('network'), kwargs.get('command')) # start traffic source (with fixed ip addres, no use for now...) - self.compute_action_start(self, dc_label, 'psrc', 'profile_source', [{'id':'output'}], None) + psrc_status = self.compute_action_start( dc_label, 'psrc', 'profile_source', [{'id':'output'}], None) + # start traffic sink (with fixed ip addres) + psink_status = self.compute_action_start(dc_label, 'psink', 'profile_sink', [{'id': 'input'}], None) # link vnf to traffic source DCNetwork = self.dcs.get(dc_label).net - DCNetwork.setChain() + DCNetwork.setChain('psrc', compute_name, + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='add-flow', weight=None, bidirectional=True) + DCNetwork.setChain('psrc', compute_name, + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='add-flow', weight=None, + match='dl_type=0x0800,nw_proto=17,udp_dst=5001', + cookie=10) + DCNetwork.setChain( compute_name, 'psink', + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='add-flow', weight=None, bidirectional=True) + DCNetwork.setChain(compute_name, 'psink', + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='add-flow', weight=None, + match='dl_type=0x0800,nw_proto=17,udp_dst=5001', + cookie=11) + + ## SSM/SP tasks: + # start traffic generation + ''' + for nw in psrc_status.get('network'): + if nw.get('intf_name') == 'output': + psrc_output_ip = unicode(nw['ip']) + break + dummy_iperf_server_ip = ipaddress.IPv4Address(psrc_output_ip) + 1 + ''' + for nw in psink_status.get('network'): + if nw.get('intf_name') == 'input': + psink_input_ip = nw['ip'] + break + + + # get monitor data and analyze + vnf_uuid = vnf_status['id'] + psrc_mgmt_ip = psrc_status['docker_network'] + + # query rate + + #need to wait a bit before containers are fully up? + time.sleep(2) + + def generate(): + for rate in [0, 1, 2, 3]: + #logging.info('query:{0}'.format(query_cpu)) + + output_line = DCNetwork.monitor_agent.profile(psrc_mgmt_ip, rate, psink_input_ip, vnf_uuid) + gevent.sleep(0) + yield output_line + # query loss + # create table + ## VIM/dummy gatekeeper's tasks: + # remove vnfs and chain + DCNetwork.setChain('psrc', compute_name, + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='del-flows', weight=None, bidirectional=True) + DCNetwork.setChain('psrc', compute_name, + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='del-flows', weight=None, + match='dl_type=0x0800,nw_proto=17,udp_dst=5001', + cookie=10) + DCNetwork.setChain(compute_name, 'psink', + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='del-flows', weight=None, bidirectional=True) + DCNetwork.setChain(compute_name, 'psink', + vnf_src_interface='output', + vnf_dst_interface=kwargs.get('input'), + cmd='del-flows', weight=None, + match='dl_type=0x0800,nw_proto=17,udp_dst=5001', + cookie=11) + self.compute_action_stop(dc_label, compute_name) + self.compute_action_stop(dc_label, 'psink') + self.compute_action_stop(dc_label, 'psrc') + return generate() def datacenter_list(self): logging.debug("RPC CALL: datacenter list") @@ -148,9 +263,4 @@ class MultiDatacenterApi(object): logging.exception("RPC error.") return ex.message -''' -if __name__ == "__main__": - test = MultiDatacenterApi({}) - test.compute_profile('dc1','vnf1', 'image',network='',command='test',other='other') -'''