- Sort Score
- Num 10 results
- Language All
Results 561 - 570 of 961 for callGet (0.06 seconds)
-
internal/stmt_store/stmt_store.go
// it defaults to defaultTTL. // // This function defines an onEvicted callback that is invoked when a cache entry is evicted. // The callback ensures that if the evicted value (v) is not nil, its Close method is called asynchronously // to release associated resources. // // Returns: // - A Store instance implemented by lruStore, which internally uses an LRU cache with the specified size, // eviction callback, and TTL.
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/DataStoreTest.java
IndexUpdateCallback callback = new TestIndexUpdateCallback(); // Execute store method dataStore.store(config, callback, params); // Verify store was called assertTrue(storeCalled.get()); assertNotNull(capturedConfig.get()); assertEquals("test-config", capturedConfig.get().getName()); assertNotNull(capturedCallback.get());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 13.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/app/job/ScriptExecutorJobTest.java
final TestableScriptExecutorJob job = new TestableScriptExecutorJob(); job.process(runtime); // When logging is disabled, store() is never called assertNull(storedJobLog.get()); } // ===================================================================================Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 11:55:54 GMT 2026 - 13.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/rank/fusion/RankFusionProcessorConcurrencyTest.java
if (!executor.isTerminated()) { executor.shutdownNow(); } } } } /** * Test that setSearcher and register can be called concurrently. */ @Test public void test_concurrentSetAndRegister() throws Exception { final int numIterations = 100; final CountDownLatch startLatch = new CountDownLatch(1);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 13.5K bytes - Click Count (0) -
guava/src/com/google/common/cache/Cache.java
* * <p><b>Warning:</b> this cache may not be recording statistical data. For example, a cache * created using {@link CacheBuilder} only does so if the {@link CacheBuilder#recordStats} method * was called. If statistics are not being recorded, a {@code CacheStats} instance with zero for * all values is returned. * */ CacheStats stats(); /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/msrpc/srvsvcTest.java
shareInfo1.encode(mockNdrBuffer); // Verify the encode operations verify(mockNdrBuffer).align(4); verify(mockNdrBuffer, times(2)).enc_ndr_referent(null, 1); // Called twice for netname and remark verify(mockNdrBuffer).enc_ndr_long(0); // Should not encode strings if fields are null verify(mockDeferredBuffer, never()).enc_ndr_string(anyString()); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12K bytes - Click Count (0) -
internal/crypto/sse-s3.go
} // There are two possibilities: // - We use a KMS -> There must be non-empty key ID and a KMS data key. // - We use a K/V -> There must be no key ID and no KMS data key. // Otherwise, the caller has passed an invalid argument combination. if keyID == "" && len(kmsKey) != 0 { logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present")) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 07 23:55:37 GMT 2024 - 7.6K bytes - Click Count (0) -
internal/event/target/webhook.go
func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) } // Only called from init() func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
src/cmd/asm/internal/arch/arm64.go
// ARM64SpecialOperand returns the internal representation of a special operand. func ARM64SpecialOperand(name string) arm64.SpecialOperand { if arm64SpecialOperand == nil { // Generate mapping when function is first called. arm64SpecialOperand = map[string]arm64.SpecialOperand{} for opd := arm64.SPOP_BEGIN; opd < arm64.SPOP_END; opd++ { arm64SpecialOperand[opd.String()] = opd } // Handle some special cases.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Mar 20 17:02:17 GMT 2026 - 6K bytes - Click Count (0) -
android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt
) {} override fun checkServerTrusted( chain: Array<out X509Certificate>?, authType: String?, ) { withoutHostCalled = true } // called by Android via reflection in X509TrustManagerExtensions @Suppress("unused", "UNUSED_PARAMETER") fun checkServerTrusted( chain: Array<out X509Certificate>, authType: String,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 29.9K bytes - Click Count (0)