- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for updateStats (0.04 sec)
-
cmd/http-stats.go
serverStats.TotalS3Canceled = ServerHTTPAPIStats{ APIStats: st.totalS3Canceled.Load(toLowerKeys), } return serverStats } // Update statistics from http request and response data func (st *HTTPStats) updateStats(api string, w *xhttp.ResponseRecorder) { st.totalS3Requests.Inc(api) // Increment the prometheus http request response histogram with appropriate label
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/handler-utils.go
f.ServeHTTP(w, r) globalHTTPStats.currentS3Requests.Dec(api) tc, _ := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if tc != nil { globalHTTPStats.updateStats(api, tc.ResponseRecorder) globalConnStats.incS3InputBytes(int64(tc.RequestRecorder.Size())) globalConnStats.incS3OutputBytes(int64(tc.ResponseRecorder.Size())) if countBktStat {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.3K bytes - Viewed (1) -
src/test/java/org/codelibs/fess/job/PurgeLogJobTest.java
public void deleteBefore(int days) { deleteJobLogCalled[0] = true; jobLogDeletedDays[0] = days; } @Override public void updateStatus() { updateJobLogStatusCalled[0] = true; } }; UserInfoService userInfoService = new UserInfoService() { @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 32.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
entry.updateState(Smb2LeaseState.SMB2_LEASE_NONE); } releaseLease(key); } catch (Exception e) { log.error("Error handling lease break for key: " + key, e); // On error, ensure we're in safe state LeaseEntry entry = leases.get(key); if (entry != null) { entry.updateState(Smb2LeaseState.SMB2_LEASE_NONE);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
docs/smb3-features/01-smb3-lease-design.md
this.lastAccessTime = createTime; this.epoch = 1; this.breaking = false; } public synchronized void updateState(int newState) { this.leaseState = newState; this.lastAccessTime = System.currentTimeMillis(); } public synchronized void incrementEpoch() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
* @param form the tag form containing updated tag information * @return HTML response redirecting to the storage list after update */ @Execute @Secured({ ROLE }) public HtmlResponse updateTags(final TagForm form) { validate(form, messages -> {}, () -> asEditTagsHtml(form.path, form.name)); final String objectName = getObjectName(form.path, form.name); try {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 25.1K bytes - Viewed (0)