Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getAndIncrement (0.11 sec)

  1. src/main/java/jcifs/internal/smb2/rdma/disni/DisniMemoryRegion.java

            // return memoryRegister.getLkey();
            return keyGenerator.getAndIncrement();
        }
    
        @Override
        protected int generateRemoteKey() {
            // In real implementation, this would get the remote key from DiSNI:
            // return memoryRegister.getRkey();
            return keyGenerator.getAndIncrement();
        }
    
        @Override
        protected long getBufferAddress(ByteBuffer buffer) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java

            valid = false;
        }
    
        @Override
        protected int generateLocalKey() {
            return keyGenerator.getAndIncrement();
        }
    
        @Override
        protected int generateRemoteKey() {
            return keyGenerator.getAndIncrement();
        }
    
        @Override
        protected long getBufferAddress(ByteBuffer buffer) {
            // Return a fake address for TCP
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/NtlmContext.java

            final byte[] sk = this.signKey;
            if (sk == null) {
                throw new CIFSException("Signing is not initialized");
            }
    
            final int seqNum = this.signSequence.getAndIncrement();
            final byte[] seqBytes = new byte[4];
            SMBUtil.writeInt4(seqNum, seqBytes, 0);
    
            final MessageDigest mac = Crypto.getHMACT64(sk);
            mac.update(seqBytes); // sequence
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

            }
        }
    
        private ChannelInfo selectRoundRobin(Collection<ChannelInfo> channels) {
            List<ChannelInfo> list = new ArrayList<>(channels);
            int index = Math.abs(roundRobinCounter.getAndIncrement() % list.size());
            return list.get(index);
        }
    
        private ChannelInfo selectLeastLoaded(Collection<ChannelInfo> channels) {
            ChannelInfo leastLoadedChannel = null;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

        }
    
        /**
         * Get and increment inconsistency count
         *
         * @return the current inconsistency count
         */
        public int getInconsistencyCount() {
            return inconsistencyCount.getAndIncrement();
        }
    
        /**
         * Reset inconsistency count
         */
        public void resetInconsistencyCount() {
            inconsistencyCount.set(0);
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/MultiChannelManager.java

                if (channels.isEmpty()) {
                    return null;
                }
    
                switch (strategy) {
                case ROUND_ROBIN:
                    int index = roundRobinIndex.getAndIncrement() % channels.size();
                    return channels.get(index);
    
                case LEAST_CONNECTIONS:
                    return channels.stream()
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
Back to top