Skip to content

Commit 225c54c

Browse files
committed
TCPBuffer
Summary: Adds a TCPBuffer implementation to tensor_engine, as a fallback example for RDMABuffer. The main change from the original TCP-based buffer is that it uses ZMQ for communications to 1) decouple from Monarch's message passing system and 2) to mimic RDMABuffer's design, and showcase how other backends can be easily added Differential Revision: D79588454
1 parent cc52e60 commit 225c54c

File tree

6 files changed

+698
-154
lines changed

6 files changed

+698
-154
lines changed

python/monarch/_src/actor/actor_mesh.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,9 @@ def __init__(
169169
self._shape = shape
170170
self._please_replace_me_actor_ids = actor_ids
171171

172+
def get_actor_id(self) -> ActorId:
173+
return self._please_replace_me_actor_ids[0]
174+
172175
@staticmethod
173176
def from_hyperactor_mesh(
174177
mailbox: Mailbox, hy_actor_mesh: PythonActorMesh, proc_mesh: "ProcMesh"

0 commit comments

Comments
 (0)