- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 319 for kduration (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/en/docs/environment-variables.md
You can also create an environment variable only for a **specific program invocation**, that is only available to that program, and only for its duration. To do that, create it right before the program itself, on the same line: <div class="termy"> ```console // Create an env var MY_NAME in line for this program call
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 7.9K bytes - Click Count (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
import java.net.HttpURLConnection import java.net.InetAddress import java.net.ProtocolException import java.net.SocketTimeoutException import java.nio.charset.StandardCharsets.UTF_8 import java.time.Duration import java.util.concurrent.TimeUnit import javax.net.ssl.HttpsURLConnection import kotlin.test.assertFailsWith import mockwebserver3.SocketEffect.CloseSocket import okhttp3.Headers
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Aug 03 22:38:00 GMT 2025 - 28K bytes - Click Count (0) -
cmd/data-usage-cache.go
func (d *dataUsageCache) load(ctx context.Context, store objectIO, name string) error { // By default, empty data usage cache *d = dataUsageCache{} load := func(name string, timeout time.Duration) (bool, error) { // Abandon if more than time.Minute, so we don't hold up scanner. // drive timeout by default is 2 minutes, we do not need to wait longer. ctx, cancel := context.WithTimeout(ctx, timeout)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/storage-rest_test.go
if err != nil { t.Fatal(err) } for { _, err := restClient.DiskInfo(t.Context(), DiskInfoOptions{}) if err == nil || errors.Is(err, errUnformattedDisk) { break } time.Sleep(time.Duration(rand.Float64() * float64(100*time.Millisecond))) } return restClient } func TestStorageRESTClientDiskInfo(t *testing.T) { restClient := newStorageRESTHTTPServerClient(t)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 11.4K bytes - Click Count (0) -
cmd/signature-v4-parser_test.go
} } } // TestParsePreSignV4 - Validates the parsing logic of Presignied v4 request from its url query values. func TestParsePreSignV4(t *testing.T) { // converts the duration in seconds into string format. getDurationStr := strconv.Itoa // used in expected preSignValues, preSignValues.Date is of type time.Time . queryTime := UTCNow() sampleTimeStr := UTCNow().Format(yyyymmdd)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:35 GMT 2025 - 27.8K bytes - Click Count (0) -
cmd/bootstrap-peer-server.go
select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
cmd/sftp-server-driver.go
var errStr string if err != nil { errStr = err.Error() } return madmin.TraceInfo{ TraceType: madmin.TraceFTP, Time: startTime, NodeName: globalLocalNodeName, FuncName: s.Method, Duration: time.Since(startTime), Path: s.Filepath, Error: errStr, Bytes: sz, Custom: map[string]string{ "user": user, "cmd": s.Method, "param": s.Filepath, "source": source,Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Feb 10 16:35:49 GMT 2025 - 11.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
public void setCacheTemplateName(final String cacheTemplateName) { this.cacheTemplateName = cacheTemplateName; } /** * Sets the facet cache duration in seconds. * * @param facetCacheDuration the cache duration in seconds */ public void setFacetCacheDuration(final long facetCacheDuration) { this.facetCacheDuration = facetCacheDuration; } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 52.6K bytes - Click Count (0) -
cmd/erasure-healing-common.go
} // Return the collected common max time, with maxima return latest, maxima } // commonTime returns a maximally occurring time from a list of time. func commonTimeAndOccurrence(times []time.Time, group time.Duration) (maxTime time.Time, maxima int) { timeOccurrenceMap := make(map[int64]int, len(times)) groupNano := group.Nanoseconds() // Ignore the uuid sentinel and count the rest. for _, t := range times {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
cmd/prepare-storage.go
// isServerResolvable - checks if the endpoint is resolvable // by sending a naked HTTP request with liveness checks. func isServerResolvable(endpoint Endpoint, timeout time.Duration) error { serverURL := &url.URL{ Scheme: endpoint.Scheme, Host: endpoint.Host, Path: pathJoin(healthCheckPathPrefix, healthCheckLivenessPath), } httpClient := &http.Client{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 11.1K bytes - Click Count (1)