core-data/org.meshtastic.core.data.manager/PacketHandlerImpl

PacketHandlerImpl

class PacketHandlerImpl(packetRepository: Lazy<PacketRepository>, radioInterfaceService: RadioInterfaceService, meshLogRepository: Lazy<MeshLogRepository>, connectionStateProvider: ConnectionStateProvider, scope: CoroutineScope) : PacketHandler(source)

Constructors

PacketHandlerImpl

constructor(packetRepository: Lazy<PacketRepository>, radioInterfaceService: RadioInterfaceService, meshLogRepository: Lazy<MeshLogRepository>, connectionStateProvider: ConnectionStateProvider, scope: CoroutineScope)

Types

Companion

object Companion

Functions

handleQueueStatus

open override fun handleQueueStatus(queueStatus: QueueStatus)

removeResponse

open override fun removeResponse(dataRequestId: Int, complete: Boolean)

sendToRadio

open suspend override fun sendToRadio(packet: MeshPacket)

Enqueue packet for transmission. Order is preserved for sequential calls from the same coroutine (mutex acquisition is uncontested between sequential calls). Transactional sequences that require strict ordering across multiple calls — e.g. an editSettings { … } begin → writes → commit sequence — MUST be issued from a single coroutine; concurrent senders share FIFO only at the per-call grain.

open override fun sendToRadio(p: ToRadio)

sendToRadioAndAwait

open suspend override fun sendToRadioAndAwait(packet: MeshPacket): Boolean

stopPacketQueue

open override fun stopPacketQueue()