Samo Penic
2018-12-23 1bc9bba5a3bb201345fcf6b690b1c884f8ab8a7d
tsclient.py
@@ -178,9 +178,13 @@
            print("[{}] Could not get CID.".format(self.id))
            self.sleep(10)
            continue
         #print("Got CID. getting RID.")
         client_ping_time_elapsed=0
         print("[{}] Connected and got client ID {}.".format(self.id, cid))
         try:
         concurrent_runs=client_ping(self.conn_address,cid)
            client_ping_time_elapsed=0
         except:
            self.sleep(10)
            continue
         self.subrunsStartStop(concurrent_runs)
         while(not self.isStopped()): #successfully registered, now start pinging and searching for job
            try:
@@ -252,7 +256,7 @@
                     try:
                        ping_run(self.conn_address, cid, rid)
                     except:
                        print("[{}] Could not ping.".format(self.id))
                        print("[{}] Could not prolong a lease on the run.".format(self.id))
                        self.p.terminate()
                        self.p=None
                        removeDir(self.workingdir.fullpath())
@@ -275,7 +279,15 @@
                  self.sleep(self.update_seconds-1)
                  client_ping_time_elapsed+=self.update_seconds
                  if(client_ping_time_elapsed>self.max_client_ping_time_elapsed-self.update_seconds/2):
                     try:
                     concurrent_runs=client_ping(self.conn_address,cid)
                     except:
                        print("[{}] Could not client ping.".format(self.sid))
                        self.p.terminate()
                        self.p=None
                        removeDir(self.workingdir.fullpath())
                        self.workingdir=None
                        break
                     self.subrunsStartStop(concurrent_runs)
                     client_ping_time_elapsed=0