- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 159 for tiver (0.02 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java
import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.timer.TimeoutTarget; /** * AccessTimeoutTarget is a class that implements the TimeoutTarget interface. * It is used to interrupt a running thread when a timeout occurs.
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.8K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen_test.go
Klaus Post <******@****.***> 1708383286 -0800
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
} func TestTransitionInfoEquals(t *testing.T) { inputs := []struct { tier string remoteObjName string remoteVersionID string status string }{ { tier: "S3TIER-1", remoteObjName: mustGetUUID(), remoteVersionID: mustGetUUID(), status: "complete", }, { tier: "S3TIER-2", remoteObjName: mustGetUUID(),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
cmd/data-usage-cache.go
return } // Update stats for tiers as they become available. for tier, st := range ats.Tiers { stats[tier] = madmin.TierStats{ TotalSize: st.TotalSize, NumVersions: st.NumVersions, NumObjects: st.NumObjects, } } } // tierStats holds per-tier stats of a remote tier. type tierStats struct { TotalSize uint64 `msg:"ts"` NumVersions int `msg:"nv"`
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted(); int drained = drain(q, new ArrayList<>(), 2, 10, MILLISECONDS, interruptibly); assertThat(drained).isAtMost(1); assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 12.2K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
return nil, err } client, err := storage.NewClient(context.Background(), option.WithCredentialsJSON(credsJSON), option.WithScopes(storage.ScopeReadWrite), option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag), ) if err != nil { return nil, err } return &warmBackendGCS{client, conf.Bucket, conf.Prefix, conf.StorageClass}, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 6.1K bytes - Viewed (0) -
cmd/warm-backend-s3.go
Transport: globalRemoteTargetTransport, Region: conf.Region, } client, err := minio.New(u.Host, opts) if err != nil { return nil, err } client.SetAppInfo(fmt.Sprintf("s3-tier-%s", tier), ReleaseTag) core := &minio.Core{Client: client} return &warmBackendS3{ client: client, core: core, Bucket: conf.Bucket,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Jun 08 16:13:30 UTC 2025 - 5.8K bytes - Viewed (0) -
cmd/warm-backend-minio.go
Transport: globalRemoteTargetTransport, TrailingHeaders: true, } client, err := minio.New(u.Host, opts) if err != nil { return nil, err } client.SetAppInfo(fmt.Sprintf("minio-tier-%s", tier), ReleaseTag) core := &minio.Core{Client: client} return &warmBackendMinIO{ warmBackendS3{ client: client, core: core, Bucket: conf.Bucket,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (1) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java
import java.util.concurrent.TimeUnit; import org.apache.http.conn.HttpClientConnectionManager; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.timer.TimeoutTarget; /** * HcConnectionMonitorTarget is responsible for monitoring and managing HTTP client connections. * It implements the TimeoutTarget interface to handle connection expiration events. *
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.3K bytes - Viewed (0) -
cmd/lock-rest-server.go
lkTimer := time.NewTimer(lockMaintenanceInterval) // Stop the timer upon returning. defer lkTimer.Stop() for { // Verifies every minute for locks held more than 2 minutes. select { case <-ctx.Done(): return case <-lkTimer.C: globalLockServer.expireOldLocks(lockValidityDuration) // Reset the timer for next cycle. lkTimer.Reset(lockMaintenanceInterval) } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0)