Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for updateStats (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/http-tracer_test.go

    		}
    	}
    }
    
    // TestHTTPStatsRaceCondition tests the race condition fix for HTTPStats.
    // This test specifically addresses the race between:
    // - Write operations via updateStats.
    // - Read operations via toServerHTTPStats(false).
    func TestRaulStatsRaceCondition(t *testing.T) {
    	httpStats := newHTTPStats()
    	// Simulate the concurrent scenario from the original race condition:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  2. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 11.4K bytes
    - Click Count (0)
  3. cmd/admin-handlers.go

    	if lrTime.Sub(currentReleaseTime) <= 0 {
    		updateStatus.Results = append(updateStatus.Results, madmin.ServerPeerUpdateStatus{
    			Host:           local,
    			Err:            fmt.Sprintf("server is running the latest version: %s", Version),
    			CurrentVersion: Version,
    		})
    
    		for _, client := range globalNotificationSys.peerClients {
    			updateStatus.Results = append(updateStatus.Results, madmin.ServerPeerUpdateStatus{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (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);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  5. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/GitWrapper.java

        }
    
        /**
         * Updates the git repository's tags from the specified remote
         * @param remote the remote to use to update
         */
        public void updateTags(String remote) {
            runCommand("git", "fetch", "--tags", Objects.requireNonNull(remote));
        }
    
        /**
         * Fetch all tags matching the specified pattern, returning them as {@link QualifiedVersion} instances.
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 06:25:29 GMT 2021
    - 3K bytes
    - Click Count (0)
  6. 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()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/job/PurgeLogJob.java

                logger.error("Failed to purge user info.", e);
                resultBuf.append(e.getMessage()).append("\n");
            }
    
            // update job logs
            try {
                jobLogService.updateStatus();
            } catch (final Exception e) {
                logger.error("Failed to purge job logs.", e);
                resultBuf.append(e.getMessage()).append("\n");
            }
    
            return resultBuf.toString();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/service/JobLogService.java

        /**
         * Updates the status of expired jobs that haven't finished.
         * Jobs that have been running longer than the expired job interval
         * without an end time are marked as failed.
         */
        public void updateStatus() {
            final long expiry = ComponentUtil.getSystemHelper().getCurrentTimeAsLong() - expiredJobInterval;
            final List<JobLog> list = jobLogBhv.selectList(cb -> {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  9. cmd/site-replication-utils.go

    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    func (sm *siteResyncMetrics) updateState(s SiteResyncStatus) error {
    	if !globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    	sm.Lock()
    	defer sm.Unlock()
    	switch s.Status {
    	case ResyncStarted:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/GenerateReleaseNotesTask.java

            // Now update the remote, and make sure we update the tags too
            gitWrapper.updateRemote(upstream);
    
            LOGGER.info("Updating tags from [{}]", upstream);
            gitWrapper.updateTags(upstream);
        }
    
        /**
         * This methods checks the supplied version and answers {@code false} if the fetching of git
         * tags can be skipped, or {@code true} otherwise.
         * <p>
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 06:25:29 GMT 2021
    - 12.9K bytes
    - Click Count (0)
Back to Top