import platform
import psutil
import random
-if os.name == 'posix':
- import resource
-else:
- resource = None
import select
import signal
import socket
import werkzeug.serving
-try:
+if os.name == 'posix':
+ # Unix only for workers
import fcntl
-except ImportError:
- pass
+ import resource
+else:
+ # Windows shim
+ signal.SIGHUP = -1
+
+# Optional process names for workers
try:
from setproctitle import setproctitle
except ImportError:
self.long_polling_pid = popen.pid
def worker_pop(self, pid):
+ if pid == self.long_polling_pid:
+ self.long_polling_pid = None
if pid in self.workers:
_logger.debug("Worker (%s) unregistered", pid)
try:
raise
def process_limit(self):
- if resource is None:
- return
# If our parent changed sucide
if self.ppid != os.getppid():
_logger.info("Worker (%s) Parent changed", self.pid)
# run test_file if provided
if test_file:
_logger.info('loading test file %s', test_file)
- if test_file.endswith('yml'):
- load_test_file_yml(registry, test_file)
- elif test_file.endswith('py'):
- load_test_file_py(registry, test_file)
+ with openerp.api.Environment.manage():
+ if test_file.endswith('yml'):
+ load_test_file_yml(registry, test_file)
+ elif test_file.endswith('py'):
+ load_test_file_py(registry, test_file)
if registry._assertion_report.failures:
rc += 1