]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr: use modules' log_level instead of mgr log level
authorRicardo Dias <rdias@suse.com>
Wed, 25 Sep 2019 10:45:38 +0000 (11:45 +0100)
committerRicardo Dias <rdias@suse.com>
Tue, 12 Nov 2019 11:49:55 +0000 (11:49 +0000)
Signed-off-by: Ricardo Dias <rdias@suse.com>
src/mgr/BaseMgrModule.cc
src/mgr/BaseMgrStandbyModule.cc
src/mgr/PyModuleRunner.cc
src/mgr/PyModuleRunner.h
src/pybind/mgr/mgr_module.py

index b340f74f1a1f4666317d6282449759c583b4c8fd..a6963bb28eb65d16ab000ee0ee5a0aad07651a66 100644 (file)
@@ -528,15 +528,14 @@ get_daemon_status(BaseMgrModule *self, PyObject *args)
 static PyObject*
 ceph_log(BaseMgrModule *self, PyObject *args)
 {
-  int level = 0;
   char *record = nullptr;
-  if (!PyArg_ParseTuple(args, "is:log", &level, &record)) {
+  if (!PyArg_ParseTuple(args, "s:log", &record)) {
     return nullptr;
   }
 
   ceph_assert(self->this_module);
 
-  self->this_module->log(level, record);
+  self->this_module->log(record);
 
   Py_RETURN_NONE;
 }
index f3fbff667cf6db9e6c913badf003617c53c7c21a..59f97d8172b9f98df1c5aff3aad613680df5af6a 100644 (file)
@@ -152,15 +152,14 @@ ceph_get_active_uri(BaseMgrStandbyModule *self, PyObject *args)
 static PyObject*
 ceph_log(BaseMgrStandbyModule *self, PyObject *args)
 {
-  int level = 0;
   char *record = nullptr;
-  if (!PyArg_ParseTuple(args, "is:log", &level, &record)) {
+  if (!PyArg_ParseTuple(args, "s:log", &record)) {
     return nullptr;
   }
 
   ceph_assert(self->this_module);
 
-  self->this_module->log(level, record);
+  self->this_module->log(record);
 
   Py_RETURN_NONE;
 }
index 403c8a9f183f30c4972e9c4d93d4f44229fb09cc..ca90f87a1db9ae13b56e4a6e5108c6808d52f393 100644 (file)
@@ -90,11 +90,11 @@ void PyModuleRunner::shutdown()
   }
 }
 
-void PyModuleRunner::log(int level, const std::string &record)
+void PyModuleRunner::log(const std::string &record)
 {
 #undef dout_prefix
-#define dout_prefix *_dout << "mgr[" << get_name() << "] "
-  dout(ceph::dout::need_dynamic(level)) << record << dendl;
+#define dout_prefix *_dout << "[" << get_name() << "] "
+  dout(0) << record << dendl;
 #undef dout_prefix
 #define dout_prefix *_dout << "mgr " << __func__ << " "
 }
index 08c85a13263606bb4d1353716dd2979a65fee655..4d0b7601928aeb9de1f6400a6e66bfa01f30f505 100644 (file)
@@ -52,7 +52,7 @@ protected:
 public:
   int serve();
   void shutdown();
-  void log(int level, const std::string &record);
+  void log(const std::string &record);
 
   const char *get_thread_name() const
   {
index e2d8466922880fcdea967dd8e409a56a550f2c53..12811a14ecfe0ddd00185cec950a0fd9d06fd90c 100644 (file)
@@ -52,18 +52,11 @@ class CPlusPlusHandler(logging.Handler):
     def __init__(self, module_inst):
         super(CPlusPlusHandler, self).__init__()
         self._module = module_inst
+        self.setFormatter(logging.Formatter("[%(levelname)-4s] %(message)s"))
 
     def emit(self, record):
-        if record.levelno <= logging.DEBUG:
-            ceph_level = 20
-        elif record.levelno <= logging.INFO:
-            ceph_level = 4
-        elif record.levelno <= logging.WARNING:
-            ceph_level = 1
-        else:
-            ceph_level = 0
-
-        self._module._ceph_log(ceph_level, self.format(record))
+        if record.levelno >= self._module._get_log_level():
+            self._module._ceph_log(self.format(record))
 
 
 def configure_logger(module_inst, module_name):
@@ -97,7 +90,7 @@ def configure_logger(module_inst, module_name):
     # Check https://docs.python.org/3/library/logging.html#logging.Logger.setLevel
     # for more information about how the effective log level is
     # determined.
-    root_logger.setLevel(logging.ERROR)
+    root_logger.setLevel(logging.CRITICAL)
 
     return logger