<CONTEXT>mWaitingConsumers.add(consumer);</BUG>}<extra_id_0>}<BUG>if (tooMany || !mJobManagerThread.canListenToNetwork()) {</BUG>CommandMessage cm = factory.obtain(CommandMessage.class);cm.set(CommandMessage.POKE);if (!tooMany) {keepAliveTimeout = timer.nanoTime() + consumerKeepAliveNs;</CONTEXT>
for (Runnable runnable : internalZeroConsumersListeners) {runnable.run();} else {if (!waitingConsumers.contains(consumer)) {waitingConsumers.add(consumer);if (tooMany || !jobManagerThread.canListenToNetwork()) {