private int drainTo()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/LogAccumulator.java [231:245]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  private int drainTo(List<ProducerBatch> c) {
    int n = 0;
    for (Map.Entry<GroupKey, ProducerBatchHolder> entry : batches.entrySet()) {
      ProducerBatchHolder holder = entry.getValue();
      synchronized (holder) {
        if (holder.producerBatch == null) {
          continue;
        }
        c.add(holder.producerBatch);
        ++n;
        holder.producerBatch = null;
      }
    }
    return n;
  }