initVal - Code Search

src/test/java/jcifs/SmbFileHandleTest.java

        when(smbFileHandle.getInitialSize()).thenReturn(expectedSize);
        long actualSize = smbFileHandle.getInitialSize();
        assertEquals(expectedSize, actualSize, "getInitialSize should return the correct initial file size.");
        verify(smbFileHandle, times(1)).getInitialSize();
    }

    /**
     * Test getInitialSize() when the size is zero.
     */
    @Test
    void testGetInitialSize_zero() {

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 5.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

    RateLimiter r = RateLimiter.create(1);
    assertTrue("Unable to acquire initial permit", r.tryAcquire());
    assertFalse("Capable of acquiring secondary permit", r.tryAcquire());
  }

  public void testDoubleMinValueCanAcquireExactlyOnce() {
    RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch);
    assertTrue("Unable to acquire initial permit", r.tryAcquire());

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Oct 28 18:19:59 UTC 2025

- 21.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

    RateLimiter r = RateLimiter.create(1);
    assertTrue("Unable to acquire initial permit", r.tryAcquire());
    assertFalse("Capable of acquiring secondary permit", r.tryAcquire());
  }

  public void testDoubleMinValueCanAcquireExactlyOnce() {
    RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch);
    assertTrue("Unable to acquire initial permit", r.tryAcquire());

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Oct 28 18:19:59 UTC 2025

- 21.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

 * the following strategies:
 *
 *  1. If the current call already has a connection that can satisfy the request it is used. Using
 *     the same connection for an initial exchange and its follow-ups may improve locality.
 *
 *  2. If there is a connection in the pool that can satisfy the request it is used. Note that it is

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Tue May 27 14:58:02 UTC 2025

- 4.2K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Logger.java

            @Nullable Throwable error) {}

    /**
     * If this is an accumulating log, it will "drain" this instance. It returns the accumulated log entries, and
     * also "resets" this instance to empty (initial) state.
     */
    @Nonnull
    default List<Entry> drain() {
        return List.of();
    }

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Thu Oct 16 06:12:36 UTC 2025

- 5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/resources/fess_indices/fess_user.user/user.json

      "employeeType" : {
        "type" : "keyword"
      },
      "facsimileTelephoneNumber" : {
        "type" : "keyword"
      },
      "postOfficeBox" : {
        "type" : "keyword"
      },
      "initials" : {
        "type" : "keyword"
      },
      "carLicense" : {
        "type" : "keyword"
      },
      "mobile" : {
        "type" : "keyword"
      },
      "postalAddress" : {

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Dec 02 13:14:56 UTC 2021

- 2.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/RelatedQueryHelper.java

        super();
    }

    /**
     * Initializes the RelatedQueryHelper after dependency injection is complete.
     * This method is called automatically by the dependency injection framework
     * and loads the initial related query configurations.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {
            logger.debug("Initializing {}", this.getClass().getSimpleName());
        }

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Fri Nov 28 16:29:12 UTC 2025

- 5.1K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportAggregationWorkAction.kt

       <link xmlns:xslthl="http://xslthl.sf.net" rel="stylesheet" href="https://fonts.googleapis.com/css?family=Lato:400,400i,700">
       <meta xmlns:xslthl="http://xslthl.sf.net" content="width=device-width, initial-scale=1" name="viewport">
       <link xmlns:xslthl="http://xslthl.sf.net" type="text/css" rel="stylesheet" href="https://docs.gradle.org/current/userguide/base.css">

    </head>
    <body>
       <h1>Incubating APIs</h1>

Registered: Wed Dec 31 11:36:14 UTC 2025

- Last Modified: Mon Jun 02 09:57:54 UTC 2025

- 5.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/config/es/fess_user_user.json

            "type" : "keyword"
          },
          "homePhone" : {
            "type" : "keyword"
          },
          "homePostalAddress" : {
            "type" : "keyword"
          },
          "initials" : {
            "type" : "keyword"
          },
          "internationaliSDNNumber" : {
            "type" : "keyword"
          },
          "labeledURI" : {
            "type" : "keyword"
          },

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Dec 02 13:14:56 UTC 2021

- 3.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-metrics.go

	startTime            time.Time // Start time for window
	expMovingAvg         float64   // Previously calculated exponential moving average
}

// newRateMeasurement creates a new instance of the measurement with the initial start time.
func newRateMeasurement(initTime time.Time) *rateMeasurement {
	return &rateMeasurement{
		startTime: initTime,
	}
}

// incrementBytes add bytes reported for a bucket/target.

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Thu Aug 15 12:04:40 UTC 2024

- 14.2K bytes

- Viewed (0)

Search Options