Changed the things that were not accepted in the review

eclipse-ecal · Apr 17, 2024 · a9021e8 · a9021e8
1 parent 4de9fd6
commit a9021e8
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 11 deletions.
diff --git a/samples/python/pubsub/binary/binary_rec/CMakeLists.txt b/samples/python/pubsub/binary/binary_rec/CMakeLists.txt
@@ -20,7 +20,7 @@ project(binary_rec)
 
 find_package(eCAL REQUIRED)
 
-set(PROJECT_GROUP minimal)
+set(PROJECT_GROUP binary)
 
 if(ECAL_INCLUDE_PY_SAMPLES)
   if(WIN32)

diff --git a/samples/python/pubsub/binary/binary_rec/binary_rec.py b/samples/python/pubsub/binary/binary_rec/binary_rec.py
@@ -1,4 +1,4 @@
-# ========================= eCAL LICENSE =================================
+ # ========================= eCAL LICENSE =================================
 #
 # Copyright (C) 2016 - 2019 Continental Corporation
 #
@@ -26,7 +26,7 @@ def main():
   print("eCAL {} ({})\n".format(ecal_core.getversion(), ecal_core.getdate()))
 
   # initialize eCAL API
-  ecal_core.initialize(sys.argv, "py_byte_rec")
+  ecal_core.initialize(sys.argv, "py_binary_rec")
 
   # set process state
   ecal_core.set_process_state(1, 1, "I feel good")
@@ -38,7 +38,7 @@ def main():
   while ecal_core.ok():
     ret, msg, time = sub.receive(500)
     if ret > 0:
-      print("Received:  {} ms   {}".format(time, msg))
+      print("Received:  {} ms   {}".format(time, bytes.fromhex(msg.decode("utf-8"))))
     else:
       print("Subscriber timeout ..")
 

diff --git a/samples/python/pubsub/binary/binary_rec_cb/CMakeLists.txt b/samples/python/pubsub/binary/binary_rec_cb/CMakeLists.txt
@@ -20,7 +20,7 @@ project(binary_rec_cb)
 
 find_package(eCAL REQUIRED)
 
-set(PROJECT_GROUP minimal)
+set(PROJECT_GROUP binary)
 
 if(ECAL_INCLUDE_PY_SAMPLES)
   if(WIN32)

diff --git a/samples/python/pubsub/binary/binary_rec_cb/binary_rec_cb.py b/samples/python/pubsub/binary/binary_rec_cb/binary_rec_cb.py
@@ -24,7 +24,7 @@
 
 # eCAL receive callback
 def callback(topic_name, msg, time):
-  print("Received:  {} ms   {}".format(time, msg))
+  print("Received:  {} ms   {}".format(time, bytes.fromhex(msg.decode("utf-8"))))
 
 def main():  
   # print eCAL version and date

diff --git a/samples/python/pubsub/binary/binary_snd/CMakeLists.txt b/samples/python/pubsub/binary/binary_snd/CMakeLists.txt
@@ -20,7 +20,7 @@ project(binary_snd)
 
 find_package(eCAL REQUIRED)
 
-set(PROJECT_GROUP minimal)
+set(PROJECT_GROUP binary)
 
 if(ECAL_INCLUDE_PY_SAMPLES)
   if(WIN32)

diff --git a/samples/python/pubsub/binary/binary_snd/binary_snd.py b/samples/python/pubsub/binary/binary_snd/binary_snd.py
@@ -28,20 +28,23 @@ def main():
   print("eCAL {} ({})\n".format(ecal_core.getversion(), ecal_core.getdate()))
 
   # initialize eCAL API
-  ecal_core.initialize(sys.argv, "py_byte_snd")
+  ecal_core.initialize(sys.argv, "py_binary_snd")
 
   # set process state
   ecal_core.set_process_state(1, 1, "I feel good")
 
   # create publisher
   pub = BinaryPublisher("Hello")
-  msg = b"Hello from eCAL"
+  msg_fox = b"4120717569636b2062726f776e20666f7820"
 
   # send messages
-  staticmsg = msg
+  msg_count = 0
   while ecal_core.ok():
+    msg_count += 1
+    hex_ascii = bytes(''.join([hex(ord(digit))[2:] for digit in str(msg_count)]), "utf-8")
+    msg = msg_fox + hex_ascii
     pub.send(msg)
-    msg = staticmsg + random.randbytes(6)
+    print("Sent: ", msg)
     time.sleep(0.01)
 
   # finalize eCAL API