Skip to content

Removed exit() call and related code inserted for test #11

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
AlessioLovato wants to merge 1 commit into
base: proto_ros2
Choose a base branch
from
Open

Removed exit() call and related code inserted for test #11

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 1 addition & 23 deletions server/src/xbot2_gui_server/ecat.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,28 +14,6 @@
from .proto import repl_cmd_pb2


# subscribe to zmq topic for ecat updates
ctx = zmq.Context()
socket = ctx.socket(zmq.SUB)
socket.connect('tcp://10.240.23.85:10000')
socket.setsockopt_string(zmq.SUBSCRIBE, '')

# receive one message
msg = socket.recv()
msg = socket.recv()

# parse message
cmd = repl_cmd_pb2.Repl_info()
cmd.ParseFromString(msg)

# print message as string
print(cmd)



exit()


class EcatHandler:

def __init__(self, srv: ServerBase, config=dict()) -> None:
Expand Down Expand Up @@ -246,4 +224,4 @@ async def run_loop(self):
@utils.handle_exceptions
async def run(self):

await utils.sync_loop(self.run_loop, dt=1./self.rate)()
await utils.sync_loop(self.run_loop, dt=1./self.rate)()