Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for computeIfAbsent (0.07 sec)

  1. src/main/java/jcifs/util/AuthenticationRateLimiter.java

                return false;
            }
    
            // Check per-account limit
            if (username != null) {
                AccountAttempts account = accountAttempts.computeIfAbsent(username, k -> new AccountAttempts());
                if (account.isLockedOut()) {
                    if (account.getLockoutExpiry().isAfter(Instant.now())) {
                        totalAttemptsBlocked.incrementAndGet();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/MetadataGraph.java

            vFrom.setCompareScope(scopedVertices);
    
            List<MetadataGraphEdge> exList = excidentEdges.computeIfAbsent(vFrom, k -> new ArrayList<>());
    
            if (!exList.contains(e)) {
                exList.add(e);
            }
    
            List<MetadataGraphEdge> inList = incidentEdges.computeIfAbsent(vTo, k -> new ArrayList<>());
    
            if (!inList.contains(e)) {
                inList.add(e);
            }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jul 23 17:27:08 UTC 2025
    - 13K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/entity/ParamMap.java

            // use original key
            return parent.replace(key, value);
        }
    
        @Override
        public V computeIfAbsent(final K key, final Function<? super K, ? extends V> mappingFunction) {
            // use original key
            return parent.computeIfAbsent(key, mappingFunction);
        }
    
        @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  4. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

            }
    
            private LongAdder getCounter(BuilderProblem.Severity severity) {
                return counters.computeIfAbsent(severity, k -> new LongAdder());
            }
    
            private List<P> getProblems(BuilderProblem.Severity severity) {
                return problems.computeIfAbsent(severity, k -> new CopyOnWriteArrayList<>());
            }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/rdma/disni/DisniMemoryRegion.java

            // or DiSNI-specific methods
    
            if (buffer.isDirect()) {
                // Assign a unique address to each buffer instance
                return bufferAddresses.computeIfAbsent(buffer, b -> addressCounter.getAndIncrement());
            } else {
                throw new IllegalArgumentException("Only direct ByteBuffers are supported for RDMA");
            }
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  6. docs/smb3-features/03-multi-channel-design.md

            
            // Mark channel as failed
            failedChannel.setState(ChannelState.FAILED);
            
            // Get or create failover state
            FailoverState state = failoverStates.computeIfAbsent(
                failedChannel.getChannelId(), 
                FailoverState::new
            );
            
            // Redistribute pending operations
            redistributePendingOperations(failedChannel);
            
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            }
    
            // Track connection metrics
            String key = getConnectionKey(address, port);
            connectionMetrics.computeIfAbsent(key, k -> new ConnectionMetrics()).recordConnection();
            activeConnections.incrementAndGet();
    
            if (nonPooled) {
                this.nonPooledConnections.offer(conn);
            } else {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

            // Mark channel as failed
            failedChannel.setState(ChannelState.FAILED);
    
            // Get or create failover state
            FailoverState state = failoverStates.computeIfAbsent(failedChannel.getChannelId(), FailoverState::new);
    
            // Redistribute pending operations
            redistributePendingOperations(failedChannel);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

            if (StringUtil.isBlank(value)) {
                return Collections.emptyList();
            }
            return split(value, ",").get(stream -> stream.map(String::trim)//
                    .map(s -> clientRuleCache.computeIfAbsent(s, t -> {
                        final String[] values = t.split(":", 2);
                        if (values.length != 2) {
                            return null;
                        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java

                    responseHeaders.put(name, values);
                }
    
                @Override
                public void addHeader(String name, String value) {
                    responseHeaders.computeIfAbsent(name, k -> new ArrayList<>()).add(value);
                }
    
                @Override
                public void setIntHeader(String name, int value) {
                }
    
                @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25.9K bytes
    - Viewed (0)
Back to top