- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 571 for peer (1.45 sec)
-
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
@Override public boolean isEmpty() { /* * Sum per-segment modCounts to avoid mis-reporting when elements are concurrently added and * removed in one segment while checking another, in which case the table was never actually * empty at any point. (The sum ensures accuracy up through at least 1<<31 per-segment * modifications before recheck.) Method containsValue() uses similar constructions for
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 89.9K bytes - Viewed (0) -
docs/bucket/notifications/README.md
Note that, you can add as many AMQP server endpoint configurations as needed by providing an identifier (like "1" in the example above) for the AMQP instance and an object of per-server configuration parameters. ### Step 2: Enable RabbitMQ bucket notification using MinIO client
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 84.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/env" "github.com/minio/pkg/v3/workers" ) //go:generate msgp -file $GOFILE -unexported // rebalanceStats contains per-pool rebalance statistics like number of objects, // versions and bytes rebalanced out of a pool type rebalanceStats struct { InitFreeSpace uint64 `json:"initFreeSpace" msg:"ifs"` // Pool free space at the start of rebalanceRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 28.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessSearchAction.java
return true; } return false; } /** * Builds and populates search form parameters including results per page, * label filtering, and sort order based on user preferences and configuration. * * @param form the search form to populate with parameters */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 13.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
double avgThreadTimeMs = totalTime.get() / (threadCount * 1_000_000.0); System.out.printf("Connection Pool Performance: %d ops in %.2f ms (%.2f ms avg per thread)%n", successCount.get(), overallTimeMs, avgThreadTimeMs); // Verify performance improvements assertTrue(exceptions.isEmpty(), "No exceptions should occur during concurrent access");
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0) -
docs/de/docs/advanced/advanced-dependencies.md
Stellen wir uns vor, wir möchten eine Abhängigkeit haben, die prüft, ob ein Query-Parameter `q` einen vordefinierten Inhalt hat. Aber wir wollen diesen vordefinierten Inhalt per Parameter festlegen können. ## Eine „aufrufbare“ Instanz { #a-callable-instance } In Python gibt es eine Möglichkeit, eine Instanz einer Klasse <abbr title="Englisch „callable“">„aufrufbar“</abbr> zu machen.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 02 17:32:56 UTC 2025 - 10.4K bytes - Viewed (0) -
README.md
### Connection Pool Tuning ```java container.singleton("httpClient", HcHttpClient.class, client -> { client.setMaxConnections(200); // Total connections client.setMaxConnectionsPerRoute(20); // Per-host connections client.setConnectionTimeout(30000); // Connection timeout client.setSocketTimeout(60000); // Read timeout }); ``` ### Memory Management ```java
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/nt/SmbComNtTransactionTest.java
// Verify that transaction is properly initialized assertNotNull(transaction); // Verify primary setup offset (should be 71 as per NTT_PRIMARY_SETUP_OFFSET) // This is set in the parent constructor assertNotNull(transaction); } @Test @DisplayName("Test constructor initialization with NT_TRANSACT_NOTIFY_CHANGE")Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
startHttp2() } } @Throws(IOException::class) private fun startHttp2() { javaNetSocket.soTimeout = 0 // HTTP/2 connection timeouts are set per-stream. val flowControlListener = connectionListener as? FlowControlListener ?: FlowControlListener.None val http2Connection = Http2Connection .Builder(client = true, taskRunner)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 14.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/Constants.java
public static final String SEARCH_LOG_ACCESS_TYPE_ADMIN = "admin"; /** Search log access type for other interfaces. */ public static final String SEARCH_LOG_ACCESS_TYPE_OTHER = "other"; /** Results per page parameter name. */ public static final String RESULTS_PER_PAGE = "resultsPerPage"; /** User code parameter name. */ public static final String USER_CODE = "userCode";
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 35.2K bytes - Viewed (0)