concore.py

import time
import os
from ast import literal_eval
import sys
import re

#if windows, create script to kill this process 
# because batch files don't provide easy way to know pid of last command
# ignored for posix!=windows, because "concorepid" is handled by script
# ignored for docker (linux!=windows), because handled by docker stop
if hasattr(sys, 'getwindowsversion'):
    with open("concorekill.bat","w") as fpid:
        fpid.write("taskkill /F /PID "+str(os.getpid())+"\n")

try:
    iport = literal_eval(open("concore.iport").read())
except:
    iport = dict()
try:
    oport = literal_eval(open("concore.oport").read())
except:
    oport = dict()


s = ''
olds = ''
delay = 1
retrycount = 0
inpath = "./in" #must be rel path for local
outpath = "./out"

#9/21/22
try:
    sparams = open(inpath+"1/concore.params").read()
    if sparams[0] == '"':  #windows keeps "" need to remove
        sparams = sparams[1:]
        sparams = sparams[0:sparams.find('"')]
    if sparams != '{':
        print("converting sparams: "+sparams)
        sparams = "{'"+re.sub(';',",'",re.sub('=',"':",re.sub(' ','',sparams)))+"}"
        print("converted sparams: " + sparams)
    try:
        params = literal_eval(sparams)
    except:
        print("bad params: "+sparams)
except:
    params = dict()
#9/30/22
def tryparam(n,i):
    try:
       return params[n]
    except:
       return i


#9/12/21
def default_maxtime(default):
    global maxtime
    try:
        maxtime = literal_eval(open(inpath+"1/concore.maxtime").read())
    except:
        maxtime = default 
default_maxtime(100)

def unchanged():
    global olds,s
    if olds==s:
        s = ''
        return True
    else:       
        olds = s       
        return False

def read(port, name, initstr):
    global s,simtime,retrycount
    time.sleep(delay)
    try:
        infile = open(inpath+str(port)+"/"+name);
        ins = infile.read()
        infile.close()
    except:
        ins = initstr
    while len(ins)==0:
        time.sleep(delay)
        infile = open(inpath+str(port)+"/"+name);
        ins = infile.read()
        infile.close()
        retrycount += 1
    s += ins
    inval = literal_eval(ins)
    simtime = max(simtime,inval[0])
    return inval[1:]

def write(port, name, val, delta=0):
    global outpath,simtime
    if isinstance(val,str):
        time.sleep(2*delay)
    elif isinstance(val,list)==False:
        print("mywrite must have list or str")
        quit() 
    try:
        with open(outpath+str(port)+"/"+name,"w") as outfile:     
            if isinstance(val,list):
                outfile.write(str([simtime+delta]+val))
                simtime += delta
            else:
                outfile.write(val)
    except:
        print("skipping"+outpath+str(port)+"/"+name);

def initval(simtime_val):
    global simtime
    val = literal_eval(simtime_val)
    simtime = val[0]
    return val[1:]