Open fire17 opened 2 months ago
reply, listen_for_request = server.reply()
try:
for payload in listen_for_request:
res = process_payload(payload)
reply(res)
except:
traceback.print_exc()
# recover[0] = True
print(".............. recovering from zmq error .........")
server.reconnect() # <-------------- THIS NEEDS TO BE INCLUDED IN THE ZEROLESS LIBRARY
# This should:
# 1. restart the server, avoid the "already exists on port error"
# 2. Handle the stuck client, by either:
# a. sending the stuck request a FAILED message, and let the client handle it
# b. recalling the function, simple recovery
# c. returning what the failed method already processed, advanced recovery (BETTER SOLUTION)
# Explanation: The ZMQ error happens at the end (on reply) which means that the server function
already ran and returned results. So right before sending via reply, that data should be temporarily saved,
and if the reply failed, it will be used after server recovery to be return immediately to the client.
print(".............. recovering done .........")
Hi there, First of all let me say thanks a lot I've been using this library for a few years and i love it for the most part
The only thing is that I cant seem to recover from errors If something has happened during the client/server conversation I have to restart all of the Servers and all of the Clients
but no matter what i do, i cant seem to recover [ALL CLIENTS AND SERVERS MUST DIE TO RESTART] I want a simple recovery without closing everything
Again this library is amazing, But the server/clients connections must be more robust, and auto handle reconnecting
Please let me know what you think, and how we can solve this Thanks a lot and all the best!