- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 392 for defer (0.17 sec)
-
cmd/os_windows.go
data := &syscall.Win32finddata{} handle, err := syscall.FindFirstFile(globAllP, data) if err != nil { if err = syscallErrToFileErr(dirPath, err); err == errFileNotFound { return nil } return err } defer syscall.FindClose(handle) for ; ; err = syscall.FindNextFile(handle, data) { if err != nil { if err == syscall.ERROR_NO_MORE_FILES { break } if isSysErrPathNotFound(err) { return nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 5K bytes - Viewed (0) -
cmd/signature-v4_test.go
} } } func TestDoesPresignedSignatureMatch(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) } // sha256 hash of "payload"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 10.5K bytes - Viewed (0) -
cmd/lock-rest-client.go
r, err := h.Call(ctx, c.connection, args) if err != nil { return false, err } defer h.PutResponse(r) ok = r.Code == dsync.RespOK switch r.Code { case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK: // no error case dsync.RespLockNotInitialized: err = errLockNotInitialized
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.go
"net/http" ) var port int func init() { flag.IntVar(&port, "port", 8080, "Port to listen on") } func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err) w.WriteHeader(http.StatusBadRequest) return } log.Printf(">>> %s %s\n", r.Method, r.URL.Path) var out bytes.Buffer
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/bucket-stats.go
qs.TgtXferStats = make(map[string]map[RMetricName]XferStats) qs.MRFStats = ReplicationMRFStats{ LastFailedCount: atomic.LoadUint64(&r.mrfStats.LastFailedCount), } r.RLock() defer r.RUnlock() brs, ok := r.Cache[bucket] if !ok { return qs } for arn := range brs.Stats { qs.TgtXferStats[arn] = make(map[RMetricName]XferStats) } count := 0 var totPeak float64
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.5K bytes - Viewed (0) -
cmd/data-scanner.go
cycleInfo.next = binary.LittleEndian.Uint64(buf[:8]) buf = buf[8:] _, err := cycleInfo.UnmarshalMsg(buf) bugLogIf(ctx, err) } scannerTimer := time.NewTimer(scannerCycle.Load()) defer scannerTimer.Stop() defer globalScannerMetrics.setCycle(nil) for { select { case <-ctx.Done(): return case <-scannerTimer.C: // Reset the timer for next cycle.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
cmd/handler-utils.go
Code: "XMinioAdminVersionMismatch", Description: desc, HTTPStatusCode: http.StatusUpgradeRequired, }, r.URL) default: defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) defer atomic.AddUint64(&globalHTTPStats.rejectedRequestsInvalid, 1) // When we are not running in S3 Express mode, generate appropriate error // for x-amz-write-offset HEADER specified.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.3K bytes - Viewed (1) -
cmd/batch-expire.go
func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error { if r.NotificationCfg.Endpoint == "" { return nil } ctx, cancel := context.WithTimeout(ctx, 10*time.Second) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body) if err != nil { return err } if r.NotificationCfg.Token != "" {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
cmd/kms-handlers_test.go
asRoot bool // Wanted in response. wantStatusCode int wantKeyNames []string wantResp []string } func TestKMSHandlersCreateKey(t *testing.T) { adminTestBed, tearDown := setupKMSTest(t, true) defer tearDown() tests := []kmsTestCase{ // Create key test { name: "create key as user with no policy want forbidden", method: http.MethodPost, path: kmsKeyCreatePath,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 22.3K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func (t *transitionState) addLastDayStats(tier string, ts tierStats) { t.lastDayMu.Lock() defer t.lastDayMu.Unlock() if _, ok := t.lastDayStats[tier]; !ok { t.lastDayStats[tier] = &lastDayTierStats{} } t.lastDayStats[tier].addStats(ts) } func (t *transitionState) getDailyAllTierStats() DailyAllTierStats { t.lastDayMu.RLock() defer t.lastDayMu.RUnlock() res := make(DailyAllTierStats, len(t.lastDayStats))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0)