- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for esClient (0.14 sec)
-
src/main/resources/esclient.xml
Shinsuke Sugaya <******@****.***> 1730900702 +0900
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Wed Nov 06 13:45:02 UTC 2024 - 16K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
} private EngineObj getEngineObj() { final EngineObj engineObj = new EngineObj(); try { final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient(); final ClusterHealthResponse response = esClient.admin().cluster().prepareHealth().execute().actionGet(fessConfig.getIndexHealthTimeout()); engineObj.clusterName = response.getClusterName();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback { @Throws(IOException::class) fun onReadMessage(text: String) @Throws(IOException::class)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketReaderTest.kt
private val serverReader = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(), perMessageDeflate = false, noContextTakeover = false, ) private val serverReaderWithCompression = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(),
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
client: Boolean, ) { val extensions = this.extensions!! synchronized(this) { this.name = name this.socket = socket this.writer = WebSocketWriter( isClient = client, sink = socket.sink, random = random, perMessageDeflate = extensions.perMessageDeflate, noContextTakeover = extensions.noContextTakeover(client),
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/math/IntMathTest.java
assertEquals( "The mean of x and y should equal the mean of y and x", expectedMean, IntMath.mean(y, x)); } /** * Computes the mean in a way that is obvious and resilient to overflow by using BigInteger * arithmetic. */ private static int computeMeanSafely(int x, int y) { BigInteger bigX = BigInteger.valueOf(x); BigInteger bigY = BigInteger.valueOf(y);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 24.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/math/LongMathTest.java
assertEquals( "The mean of x and y should equal the mean of y and x", expectedMean, LongMath.mean(y, x)); } /** * Computes the mean in a way that is obvious and resilient to overflow by using BigInteger * arithmetic. */ private static long computeMeanSafely(long x, long y) { BigInteger bigX = BigInteger.valueOf(x); BigInteger bigY = BigInteger.valueOf(y);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 31.4K bytes - Viewed (0) -
guava/src/com/google/common/math/LongMath.java
static boolean fitsInInt(long x) { return (int) x == x; } /** * Returns the arithmetic mean of {@code x} and {@code y}, rounded toward negative infinity. This * method is resilient to overflow. * * @since 14.0 */ public static long mean(long x, long y) { // Efficient method for computing the arithmetic mean. // The alternative (x + y) / 2 fails for large values.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Aug 29 16:20:07 UTC 2025 - 46.8K bytes - Viewed (0)