- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 1,056 for timer (0.02 seconds)
-
cmd/xl-storage_noatime_supported.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "os" "syscall" ) var ( // Disallow updating access times // Add non-block to avoid syscall to attempt to set epoll on files. readMode = os.O_RDONLY | 0x40000 | syscall.O_NONBLOCK // O_NOATIME // Write with data sync only used only for `xl.meta` writes
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jul 23 16:36:24 GMT 2024 - 1.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
*/ private static TestCase generateGuardWithWrongMonitorTestCase( Method method, boolean fair1, boolean fair2) { boolean timed = isTimed(method); // Not going to bother with all timeouts, just 0ms. return new TestCase(method.getName() + (timed ? "(0ms)" : "()") + "/WrongMonitor->IMSE") { @Override protected void runTest() throws Throwable { Monitor monitor1 = new Monitor(fair1);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 27.1K bytes - Click Count (0) -
docs/pt/docs/how-to/migrate-from-pydantic-v1-to-pydantic-v2.md
Se você tem uma aplicação FastAPI antiga, pode estar usando o Pydantic versão 1. O FastAPI tem suporte ao Pydantic v1 ou v2 desde a versão 0.100.0. Se você tiver o Pydantic v2 instalado, ele será utilizado. Se, em vez disso, tiver o Pydantic v1, será ele que será utilizado.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Nov 12 16:23:57 GMT 2025 - 5.8K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* "permits" gives time, i.e., integrals on this function (which is what storedPermitsToWaitTime() * computes) correspond to minimum intervals between subsequent requests, for the specified number * of requested permits. * * Here is an example of storedPermitsToWaitTime: If storedPermits == 10.0, and we want 3 permits,
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 19.3K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/Service.java
} /** * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more * than the given time. * * @param timeout the maximum time to wait * @param unit the time unit of the timeout argument * @throws TimeoutException if the service has not reached the given state within the deadlineCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 12.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* scheduled. If the task is already in the queue, the earliest execution time is used. * * The target execution time is implemented on a best-effort basis. If another task in this queue * is running when that time is reached, that task is allowed to complete before this task is * started. Similarly the task will be delayed if the host lacks compute resources. *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 7.3K bytes - Click Count (0) -
.github/workflows/stale-pr.yml
ascending: true exempt-all-milestones: true # ISSUES (deactivated) ---------------------------------------------- # This workflow should touch no issues, so times are set to -1 # (see actions/stale documentation for the behavior) days-before-issue-stale: -1 stale-issue-label: stale stale-issue-message: >Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Sep 04 22:13:29 GMT 2025 - 1.7K bytes - Click Count (0) -
cmd/bucket-replication-stats.go
qCache: newQueueCache(r), pCache: newProxyStatsCache(), srStats: newSRStats(), movingAvgTicker: time.NewTicker(2 * time.Second), wTimer: time.NewTicker(2 * time.Second), qTimer: time.NewTicker(2 * time.Second), workers: newActiveWorkerStat(r), registry: r, } go rs.collectWorkerMetrics(ctx) go rs.collectQueueMetrics(ctx) return &rs
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 13.6K bytes - Click Count (0) -
cmd/api-headers.go
"fmt" "mime" "net/http" "strconv" "strings" "time" "github.com/minio/minio-go/v7/pkg/tags" "github.com/minio/minio/internal/crypto" xhttp "github.com/minio/minio/internal/http" xxml "github.com/minio/xxml" ) // Returns a hexadecimal representation of time at the // time response is sent to the client. func mustGetRequestID(t time.Time) string { return fmt.Sprintf("%X", t.UnixNano()) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.6K bytes - Click Count (0) -
cmd/server-main.go
} func bootstrapTrace(msg string, worker func()) { if serverDebugLog { fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg) } now := time.Now() worker() dur := time.Since(now) info := madmin.TraceInfo{ TraceType: madmin.TraceBootstrap, Time: UTCNow(), NodeName: globalLocalNodeName, FuncName: "BOOTSTRAP",
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:18:36 GMT 2025 - 35.9K bytes - Click Count (4)