source: mauRepo/MolesManager/trunk/src/libs/migration/client.py @ 8137

'''
Created on 9 Nov 2011

@author: mnagni
'''
from libs.migration.processor.loadResources import LoadResources
from libs.migration.processor.migrationProcess import MigrationProcess

import threading
import time
from threading import Timer
from libs.migration.db.classes import MigrationObject
from libs.migration.processor.commons import DS_pUBLISHED, DO_BADC



class MigrationThread(threading.Thread):
    """
        Constructs a scheduler for the Moles2 to Moles3 migration.
        @param interval: define the minimal time, in seconds, between an execution and the successive. 
        If the current migration run takes more than the defined interval the next will starts
        as soon the previous ends.         
    """
    def __init__(self, interval=600):
        threading.Thread.__init__(self)
        self._doRun = True   
        self.interval = interval
    
    def stop(self):
        self._doRun = False
    
    def run(self):
        while self._doRun:
            startTime = (int)(time.time())
            timer = Timer(5, self._migrate, ())
            timer.start()
            timer.join()
            diffTime = startTime + self.interval - (int)(time.time()) 
            if diffTime > 0:
                time.sleep(diffTime)
    
    def _printTime(self):
        print "From print_time", time.time()    

    def _migrate(self):
        lr = LoadResources()
        lr.process()

        mp = MigrationProcess()
        mp.process()

#record = Moles3EPB.search(CEDA_Observation, 12)
#print DJEncoder().encode(record)

lr = LoadResources()
mp = MigrationProcess()

dataEntity = MigrationObject()
dataEntity.doc_status = DS_pUBLISHED
dataEntity.doc_owner = DO_BADC
dataEntity.doc_name = 'dataent_csip.atom'

lr.process()
mp.process(dataEntity)