Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for updateStats (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top