[client, storage] refactor: unify dynamic ZMQ socket decorator between simple_backend_manager and client

[ji-huazhong]

as title.

[ascend-robot]

CLA Signature Pass

ji-huazhong, thanks for your pull request. All authors of the commits have signed the CLA. 👍

[ascend-robot]

CLA Signature Pass

ji-huazhong, thanks for your pull request. All authors of the commits have signed the CLA. 👍

[Copilot]

Pull request overview

Refactors TransferQueue’s ZMQ request-socket lifecycle handling by introducing a shared async decorator in zmq_utils and reusing it in both the client and simple storage backend manager.

Changes:

• Added dynamic_zmq_socket() utility decorator to centralize ZMQ context/socket creation, connect, injection, and cleanup.
• Replaced AsyncTransferQueueClient.dynamic_socket() with a pre-bound module-level decorator using dynamic_zmq_socket().
• Replaced AsyncSimpleStorageManager.dynamic_storage_manager_socket() with a pre-bound module-level decorator using dynamic_zmq_socket().

Reviewed changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 1 comment.

File	Description
transfer_queue/utils/zmq_utils.py	Introduces shared dynamic_zmq_socket() decorator for async request sockets.
transfer_queue/storage/managers/simple_backend_manager.py	Switches storage-unit request methods to use the shared decorator.
transfer_queue/client.py	Switches controller request methods to use the shared decorator.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[ascend-robot]

CLA Signature Pass

ji-huazhong, thanks for your pull request. All authors of the commits have signed the CLA. 👍

[0oshowero0]

consider

with_zmq_socket(
    "put_get_socket",
    get_identity=lambda self: self.storage_manager_id,
    get_peer=lambda self, target: self.storage_unit_infos[target],
    resolve_target=lambda args, kwargs: kwargs.get("target_storage_unit"),
    timeout=...,
)