add guid

Author: tawnkramer

examples/gym_test.py

@@ -11,6 +11,7 @@
 import gym_donkeycar
 import time
 import random
+import uuid
 
 NUM_EPISODES = 3
 MAX_TIME_STEPS = 1000
@@ -75,6 +76,7 @@ def simulate(env):
         "racer_name" : "test",
         "country" : "USA",
         "bio" : "I am test client",
+        "guid" : str(uuid.uuid4()),
 
         "max_cte" : 20,
         }

examples/reinforcement_learning/ddqn.py

@@ -9,6 +9,7 @@
 import random
 import argparse
 import signal
+import uuid
 
 import numpy as np
 import gym
@@ -233,6 +234,7 @@ def run_ddqn(args):
         "racer_name" : "DDQN",
         "country" : "USA",
         "bio" : "Learning to drive w DDQN RL",
+        "guid" : str(uuid.uuid4()),
 
         "max_cte" : 10,
         }

examples/reinforcement_learning/ppo_train.py

@@ -9,6 +9,7 @@
 import argparse
 import gym
 import gym_donkeycar
+import uuid
 
 from stable_baselines.common.policies import MlpPolicy, CnnPolicy, CnnLstmPolicy
 from stable_baselines.common.vec_env import DummyVecEnv, SubprocVecEnv
@@ -72,6 +73,7 @@ def _init():
         "racer_name" : "PPO",
         "country" : "USA",
         "bio" : "Learning to drive w PPO RL",
+        "guid" : str(uuid.uuid4()),
 
         "max_cte" : 10,
         }

examples/test_cam_config.py

@@ -6,6 +6,7 @@
 import gym
 import gym_donkeycar
 import numpy as np
+import uuid
 
 if __name__ == "__main__":
 
@@ -45,6 +46,7 @@
         "racer_name" : "test",
         "country" : "USA",
         "bio" : "I am test client",
+        "guid" : str(uuid.uuid4()),
 
         "cam_resolution" : cam,
         "img_w" : cam[0],

gym_donkeycar/core/client.py

@@ -97,7 +97,7 @@ def proc_msg(self, sock):
                 for s in readable:
                     # print("waiting to recv")
                     try:
-                        data = s.recv(1024 * 64)
+                        data = s.recv(1024 * 256)
                     except ConnectionAbortedError:
                         logger.warn("socket connection aborted")
                         self.do_process_msgs = False

gym_donkeycar/envs/donkey_sim.py

@@ -150,7 +150,7 @@ def set_car_config(self, conf):
     def set_racer_bio(self, conf):
         self.conf = conf
         if "bio" in conf :
-            self.send_racer_bio(conf["racer_name"], conf["car_name"], conf["bio"], conf["country"])
+            self.send_racer_bio(conf["racer_name"], conf["car_name"], conf["bio"], conf["country"], conf["guid"])
 
     def on_recv_message(self, message):
         if 'msg_type' not in message:
@@ -357,15 +357,17 @@ def send_car_config(self, body_style, body_rgb, car_name, font_size):
         self.blocking_send(msg)
         time.sleep(0.1)
 
-    def send_racer_bio(self, racer_name, car_name, bio, country):
+    def send_racer_bio(self, racer_name, car_name, bio, country, guid):
         # body_style = "donkey" | "bare" | "car01" choice of string
         # body_rgb  = (128, 128, 128) tuple of ints
         # car_name = "string less than 64 char"
+        # guid = "some random string"
         msg = {'msg_type': 'racer_info',
             'racer_name': racer_name,
             'car_name' : car_name,
             'bio' : bio,
-            'country' : country }
+            'country' : country,
+            'guid' : guid }
         self.blocking_send(msg)
         time.sleep(0.1)