- Sort Score
- Num 10 results
- Language All
Results 361 - 370 of 1,319 for timme (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/archive/tar/writer_test.go
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 40.2K bytes - Click Count (0) -
cmd/metrics.go
if !exists { return } var dur time.Duration if !bgSeq.lastHealActivity.IsZero() { dur = time.Since(bgSeq.lastHealActivity) } ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "time", "since_last_activity"),Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (0) -
guava-testlib/test/com/google/common/testing/FakeTickerTest.java
import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import java.time.Duration; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 6.1K bytes - Click Count (0) -
soft_delete.go
if !n.Valid { return nil, nil } return n.Time, nil } func (n DeletedAt) MarshalJSON() ([]byte, error) { if n.Valid { return json.Marshal(n.Time) } return json.Marshal(nil) } func (n *DeletedAt) UnmarshalJSON(b []byte) error { if string(b) == "null" { n.Valid = false return nil } err := json.Unmarshal(b, &n.Time) if err == nil { n.Valid = true } return err }Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 4.5K bytes - Click Count (1) -
cmd/bucket-quota.go
func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) { bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (DataUsageInfo, error) { if objAPI == nil { return DataUsageInfo{}, errServerNotInitialized } ctx, done := context.WithTimeout(ctx, 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java
abstract Condition delegate(); @Override public void await() throws InterruptedException { delegate().await(); } @Override public boolean await(long time, TimeUnit unit) throws InterruptedException { return delegate().await(time, unit); } @Override public void awaitUninterruptibly() { delegate().awaitUninterruptibly(); } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 24 18:55:30 GMT 2025 - 1.8K bytes - Click Count (0) -
cmd/peer-rest-server.go
} // Wait until the specified time before executing the signal. if t := vars.Get(peerRESTExecAt); t != "" { execAt, err := time.Parse(time.RFC3339Nano, vars.Get(peerRESTExecAt)) if err != nil { logger.LogIf(GlobalContext, "signalservice", err) execAt = time.Now().Add(restartUpdateDelay) } if d := time.Until(execAt); d > 0 { time.Sleep(d) } } signal := serviceSignal(si)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
src/main/java/jcifs/DfsReferralData.java
* Get the replacement path for this referral * * @return the replacement path for this referal */ String getPath(); /** * Get the expiration time of this referral entry * * @return the expiration time of this entry */ long getExpiration(); /** * Get the next referral in the chain *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.5K bytes - Click Count (0) -
internal/http/dial_others.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 http import ( "context" "net" "syscall" "time" ) // TODO: if possible implement for non-linux platforms, not a priority at the moment // //nolint:unused func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 1.6K bytes - Click Count (0) -
internal/handlers/forwarder.go
package handlers import ( "context" "net" "net/http" "net/http/httputil" "net/url" "strings" "time" "github.com/minio/minio/internal/bpool" ) const defaultFlushInterval = time.Duration(100) * time.Millisecond // Forwarder forwards all incoming HTTP requests to configured transport. type Forwarder struct { RoundTripper http.RoundTripper PassHost bool
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.7K bytes - Click Count (0)