vim_thread.py

# -*- coding: utf-8 -*-

##
# Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U.
# This file is part of openvim
# 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.
#
# For those usages not covered by the Apache License, Version 2.0 please
# contact with: nfvlabs@tid.es
##

'''
This is thread that interact with the host and the libvirt to manage VM
One thread will be launched per host 
'''
__author__ = "Alfonso Tierno"
__date__ = "$10-feb-2017 12:07:15$"

import threading
import time
import Queue
import logging
import vimconn



# from logging import Logger
# import auxiliary_functions as af

# TODO: insert a logging system


class vim_thread(threading.Thread):

    def __init__(self, vimconn, name=None):
        '''Init a thread.
        Arguments:
            'id' number of thead
            'name' name of thread
            'host','user':  host ip or name to manage and user
            'db', 'db_lock': database class and lock to use it in exclusion
        '''
        threading.Thread.__init__(self)
        self.vim = vimconn
        if not name:
            self.name = vimconn["id"] + "-" + vimconn["config"]["datacenter_tenant_id"]
        else:
            self.name = name

        self.logger = logging.getLogger('openmano.vim.'+self.name)

        self.queueLock = threading.Lock()
        self.taskQueue = Queue.Queue(2000)


    def insert_task(self, task, *aditional):
        try:
            self.queueLock.acquire()
            task = self.taskQueue.put( (task,) + aditional, timeout=5) 
            self.queueLock.release()
            return 1, None
        except Queue.Full:
            return -1, "timeout inserting a task over host " + self.name

    def run(self):
        self.logger.debug("Starting")
        while True:
            #TODO reload service
            while True:
                self.queueLock.acquire()
                if not self.taskQueue.empty():
                    task = self.taskQueue.get()
                else:
                    task = None
                self.queueLock.release()
    
                if task is None:
                    now=time.time()
                    time.sleep(1)
                    continue        
    
                if task[0] == 'instance':
                    pass
                elif task[0] == 'image':
                    pass
                elif task[0] == 'exit':
                    print self.name, ": processing task exit"
                    self.terminate()
                    return 0
                elif task[0] == 'reload':
                    print self.name, ": processing task reload terminating and relaunching"
                    self.terminate()
                    break
                elif task[0] == 'edit-iface':
                    pass
                elif task[0] == 'restore-iface':
                    pass
                elif task[0] == 'new-ovsbridge':
                    pass
                elif task[0] == 'new-vxlan':
                    pass
                elif task[0] == 'del-ovsbridge':
                    pass
                elif task[0] == 'del-vxlan':
                    pass
                elif task[0] == 'create-ovs-bridge-port':
                    pass
                elif task[0] == 'del-ovs-port':
                    pass
                else:
                    self.logger.error("unknown task %s", str(task))

        self.logger.debug("Finishing")

    def terminate(self):
        pass