Ajout d'une suppression du verrou si la synchro dure plus de 3h
This commit is contained in:
@ -2,6 +2,7 @@
|
|||||||
import os
|
import os
|
||||||
import argparse
|
import argparse
|
||||||
import logging
|
import logging
|
||||||
|
import time
|
||||||
from functions import getSettings
|
from functions import getSettings
|
||||||
from includes.airwatchAPI import *
|
from includes.airwatchAPI import *
|
||||||
from includes.GLPIAPI import *
|
from includes.GLPIAPI import *
|
||||||
@ -66,13 +67,21 @@ if(args.staginguser != None):
|
|||||||
stagingUser = args.staginguser
|
stagingUser = args.staginguser
|
||||||
|
|
||||||
# ====================================== #
|
# ====================================== #
|
||||||
|
|
||||||
|
|
||||||
# Vérification de la présence du verrou avant de continuer
|
# Vérification de la présence du verrou avant de continuer
|
||||||
if(os.path.isfile(lockFile) and not args.force):
|
if(os.path.isfile(lockFile) and not args.force):
|
||||||
logger.debug('Lock file exists, exiting...')
|
# Récupération du temps de création de verrou en minutes
|
||||||
exit(0)
|
lockTime = (time.time() - os.path.getmtime(lockFile)) // 60
|
||||||
|
# Recréation du verrou s'il existe depuis plus de 3 heures (crash)
|
||||||
|
# sinon on quitte, une synchro est déjà en cours
|
||||||
|
if(lockTime > 180):
|
||||||
|
os.remove(lockFile)
|
||||||
|
open(lockFile, "w").close()
|
||||||
|
else:
|
||||||
|
logger.debug('Lock file exists, exiting...')
|
||||||
|
exit(0)
|
||||||
else:
|
else:
|
||||||
|
# Création du verrou s'il n'existe pas
|
||||||
open(lockFile, "w").close()
|
open(lockFile, "w").close()
|
||||||
|
|
||||||
# Initialisation de l'api Airwatch
|
# Initialisation de l'api Airwatch
|
||||||
|
|||||||
@ -2,6 +2,7 @@
|
|||||||
import os
|
import os
|
||||||
import argparse
|
import argparse
|
||||||
import logging
|
import logging
|
||||||
|
import time
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from functions import getSettings
|
from functions import getSettings
|
||||||
from includes.airwatchAPI import *
|
from includes.airwatchAPI import *
|
||||||
@ -105,11 +106,21 @@ platformFilterOut = [12]
|
|||||||
|
|
||||||
# ====================================== #
|
# ====================================== #
|
||||||
|
|
||||||
|
|
||||||
# Vérification de la présence du verrou avant de continuer
|
# Vérification de la présence du verrou avant de continuer
|
||||||
if(os.path.isfile(lockFile) and not args.force):
|
if(os.path.isfile(lockFile) and not args.force):
|
||||||
logger.debug('Lock file exists, exiting...')
|
# Récupération du temps de création de verrou en minutes
|
||||||
exit(0)
|
lockTime = (time.time() - os.path.getmtime(lockFile)) // 60
|
||||||
|
# Recréation du verrou s'il existe depuis plus de 3 heures (crash)
|
||||||
|
# sinon on quitte, une synchro est déjà en cours
|
||||||
|
if(lockTime > 180):
|
||||||
|
os.remove(lockFile)
|
||||||
|
open(lockFile, "w").close()
|
||||||
|
else:
|
||||||
|
logger.debug('Lock file exists, exiting...')
|
||||||
|
exit(0)
|
||||||
else:
|
else:
|
||||||
|
# Création du verrou s'il n'existe pas
|
||||||
open(lockFile, "w").close()
|
open(lockFile, "w").close()
|
||||||
|
|
||||||
logger.info("========= Synchronization started =========")
|
logger.info("========= Synchronization started =========")
|
||||||
|
|||||||
Reference in New Issue
Block a user