Changeset 3562 for monitoring

Timestamp:

09/12/13 18:45:38 (11 years ago)

Author:

sanmai

Message:

• Remove multiprocessing as debugging forked processes is not supported by Python.

File:

• monitoring/plugins/mpi/generic_tla_monitoring.py (modified) (3 diffs)

monitoring/plugins/mpi/generic_tla_monitoring.py

@@ -203 +203 @@
     #     print 'process id:', os.getpid()
 
-    def LDAP_query(OpenDJ_uid, command, LDAP_result_queue):
+    def LDAP_query(OpenDJ_uid, command, LDAP_result_queue) :
+
+        pdb.set_trace()
+
         try :
             os.setuid(OpenDJ_uid)
@@ -221 +224 @@
 
 
-    LDAP_result_queue = multiprocessing.Queue()
-    LDAP_query_process = multiprocessing.Process(target = LDAP_query, args = (OpenDJ_uid, command, LDAP_result_queue))
-    LDAP_query_process.start()
+    # LDAP_result_queue = multiprocessing.Queue()
+    # LDAP_query_process = multiprocessing.Process(target = LDAP_query, args = (OpenDJ_uid, command, LDAP_result_queue))
+    # LDAP_query_process.start()
     result = LDAP_result_queue.get()
-    LDAP_query_process.join()
-
+    # LDAP_query_process.join()
+
+    LDAP_query(OpenDJ_uid, command, LDAP_result_queue)
 
     if result == True:
         return { "code"      : "OK", 
-               "message"   : 'Host %s is up and responds as expected to a query "%s" with base DN "%s".' % (host, query, base_DN)
-             }
+                 "message"   : 'Host %s is up and responds as expected to a query "%s" with base DN "%s".' % (host, query, base_DN)
+               }
     else :
         return { "code"      : "CRITICAL", 
-                   "message"   : 'Host %s is not up or does not respond as expected to a query "%s" with base DN "%s".' % (host, query, base_DN)
-                 }
+                 "message"   : 'Host %s is not up or does not respond as expected to a query "%s" with base DN "%s".' % (host, query, base_DN)
+               }
 
     # current_process_ID = os.fork()
@@ -249 +253 @@
     # os.waitpid(current_process_ID, 0)
     
-    try :
-        os.setuid(Nagios_uid)
-    except OSError, e :
-        raise e
+    # try :
+    #     os.setuid(Nagios_uid)
+    # except OSError, e :
+    #     raise e
 
     #print stdout