* @throws SmbException
     *
     * @see jcifs.SmbFileHandle#release()
     */
    @Override
    public synchronized void release() throws CIFSException {
        final long usage = this.usageCount.decrementAndGet();
        if (usage == 0) {
            closeInternal(0L, false);
        } else if (log.isTraceEnabled()) {
            log.trace(String.format("Release %s (%d)", this, usage));
        }
    }

      seenExceptionsUpdater.compareAndSet(state, expect, update);
    }

    @Override
    int decrementAndGetRemainingCount(AggregateFutureState<?> state) {
      return remainingCountUpdater.decrementAndGet(state);
    }

    @Override
    String atomicHelperTypeForTest() {
      return "SafeAtomicHelper";
    }
  }

  private static final class SynchronizedAtomicHelper extends AtomicHelper {

            this.treeConnection.acquire();
        }
        return this;
    }

    @Override
    public void release() {
        final long us = this.usageCount.decrementAndGet();
        if (us == 0) {
            this.treeConnection.release();
        } else if (us < 0) {
            throw new RuntimeCIFSException("Usage count dropped below zero");
        }
    }

         * Decrements the reference count for this statistics object.
         *
         * @return the new reference count after decrementing
         */
        public int decrement() {
            return count.decrementAndGet();
        }
    }

    /**
     * Enumeration of predefined statistics actions that can be recorded
     * during crawler operations. Each action represents a specific event

        }

        public void incrementConnections() {
            activeConnections.incrementAndGet();
        }

        public void decrementConnections() {
            activeConnections.decrementAndGet();
        }

        public boolean isHealthy() {
            return isHealthy;
        }

        public void setHealthy(boolean healthy) {
            this.isHealthy = healthy;

    }

    public void release() {
        release(true);
    }

    /**
     * @param track
     */
    public void release(final boolean track) {
        final long usage = this.usageCount.decrementAndGet();
        if (log.isTraceEnabled()) {
            log.trace("Release tree " + usage + " " + this);
        }

        if (track && this.traceResource) {
            synchronized (this.releases) {

                }
            }
        }

        return this;

    }

    /**
     *
     */
    public void release() {
        final long usage = this.usageCount.decrementAndGet();
        if (log.isTraceEnabled()) {
            log.trace("Release tree connection " + usage + " " + this);
        }

        if (usage == 0) {
            synchronized (this) {

    
    public boolean canSend() {
        return sendCredits.get() > 0 && state == RdmaConnectionState.ESTABLISHED;
    }
    
    public void consumeSendCredit() {
        sendCredits.decrementAndGet();
    }
    
    public void grantSendCredit() {
        sendCredits.incrementAndGet();
    }
    
    public void grantReceiveCredit() {
        receiveCredits.incrementAndGet();
    }
    

    removeFromReplica(replica, replicatedMaxValue);
  }

  private static void removeFromReplica(Map<Integer, AtomicInteger> replica, int value) {
    AtomicInteger numOccur = replica.get(value);
    if (numOccur.decrementAndGet() == 0) {
      replica.remove(value);
    }
  }

  private static void assertIntact(MinMaxPriorityQueue<?> q) {
    if (!q.isIntact()) {
      fail("State " + Arrays.toString(q.toArray()));
    }

    private final AtomicLong registrationFailures = new AtomicLong();
    
    public void recordRegistration() { registrationsActive.incrementAndGet(); }
    public void recordUnregistration() { registrationsActive.decrementAndGet(); }
    public void recordNotification() { notificationsReceived.incrementAndGet(); }
    public void recordFailover() { failoverEvents.incrementAndGet(); }