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

PacketHandlerImpl

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

Constructors

PacketHandlerImpl

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

Types

Companion

object Companion

Functions

completeDispatchedResponse

open suspend override fun completeDispatchedResponse(dataRequestId: Int, complete: Boolean)

handleQueueStatus

open override fun handleQueueStatus(queueStatus: QueueStatus)

rearmSendAckTimeouts

open override fun rearmSendAckTimeouts()

sendToRadio

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

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 fun sendToRadioAndAwait(packet: MeshPacket): Boolean

sendToRadioAndAwaitResult

open suspend override fun sendToRadioAndAwaitResult(packet: MeshPacket): AwaitedSendResult

sendToRadioForConnection

open suspend override fun sendToRadioForConnection(packet: MeshPacket, expectedConnectionVersion: Long): Boolean

stopPacketQueue

open override fun stopPacketQueue()