Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for updateStats (0.12 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 Nov 03 19:28:11 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	}
    	err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout))
    	if err != nil {
    		return err
    	}
    	return wsutil.WriteMessage(conn, c.side, ws.OpBinary, dst)
    }
    
    func (c *Connection) connect() {
    	c.updateState(StateConnecting)
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    	// Runs until the server is shut down.
    	for {
    		if c.State() == StateShutdown {
    			return
    		}
    		dialStarted := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java

            saveToken();
            return asEditTagsHtml(form.path, form.name);
        }
    
        @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 Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 19.9K bytes
    - Viewed (0)
Back to top