Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for decrementAndGet (0.05 sec)

  1. src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java

            connectionsActive.incrementAndGet();
        }
    
        /**
         * Record RDMA connection closure
         */
        public void recordConnectionClosed() {
            connectionsActive.decrementAndGet();
        }
    
        /**
         * Record memory region allocation
         */
        public void recordMemoryRegionAllocated() {
            memoryRegionsAllocated.incrementAndGet();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

                }
                this.connections.remove(trans);
                this.nonPooledConnections.remove(trans);
                activeConnections.decrementAndGet();
                connectionsRemoved.incrementAndGet();
            }
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbTransportPool#close()
         */
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

                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");
            }
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

        return addAndGet(key, 1);
      }
    
      /**
       * Decrements by one the value currently associated with {@code key}, and returns the new value.
       */
      @CanIgnoreReturnValue
      public long decrementAndGet(K key) {
        return addAndGet(key, -1);
      }
    
      /**
       * Adds {@code delta} to the value currently associated with {@code key}, and returns the new
       * value.
       */
      @CanIgnoreReturnValue
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbTreeImpl.java

        }
    
        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) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 30K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

             * 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
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/MultiChannelManager.java

            }
    
            public void incrementConnections() {
                activeConnections.incrementAndGet();
            }
    
            public void decrementConnections() {
                activeConnections.decrementAndGet();
            }
    
            public boolean isHealthy() {
                return isHealthy;
            }
    
            public void setHealthy(boolean healthy) {
                this.isHealthy = healthy;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/SmbCircuitBreaker.java

                        throw (CIFSException) e;
                    }
                    throw new CIFSException("Circuit breaker operation failed", e);
                }
            } finally {
                activeRequests.decrementAndGet();
                if (semaphoreAcquired) {
                    requestSemaphore.release();
                }
            }
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/util/transport/Transport.java

            release();
        }
    
        /**
         * Releases a reference to this transport, decrementing the usage count.
         */
        public void release() {
            final long usage = this.usageCount.decrementAndGet();
            if (log.isTraceEnabled()) {
                log.trace("Release transport " + usage + " " + this);
            }
    
            if (usage == 0) {
                if (log.isTraceEnabled()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbTreeConnection.java

                    }
                }
            }
    
            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) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 30.4K bytes
    - Viewed (1)
Back to top