Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 1,162 for Pool (0.02 sec)

  1. 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;
          }
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  2. 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,
    				},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (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: {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (3)
  4. 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
       */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  5. 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 =
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  6. schema/field.go

    	PrimaryKey             bool
    	AutoIncrement          bool
    	AutoIncrementIncrement int64
    	Creatable              bool
    	Updatable              bool
    	Readable               bool
    	AutoCreateTime         TimeType
    	AutoUpdateTime         TimeType
    	HasDefaultValue        bool
    	DefaultValue           string
    	DefaultValueInterface  interface{}
    	NotNull                bool
    	Unique                 bool
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sat Nov 22 03:14:36 UTC 2025
    - 32.2K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    }
    
    // IsOnline - returns whether client failed to connect or not.
    func (client *storageRESTClient) IsOnline() bool {
    	return client.restClient.IsOnline() || client.IsOnlineWS()
    }
    
    // IsOnlineWS - returns whether websocket client failed to connect or not.
    func (client *storageRESTClient) IsOnlineWS() bool {
    	return client.gridConn.State() == grid.StateConnected
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  8. 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;
          }
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. 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
    	}
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Sep 19 01:49:06 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  10. 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,
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
Back to top