Searched refs:pendingPackets (Results 1 – 1 of 1) sorted by relevance
125 private val pendingPackets = ConcurrentLinkedQueue<ByteArray>() constant135 pendingPackets.add(packet) in createFd()142 val packet = pendingPackets.poll() ?: throw ErrnoException("No pending packet", EAGAIN) in readPacket()