#! /usr/bin/env python
# -*- coding: iso-8859-1 -*-
-# Copyright (C) 2007-2015 CEA/DEN, EDF R&D, OPEN CASCADE
+# Copyright (C) 2007-2017 CEA/DEN, EDF R&D, OPEN CASCADE
#
# Copyright (C) 2003-2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
# CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
pass
except:
pass
- exit(0) # see (1)
+ sys.exit(0) # see (1)
pass
# (1) If --shutdown-servers option is set to 1, session close procedure is
-# called twice: first explicitely by salome command, second by automatic
+# called twice: first explicitly by salome command, second by automatic
# atexit to handle Ctrl-C. During second call, LCC does not exist anymore and
-# a RuntimeError is raised; we explicitely exit this function with code 0 to
+# a RuntimeError is raised; we explicitly exit this function with code 0 to
# prevent parent thread from crashing.
def __killMyPort(port, filedict):
try:
with open(filedict, 'r') as fpid:
- #
- from salome_utils import generateFileName, getLogDir
- fpidomniNames = generateFileName(getLogDir(),
- prefix="",
- suffix="Pid_omniNames",
- extension="log",
- with_port=port)
- if not sys.platform == 'win32':
- cmd = 'pid=$(ps -eo pid,command | egrep "[0-9] omniNames -start {0}") ; echo $pid > {1}'.format(port, fpidomniNames )
- subprocess.call(cmd, shell=True)
- pass
- try:
- with open(fpidomniNames) as fpidomniNamesFile:
- lines = fpidomniNamesFile.readlines()
-
- os.remove(fpidomniNames)
- for l in lines:
+ process_ids=pickle.load(fpid)
+ for process_id in process_ids:
+ for pid, cmd in process_id.items():
+ if verbose(): print "stop process %s : %s"% (pid, cmd[0])
try:
- pidfield = l.split()[0] # pid should be at the first position
- if sys.platform == "win32":
- import win32pm #@UnresolvedImport
- if verbose(): print 'stop process '+pidfield+' : omniNames'
- win32pm.killpid(int(pidfield),0)
- else:
- if verbose(): print 'stop process '+pidfield+' : omniNames'
- os.kill(int(pidfield),signal.SIGKILL)
- pass
- pass
+ from salome_utils import killpid
+ killpid(int(pid))
except:
+ if verbose(): print " ------------------ process %s : %s not found"% (pid, cmd[0])
pass
- pass
- pass
- except:
- pass
- #
- try:
- process_ids=pickle.load(fpid)
- for process_id in process_ids:
- for pid, cmd in process_id.items():
- if verbose(): print "stop process %s : %s"% (pid, cmd[0])
- if cmd[0] == "omniNames":
- if not sys.platform == 'win32':
- proc1 = subprocess.Popen(shlex.split('ps -eo pid,command'),stdout=subprocess.PIPE)
- proc2 = subprocess.Popen(shlex.split('egrep "[0-9] omniNames -start"'),stdin=proc1.stdout, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
- proc1.stdout.close() # Allow proc1 to receive a SIGPIPE if proc2 exits.
- out,_ = proc2.communicate()
- # out looks like: PID omniNames -start PORT <other args>
-
- # extract omninames pid and port number
- try:
- import re
- omniNamesPid, omniNamesPort = re.search('(.+?) omniNames -start (.+?) ', out).group(1, 2)
- if omniNamesPort == port:
- if verbose():
- print "stop omniNames [pid=%s] on port %s"%(omniNamesPid, omniNamesPort)
- appliCleanOmniOrbConfig(omniNamesPort)
- from PortManager import releasePort
- releasePort(omniNamesPort)
- os.kill(int(omniNamesPid),signal.SIGKILL)
- except (ImportError, AttributeError, OSError):
- pass
- except:
- import traceback
- traceback.print_exc()
-
- try:
- if sys.platform == "win32":
- import win32pm #@UnresolvedImport @Reimport
- win32pm.killpid(int(pid),0)
- else:
- os.kill(int(pid),signal.SIGKILL)
- pass
- pass
- except:
- if verbose(): print " ------------------ process %s : %s not found"% (pid, cmd[0])
- pass
- pass # for pid, cmd ...
- pass # for process_id ...
- pass # try...
- except:
- pass
- # end with
- #
- os.remove(filedict)
- cmd='ps -eo pid,command | egrep "[0-9] omniNames -start '+str(port)+'" | sed -e "s%[^0-9]*\([0-9]*\) .*%\\1%g"'
-# pid = subprocess.check_output(shlex.split(cmd))
- pid = commands.getoutput(cmd)
- a = ""
- while pid and len(a.split()) < 2:
- a = commands.getoutput("kill -9 " + pid)
- pid = commands.getoutput(cmd)
- pass
- pass
+ pass # for pid ...
+ pass # for process_id ...
+ # end with
except:
print "Cannot find or open SALOME PIDs file for port", port
pass
- #
+ os.remove(filedict)
+ pass
#
def __guessPiDictFilename(port):
# try to shutdown session normally
import threading, time
- threading.Thread(target=shutdownMyPort, args=(port,False)).start()
+ threading.Thread(target=shutdownMyPort, args=(port,True)).start()
time.sleep(3) # wait a little, then kill processes (should be done if shutdown procedure hangs up)
try:
pass
appliCleanOmniOrbConfig(port)
+ pass
def killMyPortSpy(pid, port):
dt = 1.0
while 1:
- if sys.platform == "win32":
- from win32pm import killpid #@UnresolvedImport
- if killpid(int(pid), 0) != 0:
- return
- else:
- from os import kill
- try:
- kill(int(pid), 0)
- except OSError, e:
- if e.errno != 3:
- return
- break
- pass
+ from salome_utils import killpid
+ ret = killpid(int(pid), 0)
+ if ret == 0:
+ break
+ elif ret < 0:
+ return
from time import sleep
sleep(dt)
pass
