ahead_port

type ComponentSync struct {
	// contains filtered or unexported fields
}

type InPort interface {

	// TrySend attempts to send a packet to the downstream component.
	// This blocks until the downstream component decides its ready state.
	// Returns true if the packet was sent successfully, false if downstream is declared not ready.
	TrySend(cycle int, pkt PacketWithCycle) bool

	// MarkDone marks that the upstream component has completed the specified cycle.
	// This allows the downstream component to safely read data for this cycle.
	MarkDone(cycle int)

	// PeekReady checks if the downstream component is ready without blocking.
	// Returns (ready, decided).
	PeekReady(cycle int) (ready bool, decided bool)

	// IsReady blocks until the downstream component has decided its ready state.
	// Most components should prefer using TrySend directly.
	IsReady(cycle int) bool
}

type MockDownstream struct {
	// contains filtered or unexported fields
}

type MockUpstream struct {
	// contains filtered or unexported fields
}

type OutPort interface {

	// Receive retrieves all packets for the specified cycle from the upstream component.
	// This is a blocking call that ensures all packets for the cycle are collected.
	// Note: It internally handles the wait for upstream to be done (WaitDone).
	Receive(cycle int) []packet.Packet

	// UpdateReady updates the downstream component's ready state for the given cycle.
	// This informs the upstream whether it's ready to receive data for the specific cycle.
	UpdateReady(cycle int, ready bool)

	// WaitDone blocks until the upstream component has completed the specified cycle.
	// Note: Receive() already calls this internally.
	WaitDone(cycle int)

	// PeekDone returns the highest cycle that the upstream component has completed.
	// This is a non-blocking query method.
	PeekDone() int
}

type Packet = packet.Packet

type PacketWithCycle = packet.PacketWithCycle

type Port struct {
	// contains filtered or unexported fields
}