- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 326 for spent (0.02 seconds)
-
cmd/peer-rest-client.go
func (client *peerRESTClient) GetSysConfig(ctx context.Context) (info madmin.SysConfig, err error) { sent := time.Now() resp, err := getSysConfigRPC.Call(ctx, client.gridConn(), grid.NewMSS()) info = resp.ValueOrZero() if ti, ok := info.Config["time-info"].(madmin.TimeInfo); ok { rt := int32(time.Since(sent).Milliseconds()) ti.RoundtripDuration = rt info.Config["time-info"] = ti } return info, err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/erasure.go
wait() return nil }) }) }(disk) } wg.Wait() } // nsScanner will start scanning buckets and send updated totals as they are traversed. // Updates are sent on a regular basis and the caller *must* consume them. func (er erasureObjects) nsScanner(ctx context.Context, buckets []BucketInfo, wantCycle uint32, updates chan<- dataUsageCache, healScanMode madmin.HealScanMode) error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.1K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
public fun onRequestBody(socketEffect: SocketEffect?): Builder = apply { this.onRequestBody = socketEffect } /** Trigger [socketEffect] before the response headers are sent. */ public fun onResponseStart(socketEffect: SocketEffect?): Builder = apply { this.onResponseStart = socketEffect } /** Trigger [socketEffect] while writing the response body. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 17.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt
/** * Override the [Request.url] for caching, if it is either polluted with * transient query params, or has a canonical URL possibly for a CDN. * * Note that POST requests will not be sent to the server if this URL is set * and matches a cached response. */ fun cacheUrlOverride(cacheUrlOverride: HttpUrl?) = apply { this.cacheUrlOverride = cacheUrlOverride }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 14.7K bytes - Click Count (1) -
LICENSES/vendor/github.com/containerd/errdefs/LICENSE
or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, theCreated: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Sun Sep 22 18:50:45 GMT 2024 - 10.6K bytes - Click Count (0) -
LICENSES/vendor/github.com/containerd/log/LICENSE
or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, theCreated: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Sun Sep 22 18:50:45 GMT 2024 - 10.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
* the 'received' member of the response object will not * be set to true indicating the send and sendTransaction * methods that the next part should be sent. This is a * very indirect and simple batching control mechanism. */ if (this.andx == null || !getConfig().isUseBatching()
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 15.8K bytes - Click Count (0) -
LICENSES/third_party/forked/gotestsum/LICENSE
or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, theCreated: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Fri Apr 01 18:49:15 GMT 2022 - 11.1K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
} synchronized (LOCK) { if (!NbtAddress.isWINS(request.addr)) { break; } /* Message was sent to WINS but * failed to receive response. * Try a different WINS server. */ if (request.addr == NbtAddress.getWINSAddress()) {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 17.6K bytes - Click Count (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-cluster.json
"interval": "1m", "intervalFactor": 2, "legendFormat": "{{endpoint}},{{server}}", "refId": "A" } ], "title": "Sent Data", "type": "timeseries" }, { "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "fieldConfig": { "defaults": {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Aug 04 01:46:49 GMT 2025 - 71.2K bytes - Click Count (0)