Adding command infrastructure to python run script

grf14003 · Mar 11, 2020 · ea4c6ee · ea4c6ee
1 parent b5004ca
commit ea4c6ee
Show file tree

Hide file tree

Showing 3 changed files with 32 additions and 1 deletion.
diff --git a/bfs/implementations/breadcrumbs/algos/AlgoBreadcrumbs.cpp b/bfs/implementations/breadcrumbs/algos/AlgoBreadcrumbs.cpp
@@ -4,7 +4,6 @@
 
 void AlgoBreadcrumbs::loop()
 {
-	printf("Hello world!\n");
 	vector<Attribute>* attribs = pollForAttributes();
 	if (attribs->size() > 0)
 	{

diff --git a/bfs/scripts/log.txt b/bfs/scripts/log.txt
@@ -38,3 +38,24 @@ Listening for clients...
 Listening for clients...
 Hello new client!
 Listening for clients...
+Listening for clients...
+Hello new client!
+Listening for clients...
+Listening for clients...
+Hello new client!
+Listening for clients...
+Listening for clients...
+Hello new client!
+Listening for clients...
+Could not acquire mutex to add new client thread
+Listening for clients...
+Hello new client!
+Listening for clients...
+Could not acquire mutex to add new client thread
+Listening for clients...
+Hello new client!
+Listening for clients...
+Could not acquire mutex to add new client thread
+Listening for clients...
+Hello new client!
+Listening for clients...
diff --git a/bfs/scripts/startbfs.py b/bfs/scripts/startbfs.py
@@ -74,6 +74,17 @@ def main():
     exe_ending = ".exe"
     exe_names = get_exe_names(args.algorithm, args.io_processor, args.config)
     procs = [start_program_async(os.path.join(binary_path, x) + exe_ending) for x in exe_names]
+
+    try:
+        while True:
+            user_in = input()
+            if user_in == "q":
+                print("Quitting prompt")
+                [proc.terminate() for proc in procs]
+                break
+    except Exception as e:
+        print("Python exception: [%s]" % str(e))
+
     [proc.join() for proc in procs]
 
     print("DONE")