Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for updateStatus (0.96 sec)

  1. 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{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  2. 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();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. 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 -> {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  4. 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:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.4K bytes
    - Viewed (1)
Back to top