void recreateEventBufferIfNeeded()

in src/main/java/org/apache/geode/kafka/source/SharedEventBufferSupplier.java [28:40]

• 13 lines of code
• 6 McCabe index (conditional complexity)

  void recreateEventBufferIfNeeded(int size) {
    if (eventBuffer == null || (eventBuffer.size() + eventBuffer.remainingCapacity()) != size) {
      synchronized (GeodeKafkaSource.class) {
        if (eventBuffer == null || (eventBuffer.size() + eventBuffer.remainingCapacity()) != size) {
          BlockingQueue<GeodeEvent> oldEventBuffer = eventBuffer;
          eventBuffer = new LinkedBlockingQueue<>(size);
          if (oldEventBuffer != null) {
            eventBuffer.addAll(oldEventBuffer);
          }
        }
      }
    }
  }