#!/usr/bin/python3
|
import requests
|
import json
|
from time import sleep
|
import uuid
|
import subprocess
|
from trisurf import trisurf
|
import os
|
import shutil
|
import signal
|
import sys
|
import socket
|
CONNECT_ADDR='http://localhost:8000'
|
|
p=None
|
workingdir=None
|
|
|
|
#--- SIGINT and SIGTERM HANDLING ---
|
def signal_handler(signal,frame):
|
global p
|
global wirkingdir
|
if p is not None:
|
p.terminate()
|
if(workingdir is not None):
|
removeDir(workingdir.fullpath())
|
print("Process ended with signal " +str(signal))
|
sys.exit(0)
|
signal.signal(signal.SIGINT, signal_handler)
|
signal.signal(signal.SIGTERM, signal_handler)
|
#--- END SIGINT and SIGTERM----
|
|
|
|
def get_hostname():
|
return socket.gethostname()
|
|
def get_ip():
|
return ((([ip for ip in socket.gethostbyname_ex(socket.gethostname())[2] if not ip.startswith("127.")] or [[(s.connect(("8.8.8.8", 53)), s.getsockname()[0], s.close()) for s in [socket.socket(socket.AF_INET, socket.SOCK_DGRAM)]][0][1]]) + ["no IP found"])[0])
|
|
def get_client_id(addr, my_ip, my_hostname):
|
client_auth={'ip':my_ip,'hostname':my_hostname}
|
response=requests.post(addr+"/api/register/", data=client_auth)
|
if(response.status_code==200):
|
client_data=json.loads(response.text)
|
client_id=client_data['id']
|
return client_id
|
else:
|
raise ValueError
|
|
|
def get_run(addr,cid):
|
response=requests.get(addr+"/api/getrun/"+str(cid)+"/")
|
if(response.status_code==200):
|
client_data=json.loads(response.text)
|
rid=client_data['id']
|
tape=client_data['tape']
|
vtu=client_data['lastVTU']
|
status=client_data['status']
|
return (rid,tape,vtu,status)
|
else:
|
raise ValueError
|
|
|
def ping_run(addr,cid, rid):
|
client_data={'client_id':cid, 'run_id':rid}
|
response=requests.post(addr+"/api/ping/", data=client_data)
|
if(response.status_code==200):
|
return
|
else:
|
raise ValueError
|
|
def send_error_report(addr,cid, rid,errcode):
|
client_data={'client_id':cid, 'run_id':rid, 'error_code':errcode}
|
response=requests.post(addr+"/api/reporterr/", data=client_data)
|
if(response.status_code==200):
|
return
|
else:
|
raise ValueError
|
|
def upload(addr,cid, rid, vtu, status):
|
client_data={'client_id': cid, 'run_id': rid, 'lastVTU': vtu, 'status': status}
|
response=requests.post(addr+"/api/upload/", data=client_data)
|
if(response.status_code==200):
|
return
|
else:
|
raise ValueError
|
|
def getNewVTU(directory):
|
fset=set()
|
for file in os.listdir(directory):
|
if file.endswith(".vtu") and file.startswith("timestep_"):
|
fset.add(file)
|
return fset
|
|
|
def removeDir(directory):
|
os.chdir('/')
|
try:
|
shutil.rmtree(directory)
|
except:
|
print("Cannot remove directory "+directory+ "\n")
|
return
|
|
|
while(True):
|
try:
|
cid=get_client_id(CONNECT_ADDR, get_ip(),get_hostname())
|
except:
|
print("Cannot get CID.")
|
sleep(10)
|
continue
|
print("Got CID. getting RID.")
|
while(True):
|
try:
|
(rid,tape,vtu,status)=get_run(CONNECT_ADDR,cid)
|
except:
|
print("Could not get RID.")
|
sleep(10)
|
break
|
else:
|
#start separate thread with simulations.
|
workingdir=trisurf.Directory('/tmp/ts_'+str(uuid.uuid4()))
|
workingdir.makeifnotexist()
|
workingdir.goto()
|
with open(workingdir.fullpath()+"/tape", 'w') as f:
|
f.write(tape)
|
if(int(status)==-1):
|
cmd=['trisurf', '--force-from-tape']
|
print("Run id="+str(rid)+ " :: Starting from tape")
|
else:
|
with open(workingdir.fullpath()+"/.status",'w') as f:
|
f.write(status)
|
with open(workingdir.fullpath()+"/initial.vtu",'w') as f:
|
f.write(vtu)
|
cmd=['trisurf', '--restore-from-vtk', 'initial.vtu']
|
print("Run id="+str(rid)+ " :: Restoring from vtk, last timestep "+status)
|
p=subprocess.Popen(cmd, stdout=subprocess.DEVNULL)
|
s=int(status)
|
while(True):
|
#monitor for new file. If file is present, upload it!
|
newVTU=getNewVTU(workingdir.fullpath())
|
if newVTU: #upload
|
try:
|
for nv in sorted(newVTU):
|
with open(nv,'r') as f:
|
fc=f.read()
|
s=s+1
|
print('Uploading '+nv)
|
upload(CONNECT_ADDR, cid, rid, fc, s)
|
os.unlink(nv)
|
except:
|
print("Could not upload")
|
p.terminate()
|
removeDir(workingdir.fullpath())
|
break
|
else:
|
print("VTU uploaded")
|
else: #ping
|
try:
|
ping_run(CONNECT_ADDR, cid, rid)
|
except:
|
print("Could not ping")
|
p.terminate()
|
removeDir(workingdir.fullpath())
|
#stop simulations
|
break
|
#check if trisurf is still running. If not break the highest level loop.
|
sleep(1)
|
if(p.poll() is not None): # trisurf exited!
|
print("Trisurf was stopped with return code {}".format(p.returncode))
|
if(p.returncode!=0):
|
try:
|
send_error_report(CONNECT_ADDR, cid, rid, p.returncode)
|
except:
|
print("Server didn't accept error report")
|
removeDir(workingdir.fullpath())
|
break
|
sleep(100)
|
|
|
