- Sort Score
- Result 10 results
- Languages All
Results 711 - 720 of 1,131 for currentIO (0.04 sec)
-
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseContext.java
* @param leaseKey the lease key to set */ public void setLeaseKey(Smb2LeaseKey leaseKey) { this.leaseKey = leaseKey; } /** * Gets the current lease state flags for this directory * @return the lease state */ public int getLeaseState() { return leaseState; } /** * Sets the lease state flags for this directoryRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 9.4K bytes - Viewed (0) -
internal/lru/lru.go
c.mu.Lock() defer c.mu.Unlock() now := time.Now() // Check for existing item if ent, ok := c.items[key]; ok { c.evictList.MoveToFront(ent) c.removeFromBucket(ent) // remove the entry from its current bucket as expiresAt is renewed ent.Value = value ent.ExpiresAt = now.Add(c.ttl) c.addToBucket(ent) return false } // Add new item
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java
return redirect(e.getActionClass()); } } /** * Hook method called before action execution. * <p> * This method logs user access activity for the current request. * </p> * * @param runtime the action runtime context * @return the action response from the parent hook */ @Override
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/exentity/WebConfig.java
try { boost = Float.parseFloat(value); } catch (final Exception e) { if (logger.isDebugEnabled()) { logger.debug("Invalid boost value, keeping current: value={}, error={}", value, e.getMessage()); } } } } @Override public String getConfigId() { return ConfigType.WEB.getConfigId(getId()); }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 02:07:40 UTC 2025 - 10.2K bytes - Viewed (0) -
src/test/java/jcifs/pac/ASN1UtilTest.java
} // --- as(Class, DLSequence, int) --- @Test void testAs_DLSequence_RecursiveBug() { // This test exposes a recursive bug in the current implementation // The method calls itself, leading to a StackOverflowError. ASN1EncodableVector vector = new ASN1EncodableVector(); vector.add(new ASN1Integer(10));Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.4K bytes - Viewed (0) -
cmd/metacache-bucket.go
if !ok { return update, errFileNotFound } existing.update(update) b.caches[update.id] = existing b.updated = true return existing, nil } // cloneCaches will return a clone of all current caches. func (b *bucketMetacache) cloneCaches() (map[string]metacache, map[string][]string) { b.mu.RLock() defer b.mu.RUnlock() dst := make(map[string]metacache, len(b.caches)) maps.Copy(dst, b.caches)Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.6K bytes - Viewed (0) -
internal/hash/crc.go
package hash import ( "encoding/base64" "encoding/binary" "fmt" "hash/crc32" "hash/crc64" "math/bits" ) // AddPart will merge a part checksum into the current, // as if the content of each was appended. // The size of the content that produced the second checksum must be provided. // Not all checksum types can be merged, use the CanMerge method to check. // Checksum types must match.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jan 20 14:49:07 UTC 2025 - 5.8K bytes - Viewed (0) -
src/test/java/jcifs/netbios/NodeStatusRequestTest.java
// Act & Assert assertThrows(RuntimeException.class, () -> { spyRequest.writeBodyWireFormat(dst, 0); }); // Verify hexCode is NOT restored when exception occurs (current implementation behavior) assertEquals(0x00, mockName.hexCode); }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlXpathExtractor.java
} catch (final Exception e) { throw new ExtractException(e); } } /** * Gets an XPathAPI instance from the cache for the current thread. * * @return the XPathAPI instance */ protected XPathAPI getXPathAPI() { try { return xpathAPICache.get(Thread.currentThread().getName());
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Oct 04 08:47:19 UTC 2025 - 10.4K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
/** * All registered subscribers, indexed by event type. * * <p>The {@link CopyOnWriteArraySet} values make it easy and relatively lightweight to get an * immutable snapshot of all current subscribers to an event without any locking. */ private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = Maps.newConcurrentMap(); /** The event bus this registry belongs to. */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 10.8K bytes - Viewed (0)