- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 725 for pools (0.02 sec)
-
cmd/admin-router.go
// Pool operations adminRouter.Methods(http.MethodGet).Path(adminVersion + "/pools/list").HandlerFunc(adminMiddleware(adminAPI.ListPools, traceAllFlag)) adminRouter.Methods(http.MethodGet).Path(adminVersion+"/pools/status").HandlerFunc(adminMiddleware(adminAPI.StatusPool, traceAllFlag)).Queries("pool", "{pool:.*}")
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:03 UTC 2025 - 26.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
objAPI := newObjectLayerFn() if objAPI == nil { return np, grid.NewRemoteErr(errServerNotInitialized) } pools, ok := objAPI.(*erasureServerPools) if !ok { return np, nerr } if err := pools.ReloadPoolMeta(context.Background()); err != nil { return np, grid.NewRemoteErr(err) } return np, nerr }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 53.6K bytes - Viewed (0) -
cmd/erasure-healing_test.go
if err != nil { t.Fatal(err) } defer removeRoots(fsDirs) pools := mustGetPoolEndpoints(0, fsDirs[:16]...) pools = append(pools, mustGetPoolEndpoints(1, fsDirs[16:]...)...) // Everything is fine, should return nil objLayer, _, err := initObjectLayer(ctx, pools) if err != nil { t.Fatal(err) } bucket := getRandomBucketName() object := getRandomObjectName()Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
*/ public JvmObj() { // Default constructor } /** JVM memory statistics */ public JvmMemoryObj memory; /** JVM buffer pool statistics */ public JvmPoolObj[] pools; /** JVM garbage collection statistics */ public JvmGcObj[] gc; /** JVM thread statistics */ public JvmThreadsObj threads;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0) -
src/main/java/jcifs/SmbTransportPool.java
boolean exclusive, boolean forceSigning); /** * Removes a transport from the pool. * * @param trans the transport to remove */ void removeTransport(SmbTransport trans); /** * Closes the pool and all connections in it * * @return whether any transport was still in use *Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.5K bytes - Viewed (0) -
cmd/object-api-interface.go
EncryptFn objectMetaEncryptFn // SkipDecommissioned set to 'true' if the call requires skipping the pool being decommissioned. // mainly set for certain WRITE operations. SkipDecommissioned bool // SkipRebalancing should be set to 'true' if the call should skip pools // participating in a rebalance operation. Typically set for 'write' operations. SkipRebalancing bool
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/endpoint_test.go
err := mergeDisksLayoutFromArgs(testCase.args, &srvCtxt) if err != nil && testCase.expectedErr == nil { t.Errorf("Test %d: unexpected error: %v", i+1, err) } pools, setupType, err := CreatePoolEndpoints(testCase.serverAddr, srvCtxt.Layout.pools...) if err == nil && testCase.expectedErr != nil { t.Errorf("Test %d: expected = %v, got = <nil>", i+1, testCase.expectedErr) } if err == nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 18.9K bytes - Viewed (0) -
cmd/admin-handlers.go
// No ellipses pattern. Anonymize host name from every pool arg pools := strings.Fields(poolsArgs) anonPools = make([]string, len(pools)) for index, arg := range pools { anonPools[index] = anonAddr(arg) } return cmdLineWithoutPools + strings.Join(anonPools, " ") } // Ellipses pattern in pool args. Regex groups: // 1 - server prefix // 2 - number sequence for servers
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 99.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
this.loadBalancingStrategy = getLoadBalancingStrategyFromConfig(config); this.healthCheckInterval = getHealthCheckIntervalFromConfig(config); // Create thread pools this.channelExecutor = Executors.newCachedThreadPool(r -> { Thread t = new Thread(r, "SMB3-MultiChannel-Worker"); t.setDaemon(true); return t; });
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java
this.totalAllocated = new AtomicLong(); this.totalReleased = new AtomicLong(); // Pre-allocate buffer pool initializeBufferPool(); } /** * Initialize the buffer pool with pre-allocated regions */ private void initializeBufferPool() { // Allocate send buffers for (int i = 0; i < initialSendBuffers; i++) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.7K bytes - Viewed (0)