Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 1,250 for pool (0.03 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top