Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 561 - 570 of 961 for callGet (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top