ed8b14e7e3
Framework provides multi process execution environment support for NFP modules. Multi processing is implemented using oslo_service and python multiprocessing library. All the common initializations of NFP modules for conf, log, processes, rpc, events are implemented in the framework. Supports: a) Autloads NFP modules & their init. b) RPC init & endpoint registration. c) Event registration. d) Multiple worker processes. e) Threadpool per worker. f) Event loadbalancing across workers. g) *aas RPC Agent state reporting support. h) Periodic polling for an event. i) Individual spacing for periodic events. j) Event binding & sequencing. Change-Id: I99bfe8ada82c8a14302616102505541805e9021a Implements: blueprint gbp-network-services-framework Co-Authored-By: Yogesh Rajmane <yogesh.rajmane@oneconvergence.com> (cherry picked from commitd43fbe9a11) (cherry picked from commit2ed8697526)
117 lines
3.3 KiB
Python
117 lines
3.3 KiB
Python
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
from oslo_log import log as oslo_logging
|
|
|
|
import logging
|
|
import os
|
|
import sys
|
|
import threading
|
|
|
|
if hasattr(sys, 'frozen'): # support for py2exe
|
|
_srcfile = "logging%s__init__%s" % (os.sep, __file__[-4:])
|
|
elif __file__[-4:].lower() in ['.pyc', '.pyo']:
|
|
_srcfile = __file__[:-4] + '.py'
|
|
else:
|
|
_srcfile = __file__
|
|
_srcfile = os.path.normcase(_srcfile)
|
|
|
|
|
|
def currentframe():
|
|
"""Return the frame object for the caller's stack frame."""
|
|
try:
|
|
raise Exception
|
|
except Exception:
|
|
return sys.exc_info()[2].tb_frame.f_back
|
|
|
|
|
|
if hasattr(sys, '_getframe'):
|
|
currentframe = lambda: sys._getframe(3)
|
|
|
|
|
|
class WrappedLogger(logging.Logger):
|
|
|
|
def __init__(self, name):
|
|
logging.Logger.__init__(self, name)
|
|
|
|
def findCaller(self):
|
|
"""
|
|
Find the stack frame of the caller so that we can note the source
|
|
file name, line number and function name.
|
|
"""
|
|
f = currentframe()
|
|
# On some versions of IronPython, currentframe() returns None if
|
|
# IronPython isn't run with -X:Frames.
|
|
if f is not None:
|
|
f = f.f_back
|
|
if f.f_back:
|
|
f = f.f_back
|
|
rv = "(unknown file)", 0, "(unknown function)"
|
|
while hasattr(f, "f_code"):
|
|
co = f.f_code
|
|
filename = os.path.normcase(co.co_filename)
|
|
if filename == _srcfile:
|
|
f = f.f_back
|
|
continue
|
|
rv = (co.co_filename, f.f_lineno, co.co_name)
|
|
break
|
|
return rv
|
|
|
|
def makeRecord(self, name, level, fn,
|
|
lno, msg, args, exc_info, func=None, extra=None):
|
|
context = getattr(logging_context_store, 'context', None)
|
|
if context:
|
|
_prefix = context.emit()
|
|
msg = "%s-%s" % (_prefix, msg)
|
|
return super(WrappedLogger, self).makeRecord(
|
|
name, level, fn, lno, msg,
|
|
args, exc_info, func=func, extra=extra)
|
|
|
|
|
|
logging.setLoggerClass(WrappedLogger)
|
|
logging_context_store = threading.local()
|
|
|
|
|
|
class NfpLogContext(object):
|
|
|
|
def __init__(self, **kwargs):
|
|
self.meta_id = kwargs.get('meta_id', '')
|
|
self.auth_token = kwargs.get('auth_token', '')
|
|
|
|
def emit(self):
|
|
return "[LogMetaID:%s]" % (self.meta_id)
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'meta_id': self.meta_id,
|
|
'auth_token': self.auth_token}
|
|
|
|
|
|
def getLogger(name):
|
|
return oslo_logging.getLogger(name)
|
|
|
|
|
|
def store_logging_context(**kwargs):
|
|
context = NfpLogContext(**kwargs)
|
|
logging_context_store.context = context
|
|
|
|
|
|
def clear_logging_context(**kwargs):
|
|
logging_context_store.context = None
|
|
|
|
|
|
def get_logging_context():
|
|
context = getattr(logging_context_store, 'context', None)
|
|
if context:
|
|
return context.to_dict()
|
|
return {}
|