Searched refs:dataQueue (Results 1 – 2 of 2) sorted by relevance
104 final BlockingQueue<byte[]> dataQueue; field in EchoServer.EchoMachine115 dataQueue = new LinkedBlockingQueue<byte[]>(QUEUE_SIZE); in EchoMachine()120 if (dumpWhenFull && dataQueue.remainingCapacity() == 0) { in pushUnit()127 if (dataQueue.isEmpty()) { in pushUnit()134 dataQueue.put(new byte[] {}); in pushUnit()140 dataQueue.put(data); in pushUnit()154 dataQueue.clear(); in shutdown()161 while (!dataQueue.isEmpty()) { in handleMessage()162 callback.write(dataQueue.remove()); in handleMessage()
META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...