Changeset 1490


Ignore:
Timestamp:
May 12, 2016, 11:42:08 AM (3 years ago)
Author:
joamuran
Message:

fixed LmdServer?.py

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lmd/trunk/fuentes/lmd-server.install/usr/share/n4d/python-plugins/LmdServer.py

    r1180 r1490  
    362362                       
    363363                        #temp.close()
    364                        
    365                         job['status']="finished"
     364                        if (str(ret)=='0'):
     365                                job['status']="finished"
     366                        else:
     367                                job['status']="broken"
    366368                        job['msg']=str(ret)
    367369                        print "[LmdServer] END WAIT AT"+str(datetime.datetime.now())
     
    569571               
    570572                # Remove listener
    571                
    572573                from operator import itemgetter
    573574                try:
    574575                        # If job_id is None, search job_ib by ip and port
    575576                        tuple_ip_port = (str(ip),str(port))
     577                        print (tuple_ip_port)
    576578                        if job_id == None:
     579                                print self.global_listeners
    577580                                job_id = self.global_listeners[tuple_ip_port]
    578581                        # Get job identified by job_id
     
    581584                        # Get listener identified by (ip:port)
    582585                        current_listener_index=map(itemgetter('ip','port'), current_job['listeners']).index((ip,int (port, base=10)))
    583                        
    584586                        # Kill process (only addition to remove_listener)
    585587                        os.killpg(current_job['process'].pid,signal.SIGKILL)
    586                         current_job['status']='finished'
    587                        
     588                        current_job['status']='broken'
    588589
    589590                        # Close port and remove listener to current_job
     
    592593                        #remove listener reference
    593594                        self.global_listeners.pop(tuple_ip_port)
    594                        
    595595                       
    596596                        return True
Note: See TracChangeset for help on using the changeset viewer.