Commit 9edcf921 authored by Anael Beutot's avatar Anael Beutot
Browse files

Change BaseJog to BaseThreadedJob.

parent 94ea6fe0

ccnode/hypervisor/jobs.py

+5 −5
Original line number Diff line number Diff line
@@ -4,13 +4,13 @@ import socket 
import logging

from hashlib import md5



from ccnode.jobs import BaseJob

from ccnode.jobs import BaseThreadedJob





logger = logging.getLogger(__name__)





class ImportVolume(BaseJob):

class ImportVolume(BaseThreadedJob):

    """Import volume job.



    """
@@ -18,7 +18,7 @@ class ImportVolume(BaseJob): 
    HASH = md5



    def __init__(self, job_manager, ev_loop, volume):

        BaseJob.__init__(self, job_manager, ev_loop)

        BaseThreadedJob.__init__(self, job_manager, ev_loop)



        self.checksum = None

        self.volume = volume
@@ -153,7 +153,7 @@ class ImportVolume(BaseJob): 
        logger.debug('Volume import done')





class ExportVolume(BaseJob):

class ExportVolume(BaseThreadedJob):

    """Export volume job.



    """
@@ -166,7 +166,7 @@ class ExportVolume(BaseJob): 
        :param raddr: remote IP address

        :param rport: remote TCP port

        """

        BaseJob.__init__(self, job_manager, ev_loop)

        BaseThreadedJob.__init__(self, job_manager, ev_loop)



        # where to connect to send the volume

        self.raddr = raddr

ccnode/jobs.py

+2 −2
Original line number Diff line number Diff line
@@ -54,8 +54,8 @@ class JobManager(object): 
        pass





class BaseJob(Thread):

    """Base job

class BaseThreadedJob(Thread):

    """Job running in a background thread.



    Handles job notification to the job manager.

    """