Changeset 1490 for lmd/trunk/fuentes/lmd-server.install

Timestamp:

May 12, 2016, 11:42:08 AM (5 years ago)

Author:

joamuran

Message:

fixed LmdServer?.py

File:

• lmd/trunk/fuentes/lmd-server.install/usr/share/n4d/python-plugins/LmdServer.py (modified) (4 diffs)

lmd/trunk/fuentes/lmd-server.install/usr/share/n4d/python-plugins/LmdServer.py

@@ -362 +362 @@
                         
                         #temp.close()
-                        
-                        job['status']="finished"
+                        if (str(ret)=='0'):
+                                job['status']="finished"
+                        else:
+                                job['status']="broken"
                         job['msg']=str(ret)
                         print "[LmdServer] END WAIT AT"+str(datetime.datetime.now())
@@ -569 +571 @@
                 
                 # Remove listener
-                
                 from operator import itemgetter
                 try:
                         # If job_id is None, search job_ib by ip and port
                         tuple_ip_port = (str(ip),str(port))
+                        print (tuple_ip_port)
                         if job_id == None:
+                                print self.global_listeners
                                 job_id = self.global_listeners[tuple_ip_port]
                         # Get job identified by job_id
@@ -581 +584 @@
                         # Get listener identified by (ip:port)
                         current_listener_index=map(itemgetter('ip','port'), current_job['listeners']).index((ip,int (port, base=10)))
-                        
                         # Kill process (only addition to remove_listener)
                         os.killpg(current_job['process'].pid,signal.SIGKILL)
-                        current_job['status']='finished'
-                        
+                        current_job['status']='broken'
 
                         # Close port and remove listener to current_job
@@ -592 +593 @@
                         #remove listener reference
                         self.global_listeners.pop(tuple_ip_port)
-                        
                         
                         return True