Christophe Monniez
bb14c41663
Purpose:
The psycogreen module is unmaintained. Last source update was in
2015 and last pypi package was in 2012. Odoo only use a small
part of the psycogreen module that could be written directly in
the odoo code. This commit reproduce the small function from
psycogreen used in ODoo and remove all depencies from it.
Also the copyright and license are honored and the documentation
is updated accordingly.
pypi pckage: https://pypi.python.org/pypi/psycogreen
bitbucket repos: https://bitbucket.org/dvarrazzo/psycogreen/
105 lines
3.7 KiB
Python
105 lines
3.7 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
|
|
|
""" OpenERP core library."""
|
|
|
|
#----------------------------------------------------------
|
|
# odoo must be a namespace package for odoo.addons to become one too
|
|
# https://packaging.python.org/guides/packaging-namespace-packages/
|
|
#----------------------------------------------------------
|
|
__path__ = __import__('pkgutil').extend_path(__path__, __name__)
|
|
|
|
#----------------------------------------------------------
|
|
# Running mode flags (gevent, prefork)
|
|
#----------------------------------------------------------
|
|
# Is the server running with gevent.
|
|
import sys
|
|
evented = False
|
|
if len(sys.argv) > 1 and sys.argv[1] == 'gevent':
|
|
sys.argv.remove('gevent')
|
|
import gevent.monkey
|
|
import psycopg2
|
|
from gevent.socket import wait_read, wait_write
|
|
gevent.monkey.patch_all()
|
|
|
|
def gevent_wait_callback(conn, timeout=None):
|
|
"""A wait callback useful to allow gevent to work with Psycopg."""
|
|
# Copyright (C) 2010-2012 Daniele Varrazzo <daniele.varrazzo@gmail.com>
|
|
# This function is borrowed from psycogreen module which is licensed
|
|
# under the BSD license (see in odoo/debian/copyright)
|
|
while 1:
|
|
state = conn.poll()
|
|
if state == psycopg2.extensions.POLL_OK:
|
|
break
|
|
elif state == psycopg2.extensions.POLL_READ:
|
|
wait_read(conn.fileno(), timeout=timeout)
|
|
elif state == psycopg2.extensions.POLL_WRITE:
|
|
wait_write(conn.fileno(), timeout=timeout)
|
|
else:
|
|
raise psycopg2.OperationalError(
|
|
"Bad result from poll: %r" % state)
|
|
psycopg2.extensions.set_wait_callback(gevent_wait_callback)
|
|
evented = True
|
|
|
|
# Is the server running in prefork mode (e.g. behind Gunicorn).
|
|
# If this is True, the processes have to communicate some events,
|
|
# e.g. database update or cache invalidation. Each process has also
|
|
# its own copy of the data structure and we don't need to care about
|
|
# locks between threads.
|
|
multi_process = False
|
|
|
|
#----------------------------------------------------------
|
|
# libc UTC hack
|
|
#----------------------------------------------------------
|
|
# Make sure the OpenERP server runs in UTC.
|
|
import os
|
|
os.environ['TZ'] = 'UTC' # Set the timezone
|
|
import time
|
|
if hasattr(time, 'tzset'):
|
|
time.tzset()
|
|
|
|
#----------------------------------------------------------
|
|
# Shortcuts
|
|
#----------------------------------------------------------
|
|
# The hard-coded super-user id (a.k.a. administrator, or root user).
|
|
SUPERUSER_ID = 1
|
|
|
|
def registry(database_name=None):
|
|
"""
|
|
Return the model registry for the given database, or the database mentioned
|
|
on the current thread. If the registry does not exist yet, it is created on
|
|
the fly.
|
|
"""
|
|
if database_name is None:
|
|
import threading
|
|
database_name = threading.currentThread().dbname
|
|
return modules.registry.Registry(database_name)
|
|
|
|
#----------------------------------------------------------
|
|
# Imports
|
|
#----------------------------------------------------------
|
|
from . import addons
|
|
from . import conf
|
|
from . import loglevels
|
|
from . import modules
|
|
from . import netsvc
|
|
from . import osv
|
|
from . import release
|
|
from . import service
|
|
from . import sql_db
|
|
from . import tools
|
|
|
|
#----------------------------------------------------------
|
|
# Model classes, fields, api decorators, and translations
|
|
#----------------------------------------------------------
|
|
from . import models
|
|
from . import fields
|
|
from . import api
|
|
from odoo.tools.translate import _
|
|
|
|
#----------------------------------------------------------
|
|
# Other imports, which may require stuff from above
|
|
#----------------------------------------------------------
|
|
from . import cli
|
|
from . import http
|