- Sort Score
- Num 10 results
- Language All
Results 521 - 530 of 690 for selected (0.05 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
allocateAndLeakAllocation(poolApi, c1) awaitGarbageCollection() assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(c1.calls).isEmpty() // Can't allocate once a leak has been detected. assertThat(c1.noNewExchanges).isTrue() } @Test fun interruptStopsThread() { val taskRunnerThreads = mutableListOf<Thread>() val taskRunner = TaskRunner(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 8.2K bytes - Click Count (0) -
internal/s3select/errors.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package s3select import "strings" // SelectError - represents s3 select error specified in // https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectSELECTContent.html#RESTObjectSELECTContent-responses-special-errors. type SelectError interface { Cause() error ErrorCode() string
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoDescriptorCreator.java
import org.slf4j.LoggerFactory; /** * <p> * Resolves dependencies for the artifacts in context of the lifecycle build * </p> * <strong>NOTE:</strong> This class is not part of any public api and can be changed or deleted without prior notice. * * @since 3.0 */ @Named @Singleton public class MojoDescriptorCreator { private final Logger logger = LoggerFactory.getLogger(getClass());
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Mar 25 09:45:07 GMT 2025 - 11.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/MapTestSuiteBuilder.java
parentBuilder) { // TODO: Once invariant support is added, supply invariants to each of the // derived suites, to check that mutations to the derived collections are // reflected in the underlying map. List<TestSuite> derivedSuites = super.createDerivedSuites(parentBuilder); if (parentBuilder.getFeatures().contains(CollectionFeature.SERIALIZABLE)) { derivedSuites.add(Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 20:54:16 GMT 2025 - 11K bytes - Click Count (0) -
cmd/xl-storage_test.go
} if err := xl.WriteMetadata(ctx, "", volume, object, fi); err != nil { t.Fatalf("Unable to create object, %s", err) } } var deleted [len(versions)]bool checkVerExist := func(t testing.TB) { t.Helper() for i := range versions { shouldExist := !deleted[i] fi, err := xl.ReadVersion(ctx, "", volume, object, versions[i], ReadOptions{}) if shouldExist { if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 66K bytes - Click Count (0) -
cmd/erasure-server-pool-decom.go
// to decommission, just skip it, this also includes // any other versions that have already expired. remainingVersions := len(fivs.Versions) - expired if version.Deleted && remainingVersions == 1 && rcfg == nil { decommissioned++ stopFn(version.Size, errors.New("DELETE marked object with no other non-current versions will be skipped")) continue }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/FindMissingDocumentationFiles.java
"build_jenkins", "build_teamcity", "build_github_actions", "sec:configure_github_actions", "build_travis", // fixed with redirection (javascript in deleted pages) "sec:component_selection_rules", "sub:declaring_dependency_with_dynamic_version", "sub:declaring_dependency_with_changing_version", "sec:controlling_dependency_caching_programmatically",
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Aug 21 15:38:58 GMT 2025 - 8.5K bytes - Click Count (0) -
cmd/bucket-targets.go
} // heartBeat performs liveness check on remote endpoints. func (sys *BucketTargetSys) heartBeat(ctx context.Context) { hcTimer := time.NewTimer(defaultHealthCheckDuration) defer hcTimer.Stop() for { select { case <-hcTimer.C: sys.hMutex.RLock() eps := make([]madmin.ServerProperties, 0, len(sys.hc)) for _, ep := range sys.hc {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultPluginValidationManager.java
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:32 GMT 2025 - 17.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/CompactHashing.java
private static final int HASH_TABLE_BITS_MAX_BITS = 5; /** Use high bits of metadata for modification count. */ static final int MODIFICATION_COUNT_INCREMENT = 1 << HASH_TABLE_BITS_MAX_BITS; /** Bitmask that selects the low bits of metadata to get hashTableBits. */ static final int HASH_TABLE_BITS_MASK = (1 << HASH_TABLE_BITS_MAX_BITS) - 1; /** Maximum size of a compact hash-based collection (2^30 - 1 because 0 is UNSET). */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Aug 11 19:31:30 GMT 2025 - 7K bytes - Click Count (0)