Searched refs:multicastPacketQueue (Results 1 – 2 of 2) sorted by relevance
70 final Queue<DatagramPacket> multicastPacketQueue = new ArrayDeque<>(); field in MdnsSocketClient181 synchronized (multicastPacketQueue) { in stopDiscovery()182 multicastPacketQueue.clear(); in stopDiscovery()212 sendMdnsPackets(packets, multicastPacketQueue, onlyUseIpv6OnIpv6OnlyNetworks); in sendPacketRequestingMulticastResponse()221 sendMdnsPackets(packets, multicastPacketQueue, onlyUseIpv6OnIpv6OnlyNetworks); in sendPacketRequestingUnicastResponse()369 synchronized (multicastPacketQueue) { in sendThreadMain()370 multicastPacketsToSend.addAll(multicastPacketQueue); in sendThreadMain()371 multicastPacketQueue.clear(); in sendThreadMain()393 synchronized (multicastPacketQueue) { in sendThreadMain()396 multicastPacketQueue.isEmpty() && unicastPacketQueue.isEmpty(); in sendThreadMain()
364 synchronized (mdnsClient.multicastPacketQueue) { in testStopDiscovery_queueIsCleared()365 assertTrue(mdnsClient.multicastPacketQueue.isEmpty()); in testStopDiscovery_queueIsCleared()376 synchronized (mdnsClient.multicastPacketQueue) { in testSendPacket_afterDiscoveryStops()377 assertTrue(mdnsClient.multicastPacketQueue.isEmpty()); in testSendPacket_afterDiscoveryStops()391 synchronized (mdnsClient.multicastPacketQueue) { in testSendPacket_queueReachesSizeLimit()392 assertTrue(mdnsClient.multicastPacketQueue.size() <= 2); in testSendPacket_queueReachesSizeLimit()