public int getCompleted()

in tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java [96:107]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public int getCompleted() {
    int ackedAmt;
    int failedAmt;

    synchronized(acked) {
      ackedAmt = acked.get(_id);
    }
    synchronized(failed) {
      failedAmt = failed.get(_id);
    }
    return ackedAmt + failedAmt;
  }