- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 1,250 for pool (0.03 seconds)
-
cmd/erasure-object_test.go
}) if err != nil { t.Fatalf("Erasure Object upload failed: <ERROR> %s", err) } versions[i] = objInfo.VersionID } // Remove and check the version in the second pool, then // remove and check the version in the first pool for testIdx, vid := range []string{versions[1], versions[0]} { names := []ObjectToDelete{ { ObjectV: ObjectV{ ObjectName: objectName, VersionID: vid, },Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 38.3K bytes - Click Count (0) -
tensorflow/c/c_api_experimental.cc
tensorflow::GetBuildXlaOpsPassFlags(); bool original = flags->tf_xla_enable_lazy_compilation; flags->tf_xla_enable_lazy_compilation = enable; return original; } unsigned char TF_SetTfXlaCpuGlobalJit(unsigned char enable) { tensorflow::MarkForCompilationPassFlags* flags = tensorflow::GetMarkForCompilationPassFlags(); bool original = flags->tf_xla_cpu_global_jit;
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Oct 04 05:55:32 GMT 2025 - 29.4K bytes - Click Count (0) -
cmd/api-errors.go
}, ErrAdminRebalanceAlreadyStarted: { Code: "XMinioAdminRebalanceAlreadyStarted", Description: "Pool rebalance is already started", HTTPStatusCode: http.StatusConflict, }, ErrAdminRebalanceNotStarted: { Code: "XMinioAdminRebalanceNotStarted", Description: "Pool rebalance is not started", HTTPStatusCode: http.StatusNotFound, }, ErrMaximumExpires: {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 16 07:34:24 GMT 2025 - 93K bytes - Click Count (3) -
cmd/object-api-errors.go
} func isErrPreconditionFailed(err error) bool { _, ok := err.(PreConditionFailed) return ok } // isErrMethodNotAllowed - Check if error type is MethodNotAllowed. func isErrMethodNotAllowed(err error) bool { var methodNotAllowed MethodNotAllowed return errors.As(err, &methodNotAllowed) } func isErrInvalidRange(err error) bool { if errors.Is(err, errInvalidRange) { return true }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 09 02:05:14 GMT 2024 - 22.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
// Test multiple components together long start = System.nanoTime(); // 1. Connection Pool Test SmbTransportPoolImpl pool = new SmbTransportPoolImpl(); pool.setMaxPoolSize(50); for (int i = 0; i < 100; i++) { pool.contains(null); // Should be fast without global sync } // 2. Buffer Cache Test for (int i = 0; i < 100; i++) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 15.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
} } finally { // Important to null this out here - if we did *not* execute inline, we might still // run() on the same thread that called execute() - such as in a thread pool, and think // that it was happening inline. As a side benefit, avoids holding on to the Thread object // longer than necessary. submitting = null; } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* * If received data is unexpected: [exception] is a [ProtocolException]. * * Each call is made on either a reused [Connection] from a pool, or on a new connection * established from a planned [Route]. OkHttp won't retry if it's already attempted all * available routes. * * @param retry true if OkHttp will make another attempt */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
} /** * We had a bug where web socket connections were leaked if the HTTP connection upgrade was not * successful. This test confirms that connections are released back to the connection pool! * https://github.com/square/okhttp/issues/4258 */ @Test @Throws(Exception::class) fun webSocketConnectionIsReleased() { // This test assumes HTTP/1.1 pooling semantics. client =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
docs/smb3-features/03-multi-channel-design.md
SmbTransport alternativeTransport = selectTransport(message); alternativeTransport.send(message); } else { throw e; } } } ``` ### 5.2 Transport Pool Integration ```java // In SmbTransportPool.java public SmbTransport getMultiChannelTransport(SmbSession session, NetworkInterfaceInfo localIf,
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 39.6K bytes - Click Count (0) -
finisher_api.go
} Scan(rows, tx, ScanInitialized) return tx.Error } // Connection uses a db connection to execute an arbitrary number of commands in fc. When finished, the connection is // returned to the connection pool. func (db *DB) Connection(fc func(tx *DB) error) (err error) { if db.Error != nil { return db.Error } tx := db.getInstance() sqlDB, err := tx.DB() if err != nil { return }
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Fri Sep 19 01:49:06 GMT 2025 - 22.9K bytes - Click Count (0)