- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 391 for ctx_ (0.05 sec)
-
internal/http/transports.go
// communicating with client cert authentication. func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) { transport := s.NewHTTPTransportWithTimeout(1 * time.Minute) if clientCert != "" && clientKey != "" { c, err := certs.NewManager(ctx, clientCert, clientKey, tls.LoadX509KeyPair) if err != nil { return nil, err } if c != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
m.Set(drivePercUtil, ioStats.percUtil, labels...) } // loadDriveMetrics - `MetricsLoaderFn` for node drive metrics. func loadDriveMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { driveMetrics, err := c.driveMetrics.Get() if err != nil { metricsLogIf(ctx, err) return nil } for _, disk := range driveMetrics.storageInfo.Disks { labels := []string{ driveL, disk.DrivePath,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun May 12 17:23:50 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/handler-api.go
w.Header().Set("X-RateLimit-Limit", strconv.Itoa(cap(pool))) w.Header().Set("X-RateLimit-Remaining", strconv.Itoa(cap(pool)-len(pool))) ctx := r.Context() select { case pool <- struct{}{}: defer func() { <-pool }() globalHTTPStats.addRequestsInQueue(-1) if contextCanceled(ctx) { w.WriteHeader(499) return } f.ServeHTTP(w, r) case <-r.Context().Done():
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/metacache-entries.go
// otherwise the function will return nil. func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error { defer xioutil.SafeClose(out) top := make([]*metaCacheEntry, len(in)) nDone := 0 ctxDone := ctx.Done() // Use simpler forwarder. if len(in) == 1 { for { select { case <-ctxDone: return ctx.Err() case v, ok := <-in[0]: if !ok {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/erasure-encode_test.go
return "bad-disk" } func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error { return errFaultyDisk } func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) { return nil, errFaultyDisk } func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/metrics-realtime.go
} } metrics[d.Endpoint] = dm } return metrics } func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if !globalIsDistErasure { return } all := globalNotificationSys.GetMetrics(ctx, types, opts) for _, remote := range all { m.Merge(&remote) } return m
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
tests/test_multi_body_errors.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Apr 18 19:40:57 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/erasure-sets_test.go
} } // TestNewErasure - tests initialization of all input disks // and constructs a valid `Erasure` object func TestNewErasureSets(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 // Maximum disks. var erasureDisks []string for i := 0; i < nDisks; i++ {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateResponse.java
ncpos += 4; ncpos += 4; // Reserved NegotiateContextResponse ctx = createContext(type); if ( ctx != null ) { ctx.decode(buffer, ncpos, dataLen); contexts[ i ] = ctx; } ncpos += dataLen; if ( i != negotiateContextCount - 1 ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Mar 22 10:09:46 UTC 2020 - 17.6K bytes - Viewed (0) -
cmd/api-headers.go
if strings.Contains(objInfo.ETag, "-") && len(objInfo.Parts) > 0 { w.Header()[xhttp.AmzMpPartsCount] = []string{strconv.Itoa(len(objInfo.Parts))} } } // Write object header func setObjectHeaders(ctx context.Context, w http.ResponseWriter, objInfo ObjectInfo, rs *HTTPRangeSpec, opts ObjectOptions) (err error) { // set common headers setCommonHeaders(w) // Set last modified time.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 28 04:44:00 UTC 2024 - 7K bytes - Viewed (0)