- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 682 for mycket (0.19 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractConditionAggregation.java
import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.RangeAggregationBuilder; import org.opensearch.search.aggregations.bucket.sampler.SamplerAggregationBuilder; import org.opensearch.search.aggregations.bucket.terms.SignificantTermsAggregationBuilder; import org.opensearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 12.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
.build() class SocketClosingEventListener : EventListener() { var shouldClose: Boolean = false var lastSocket: Socket? = null override fun connectionAcquired( call: Call, connection: Connection, ) { lastSocket = connection.socket() } override fun requestHeadersStart(call: Call) { if (shouldClose) { lastSocket!!.close() } } }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 3K bytes - Click Count (0) -
docs/bucket/lifecycle/DESIGN.md
Lifecycle transition functionality provided in [bucket lifecycle guide](https://github.com/minio/minio/master/docs/bucket/lifecycle/README.md) allows tiering of content from MinIO object store to public clouds or other MinIO clusters. Transition tiers can be added to MinIO using `mc admin tier add` command to associate a `gcs`, `s3` or `azure` bucket or prefix path on a bucket to the tier name.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 4.2K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt
import okio.asOkioSocket import okio.buffer /** * Adapts a [java.net.Socket] to MockWebServer's needs. * * Note that [asOkioSocket] returns a socket that closes the underlying [java.net.Socket] when both * of its component streams are closed. This class takes advantage of that. */ internal class MockWebServerSocket( val javaNetSocket: Socket, ) : Closeable, BufferedSocket {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 3.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* permits per second: * * {@snippet : * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits per second * void submitPacket(byte[] packet) { * rateLimiter.acquire(packet.length); * networkService.send(packet); * } * } * * <p>It is important to note that the number of permits requested <i>never</i> affects theCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:05:27 GMT 2025 - 21.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/NbtSocket.java
import java.net.InetAddress; import java.net.Socket; import jcifs.smb1.Config; import jcifs.smb1.util.LogStream; /** Do not use this class. Writing to the OutputStream of this type of socket requires leaving a 4 byte prefix for the NBT header. IOW you must call write( buf, 4, len ). Calling write( buf, 0, len ) will generate an error. */ public class NbtSocket extends Socket {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.1K bytes - Click Count (0) -
docs/site-replication/run-multi-site-oidc.sh
if [ $? -ne 0 ]; then echo "expected bucket to be mirrored with object-lock but not present, exiting..." exit_1 fi if [ "${enabled_minio2}" != "Enabled" ]; then echo "expected bucket to be mirrored with object-lock enabled, exiting..." exit_1 fi enabled_minio1=$(./mc stat --json minio1/newbucket-olock | jq -r .ObjectLock.enabled) if [ $? -ne 0 ]; then
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 24 08:03:58 GMT 2024 - 8.5K bytes - Click Count (0) -
cmd/batch-replicate_test.go
# endpoint: "http://127.0.0.1:9000" # # path: "on|off|auto" # "on" enables path-style bucket lookup. "off" enables virtual host (DNS)-style bucket lookup. Defaults to "auto" # credentials: # accessKey: minioadmin # Required # secretKey: minioadmin # Required # # sessionToken: SESSION-TOKEN # Optional only available when rotating credentials are used
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 01 12:53:30 GMT 2024 - 7.9K bytes - Click Count (0) -
docs/contribute/concurrency.md
We can't rely on application threads to read data from the socket. Application threads are transient: sometimes they're reading and writing and sometimes they're off doing application-layer things. But the socket is permanent, and it needs constant attention: we dispatch all incoming frames so the connection is good-to-go when the application layer needs it. So we have a dedicated thread for every socket that just reads frames and dispatches them.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/DcerpcConstantsTest.java
} @Test @DisplayName("All RPC packet flags should have unique values") void testRpcPacketFlagsUniqueness() { // Verify that RPC packet flags are unique and follow bit pattern assertEquals(1, Integer.bitCount(DcerpcConstants.RPC_C_PF_BROADCAST), "RPC_C_PF_BROADCAST should be a single bit");Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13.5K bytes - Click Count (0)