Skip to content

vllm.distributed.ec_transfer.ec_connector.cpu.control.base

Abstract base classes for the EC control plane.

ControlConnection wraps a single peer channel (one DEALER socket).

Classes:

ControlConnection

Bases: ABC

Bidirectional message channel to a single remote peer.

All I/O is non-blocking: send enqueues without blocking; recv drains all buffered inbound messages since the last call.

Methods:

  • close –

    Release all resources. Idempotent.

  • mark_dead –

    Signal that the peer disconnected. Sets alive to False.

  • recv –

    Drain and return all buffered inbound messages.

  • send –

    Enqueue msg for delivery. Must not block.

Attributes:

  • alive (bool) –

    True if the connection is still usable.

Source code in vllm/distributed/ec_transfer/ec_connector/cpu/control/base.py 
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
class ControlConnection(ABC):
    """Bidirectional message channel to a single remote peer.

    All I/O is non-blocking: send enqueues without blocking; recv drains
    all buffered inbound messages since the last call.
    """

    @property
    @abstractmethod
    def alive(self) -> bool:
        """True if the connection is still usable."""

    @abstractmethod
    def send(self, msg: bytes) -> None:
        """Enqueue msg for delivery. Must not block."""

    @abstractmethod
    def recv(self) -> list[bytes]:
        """Drain and return all buffered inbound messages."""

    @abstractmethod
    def mark_dead(self) -> None:
        """Signal that the peer disconnected. Sets alive to False."""

    @abstractmethod
    def close(self) -> None:
        """Release all resources. Idempotent."""

alive abstractmethod property

True if the connection is still usable.

close() abstractmethod

Release all resources. Idempotent.

Source code in vllm/distributed/ec_transfer/ec_connector/cpu/control/base.py 
35
36
37
@abstractmethod
def close(self) -> None:
    """Release all resources. Idempotent."""

mark_dead() abstractmethod

Signal that the peer disconnected. Sets alive to False.

Source code in vllm/distributed/ec_transfer/ec_connector/cpu/control/base.py 
31
32
33
@abstractmethod
def mark_dead(self) -> None:
    """Signal that the peer disconnected. Sets alive to False."""

recv() abstractmethod

Drain and return all buffered inbound messages.

Source code in vllm/distributed/ec_transfer/ec_connector/cpu/control/base.py 
27
28
29
@abstractmethod
def recv(self) -> list[bytes]:
    """Drain and return all buffered inbound messages."""

send(msg) abstractmethod

Enqueue msg for delivery. Must not block.

Source code in vllm/distributed/ec_transfer/ec_connector/cpu/control/base.py 
23
24
25
@abstractmethod
def send(self, msg: bytes) -> None:
    """Enqueue msg for delivery. Must not block."""